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{
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
}
-// 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{
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