kern/v4/d2/kserv_http/kserv_http_test.go

package kserv_http

import (
	"os"
	"testing"
	"time"

	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
	"gitp78su.ipnodns.ru/svi/kern/v4/d1/mock_env"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/kern_ctx"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/kspec"
)

const (
	baseUrl = "http://localhost:18400/"
)

type tester struct {
	t     *testing.T
	kCtx  *kern_ctx.KernCtx
	wg    kspec.IKernelWg
	me    *mock_env.MockEnv
	owner *d0.LOwner
}

func TestKernelServHttp(t *testing.T) {
	kCtx := kern_ctx.GetKernCtx()
	owner := d0.LetOwner(1, "test_kernel_serv_http")
	sf := &tester{
		t:     t,
		kCtx:  kCtx,
		wg:    kCtx.Wg(),
		owner: owner,
	}
	sf.new()
	sf.close()
}

// Закрытие HTTP-сервера.
func (sf *tester) close() {
	sf.t.Log("close")
	sf.kCtx.Cancel()
	sf.wg.Wait()
	kernServHttp.close()
	if kernServHttp.IsWork() {
		sf.t.Fatalf("close(): isWork==true")
	}
	kernServHttp.Run()
	chErr := make(chan *d0.LErr, 2)
	chErr <- d0.LetErr("test err")
	close(chErr)
	kernServHttp.fnChErr(chErr)
}

// Создание сервера HTTP.
func (sf *tester) new() {
	sf.t.Log("new()")
	sf.newBad1()
	sf.newBad2()
	sf.newGood1()
	sf.newBad3()
}

// Повторный запуск сервера на том же порту.
func (sf *tester) newBad3() {
	sf.t.Log("newBad3()")
	serv := GetKernelServHttp()
	go serv.Run()
	count := 0
	for count < 20 {
		time.Sleep(time.Millisecond * 1)
		count++
	}
}

func (sf *tester) newGood1() {
	sf.t.Log("newGood1()")
	defer func() {
		if _panic := recover(); _panic != nil {
			sf.t.Fatalf("newGood1(): panic=%v", _panic)
		}
	}()
	sf.me = mock_env.MakeEnv(sf.owner)
	_ = os.Unsetenv("LOCAL_HTTP_URL")
	_ = os.Setenv("LOCAL_HTTP_URL", baseUrl)
	sf.kCtx.Set(d0.LetTxt("monolitName"), "test_monolit", "comment")
	serv := GetKernelServHttp().(*kServHttp)
	if serv != kernServHttp {
		sf.t.Fatalf("newGood1(): bad IKernelServHttp")
	}
	if webFiber := serv.Fiber(); webFiber != kernServHttp.fiberApp {
		sf.t.Fatalf("newGood1(): webFiber==serv.appFiber")
	}
	if log := serv.Log(); log == nil {
		sf.t.Fatalf("newGood1(): log==nil")
	}
	// go serv.Run()
	// count := 0
	// for count < 50 {
	// 	SleepMs()
	// 	count++
	// }
	serv.Run()
}

// Не указана SERVER_HTTP_PORT.
func (sf *tester) newBad2() {
	sf.t.Log("newBad2()")
	_ = GetKernelServHttp()
}

// Нет контекста ядра.
func (sf *tester) newBad1() {
	sf.t.Log("newBad1()")
	_ = GetKernelServHttp()
}