sns: Add parameters for fifo topics (ansible-collections#1733)

sns: Add parameters for fifo topics

SUMMARY
Implements ansible-collections#1718. Adding message_group_id and message_deduplication_id to support publishing of messages to fifo topics.
ISSUE TYPE

Feature Pull Request

COMPONENT NAME
sns

Reviewed-by: Mark Chappell

sns.py

@@ -69,11 +69,28 @@
   message_structure:
     description:
       - The payload format to use for the message.
-      - This must be 'json' to support protocol-specific messages (C(http), C(https), C(email), C(sms), C(sqs)).
-      - It must be 'string' to support I(message_attributes).
+      - This must be C(json) to support protocol-specific messages (C(http), C(https), C(email), C(sms), C(sqs)).
+      - It must be C(string) to support I(message_attributes).
     default: json
     choices: ['json', 'string']
     type: str
+  message_group_id:
+    description:
+      - A tag which is used to process messages that belong to the same group in a FIFO manner.
+      - Has to be included when publishing a message to a fifo topic.
+      - Can contain up to 128 alphanumeric characters and punctuation.
+    type: str
+    version_added: 5.4.0
+  message_deduplication_id:
+    description:
+      - Only in connection with the message_group_id.
+      - Overwrites the auto generated MessageDeduplicationId.
+      - Can contain up to 128 alphanumeric characters and punctuation.
+      - Messages with the same deduplication id getting recognized as the same message.
+      - Gets overwritten by an auto generated token, if the topic has ContentBasedDeduplication set.
+    type: str
+    version_added: 5.4.0
+
 extends_documentation_fragment:
   - amazon.aws.region.modules
   - amazon.aws.common.modules
@@ -108,6 +125,14 @@
         data_type: String
         string_value: "green"
   delegate_to: localhost
+
+- name: Send message to a fifo topic
+  community.aws.sns:
+    topic: "deploy"
+    msg: "Message with message group id"
+    subject: Deploy complete!
+    message_group_id: "deploy-1"
+  delegate_to: localhost
 """
 
 RETURN = r"""
@@ -121,6 +146,10 @@
   returned: when success
   type: str
   sample: 2f681ef0-6d76-5c94-99b2-4ae3996ce57b
+sequence_number:
+  description: A 128 bits long sequence number which gets assigned to the message in fifo topics
+  returned: when success
+  type: str
 """
 
 import json
@@ -154,6 +183,8 @@ def main():
         topic=dict(required=True),
         message_attributes=dict(type='dict'),
         message_structure=dict(choices=['json', 'string'], default='json'),
+        message_group_id=dict(),
+        message_deduplication_id=dict(),
     )
 
     for p in protocols:
@@ -172,6 +203,11 @@ def main():
             module.fail_json(msg='message_attributes is only supported when the message_structure is "string".')
         sns_kwargs['MessageAttributes'] = module.params['message_attributes']
 
+    if module.params["message_group_id"]:
+        sns_kwargs["MessageGroupId"] = module.params["message_group_id"]
+        if module.params["message_deduplication_id"]:
+            sns_kwargs["MessageDeduplicationId"] = module.params["message_deduplication_id"]
+
     dict_msg = {
         'default': sns_kwargs['Message']
     }
@@ -202,7 +238,12 @@ def main():
     except (BotoCoreError, ClientError) as e:
         module.fail_json_aws(e, msg='Failed to publish message')
 
-    module.exit_json(msg='OK', message_id=result['MessageId'])
+    sns_result = dict(msg="OK", message_id=result["MessageId"])
+
+    if module.params["message_group_id"]:
+        sns_result["sequence_number"] = result["SequenceNumber"]
+
+    module.exit_json(**sns_result)
 
 
 if __name__ == '__main__':