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

// package dict_sub_hook -- словарь потребителей топика по подписке.
package dict_sub_hook

import (
	"sync"

	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kspec"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/lti/bus_ent"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/lti/bus_spec"
)

// dictSubHook -- словарь потребителей топика по подписке.
type dictSubHook struct {
	kCtx  kspec.IKernelCtx
	dict  map[bus_ent.AHandlerName]struct{} // В качестве ключа -- URL веб-хука
	block sync.RWMutex
}

// NewDictSubHook -- возвращает новый словарь веб-хуков одного топика.
func NewDictSubHook() bus_spec.IDictSubHook {
	sf := &dictSubHook{
		kCtx: kctx.GetKernelCtx(),
		dict: map[bus_ent.AHandlerName]struct{}{},
	}
	return sf
}

// Unsubscribe -- удаляет из словаря подписки обработчик.
func (sf *dictSubHook) Unsubscribe(handler bus_spec.IBusHandlerSubscribe) {
	sf.block.Lock()
	defer sf.block.Unlock()
	if handler == nil {
		sf.kCtx.Log().Err("dictSubHook.Unsubscribe(): handler==nil")
		return
	}
	handlerName := handler.Name()
	delete(sf.dict, handlerName.Get())
	sf.kCtx.Del(handlerName.String())
}

// Subscribe -- добавляет в словарь подписки новый обработчик.
func (sf *dictSubHook) Subscribe(handler bus_spec.IBusHandlerSubscribe) {
	sf.block.Lock()
	defer sf.block.Unlock()
	helpers.Hassert(handler != nil, "dictSubHook.Subscribe(): handler==nil", []any{})
	handlerName := handler.Name()
	sf.dict[handlerName.Get()] = struct{}{}
	sf.kCtx.Set(handlerName.String(), handler, "subscribe handler")
}

// Read -- вызывает все обработчики словаря подписок.
func (sf *dictSubHook) Read(binMsg []byte) {
	sf.block.RLock()
	defer sf.block.RUnlock()
	for handlerName := range sf.dict {
		optHand := sf.kCtx.Get(string(handlerName))
		if optHand.IsNone() {
			sf.kCtx.Del(string(handlerName))
			continue
		}
		handler := optHand.Some().Val().(bus_spec.IBusHandlerSubscribe)
		go handler.FnBack(binMsg)
	}
}