kern/v4/lev1/kbus_msg/msg_sub/msg_sub.go

// package msg_sub -- сообщения для подписки.
package msg_sub

import (
	"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"
)

// SubscribeReq -- входящий запрос на подписку.
type SubscribeReq struct {
	Topic_   *topic.ATopic `json:"topic"` // Топик, на который надо подписаться
	Uuid_    string        `json:"uuid"`
	WebHook_ string        `json:"web_hook"` // Веб-хук для обратного вызова
}

// SelfCheck -- проверяет поля на правильность.
func (sf *SubscribeReq) SelfCheck() {
	mKh.Hassert(sf.Topic_.Get() != "", "SubscribeReq.SelfCheck(): topic is empty")
	mKh.Hassert(sf.Uuid_ != "", "SubscribeReq.SelfCheck(): uuid is empty")
	mKh.Hassert(sf.WebHook_ != "", "SubscribeReq.SelfCheck(): WebHook_ is empty")
}

// SubscribeResp -- ответ на запрос подписки.
type SubscribeResp struct {
	Status_ string                     `json:"status"`
	Uuid_   string                     `json:"uuid"`
	Name_   *handler_name.AHandlerName `json:"name"` // Уникальное имя подписки
}

// SelfCheck -- проверяет правильность своих полей.
func (sf *SubscribeResp) SelfCheck() {
	mKh.Hassert(sf.Status_ != "", "SubscribeResp.SelfCheck(): status is empty")
	mKh.Hassert(sf.Name_ != nil, "SubscribeResp.SelfCheck(): name is empty")
}