msg_serve_test.go 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. package msg_serve
  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 TestServeMsg(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 := &ServeResp{
  22. Status_: defs.Txt("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 := &ServeResp{}
  35. resp.SelfCheck()
  36. }
  37. var (
  38. qName = bus_ent.ATopic("test_topic")
  39. )
  40. // Работа с запросом.
  41. func (sf *tester) req() {
  42. sf.t.Log("req")
  43. sf.reqBad1()
  44. req := &ServeReq{
  45. Topic_: qName,
  46. Uuid_: defs.Txt("test_uuid"),
  47. BinReq_: []byte("test msg"),
  48. }
  49. req.SelfCheck()
  50. }
  51. // Кривые поля.
  52. func (sf *tester) reqBad1() {
  53. sf.t.Log("reqBad1")
  54. defer func() {
  55. if _panic := recover(); _panic == nil {
  56. sf.t.Fatalf("reqBad1(): panic==nil")
  57. }
  58. }()
  59. req := &ServeReq{}
  60. req.SelfCheck()
  61. }