msg_unsub_test.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. package msg_unsub
  2. import (
  3. "testing"
  4. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
  5. "gitp78su.ipnodns.ru/svi/kern/v4/lev2/lti/bus_ent"
  6. )
  7. type tester struct {
  8. t *testing.T
  9. }
  10. func TestPublishMsg(t *testing.T) {
  11. sf := &tester{
  12. t: t,
  13. }
  14. sf.req()
  15. sf.resp()
  16. }
  17. // Работа с ответом.
  18. func (sf *tester) resp() {
  19. sf.t.Log("resp")
  20. sf.respBad1()
  21. resp := &UnsubResp{
  22. Status_: defs.TxtFix("test_ok"),
  23. }
  24. resp.SelfCheck()
  25. }
  26. // Кривые поля ответа.
  27. func (sf *tester) respBad1() {
  28. sf.t.Log("respBad1")
  29. defer func() {
  30. if _panic := recover(); _panic == nil {
  31. sf.t.Fatalf("respBad1(): panic==nil")
  32. }
  33. }()
  34. resp := &UnsubResp{}
  35. resp.SelfCheck()
  36. }
  37. // Работа с запросом.
  38. func (sf *tester) req() {
  39. sf.t.Log("req")
  40. sf.reqBad1()
  41. req := &UnsubReq{
  42. HandlerName_: bus_ent.AHandlerName("test_topic"),
  43. Uuid_: defs.TxtFix("test_uuid"),
  44. }
  45. req.SelfCheck()
  46. }
  47. // Кривые поля.
  48. func (sf *tester) reqBad1() {
  49. sf.t.Log("reqBad1")
  50. defer func() {
  51. if _panic := recover(); _panic == nil {
  52. sf.t.Fatalf("reqBad1(): panic==nil")
  53. }
  54. }()
  55. req := &UnsubReq{}
  56. req.SelfCheck()
  57. }