kern/v4/kern_test.go

package kern

import (
	"os"
	"testing"

	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
	"gitp78su.ipnodns.ru/svi/kern/v4/d0/defs"
	"gitp78su.ipnodns.ru/svi/kern/v4/d1/log_buf"
	"gitp78su.ipnodns.ru/svi/kern/v4/d1/mock_env"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lsi/store_ent"
	"gitp78su.ipnodns.ru/svi/kern/v4/d3/mod_ent"
)

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

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

func TestBuilders(t *testing.T) {
	owner := d0.LetOwner(1, "test_kern")
	sf := &tester{
		t:         t,
		me:        mock_env.MakeEnv(owner),
		owner:     owner,
	}
	_ = 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")
	_ = NewSome("test err")
	_ = NewNone[int64]()

	valInt := LetNum(sf.owner, 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 := MutSafeTxt("test %v", 123)
	if safeStr == nil {
		sf.t.Fatalf("new(): ISafeStr==nil")
	}

	// fnIf := mL0.FnIf(helpers.If)
	// if fnIf == nil {
	// 	sf.t.Fatalf("new(): If==nil")
	// }
}

func (sf *tester) new2() {
	kCtx := GetKernelCtx()
	if kCtx == 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_: d0.MutSafeBool(sf.owner, true),
	}
	logBuf := NewLogBuf(param)
	if logBuf == nil {
		sf.t.Fatalf("new2(): ILogBuf==nil")
	}
	boolReact := MutSafeBoolReact(sf.owner, false)
	if boolReact == nil {
		sf.t.Fatalf("new2(): ISafeBoolReact==nil")
	}
	safeInt := MutSafeNum(sf.owner, 12)
	if safeInt == nil {
		sf.t.Fatalf("new2(): ISafeInt==nil")
	}
	lCtx := NewLocalCtx(sf.owner, kCtx.SelfCtx())
	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.LetModuleName("test_mod")
	mod := NewKernelModule(sf.owner, modName)
	if mod == nil {
		sf.t.Fatalf("new1(): IKernelModule==nil")
	}

	clientLocal := NewClientBusLocal()
	if clientLocal == nil {
		sf.t.Fatalf("new1(): (local) IBusClient==nil")
	}
	clientHttp := NewClientBusHttp(sf.owner, defs.LetTxt("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 := d0.MutSafeBool(sf.owner, 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")
	}
}