added aws sns adapter

.github/workflows/tests.yml

@@ -25,6 +25,7 @@ jobs:
         TWILIO_FROM: ${{ secrets.TWILIO_FROM }}
         TELNYX_API_KEY: ${{ secrets.TELNYX_API_KEY }}
         TELNYX_PUBLIC_KEY: ${{ secrets.TELNYX_PUBLIC_KEY }}
+        AWSSNS_API_GATEWAY_URL: ${{ secrets.AWSSNS_API_GATEWAY_URL }}
         APNS_AUTHKEY_8KVVCLA3HL: ${{ secrets.APNS_AUTHKEY_8KVVCLA3HL }}
         APNS_AUTH_ID: ${{ secrets.APNS_AUTH_ID }}
         APNS_TEAM_ID: ${{ secrets.APNS_TEAM_ID }}

docker-compose.yml

@@ -14,6 +14,7 @@ services:
     - TWILIO_FROM
     - TELNYX_API_KEY
     - TELNYX_PUBLIC_KEY
+    - AWSSNS_API_GATEWAY_URL
     - APNS_AUTHKEY_8KVVCLA3HL
     - APNS_AUTH_ID
     - APNS_TEAM_ID

src/Utopia/Messaging/Adapters/Push/AWSSNS.php

@@ -0,0 +1,62 @@
+<?php
+
+namespace Utopia\Messaging\Adapters\Push;
+
+use Utopia\Messaging\Adapters\Push as PushAdapter;
+use Utopia\Messaging\Messages\Push;
+
+class AWSSNS extends PushAdapter
+{
+    /**
+     * @param string $apiGatewayUrl
+     */
+    public function __construct(
+        private string $apiGatewayUrl
+    ) {
+    }
+
+    /**
+     * Get adapter name.
+     *
+     * @return string
+     */
+    public function getName(): string
+    {
+        return 'AWSSNS';
+    }
+
+    /**
+     * Get max messages per request.
+     *
+     * @return int
+     */
+    public function getMaxMessagesPerRequest(): int
+    {
+        return 5000;
+    }
+
+    /**
+     * {@inheritdoc}
+     *
+     * @throws \Exception
+     */
+    protected function process(Push $message): string
+    {
+        // Create the payload
+        $payload = [
+            'message' => $message->getData()
+        ];
+
+        // Make the HTTP request
+        $response = $this->request(
+            method: 'POST',
+            url: $this->apiGatewayUrl,
+            headers: [
+                'Content-Type: application/json',
+            ],
+            body: json_encode($payload)
+        );
+
+        return $response;
+    }
+}

tests/e2e/Push/AWSSNSTest.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace Tests\E2E;
+
+use Utopia\Messaging\Adapters\Push\AWSSNS as AWSSNSAdapter;
+use Utopia\Messaging\Messages\Push;
+
+class AWSSNSTest extends Base
+{
+    public function testSend(): void
+    {
+        $apiGatewayUrl = getenv('AWSSNS_API_GATEWAY_URL');
+
+        $adapter = new AWSSNSAdapter($apiGatewayUrl);
+
+        $message = new Push(
+            data: null
+        );
+
+        $response = json_decode($adapter->send($message), true);
+
+        $this->assertNotEmpty($response);
+        $this->assertEquals('success', $response['status'] ?? null);
+        $this->assertNotEmpty($response['MessageId'] ?? null);
+    }
+}