kern/v4/kern_test.go

package kern

import (
	"os"
	"testing"

	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/log_buf"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/mock_env"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/safe_bool"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/lsi/store_ent"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_ent"
)

const (
	baseUrl   = "http://127.0.0.1:18420/"
	pathStore = "/store/store_helpers"
)

type tester struct {
	t  *testing.T
	me *mock_env.MockEnv
}

func TestBuilders(t *testing.T) {
	sf := &tester{
		t:  t,
		me: mock_env.MakeEnv(),
	}
	_ = os.Unsetenv("LOCAL_STORE_PATH")
	_ = os.Setenv("LOCAL_STORE_PATH", pathStore)
	_ = os.Unsetenv("LOCAL_HTTP_URL")
	_ = os.Setenv("LOCAL_HTTP_URL", baseUrl)
	fnClear := func() {
		_ = os.RemoveAll(pathStore)
	}
	fnClear()
	defer fnClear()
	sf.new()
}

// создание компонентов.
func (sf *tester) new() {
	sf.t.Log("new")
	ctx := GetKernelCtx()
	if ctx == nil {
		sf.t.Fatalf("new(): IKernelCtx==nil")
	}
	sf.new0()
	sf.new1()
	sf.new2()
	sf.new3()

	_ = NewOk("test ok")
	_ = NewErr[core_spec.EBool](defs.Err("test err"))
	_ = NewSome("test err")
	_ = NewNone[int64]()

	valInt := NewInt(28)
	if val := valInt.Get(); val != 28 {
		sf.t.Fatalf("new(): cal(%v)!=28", val)
	}

	kernServHttp := GetKernelServerHttp()
	go kernServHttp.Run()
	ctx.Cancel()
	ctx.Wg().Wait()
	ctx.Cancel()
	ctx.Wg().Wait()
}

func (sf *tester) new3() {
	safeStr := NewSafeString()
	if safeStr == nil {
		sf.t.Fatalf("new(): ISafeStr==nil")
	}

	fnHassert := mL1.FnHassert(helpers.Hassert)
	if fnHassert == nil {
		sf.t.Fatalf("new(): Hassert==nil")
	}

	fnAssert := mL1.FnAssert(helpers.Assert)
	if fnAssert == nil {
		sf.t.Fatalf("new(): Assert==nil")
	}
}

func (sf *tester) new2() {
	ctx := GetKernelCtx()
	if ctx == nil {
		sf.t.Fatalf("new(): IKernelCtx==nil")
	}
	modServHttp := GetModuleServHttp()
	if modServHttp == nil {
		sf.t.Fatalf("new2(): modServHttp==nil")
	}

	modKernelCtx := GetModuleKernelCtx()
	if modKernelCtx == nil {
		sf.t.Fatalf("new2(): modKernelCtx==nil")
	}
	modKernelKeeper := GetModuleKernelKeeper()
	if modKernelKeeper == nil {
		sf.t.Fatalf("new2(): modKernelKeeper==nil")
	}
	modWui := GetModuleWui()
	if modWui == nil {
		sf.t.Fatalf("new2(): modWui==nil")
	}

	param := &log_buf.LogBufParam{
		IsTerm_: safe_bool.NewSafeBool(true),
	}
	logBuf := NewLogBuf(param)
	if logBuf == nil {
		sf.t.Fatalf("new2(): ILogBuf==nil")
	}
	boolReact := NewSafeBoolReact()
	if boolReact == nil {
		sf.t.Fatalf("new2(): ISafeBoolReact==nil")
	}
	safeInt := NewSafeInt(12)
	if safeInt == nil {
		sf.t.Fatalf("new2(): ISafeInt==nil")
	}
	lCtx := NewLocalCtx(ctx.Ctx())
	if lCtx == nil {
		sf.t.Fatalf("new2(): ILocalCtx==nil")
	}
}

func (sf *tester) new1() {
	monLocal := GetMonolitLocal("mon_local")
	if monLocal == nil {
		sf.t.Fatalf("new1(): (local) IKernelMonolit==nil")
	}

	monHttp := GetMonolitHttp("mon_http")
	if monHttp == nil {
		sf.t.Fatalf("new1(): (http) IKernelMonolit==nil")
	}
	modName := mod_ent.NewModuleNameFix("test_mod")
	mod := NewKernelModule(modName)
	if mod == nil {
		sf.t.Fatalf("new1(): IKernelModule==nil")
	}

	clientLocal := NewClientBusLocal()
	if clientLocal == nil {
		sf.t.Fatalf("new1(): (local) IBusClient==nil")
	}
	clientHttp := NewClientBusHttp(defs.Txt("test_url"))
	if clientHttp == nil {
		sf.t.Fatalf("new1(): (http) IBusClient==nil")
	}
}

var (
	str1 = store_ent.NewStoreKeyFix("test_builders")
)

func (sf *tester) new0() {
	store := GetKernelStoreKv()
	res := store.Delete(str1)
	if res.IsErr() {
		sf.t.Fatalf("new0(): get empty key, store, err=%v", res.Err())
	}
	safeBool := NewSafeBool(true)
	if safeBool == nil {
		sf.t.Fatalf("new0(): ISafeBool==nil")
	}

	kernBus := GetKernelBusLocal()
	if kernBus == nil {
		sf.t.Fatalf("new0(): (local) IKernelBus==nil")
	}

	kernBusHttp := GetKernelBusHttp()
	if kernBusHttp == nil {
		sf.t.Fatalf("new0(): (http) IKernelBus==nil")
	}
}