kern/v4/d2/log_topic/log_topic_test.go

package log_topic

import (
	"testing"

	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/kern_ctx"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/bus_ent/topic"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/kbus_local/client_bus_local"
)

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

func TestLogTopic(t *testing.T) {
	sf := &tester{
		t: t,
		owner: d0.LetOwner(1,"test_owner"),
	}
	sf.new()
}

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

// Правильное создание топика.
func (sf *tester) newGood1() {
	sf.t.Log("newGood1")
	busClient := client_bus_local.NewClientBusLocal()
	qTopicTest := topic.LetTopic("test_topic")
	client := NewLogTopic(sf.owner, qTopicTest, busClient).Hassert("newGood1()")
	res := client.Pub([]byte("test_msg"))
	if res.IsErr() {
		sf.t.Fatalf("newGood1(): err=%v", res.Err())
	}
	kCtx := kern_ctx.GetKernCtx()
	kCtx.Cancel()
	kCtx.Wg().Wait()
	res = client.Pub([]byte("test_msg"))
	if !res.IsErr() {
		sf.t.Fatalf("newGood1(): err==nil")
	}
}