X-Git-Url: https://git.giacomolli.uk/onehouse/blobdiff_plain/b28ae53ae04c41116acb2beae9d5a2128a187c83..db3091ee257788c92421a5b8b1af49d429ce8f8e:/protocol/builders.go?ds=sidebyside diff --git a/protocol/builders.go b/protocol/builders.go index b9a39f7..16f94f8 100644 --- 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 } -// 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{ @@ -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 { - return Message[BatchPayload]{}, fmt.Errorf("parse commandbatch: %w", err) + return Message[BatchPayload]{}, fmt.Errorf("parse command batch: %w", err) } return message, nil @@ -160,7 +160,7 @@ func ParseResult(topic string, data []byte, retained bool) (Message[ResultPayloa 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{ @@ -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 { - return Message[HubStatusPayload]{}, fmt.Errorf("parse hubstatus: %w", err) + return Message[HubStatusPayload]{}, fmt.Errorf("parse hub status: %w", err) } return message, nil