kern/v4/lev2/lti/dot/msg_sub/msg_sub.go

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

import (
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/lti/bus_ent"
)

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

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

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

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