From 3e61154cf6cbb4bd513aa26dfd3281a8348c6298 Mon Sep 17 00:00:00 2001
From: kevin <kevinjosephjohn@icloud.com>
Date: Thu, 6 Jun 2024 22:45:52 +0530
Subject: [PATCH] Added SMSGatewayHub adapter

---
 .../Messaging/Adapter/SMS/SmsGatewayHub.php   | 91 +++++++++++++++++++
 .../Adapter/SMS/SmsGatewayHubTest.php         | 30 ++++++
 2 files changed, 121 insertions(+)
 create mode 100644 src/Utopia/Messaging/Adapter/SMS/SmsGatewayHub.php
 create mode 100644 tests/Messaging/Adapter/SMS/SmsGatewayHubTest.php

diff --git a/src/Utopia/Messaging/Adapter/SMS/SmsGatewayHub.php b/src/Utopia/Messaging/Adapter/SMS/SmsGatewayHub.php
new file mode 100644
index 0000000..834cd71
--- /dev/null
+++ b/src/Utopia/Messaging/Adapter/SMS/SmsGatewayHub.php
@@ -0,0 +1,91 @@
+<?php
+
+namespace Utopia\Messaging\Adapter\SMS;
+
+use Utopia\Messaging\Adapter\SMS as SMSAdapter;
+use Utopia\Messaging\Messages\SMS as SMSMessage;
+use Utopia\Messaging\Response;
+
+class SMSGatewayHub extends SMSAdapter
+{
+    protected const NAME = 'SMSGatewayHub';
+
+    /**
+     * @param  string  $apiKey SMS Gateway Hub API Key
+     * @param  string  $senderId SMS Gateway Hub Sender ID
+     * @param  string  $route SMS Gateway Hub Route
+     * @param  string  $dltTemplateId SMS Gateway Hub DLT Template ID
+     * @param  string  $peId SMS Gateway Hub PEID
+     */
+    public function __construct(
+        private string $apiKey,
+        private string $senderId,
+        private string $route,
+        private string $dltTemplateId,
+        private string $peId,
+    ) {
+    }
+
+    public function getName(): string
+    {
+        return static::NAME;
+    }
+
+    public function getMaxMessagesPerRequest(): int
+    {
+        return 100;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function process(SMSMessage $message): array
+    {
+        $recipients = [];
+        foreach ($message->getTo() as $recipient) {
+            $recipients[] = \ltrim($recipient, '+');
+        }
+
+        $response = new Response($this->getType());
+
+        // Construct the query string
+        $queryParams = http_build_query([
+            'apiKey' => $this->apiKey,
+            'senderid' => $this->senderId,
+            'channel' => 'Trans',
+            'DCS' => '0',
+            'flashsms' => '0',
+            'number' => \implode(',', $recipients),
+            'text' => $message->getContent(),
+            'route' => $this->route,
+            'DLTTemplateId' => $this->dltTemplateId,
+            'PEID' => $this->peId,
+        ]);
+
+        $url = 'https://login.smsgatewayhub.com/api/mt/SendSMS?' . $queryParams;
+        $result = $this->request(
+            'GET',
+            $url,
+            [
+                'Content-Type: application/json',
+            ]
+        );
+
+        // Log the URL and result for debugging
+        \error_log('Request URL: ' . $url);
+        \error_log('Response: ' . \json_encode($result));
+
+        if ($result['statusCode'] === 200) {
+            $response->setDeliveredTo(\count($message->getTo()));
+            foreach ($message->getTo() as $to) {
+                $response->addResult($to);
+            }
+        } else {
+            foreach ($message->getTo() as $to) {
+                $response->addResult($to, 'Unknown error');
+            }
+        }
+
+        return $response->toArray();
+    }
+}
diff --git a/tests/Messaging/Adapter/SMS/SmsGatewayHubTest.php b/tests/Messaging/Adapter/SMS/SmsGatewayHubTest.php
new file mode 100644
index 0000000..ee7d1c6
--- /dev/null
+++ b/tests/Messaging/Adapter/SMS/SmsGatewayHubTest.php
@@ -0,0 +1,30 @@
+<?php
+
+namespace Utopia\Tests\Adapter\SMS;
+
+use Utopia\Messaging\Adapter\SMS\SMSGatewayHub;
+use Utopia\Messaging\Messages\SMS;
+use Utopia\Tests\Adapter\Base;
+
+class SMSGatewayHubTest extends Base
+{
+    public function testSendSMS(): void
+    {
+        $sender = new SMSGatewayHub(
+            apiKey: getenv('SMS_GATEWAY_APIKEY'),
+            senderId: getenv('SMS_GATEWAY_SENDER_ID'),
+            route: getenv('SMS_GATEWAY_ROUTE'),
+            dltTemplateId: getenv('SMS_GATEWAY_DLT_TEMPLATE_ID'),
+            peId: getenv('SMS_GATEWAY_PEID')
+        );
+
+        $message = new SMS(
+            to: [917358240825],
+            content: 'Your login OTP is 789456. This OTP is Valid for 5 Minutes. Never share your OTP with anyone.',
+        );
+
+        $response = $sender->send($message);
+
+        $this->assertResponse($response);
+    }
+}