kern/v4/d2/lti/dot/msg_sub/msg_sub_test.go

package msg_sub

import (
	"testing"

	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/bus_ent"
)

type tester struct {
	t     *testing.T
	owner *d0.LOwner
}

func TestPublishMsg(t *testing.T) {
	sf := &tester{
		t:     t,
		owner: d0.LetOwner(1, "test_owner"),
	}
	sf.req()
	sf.resp()
}

// Работа с ответом.
func (sf *tester) resp() {
	sf.t.Log("resp")
	sf.respBad1()
	resp := &SubscribeResp{
		Status_: d0.LetTxt(sf.owner, "test_ok"),
	}
	resp.SelfCheck()
}

// Кривые поля ответа.
func (sf *tester) respBad1() {
	sf.t.Log("respBad1")
	defer func() {
		if _panic := recover(); _panic == nil {
			sf.t.Fatalf("respBad1(): panic==nil")
		}
	}()
	resp := &SubscribeResp{}
	resp.SelfCheck()
}

var (
	qName = bus_ent.ATopic("test_topic")
)

// Работа с запросом.
func (sf *tester) req() {
	sf.t.Log("req")
	sf.reqBad1()
	req := &SubscribeReq{
		Topic_:   qName,
		Uuid_:    d0.LetTxt(sf.owner,"test_uuid"),
		WebHook_: d0.LetTxt(sf.owner,"test msg"),
	}
	req.SelfCheck()
}

// Кривые поля.
func (sf *tester) reqBad1() {
	sf.t.Log("reqBad1")
	defer func() {
		if _panic := recover(); _panic == nil {
			sf.t.Fatalf("reqBad1(): panic==nil")
		}
	}()
	req := &SubscribeReq{}
	req.SelfCheck()
}