Easier chat id migrations with callback

Author: TiiFuchs

src/Bot.php

@@ -24,6 +24,7 @@
 use Telepath\Handlers\ConversationHandler;
 use Telepath\Handlers\Handler;
 use Telepath\Layers\Generated;
+use Telepath\Telegram\ResponseParameters;
 use Telepath\Telegram\Update;
 
 class Bot extends Generated
@@ -125,11 +126,8 @@ protected function discoverPsr4(string $path): static
 
                     $this->handlers[] = $attribute->newInstance()
                         ->assign($class, $method->getName());
-
                 }
-
             }
-
         }
 
         if (count($this->handlers) === 0) {
@@ -202,9 +200,7 @@ public function handlePolling(?array $allowedUpdates = null, int $timeout = 60):
 
                 $offset = max($offset, $update->update_id + 1);
                 $this->processUpdate($update);
-
             }
-
         }
     }
 
@@ -231,7 +227,7 @@ public function username(): string
         }
 
         // Check cache
-        $cacheKey = 'telepath.username.'. sha1($this->token);
+        $cacheKey = 'telepath.username.'.sha1($this->token);
         $username = $this->cache()?->get($cacheKey);
         if ($username !== null) {
             $this->username = $username;
@@ -289,6 +285,16 @@ protected function processUpdate(Update $update): mixed
     {
         $this->container->extend(Update::class)->setConcrete($update);
 
+        // Check for chat_id_migration
+        if ($update->message?->migrate_to_chat_id || $update->message?->migrate_from_chat_id) {
+            $message = $update->message;
+
+            $fromChatId = $message->migrate_from_chat_id ?? $message->chat->id;
+            $toChatId = $message->migrate_to_chat_id ?? $message->chat->id;
+
+            $this->callChatIdMigrationCallbacks($fromChatId, $toChatId);
+        }
+
         $responsibleHandlers = [];
 
         $conversationHandler = $this->getAvailableConversationHandler($update);
@@ -340,4 +346,61 @@ private function getNamespace(string $file): ?string
 
         return $namespace ?: null;
     }
+
+    /**
+     * @var array<callable(int, int): void>
+     */
+    protected array $chatIdMigrationCallbacks = [];
+
+    protected function callChatIdMigrationCallbacks(int $fromChatId, int $toChatId): void
+    {
+        foreach ($this->chatIdMigrationCallbacks as $callback) {
+            $callback($fromChatId, $toChatId);
+        }
+    }
+
+    /**
+     * @param  callable(int $fromChatId, int $toChatId): void  $callback
+     */
+    public function chatIdMigrationCallback(callable $callback): static
+    {
+        $this->chatIdMigrationCallbacks[] = $callback;
+
+        return $this;
+    }
+
+    /**
+     * @param array{
+     *     ok: bool,
+     *     description?: string,
+     *     result?: array,
+     *     error_code?: int,
+     *     parameters?: array,
+     * } $response
+     */
+    public function rescueError(string $method, array $data, array $response): mixed
+    {
+        if (! isset($response['parameters'])) {
+            return null;
+        }
+
+        $responseParameters = new ResponseParameters($response['parameters']);
+
+        if ($responseParameters->migrate_to_chat_id) {
+            if (! isset($data['chat_id'])) {
+                return null;
+            }
+
+            $fromChatId = $data['chat_id'];
+            $toChatId = $responseParameters->migrate_to_chat_id;
+
+            $this->callChatIdMigrationCallbacks($fromChatId, $toChatId);
+
+            $data['chat_id'] = $toChatId;
+
+            return $this->$method($data);
+        }
+
+        return null;
+    }
 }

src/Layers/Base.php

@@ -58,10 +58,28 @@ public function raw(string $method, $data = []): mixed
             default => $this->sendAsJson($method, $data)
         };
 
+        /**
+         * @var array{
+         *     ok: bool,
+         *     description?: string,
+         *     result?: array,
+         *     error_code?: int,
+         *     parameters?: array,
+         * } $json
+         */
         $json = json_decode($response->getBody()->getContents(), true);
 
         if ($json['ok'] !== true) {
-            throw new TelegramException($json['description'], $json['error_code'] ?? 0);
+            $result = $this->rescueError($method, $data, $json);
+
+            if ($result !== null) {
+                return $result;
+            }
+
+            throw new TelegramException(
+                $json['description'] ?? 'An unknown error occured',
+                $json['error_code'] ?? 0
+            );
         }
 
         $this->lastApiResult = $json['description'] ?? null;
@@ -70,7 +88,11 @@ public function raw(string $method, $data = []): mixed
         preg_match('/@return (.+)\[]\n/u', $method->getDocComment(), $matches);
 
         return $this->objectify($json['result'], $method->getReturnType(), $matches[1] ?? null, $this);
+    }
 
+    protected function rescueError(string $method, array $data, array $response): mixed
+    {
+        return null;
     }
 
     protected function extractFiles(array|object &$input, int $depth = 1): array
@@ -120,7 +142,6 @@ protected function sendAsMultipart(string $method, array $data): \Psr\Http\Messa
                 'name' => $key,
                 'contents' => $value,
             ];
-
         }
 
         return $this->httpClient()->post($method, [
@@ -166,7 +187,6 @@ protected function hasInputFiles(array $data): bool
             if ($value instanceof InputMedia) {
                 return true;
             }
-
         }
 
         return false;