kern/v4/lev2/kbus/dict_sub_hook/dict_sub_hook_test.go

package dict_sub_hook

import (
	"testing"

	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/alias"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/mock_hand_sub_local"
)

type tester struct {
	t        *testing.T
	dict     *dictSubHook
	handSub  *mock_hand_sub_local.MockHandlerSub
	handSub2 *mock_hand_sub_local.MockHandlerSub
}

var (
	qTopicHand1 = alias.NewATopic("hand_topic1")
	qTopicHand2 = alias.NewATopic("hand_topic2")
)

func TestDictSubWebHook(t *testing.T) {
	sf := &tester{
		t:        t,
		handSub:  mock_hand_sub_local.NewMockHandlerSub(qTopicHand1, "hand_name1"),
		handSub2: mock_hand_sub_local.NewMockHandlerSub(qTopicHand2, "hand_name2"),
	}
	sf.new()
	sf.add()
	sf.read()
	sf.unsub()
}

// Отписка обработчика от топика.
func (sf *tester) unsub() {
	sf.t.Log("unsub")
	sf.dict.Unsubscribe(sf.handSub)
}

// Чтение входящего сообщения по подписке.
func (sf *tester) read() {
	sf.t.Log("read")
	sf.dict.Read([]byte("test_msg"))
}

// Добавляет хуки в словарь.
func (sf *tester) add() {
	sf.t.Log("add")
	sf.addBad1()
	sf.addGood1()
}

func (sf *tester) addGood1() {
	sf.t.Log("addGood1")
	sf.dict.Subscribe(sf.handSub)
	sf.dict.Subscribe(sf.handSub)
	sf.dict.Subscribe(sf.handSub2)
	if _len := len(sf.dict.dict); _len != 2 {
		sf.t.Fatalf("new(): len(%v)!=2", _len)
	}
}

// нет веб-хука для добавления.
func (sf *tester) addBad1() {
	sf.t.Log("addBad1")
	sf.dict.Subscribe(nil)
}

// Создание словаря.
func (sf *tester) new() {
	sf.t.Log("new")
	sf.dict = NewDictSubHook().(*dictSubHook)
	if sf.dict == nil {
		sf.t.Fatalf("new(): dict==nil")
	}
	if _len := len(sf.dict.dict); _len != 0 {
		sf.t.Fatalf("new(): len(%v)!=0", _len)
	}
}