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

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

import (
	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kalias"
)

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

// SelfCheck -- проверяет поля на правильность.
func (sf *SubscribeReq) SelfCheck() {
	mKh.Hassert(sf.Topic_ != "", "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_   mKa.AHandlerName `json:"name"` // Уникальное имя подписки
}

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