Feat push

.gitignore

@@ -1,3 +1,7 @@
 .idea
 vendor
 .phpunit.result.cache
+Makefile
+.envrc
+.env
+*.p8

composer.json

@@ -26,8 +26,8 @@
     "ext-curl": "*"
   },
   "require-dev": {
-    "phpunit/phpunit": "9.5.*",
-    "phpmailer/phpmailer": "6.6.*",
+    "phpunit/phpunit": "^9.6",
+    "phpmailer/phpmailer": "^6.8",
     "laravel/pint": "^1.2"
   },
   "config": {

docker-compose.yml

@@ -8,6 +8,8 @@ services:
       - ./src:/usr/local/src/src
       - ./tests:/usr/local/src/tests
       - ./phpunit.xml:/usr/local/src/phpunit.xml
+    env_file:
+      - .env
 
   maildev:
     image: appwrite/mailcatcher:1.0.0

phpunit.xml

@@ -6,7 +6,7 @@
          convertNoticesToExceptions="true"
          convertWarningsToExceptions="true"
          processIsolation="false"
-         stopOnFailure="false"
+         stopOnFailure="true"
 >
     <testsuites>
         <testsuite name="unit">

src/Utopia/Messaging/Adapters/Email/Mailgun.php

@@ -34,19 +34,21 @@ public function getMaxMessagesPerRequest(): int
      */
     protected function process(Email $message): string
     {
-        return $this->request(
+        $response = $this->request(
             method: 'POST',
             url: "https://api.mailgun.net/v3/{$this->domain}/messages",
             headers: [
                 'Authorization: Basic '.base64_encode('api:'.$this->apiKey),
             ],
             body: \http_build_query([
-                'from' => $message->getFrom(),
                 'to' => \implode(',', $message->getTo()),
+                'from' => $message->getFrom(),
                 'subject' => $message->getSubject(),
                 'text' => $message->isHtml() ? null : $message->getContent(),
                 'html' => $message->isHtml() ? $message->getContent() : null,
             ]),
         );
+
+        return $response;
     }
 }

src/Utopia/Messaging/Adapters/Email/Sendgrid.php

@@ -7,9 +7,7 @@
 
 class Sendgrid extends EmailAdapter
 {
-    public function __construct(
-        private string $apiKey,
-    ) {
+    public function __construct(private string $apiKey) {
     }
 
     public function getName(): string

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

@@ -0,0 +1,95 @@
+<?php
+
+namespace Utopia\Messaging\Adapters\Push;
+
+use Utopia\Messaging\Adapters\Push as PushAdapter;
+use Utopia\Messaging\Messages\Push;
+
+class APNS extends PushAdapter
+{
+    private $authKey;
+    private $authKeyId;
+    private $teamId;
+    private $bundleId;
+    private $endpoint;
+
+    public function __construct(string $authKey, string $authKeyId, string $teamId, string $bundleId, string $endpoint)
+    {
+        $this->authKey = $authKey;
+        $this->authKeyId = $authKeyId;
+        $this->teamId = $teamId;
+        $this->bundleId = $bundleId;
+        $this->endpoint = $endpoint;
+    }
+
+    public function getName(): string
+    {
+        return 'APNS';
+    }
+
+
+    public function getMaxMessagesPerRequest(): int
+    {
+        return 1000;
+    }
+
+    public function process(Push $message): string
+    {
+        $headers = [
+            'authorization: bearer ' . $this->generateJwt(),
+            'apns-topic: ' . $this->bundleId,
+        ];
+
+        $payload = json_encode([
+            'aps' => [
+                'alert' => [
+                    'title' => $message->getTitle(),
+                    'body' => $message->getBody(),
+                ],
+                'badge' => $message->getBadge(),
+                'sound' => $message->getSound(),
+                'data' => $message->getData(),
+            ],
+        ]);
+
+        // Assuming the 'to' array contains device tokens for the push notification recipients.
+        foreach ($message->getTo() as $to) {
+            $url = $this->endpoint . '/3/device/' . $to;
+            $response = $this->request('POST', $url, $headers, $payload);
+
+            // You might want to handle each response here, for instance, logging failures
+        }
+
+        // This example simply returns the last response, adjust as needed
+        return $response;
+    }
+
+    private function generateJwt(): string
+    {
+        $header = json_encode(['alg' => 'ES256', 'kid' => $this->authKeyId]);
+        $claims = json_encode([
+            'iss' => $this->teamId,
+            'iat' => time(),
+        ]);
+
+        $base64UrlHeader = str_replace(['+', '/', '='], ['-', '_', ''], base64_encode($header));
+        $base64UrlClaims = str_replace(['+', '/', '='], ['-', '_', ''], base64_encode($claims));
+
+        $privateKeyResource = openssl_pkey_get_private(file_get_contents($this->authKey));
+        if (!$privateKeyResource) {
+            throw new \Exception('Invalid private key');
+        }
+
+        $signature = '';
+        $success = openssl_sign("$base64UrlHeader.$base64UrlClaims", $signature, $privateKeyResource, OPENSSL_ALGO_SHA256);
+
+        if (!$success) {
+            throw new \Exception('Failed to sign JWT');
+        }
+
+        $base64UrlSignature = str_replace(['+', '/', '='], ['-', '_', ''], base64_encode($signature));
+
+        return "$base64UrlHeader.$base64UrlClaims.$base64UrlSignature";
+    }
+
+}

src/Utopia/Messaging/Entities/Entity.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace Utopia\Messaging\Adapters\Push\Entities;
+
+abstract class Entity {
+  protected $id;
+}