for _, tc := range testCases {
t.Run(tc.name, func(t *testing.T) {
- data, err := EncodeEnvelope(metadata, json.RawMessage(tc.payload))
+ data, err := encodeEnvelope(metadata, json.RawMessage(tc.payload))
if tc.kind == Event {
require.Error(t, err)
Kind: tc.kind,
ID: deviceID,
Target: tc.target,
- }).Topic()
+ }).topic()
require.NoError(t, err)
_, err = Parse(topic, data, false)