(t *testing.T)
| 1740 | } |
| 1741 | |
| 1742 | func TestServerProcessPublishOnMessageRecvRejected(t *testing.T) { |
| 1743 | s := newServer() |
| 1744 | require.NotNil(t, s) |
| 1745 | hook := new(modifiedHookBase) |
| 1746 | hook.fail = true |
| 1747 | hook.err = packets.ErrRejectPacket |
| 1748 | |
| 1749 | err := s.AddHook(hook, nil) |
| 1750 | require.NoError(t, err) |
| 1751 | |
| 1752 | _ = s.Serve() |
| 1753 | defer s.Close() |
| 1754 | cl, _, _ := newTestClient() |
| 1755 | err = s.processPublish(cl, *packets.TPacketData[packets.Publish].Get(packets.TPublishBasic).Packet) |
| 1756 | require.NoError(t, err) // packets rejected silently |
| 1757 | } |
| 1758 | |
| 1759 | func TestServerProcessPacketPublishQos0(t *testing.T) { |
| 1760 | s := newServer() |
nothing calls this directly
no test coverage detected