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

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

import (
	"fmt"
	"sync"

	. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kalias"
	. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/ktypes"
	. "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
)

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

// NewDictSubHook -- возвращает новый словарь веб-хуков одного топика
func NewDictSubHook() IResult[IDictSubHook] {
	resKernCtx := kctx.GetKernelCtx()
	if resKernCtx.IsErr() {
		err := fmt.Errorf("dictSubHook.NewDictSubHook(): in get kernel ctx, err=\n\t%w", resKernCtx.Err())
		return NewErr[IDictSubHook](err)
	}
	sf := &dictSubHook{
		ctx:  resKernCtx.Val(),
		dict: map[AHandlerName]bool{},
	}
	return NewRes(IDictSubHook(sf))
}

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

// Subscribe -- добавляет в словарь подписки новый обработчик
func (sf *dictSubHook) Subscribe(handler IBusHandlerSubscribe) IResult[bool] {
	sf.block.Lock()
	defer sf.block.Unlock()
	if handler == nil {
		err := fmt.Errorf("dictSubHook.Subscribe(): handler==nil")
		return NewErr[bool](err)
	}
	handlerName := handler.Name()
	sf.dict[handlerName] = true
	res := sf.ctx.Set(string(handlerName), handler, "subscribe handler")
	if res.IsErr() {
		err := fmt.Errorf("dictSubHook.Subscribe(): in set subscribe handler in kernel ctx, err=\n\t%w", res.Err())
		return NewErr[bool](err)
	}
	return NewRes(true)
}

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