kern/v4/d2/lti/kbus_local/kbus_local_test.go

package kbus_local

import (
	"testing"

	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/bus_ent/topic"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/bus_mock/mock_hand_serve"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/bus_mock/mock_hand_sub_local"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/bus_spec"
)

type tester struct {
	t        *testing.T
	owner    *d0.LOwner
	lBus     bus_spec.IKernelBus
	handSub  *mock_hand_sub_local.MockHandlerSub
	handServ *mock_hand_serve.MockHandlerServe
}

func TestKernelBusLocal(t *testing.T) {
	owner := d0.LetOwner(1, "test_owner")
	qTopicSub := topic.LetTopic("topic_hand_sub")
	qTopicServ := topic.LetTopic("topic_hand_serv")
	sf := &tester{
		t:        t,
		owner:    owner,
		handSub:  mock_hand_sub_local.NewMockHandlerSub(owner,qTopicSub, d0.LetTxt(owner, "mock_hand_sub")),
		handServ: mock_hand_serve.NewMockHandlerServe(qTopicServ, "mock_hand_serv"),
	}
	sf.new()
}

// Создание локальной шины.
func (sf *tester) new() {
	sf.t.Log("new")
	sf.newGood1()

}

func (sf *tester) newGood1() {
	sf.t.Log("newGood1")
	defer func() {
		if _panic := recover(); _panic != nil {
			sf.t.Fatalf("newGood1(): panic=%v", _panic)
		}
	}()
	sf.lBus = GetKernelBusLocal()
	sf.lBus = GetKernelBusLocal()
	if sf.lBus == nil {
		sf.t.Fatalf("newGood1(): IKernelBus==nil")
	}
	if !sf.lBus.IsWork() {
		sf.t.Fatalf("newGood1(): bus not work")
	}
}