kern/v4/lev2/kserv_http_std/kserv_http_std.go

// package kserv_http_std -- реализация HTTP-сервера на стандартной библиотеке.
package kserv_http_std

import (
	"fmt"
	"net/http"
	"sync"
	"time"

	"gitp78su.ipnodns.ru/svi/kern/v4/lev0"
	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/log_buf"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/safe_bool"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kspec"
)

// kServHttpStd -- реализация HTTP-сервера на стандартной библиотеке.
type kServHttpStd struct {
	kCtx   kspec.IKernelCtx
	log    comp_spec.ILogBuf
	port   lev0.LInt
	server *http.Server
}

var (
	kServ *kServHttpStd
	mu    sync.Mutex
)

// GetKservHttpStd -- возвращает HTTP-сервер на стандартной библиотеке.
func GetKservHttpStd() *lev0.Result[*kServHttpStd] {
	mu.Lock()
	defer mu.Unlock()
	if kServ != nil {
		return lev0.ResOk(kServ)
	}
	logBufParam := &log_buf.LogBufParam{
		IsTerm_: safe_bool.NewSafeBool(true),
		Prefix_: lev0.LetTxt("kServHttpStd"),
	}
	log := mL1.NewLogBuf(logBufParam)
	log.Debug("GetKservHttpStd()")
	resPort := mL1.NewSafeIntGetenv(lev0.LetTxt("SERV_HTTP_STD_PORT"))
	resPort.Hassert("in get env SERV_HTTP_STD_PORT")
	sf := &kServHttpStd{
		kCtx: kctx.GetKernelCtx(),
		log:  log,
		port: resPort.Ok(),
	}
	kServ = sf
	return lev0.ResOk(sf)
}

// Run -- запускает сервер вы работу.
func (sf *kServHttpStd) Run() {
	sf.server = &http.Server{
		Addr:         fmt.Sprintf(":%v", sf.port),
		ReadTimeout:  30 * time.Second,
		WriteTimeout: 30 * time.Second,
		IdleTimeout:  75 * time.Second,
		Handler:      nil,
	}
	// Запуск сервера в горутине
	go func() {
		msg := lev0.LetTxt("kServHttpStd.Run().fn(): run on http://%v", sf.server.Addr)
		sf.log.Debug(msg.Get())
		if err := sf.server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
			err := lev0.LetErr("kServHttpStd.Run.fn(): in work, err=\n\t%v", err)
			sf.log.Err(err)
		}
	}()
	go sf.close()
	if err := sf.server.Shutdown(sf.kCtx.Ctx()); err != nil {
		sf.log.Debug("kServHttpStd.Run(): ошибка при graceful shutdown, err=\n\t%v", err)
	}

	sf.log.Info("Сервер остановлен")
}

func (sf *kServHttpStd) close() {

}