kern/v4/mds/mod_keeper/mod_keeper.go

// package mod_keeper -- модуль сторожа ядра
package mod_keeper

import (
	"fmt"
	"sync"

	"gitp78su.ipnodns.ru/svi/kern/v4/krn/kctx"
	"gitp78su.ipnodns.ru/svi/kern/v4/krn/kmodule"
	"gitp78su.ipnodns.ru/svi/kern/v4/krn/kserv_http"
	. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/ktypes"
	. "gitp78su.ipnodns.ru/svi/kern/v4/lev1/result"
	"gitp78su.ipnodns.ru/svi/kern/v4/mds/mod_serv_http/http_api"
	"gitp78su.ipnodns.ru/svi/kern/v4/mds/mod_serv_http/page_module"
	"gitp78su.ipnodns.ru/svi/kern/v4/mds/mod_serv_http/page_monolit"
)

// ModuleKeeper -- модуль сторожа
type ModuleKeeper struct {
	IKernelModule
	kCtx      IKernelCtx
	kServHttp IKernelServerHttp
	log       ILogBuf
}

var (
	mod   *ModuleKeeper
	block sync.Mutex
)

// GetModuleKeeper -- возвращает новый модуль сторожа ядра
func GetModuleKeeper() IResult[*ModuleKeeper] {
	block.Lock()
	defer block.Unlock()
	if mod != nil {
		return NewRes(mod)
	}
	resHttp := kserv_http.GetKernelServHttp()
	if resHttp.IsErr() {
		err := fmt.Errorf("GetModuleKeeper(): in get KernelServerHttp, err=\n\t%w", resHttp.Err())
		return NewErr[*ModuleKeeper](err)
	}
	resModKeep := kmodule.NewKernelModule("kKeeper")
	if resModKeep.IsErr() {
		err := fmt.Errorf("GetModuleKeeper(): in get resModKeeper, err=\n\t%w", resModKeep.Err())
		return NewErr[*ModuleKeeper](err)
	}
	sf := &ModuleKeeper{
		kCtx:          kctx.GetKernelCtx(),
		IKernelModule: resModKeep.Val(),
		kServHttp:     resHttp.Val(),
	}
	sf.log = sf.kCtx.Keeper().Log()
	_ = page_monolit.GetPageMonolit()
	_ = page_module.GetPageModule()

	_ = http_api.NewHttpApi()
	mod = sf
	return NewRes(sf)
}

// Run -- запускает модуль в работу
func (sf *ModuleKeeper) Run() {
	sf.log.Info("ModuleKernelCtx.Run(): module=%v, is run", sf.Name())
	go sf.kServHttp.Run()
}

// IsWork -- признак работы модуля
func (sf *ModuleKeeper) IsWork() bool {
	return sf.kCtx.Wg().IsWork()
}