add message group id if the publishing happens on a fifo queue

Author: MrDHat

publisher/sns/sns.go

@@ -3,6 +3,7 @@ package sns
 import (
 	"context"
 	"encoding/json"
+	"strings"
 
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/request"
@@ -37,6 +38,8 @@ type Publisher struct {
 func (p *Publisher) Publish(ctx context.Context, msg interface{}) error {
 	b, err := json.Marshal(msg)
 
+	defaultMessageGroupID := "default"
+
 	if err != nil {
 		return err
 	}
@@ -45,6 +48,10 @@ func (p *Publisher) Publish(ctx context.Context, msg interface{}) error {
 		Message:  aws.String(string(b)),
 		TopicArn: &p.cfg.TopicArn,
 	}
+	// if the topic is a fifo topic, we need to set the message group id
+	if strings.Contains(strings.ToLower(*input.TopicArn), "fifo") {
+		input.MessageGroupId = &defaultMessageGroupID
+	}
 
 	_, err = p.sns.PublishWithContext(ctx, input)