Build typed MQTT publications

[onehouse] / protocol / address_test.go

diff --git a/protocol/address_test.go b/protocol/address_test.go
index f6600c8885d7b8dfe349c26f035bc198b4753db1..eca76d7520b81a3d0875b02caf9e61fbcac8343a 100644 (file)
--- a/protocol/address_test.go
+++ b/protocol/address_test.go
@@ -20,20 +20,65 @@ func TestAddressRoundTrip(t *testing.T) {
                target string
                suffix string
        }{
-               {name: "routes metadata", kind: Descriptor, suffix: "descriptor"},
-               {name: "routes reachability", kind: Availability, suffix: "availability"},
-               {name: "routes retained values", kind: Reported, target: "relay.1", suffix: "reported/relay.1"},
-               {name: "routes samples", kind: Telemetry, target: "power", suffix: "telemetry/power"},
-               {name: "routes occurrences", kind: Event, target: "press", suffix: "events/press"},
-               {name: "routes requests", kind: Command, target: "relay", suffix: "commands/relay"},
-               {name: "routes ordered requests", kind: CommandBatch, suffix: "commands/$batch"},
-               {name: "routes outcomes", kind: Result, target: commandID, suffix: "results/" + commandID},
-               {name: "routes hub diagnostics", kind: HubStatus, suffix: "status"},
+               {
+                       name:   "routes metadata",
+                       kind:   Descriptor,
+                       suffix: "descriptor",
+               },
+               {
+                       name:   "routes reachability",
+                       kind:   Availability,
+                       suffix: "availability",
+               },
+               {
+                       name:   "routes retained values",
+                       kind:   Reported,
+                       target: "relay.1",
+                       suffix: "reported/relay.1",
+               },
+               {
+                       name:   "routes samples",
+                       kind:   Telemetry,
+                       target: "power",
+                       suffix: "telemetry/power",
+               },
+               {
+                       name:   "routes occurrences",
+                       kind:   Event,
+                       target: "press",
+                       suffix: "events/press",
+               },
+               {
+                       name:   "routes requests",
+                       kind:   Command,
+                       target: "relay",
+                       suffix: "commands/relay",
+               },
+               {
+                       name:   "routes ordered requests",
+                       kind:   CommandBatch,
+                       suffix: "commands/$batch",
+               },
+               {
+                       name:   "routes outcomes",
+                       kind:   Result,
+                       target: commandID,
+                       suffix: "results/" + commandID,
+               },
+               {
+                       name:   "routes hub diagnostics",
+                       kind:   HubStatus,
+                       suffix: "status",
+               },
        }
 
        for _, tc := range testCases {
                t.Run(tc.name, func(t *testing.T) {
-                       address := Address{Kind: tc.kind, ID: deviceID, Target: tc.target}
+                       address := Address{
+                               Kind:   tc.kind,
+                               ID:     deviceID,
+                               Target: tc.target,
+                       }
                        topic, err := address.Topic()
                        require.NoError(t, err)
 
@@ -76,7 +121,10 @@ func TestParseTopicRejectsMalformedAddresses(t *testing.T) {
 func TestSubscriptionsSelectOnlyTheirDirection(t *testing.T) {
        filters := CoreSubscriptions()
        require.Len(t, filters, 6)
-       require.Equal(t, Subscription{Filter: Root + "/devices/+/telemetry/+", QoS: 0}, filters[3])
+       require.Equal(t, Subscription{
+               Filter: Root + "/devices/+/telemetry/+",
+               QoS:    0,
+       }, filters[3])
 
        for index, filter := range filters {
                require.NotContains(t, filter.Filter, "commands")