Merge pull request #2 from huangjimmy/issue_134_publish_to_sqs

Fix mj1618#134 0.76.0: SNS -> publish to subscribed SQS queue, "Records" a…
huangjimmy · Feb 25, 2023 · d7a50fe · d7a50fe
2 parents 1ea482c + 3935b5d
commit d7a50fe
Showing 1 changed file with 8 additions and 24 deletions.
diff --git a/src/sns-server.ts b/src/sns-server.ts
@@ -301,30 +301,14 @@ export class SNSServer implements ISNSServer {
     const sqsEndpoint = `${subEndpointUrl.protocol}//${subEndpointUrl.host}/`;
     const sqs = new SQS({ endpoint: sqsEndpoint, region: this.region });
 
-    if (sub["Attributes"]["RawMessageDelivery"] === "true") {
-      return sqs
-        .sendMessage({
-          QueueUrl: sub.Endpoint,
-          MessageBody: event,
-          MessageAttributes: formatMessageAttributes(messageAttributes),
-          ...(messageGroupId && { MessageGroupId: messageGroupId }),
-        })
-        .promise();
-    } else {
-      const record = {
-        awsRegion: this.region,
-        eventSource: "aws:sqs",
-        body: event,
-      };
-      return sqs
-        .sendMessage({
-          QueueUrl: sub.Endpoint,
-          MessageBody: JSON.stringify({ Records: [record] }),
-          MessageAttributes: formatMessageAttributes(messageAttributes),
-          ...(messageGroupId && { MessageGroupId: messageGroupId }),
-        })
-        .promise();
-    }
+    return sqs
+      .sendMessage({
+        QueueUrl: sub.Endpoint,
+        MessageBody: event,
+        MessageAttributes: formatMessageAttributes(messageAttributes),
+        ...(messageGroupId && { MessageGroupId: messageGroupId }),
+      })
+      .promise();
   }
 
   public publish(