From bc9f5370e4122996113ed0b7be3aa4ea99b05415 Mon Sep 17 00:00:00 2001
From: Makarychev Nikolay <admin@caa.center>
Date: Mon, 8 Jul 2024 15:12:43 +0500
Subject: [PATCH] Added SmsRu adapter

---
 src/Utopia/Messaging/Adapter/SMS/SmsRu.php | 82 ++++++++++++++++++++++
 1 file changed, 82 insertions(+)
 create mode 100644 src/Utopia/Messaging/Adapter/SMS/SmsRu.php

diff --git a/src/Utopia/Messaging/Adapter/SMS/SmsRu.php b/src/Utopia/Messaging/Adapter/SMS/SmsRu.php
new file mode 100644
index 0000000..c33b30d
--- /dev/null
+++ b/src/Utopia/Messaging/Adapter/SMS/SmsRu.php
@@ -0,0 +1,82 @@
+<?php
+
+namespace Utopia\Messaging\Adapter\SMS;
+
+// Reference Material
+// https://www.textmagic.com/docs/api/send-sms/#How-to-send-bulk-text-messages
+
+use Utopia\Messaging\Adapter\SMS as SMSAdapter;
+use Utopia\Messaging\Messages\SMS as SMSMessage;
+use Utopia\Messaging\Response;
+
+class SmsRu extends SMSAdapter
+{
+    protected const NAME = 'SmsRu';
+
+    /**
+     * @param  string  $username Textmagic account username
+     * @param  string  $apiKey Textmagic account API key
+     */
+    public function __construct(
+        private string $username,
+        private string $apiKey,
+        private ?string $from = null
+    ) {
+    }
+
+    public function getName(): string
+    {
+        return static::NAME;
+    }
+
+    public function getMaxMessagesPerRequest(): int
+    {
+        return 1000;
+    }
+
+    /**
+     * {@inheritdoc}
+     *
+     * @throws \Exception
+     */
+    protected function process(SMSMessage $message): array
+    {
+        $to = \array_map(
+            fn ($to) => \ltrim($to, '+'),
+            $message->getTo()
+        );
+
+        $response = new Response($this->getType());
+        $result = $this->request(
+            method: 'POST',
+            url: 'https://rest.textmagic.com/api/v2/messages',
+            headers: [
+                'Content-Type: application/x-www-form-urlencoded',
+                'X-TM-Username: ' . $this->username,
+                'X-TM-Key: '. $this->apiKey,
+            ],
+            body: [
+                'text' => $message->getContent(),
+                'from' => \ltrim($this->from ?? $message->getFrom(), '+'),
+                'phones' => \implode(',', $to),
+            ],
+        );
+
+        if ($result['statusCode'] >= 200 && $result['statusCode'] < 300) {
+            $response->setDeliveredTo(\count($message->getTo()));
+            foreach ($message->getTo() as $to) {
+                $response->addResult($to);
+            }
+        } else {
+            foreach ($message->getTo() as $to) {
+                if (!\is_null($result['response']['message'] ?? null)) {
+                    $response->addResult($to, $result['response']['message']);
+                } else {
+                    $response->addResult($to, 'Unknown error');
+                }
+            }
+        }
+
+        return $response->toArray();
+    }
+}