kern/v4/lev2/kbus/dict_topic_sub/dict_topic_sub_test.go

package dict_topic_sub

import (
	"testing"

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

type tester struct {
	t    *testing.T
	dict *dictTopicSub
	hand *mock_hand_sub_local.MockHandlerSub
}

var (
	qTopicDictSub  = alias.NewATopic("topic_dict_sub")
	qTopicDictSub1 = alias.NewATopic("topic_dict_sub1")
	qTopicTest     = alias.NewATopic("test_test")
	qTopicTestBad  = alias.NewATopic("test_bad_topic")
	qTopicEmpty    = alias.NewATopic("")
)

func TestDictSub(t *testing.T) {
	sf := &tester{
		t:    t,
		hand: mock_hand_sub_local.NewMockHandlerSub(qTopicDictSub, "name_dict_sub"),
	}
	sf.new()
	sf.addBad1()
	sf.addGood1()
	sf.addGood2()
	sf.callGood10()
	sf.callGood1()
	sf.callBad2()
	sf.delBad1()
	sf.delGood2()
	sf.unsub1()
}

// Прямой вызов отписки от топика которого точно нет.
func (sf *tester) unsub1() {
	sf.t.Log("unsub1")
	sf.dict.Unsubscribe(sf.hand)
	sf.dict.Read(qTopicTest, []byte("test test"))
	hand := mock_hand_sub_local.NewMockHandlerSub(qTopicDictSub1, "name_dict_sub")
	sf.dict.Unsubscribe(hand)
	count := 0
	for count < 100 {
		SleepMs()
		count++
	}
	sf.dict.Read(qTopicDictSub, []byte("test test"))
	count = 0
	for count < 200 {
		SleepMs()
		count++
	}
}

func (sf *tester) delGood2() {
	sf.t.Log("delGood2()")
	defer func() {
		if _panic := recover(); _panic != nil {
			sf.t.Fatalf("delGood2(): panic=%v", _panic)
		}
	}()
	sf.dict.Unsubscribe(sf.hand)
	sf.dict.Unsubscribe(sf.hand)
}

// Удаляет, чего нет.
func (sf *tester) delBad1() {
	sf.t.Log("delBad1()")
	sf.dict.Unsubscribe(nil)
}

func (sf *tester) callGood1() {
	sf.t.Log("callGood1")
	sf.dict.Read(sf.hand.Topic(), []byte("test_good"))
}

// повторное добавление обработчика.
func (sf *tester) addGood2() {
	sf.t.Log("addGood2")
	res := sf.dict.Subscribe(sf.hand)
	res.Hassert("addGood2()")
}

// Правильное добавление обработчика подписки.
func (sf *tester) addGood1() {
	sf.t.Log("addGood1()")
	res := sf.dict.Subscribe(sf.hand)
	res.Hassert("addGood1()")
}

// Вместо обработчика пустышка.
func (sf *tester) addBad1() {
	sf.t.Log("addBad1()")
	res := sf.dict.Subscribe(nil)
	if res.IsOk() {
		sf.t.Fatalf("addBad1(): res.IsOk()==true")
	}
}

// Нет топика.
func (sf *tester) callBad2() {
	sf.t.Log("callBad2")
	sf.dict.Read(qTopicEmpty, []byte("test_msg"))
}

// Нет данных в топике.
func (sf *tester) callGood10() {
	sf.t.Log("callGood10")
	defer func() {
		if _panic := recover(); _panic != nil {
			sf.t.Fatalf("callGood10(): panic=%v", _panic)
		}
	}()
	sf.dict.Read(qTopicTestBad, []byte("test"))
}

// Создание словаря подписчиков.
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.dict = NewDictTopicSub().Hassert("newGood1()")
	if sf.dict == nil {
		sf.t.Fatalf("newGood1(): DictSub==nil")
	}
}