kern/v4/lev2/mock_hand_sub_local/mock_hand_sub.go

// package mock_hand_sub -- мок-обработчик подписки.
package mock_hand_sub_local

import (
	"crypto/rand"
	"sync"

	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/handler_name"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/topic"
	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
)

type MockHandlerSub struct {
	Msg_   []byte                     // Для обратного вызова
	Name_  *handler_name.AHandlerName // Уникальное имя мок-обработчика подписки
	Topic_ *topic.ATopic              // Имя топика подписки
	block  sync.RWMutex
}

// NewMockHandlerSub -- возвращает новый обработчик подписки.
func NewMockHandlerSub(topic *topic.ATopic, localHook string) *MockHandlerSub {
	mKh.Hassert(topic.Get() != "", "NewMockHandlerSub(): topic is empty")
	mKh.Hassert(localHook != "", "NewMockHandlerSub(): name is empty")
	sf := &MockHandlerSub{
		Topic_: topic,
		Name_:  mKd.NewHandlerName(localHook + "_" + rand.Text()),
	}
	_ = mKs.IBusHandlerSubscribe(sf)
	return sf
}

// Возвращает хранимое значение.
func (sf *MockHandlerSub) Msg() string {
	sf.block.RLock()
	defer sf.block.RUnlock()
	return string(sf.Msg_)
}

// Функция обратного вызова подписки.
func (sf *MockHandlerSub) FnBack(binMsg []byte) {
	sf.block.Lock()
	defer sf.block.Unlock()
	sf.Msg_ = binMsg
}

// Возвращает уникальное имя обработчика подписки.
func (sf *MockHandlerSub) Topic() *topic.ATopic {
	return sf.Topic_
}

// Возвращает топик для обработчика подписки.
func (sf *MockHandlerSub) Name() *handler_name.AHandlerName {
	return sf.Name_
}