Build typed MQTT publications

[onehouse] / protocol / envelope.go

diff --git a/protocol/envelope.go b/protocol/envelope.go
index 9db8c03a4c348639d0529003ffd87f8837ca0d60..a6833a4ca2f5ab6489bf9a70d1ba1e503020a52d 100644 (file)
--- a/protocol/envelope.go
+++ b/protocol/envelope.go
@@ -15,8 +15,10 @@ const (
 
        // MeasurementRepeatInterval bounds equal retained measurement repeats.
        MeasurementRepeatInterval = 5 * time.Minute
+
        // OnlineRepeatInterval bounds equal online availability repeats.
        OnlineRepeatInterval = 5 * time.Minute
+
        // DeviceContactTimeout bounds the age of device contact evidence.
        DeviceContactTimeout = 15 * time.Minute
 )
@@ -45,7 +47,11 @@ func EncodeEnvelope(metadata Metadata, payload any) ([]byte, error) {
                return nil, fmt.Errorf("encode payload: %w", err)
        }
 
-       envelope := Envelope{Schema: Schema, Metadata: metadata, Payload: encoded}
+       envelope := Envelope{
+               Schema:   Schema,
+               Metadata: metadata,
+               Payload:  encoded,
+       }
        err = validateEnvelope(envelope)
        if err != nil {
                return nil, fmt.Errorf("validate envelope: %w", err)