Queue device commands and replay first results

[onehouse] / protocol / builders.go

diff --git a/protocol/builders.go b/protocol/builders.go
index b9a39f77b712eb17cdb3a4a4b7c35093c6194738..16f94f83987d2133fa85311aa5479af83650599c 100644 (file)
--- a/protocol/builders.go
+++ b/protocol/builders.go
@@ -121,7 +121,7 @@ func ParseCommand(topic string, data []byte, retained bool) (Message[ValuePayloa
        return message, nil
 }
 
        return message, nil
 }
 

-// BuildCommandBatch returns a validated commandbatch publication with its
+// BuildCommandBatch returns a validated command batch publication with its

 // delivery rules.
 func BuildCommandBatch(deviceID string, metadata Metadata, payload BatchPayload) (Publication, error) {
        return buildMessage(Address{
 // delivery rules.
 func BuildCommandBatch(deviceID string, metadata Metadata, payload BatchPayload) (Publication, error) {
        return buildMessage(Address{


@@ -135,7 +135,7 @@ func BuildCommandBatch(deviceID string, metadata Metadata, payload BatchPayload)
 func ParseCommandBatch(topic string, data []byte, retained bool) (Message[BatchPayload], error) {
        message, err := parseMessage[BatchPayload](CommandBatch, topic, data, retained)
        if err != nil {
 func ParseCommandBatch(topic string, data []byte, retained bool) (Message[BatchPayload], error) {
        message, err := parseMessage[BatchPayload](CommandBatch, topic, data, retained)
        if err != nil {

-               return Message[BatchPayload]{}, fmt.Errorf("parse commandbatch: %w", err)
+               return Message[BatchPayload]{}, fmt.Errorf("parse command batch: %w", err)

        }
 
        return message, nil
        }
 
        return message, nil


@@ -160,7 +160,7 @@ func ParseResult(topic string, data []byte, retained bool) (Message[ResultPayloa
        return message, nil
 }
 
        return message, nil
 }
 

-// BuildHubStatus returns a validated hubstatus publication with its delivery
+// BuildHubStatus returns a validated hub status publication with its delivery

 // rules.
 func BuildHubStatus(hubID string, metadata Metadata, payload HubStatusPayload) (Publication, error) {
        return buildMessage(Address{
 // rules.
 func BuildHubStatus(hubID string, metadata Metadata, payload HubStatusPayload) (Publication, error) {
        return buildMessage(Address{


@@ -174,7 +174,7 @@ func BuildHubStatus(hubID string, metadata Metadata, payload HubStatusPayload) (
 func ParseHubStatus(topic string, data []byte, retained bool) (Message[HubStatusPayload], error) {
        message, err := parseMessage[HubStatusPayload](HubStatus, topic, data, retained)
        if err != nil {
 func ParseHubStatus(topic string, data []byte, retained bool) (Message[HubStatusPayload], error) {
        message, err := parseMessage[HubStatusPayload](HubStatus, topic, data, retained)
        if err != nil {

-               return Message[HubStatusPayload]{}, fmt.Errorf("parse hubstatus: %w", err)
+               return Message[HubStatusPayload]{}, fmt.Errorf("parse hub status: %w", err)

        }
 
        return message, nil
        }
 
        return message, nil