kern/v4/d3/mod_serv_http/mod_serv_http_test.go

package mod_serv_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"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/kern_ctx"
	"gitp78su.ipnodns.ru/svi/kern/v4/d3/mod_spec"
)

const (
	baseUrl   = "http://localhost:18390/"
	pathStore = "/store/store_mod_serv_http"
)

type tester struct {
	t     *testing.T
	me    *mock_env.MockEnv
	kCtx  *d2.KernCtx
	mod   mod_spec.IKernelModule
	owner *d0.LOwner
}

func TestModServHttp(t *testing.T) {
	owner := d0.LetOwner(1, "isol_kern_serv_http")
	sf := &tester{
		t:     t,
		owner: owner,
		me:    mock_env.MakeEnv(owner),
		kCtx:  kern_ctx.GetKernCtx(),
	}
	err := os.Unsetenv("LOCAL_STORE_PATH")
	d0.If(err != nil).Hassert("err=%v", err)
	err = os.Setenv("LOCAL_STORE_PATH", pathStore)
	d0.If(err != nil).Hassert("err=%v", err)
	err = os.Unsetenv("LOCAL_HTTP_URL")
	d0.If(err != nil).Hassert("err=%v", err)
	err = os.Setenv("LOCAL_HTTP_URL", baseUrl)
	d0.If(err != nil).Hassert("err=%v", err)
	fnClear := func() {
		pwd := sf.me.Pwd().String() + pathStore
		_ = os.RemoveAll(pwd)
	}
	fnClear()
	defer fnClear()
	sf.kCtx.Set(d0.LetTxt("monolitName"), "test_monolit", "test")
	sf.new()
	sf.done()
}

// Завершение работы.
func (sf *tester) done() {
	sf.t.Log("done")
	sf.kCtx.Cancel()
	sf.kCtx.Wg().Wait()
	if isWork := sf.mod.IsWork(); isWork {
		sf.t.Fatalf("newGood1(): isWork==true")
	}
}

// Создание нового модуля HTTP-сервера.
func (sf *tester) new() {
	sf.t.Log("new")
	// sf.newBad1()
	sf.newGood1()
}

func (sf *tester) newGood1() {
	sf.t.Log("newGood1")
	_ = mock_env.MakeEnv(sf.owner)
	err := os.Unsetenv("LOCAL_HTTP_URL")
	d0.If(err != nil).Hassert("newGood1(): err=%v", err)
	err = os.Setenv("LOCAL_HTTP_URL", "http://localhost:18301/")
	d0.If(err != nil).Hassert("newGood1(): err=%v", err)
	sf.mod = GetModuleServHttp()
	_ = GetModuleServHttp()
	if sf.mod == nil {
		sf.t.Fatalf("newGood1(): mod==nil")
	}
	go sf.mod.Run()
	for {
		time.Sleep(time.Millisecond * 1)
		if sf.mod.IsWork() {
			return
		}
	}
}

// нет ничего для создания модуля
// func (sf *tester) newBad1() {
// 	sf.t.Log("newBad1")
// 	defer func() {
// 		if _panic := recover(); _panic == nil {
// 			sf.t.Fatalf("newBad1(): panic==nil")
// 		}
// 	}()
// 	_ = GetModuleServHttp()
// }