kern/v4/d2/kmonolit/kmonolit_test.go

package kmonolit

import (
	"os"
	"testing"
	"time"

	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
	"gitp78su.ipnodns.ru/svi/kern/v4/d0/defs"
	"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/kmodule"
	"gitp78su.ipnodns.ru/svi/kern/v4/d3/mod_ent"
	"gitp78su.ipnodns.ru/svi/kern/v4/d3/mod_ent/module_name"
	"gitp78su.ipnodns.ru/svi/kern/v4/d3/mod_spec"
)

const (
	baseUrl   = "http://127.0.0.1:18430/"
	pathStore = "/store/store_kmonolit"
)

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

func TestKernMono(t *testing.T) {
	owner := d0.LetOwner(1, "test_isol_base")
	sf := &tester{
		t:     t,
		owner: owner,
		me:    mock_env.MakeEnv(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()
	sf.run()
	sf.add()
	sf.done()
}

func (sf *tester) done() {
	sf.t.Log("done")
	kCtx := kern_ctx.GetKernCtx()
	kCtx.Cancel()
	kCtx.Wg().Wait()
	sf.mon.Run()
	sf.mon.Wait()
	sf.mon.Run()
}

// Добавление модуля в монолит.
func (sf *tester) add() {
	sf.t.Log("add")
	sf.addGood1()
}

type mod struct {
	mod_spec.IKernelModule
}

func (sf *tester) newMod(name *module_name.LModuleName) mod_spec.IKernelModule {
	isol := &mod{
		IKernelModule: kmodule.NewKernelModule(sf.owner, name),
	}
	return isol
}

func (sf *mod) Run() {}

func (sf *tester) addGood1() {
	sf.t.Log("addGood1")
	modName := mod_ent.LetModuleName("test_module")
	mod := sf.newMod(modName)
	sf.mon.Add(mod)
}

func (sf *tester) run() {
	sf.t.Log("run")
	modName := module_name.LetModuleName("test_mod1")
	mod := sf.newMod(modName)
	sf.mon.Add(mod)
	sf.mon.Run()
	isWork := sf.mon.IsWork()
	if isWork.IsNot() {
		sf.t.Fatalf("newGood1(): isWork==false")
	}
}

// Создаёт новый монолит.
func (sf *tester) new() {
	sf.t.Log("new")
	sf.newBad1()
	sf.newGood1()
}

var txIsLocal = defs.LetTxt("isLocal")

func (sf *tester) newGood1() {
	sf.t.Log("newGood1")
	defer func() {
		if _panic := recover(); _panic != nil {
			sf.t.Fatalf("newGood1(): panic=%v", _panic)
		}
	}()
	kCtx := kern_ctx.GetKernCtx()
	kCtx.Set(txIsLocal, true, "type bus")
	for {
		time.Sleep(time.Millisecond * 1)
		if kCtx.Get(txIsLocal) != nil {
			break
		}
	}
	sf.mon = LetModMonolit("test_monolit")
	isLocal := sf.mon.IsLocal()
	if isLocal.IsNot() {
		sf.t.Fatalf("newGood1(): isLocal==false")
	}
	if name := sf.mon.Name(); name != "test_monolit" {
		sf.t.Fatalf("newGood1(): name(%v)!='test_monolit'", name)
	}
	if log := sf.mon.Log(); log == nil {
		sf.t.Fatalf("newGood1(): log==nil")
	}
	if ctx := sf.mon.Ctx(); ctx == nil {
		sf.t.Fatalf("newGood1(): ctx==nil")
	}
	sf.mon = LetModMonolit("")
}

// Нет признака локальности.
func (sf *tester) newBad1() {
	sf.t.Log("newBad1")
	_ = LetModMonolit("test_32")
}