kern/v4/lev3/mod_serv_http/mod_serv_http.go

// package mod_serv_http -- модуль HTTP-сервера.
package mod_serv_http

import (
	"fmt"
	"sync"

	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/alias"
	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/ktypes"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kserv_http"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/http_api"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/page_module"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/page_monolit"
)

// ModuleServHttp -- модуль HTTP-сервера.
type ModuleServHttp struct {
	mKt.IKernelModule
	kServHttp mKt.IKernelServerHttp
	log       mKt.ILogBuf
}

var (
	mod   *ModuleServHttp
	block sync.RWMutex
)

// GetModuleServHttp -- возвращает новый модуль HTTP-сервера.
func GetModuleServHttp() *mL0.Result[*ModuleServHttp] {
	block.Lock()
	defer block.Unlock()
	if mod != nil {
		return mL0.NewRes(mod)
	}
	modName := alias.NewAModuleName("kServHttp")
	resMod := kmodule.NewKernelModule(modName)
	if resMod.IsErr() {
		err := fmt.Errorf("GetModuleServHttp(): in NewKernelModule, err=\n\t%w", resMod.Err())
		return mL0.NewErr[*ModuleServHttp](err)
	}
	resHttp := kserv_http.GetKernelServHttp()
	if resHttp.IsErr() {
		err := fmt.Errorf("GetModuleServHttp(): in GetKernelServHttp, err=\n\t%w", resHttp.Err())
		return mL0.NewErr[*ModuleServHttp](err)
	}
	sf := &ModuleServHttp{
		IKernelModule: resMod.Val(),
		kServHttp:     resHttp.Val(),
	}
	sf.log = sf.Ctx().Log()
	_ = page_monolit.GetPageMonolit()
	_ = page_module.GetPageModule()

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

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

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