kern/v4/lev2/kserv_http/kserv_http.go

// package kserv_http -- встроенный HTTP-сервер.
package kserv_http

import (
	"embed"
	"fmt"
	"io/fs"
	"net/http"
	"os"
	"strings"
	"sync"
	"time"

	"github.com/gofiber/contrib/v3/monitor"
	"github.com/gofiber/fiber/v3"
	"github.com/gofiber/fiber/v3/middleware/compress"
	"github.com/gofiber/fiber/v3/middleware/static"

	"gitp78su.ipnodns.ru/svi/kern/v4/lev0"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kern_ctx"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kern_ent/stream_name"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kspec"
)

var (
	msg0       = lev0.Txt("kernel_server_http")
	streamName = stream_name.NewAStreamName(msg0) // Контрольная строка для ожидателя потока
)

// kServHttp -- встроенный HTTP-сервер.
type kServHttp struct {
	kCtx     *kern_ctx.KernCtx
	lCtx     *lev1.LocalCtx
	log      *lev1.LogBuf
	strUrl   *lev0.LTxt // URL, на котором слушает HTTP-сервер
	fiberApp *fiber.App
	isWork   *lev0.MSafeBool
	isEnd    *lev0.MSafeBool
}

//go:embed static/*
var embedDirStatic embed.FS

var (
	kernServHttp *kServHttp
	block        sync.Mutex
)

func getParams() (*lev0.LTxt, *lev1.LogBuf, *kern_ctx.KernCtx) {
	param := &lev1.LogBufParam{
		IsTerm_: lev0.MutSafeBool(true),
		Prefix_: lev0.LetTxt("kServHttp"),
	}
	log := lev1.NewLogBuf(param)
	log.Debug("GetKernelServHttp(): first run")
	strLocalUrl := os.Getenv("LOCAL_HTTP_URL")
	lev0.If(strLocalUrl == "").Hassert("getParams(): env LOCAL_HTTP_URL not set")
	kCtx := kern_ctx.GetKernCtx()
	return lev0.LetTxt(strLocalUrl), log, kCtx
}

// GetKernelServHttp -- возвращает  встроенный HTTP-сервер.
func GetKernelServHttp() kspec.IKernelServerHttp {
	block.Lock()
	defer block.Unlock()
	if kernServHttp != nil {
		kernServHttp.log.Debug("GetKernelServHttp()")
		return kernServHttp
	}
	strLocalUrl, log, kCtx := getParams()

	optMonolit := kCtx.Get(lev0.LetTxt("monolitName"))
	optMonolit.Hassert("GetKernelServHttp(): not have monolit name from kCtx")
	strMonolit := optMonolit.Some().Val().(*lev0.LTime)
	confFiber := fiber.Config{
		ServerHeader: strMonolit.String(),
		UnescapePath: true,
		ReadTimeout:  time.Second * 15,
		WriteTimeout: time.Second * 15,
		AppName:      strMonolit.String(),
	}
	sf := &kServHttp{
		kCtx:     kCtx,
		log:      log,
		lCtx:     lev1.NewLocalCtx(kCtx.SelfCtx()),
		strUrl:   strLocalUrl,
		fiberApp: fiber.New(confFiber),
		isWork:   lev0.MutSafeBool(false),
		isEnd:    lev0.MutSafeBool(false),
	}
	sf.fiberApp.Use(compress.New(compress.Config{
		Level: compress.LevelBestCompression, // 2
	}))
	sf.fiberApp.Get("/static", static.New("/static", static.Config{
		FS:     fs.FS(embedDirStatic),
		Browse: true,
		MaxAge: 3600 * 24,
	}))
	// Или расширьте конфигурацию для индивидуальной настройки
	// Назначьте промежуточное программное обеспечение для /metrics
	// и измените заголовок на `Страница метрик MyService`
	sf.fiberApp.Get("/metrics", monitor.New(monitor.Config{
		Title: fmt.Sprintf("Страница метрик %q", strMonolit),
	}))
	sf.kCtx.Wg().Add(streamName)
	kCtx.Set(lev0.LetTxt("fiberApp"), sf.fiberApp, "GetKernelServHttp() internal fiber app")
	kernServHttp = sf
	kCtx.Set(lev0.LetTxt("kServHttp"), kernServHttp, "kServHttp")
	return kernServHttp
}

// IsWork -- возвращает признак работы.
func (sf *kServHttp) IsWork() lev0.Bool {
	return sf.isWork.Get()
}

// Log -- возвращает локальный лог.
func (sf *kServHttp) Log() *lev1.LogBuf {
	return sf.log
}

// Fiber -- возвращает объект веб-приложения fiber.
func (sf *kServHttp) Fiber() *fiber.App {
	return sf.fiberApp
}

// Run -- запускает сервер в работу (не блокирующий вызов).
func (sf *kServHttp) Run() {
	block.Lock()
	defer block.Unlock()
	if sf.isEnd.Get() {
		return
	}
	if sf.isWork.Get() {
		return
	}
	sf.log.Debug("Run(): url='%v'", sf.strUrl)
	lstPort := strings.Split(sf.strUrl.String(), ":")
	strPort := lstPort[len(lstPort)-1]
	strPort = strings.ReplaceAll(strPort, "/", "")
	strPort = strings.ReplaceAll(strPort, `"`, "")
	chErr := make(chan *lev0.LErr, 2)
	fnListen := func() {
		defer close(chErr)
		err := sf.fiberApp.Listen(":" + strPort)
		chErr <- lev0.LetErr("kServHttp.Run().fnListen(): in listen server on port=%q, err=\n\t%v", strPort, err)
	}
	go fnListen()
	go sf.fnChErr(chErr)
	fnCheckServer := func() error {
		client := &http.Client{Timeout: 5 * time.Millisecond}
		url := lev0.LetTxt(sf.strUrl.Get() + "monitor")
		sf.log.Debug("url=%v", url.Get())
		var (
			resp *http.Response
			err  error
		)
		if resp, err = client.Get(url.String()); err == nil {
			_ = resp.Body.Close()
		}
		return err
	}

	for {
		time.Sleep(time.Millisecond * 10)
		err := fnCheckServer()
		if err == nil {
			break
		}
	}

	sf.isWork.Set()
	go sf.close()
}

// В отдельном потоке ждёт закрытия канала.
func (sf *kServHttp) fnChErr(chErr <-chan *lev0.LErr) {
	err := <-chErr
	if err.Get() != "<nil>" {
		err := lev0.LetErr("kServHttp.fnChErr(): in listen, err=\n\t%w", err)
		sf.log.Err(err)
		sf.kCtx.Cancel()
	}
}

// Ожидает окончания работы.
func (sf *kServHttp) close() {
	sf.kCtx.Wait()
	if !sf.isWork.Get() {
		return
	}
	sf.isWork.Reset()
	sf.isEnd.Set()
	err := sf.fiberApp.Server().Shutdown()
	lev0.If(err != nil).Assert("kServHttp.close(): in close server, err=\n\t%v", err)
	sf.kCtx.Wg().Done(streamName)
	sf.log.Debug("close(): end")
}