Added BotRemovedFromChatUpdate & ChatTitleChangedUpdate & MessageChatCreatedUpdate & UserAddedToChatUpdate & UserRemovedFromChatUpdate

Author: BushlanovDev

README.md

@@ -4,6 +4,9 @@
 [![PHP version](https://img.shields.io/badge/php-%3E%3D%208.3-8892BF.svg?style=flat-square)](https://github.com/BushlanovDev/max-bot-api-client-php)
 [![Software License](https://img.shields.io/badge/license-MIT-brightgreen.svg?style=flat-square)](LICENSE)
 
+> [!CAUTION]  
+> На мой взгляд `Max Messenger` является ни чем иным как малварью, созданной для слежки за гражданами РФ.
+> Настоятельно не рекомендую использовать свой настоящий номер телефона, на реальных устройствах, и для личной переписки.
 
 > [!IMPORTANT]  
 > Библиотека в стадии активной разработки.
@@ -16,3 +19,51 @@
 
 Откройте диалог с [MasterBot](https://max.ru/MasterBot), следуйте инструкциям и создайте нового бота. После создания
 бота MasterBot отправит вам токен.
+
+## Реализованные методы
+
+#### Bots
+
+- `[x] GET /me` (`getBotInfo`) — *Получение информации о боте.*
+- `[ ] PATCH /me` (`editBotInfo`) — *Редактирование информации о боте.*
+
+#### Chats
+
+- `[ ] GET /chats` (`getChats`) — *Получение списка всех чатов бота.*
+- `[ ] GET /chats/{chatLink}` (`getChatByLink`) — *Получение информации о чате по ссылке.*
+- `[x] GET /chats/{chatId}` (`getChat`) — *Получение информации о чате по ID.*
+- `[ ] PATCH /chats/{chatId}` (`editChat`) — *Редактирование информации о чате.*
+- `[ ] DELETE /chats/{chatId}` (`deleteChat`) — *Удаление чата.*
+- `[ ] POST /chats/{chatId}/actions` (`sendAction`) — *Отправка действия в чат (например, "печатает...").*
+- `[ ] GET /chats/{chatId}/pin` (`getPinnedMessage`) — *Получение закрепленного сообщения.*
+- `[ ] PUT /chats/{chatId}/pin` (`pinMessage`) — *Закрепление сообщения.*
+- `[ ] DELETE /chats/{chatId}/pin` (`unpinMessage`) — *Открепление сообщения.*
+- `[ ] GET /chats/{chatId}/members/me` (`getMembership`) — *Получение информации о членстве бота в чате.*
+- `[ ] DELETE /chats/{chatId}/members/me` (`leaveChat`) — *Выход бота из чата.*
+- `[ ] GET /chats/{chatId}/members/admins` (`getAdmins`) — *Получение администраторов чата.*
+- `[ ] POST /chats/{chatId}/members/admins` (`postAdmins`) — *Назначение администраторов чата.*
+- `[ ] DELETE /chats/{chatId}/members/admins/{userId}` (`deleteAdmins`) — *Снятие прав администратора.*
+- `[ ] GET /chats/{chatId}/members` (`getMembers`) — *Получение участников чата.*
+- `[ ] POST /chats/{chatId}/members` (`addMembers`) — *Добавление участников в чат.*
+- `[ ] DELETE /chats/{chatId}/members` (`removeMember`) — *Удаление участника из чата.*
+
+#### Subscriptions
+
+- `[x] GET /subscriptions` (`getSubscriptions`) — *Получение списка Webhook-подписок.*
+- `[x] POST /subscriptions` (`subscribe`) — *Создание Webhook-подписки.*
+- `[x] DELETE /subscriptions` (`unsubscribe`) — *Удаление Webhook-подписки.*
+- `[x] GET /updates` (`getUpdates`) — *Получение обновлений через Long-Polling.*
+
+#### Upload
+
+- `[x] POST /uploads` (`getUploadUrl`) — *Получение URL для загрузки файла.*
+
+#### Messages
+
+- `[ ] GET /messages` (`getMessages`) — *Получение списка сообщений из чата.*
+- `[x] POST /messages` (`sendMessage`) — *Отправка сообщения.*
+- `[ ] PUT /messages` (`editMessage`) — *Редактирование сообщения.*
+- `[ ] DELETE /messages` (`deleteMessage`) — *Удаление сообщения.*
+- `[ ] GET /messages/{messageId}` (`getMessageById`) — *Получение сообщения по ID.*
+- `[ ] GET /videos/{videoToken}` (`getVideoAttachmentDetails`) — *Получение детальной информации о видео.*
+- `[ ] POST /answers` (`answerOnCallback`) — *Ответ на нажатие callback-кнопки.*

src/Api.php

@@ -9,6 +9,7 @@
 use BushlanovDev\MaxMessengerBot\Enums\UploadType;
 use BushlanovDev\MaxMessengerBot\Exceptions\ClientApiException;
 use BushlanovDev\MaxMessengerBot\Exceptions\NetworkException;
+use BushlanovDev\MaxMessengerBot\Exceptions\SecurityException;
 use BushlanovDev\MaxMessengerBot\Exceptions\SerializationException;
 use BushlanovDev\MaxMessengerBot\Models\AbstractModel;
 use BushlanovDev\MaxMessengerBot\Models\Attachments\Requests\AbstractAttachmentRequest;
@@ -20,9 +21,11 @@
 use BushlanovDev\MaxMessengerBot\Models\Result;
 use BushlanovDev\MaxMessengerBot\Models\Subscription;
 use BushlanovDev\MaxMessengerBot\Models\UpdateList;
+use BushlanovDev\MaxMessengerBot\Models\Updates\AbstractUpdate;
 use BushlanovDev\MaxMessengerBot\Models\UploadEndpoint;
 use InvalidArgumentException;
 use LogicException;
+use Psr\Http\Message\ServerRequestInterface;
 use ReflectionException;
 use RuntimeException;
 
@@ -105,6 +108,146 @@ public function createWebhookHandler(?string $secret = null): WebhookHandler
         return new WebhookHandler($this, $this->modelFactory, $secret);
     }
 
+    /**
+     * Parses an incoming webhook request and returns a single Update object.
+     * This is an alternative to the event-driven WebhookHandler::handle() method,
+     * allowing for manual processing of updates.
+     *
+     * @param string|null $secret The secret key to verify the request signature.
+     * @param ServerRequestInterface|null $request The PSR-7 request object. If null, it's created from globals.
+     *
+     * @return AbstractUpdate The parsed update object (e.g., MessageCreatedUpdate).
+     * @throws \ReflectionException
+     * @throws SecurityException
+     * @throws SerializationException
+     * @throws \LogicException
+     */
+    public function getWebhookUpdate(?string $secret = null, ?ServerRequestInterface $request = null): AbstractUpdate
+    {
+        return $this->createWebhookHandler($secret)->getUpdate($request);
+    }
+
+    /**
+     * A simple way to process a single incoming webhook request using callbacks.
+     * This method creates a WebhookHandler, registers the provided callbacks, and processes the request.
+     *
+     * @param array<string, callable> $handlers An associative array where keys are UpdateType string values
+     *        (e.g., UpdateType::MessageCreated->value) and values are handlers.
+     * @param string|null $secret The secret key for request verification.
+     * @param ServerRequestInterface|null $request The PSR-7 request object.
+     *
+     * @throws SecurityException
+     * @throws SerializationException
+     * @throws ReflectionException
+     * @throws LogicException
+     */
+    public function handleWebhooks(
+        array $handlers,
+        ?string $secret = null,
+        ?ServerRequestInterface $request = null,
+    ): void {
+        $webhookHandler = $this->createWebhookHandler($secret);
+
+        foreach ($handlers as $updateType => $callback) {
+            $updateType = UpdateType::tryFrom($updateType);
+            // @phpstan-ignore-next-line
+            if ($updateType && is_callable($callback)) {
+                $webhookHandler->addHandler($updateType, $callback);
+            }
+        }
+
+        $webhookHandler->handle($request);
+    }
+
+    /**
+     * You can use this method for getting updates in case your bot is not subscribed to WebHook.
+     * The method is based on long polling.
+     *
+     * @param int|null $limit Maximum number of updates to be retrieved (1-1000).
+     * @param int|null $timeout Timeout in seconds for long polling (0-90).
+     * @param int|null $marker Pass `null` to get updates you didn't get yet.
+     * @param UpdateType[]|null $types Comma separated list of update types your bot want to receive.
+     *
+     * @return UpdateList
+     * @throws ClientApiException
+     * @throws NetworkException
+     * @throws ReflectionException
+     * @throws SerializationException
+     */
+    public function getUpdates(
+        ?int $limit = null,
+        ?int $timeout = null,
+        ?int $marker = null,
+        ?array $types = null,
+    ): UpdateList {
+        $query = [
+            'limit' => $limit,
+            'timeout' => $timeout,
+            'marker' => $marker,
+            'types' => $types !== null ? implode(',', array_map(fn($type) => $type->value, $types)) : null,
+        ];
+
+        return $this->modelFactory->createUpdateList(
+            $this->client->request(
+                self::METHOD_GET,
+                self::ACTION_UPDATES,
+                array_filter($query, fn($value) => $value !== null),
+            )
+        );
+    }
+
+    /**
+     * Starts a long-polling loop to process updates using callbacks.
+     * This method will run indefinitely until the script is terminated.
+     *
+     * @param array<string, callable> $handlers An associative array where keys are UpdateType enums
+     *        and values are the corresponding handler functions.
+     * @param int|null $timeout Timeout in seconds for long polling (0-90). Defaults to 90.
+     * @param int|null $marker Pass `null` to get updates you didn't get yet.
+     */
+    public function handleUpdates(array $handlers, ?int $timeout = null, ?int $marker = null): void
+    {
+        // @phpstan-ignore-next-line
+        while (true) {
+            try {
+                $this->processUpdatesBatch($handlers, $timeout, $marker);
+            } catch (NetworkException $e) {
+                error_log("Network error: " . $e->getMessage());
+                sleep(5);
+            } catch (\Exception $e) {
+                error_log("An error occurred: " . $e->getMessage());
+                sleep(1);
+            }
+        }
+    }
+
+    /**
+     * Processes a single batch of updates. This is the core logic used by handleUpdates().
+     * Useful for custom loop implementations or for testing.
+     *
+     * @param array<string, callable> $handlers An associative array of update handlers.
+     * @param int|null $timeout Timeout for the getUpdates call.
+     * @param int|null $marker The marker for which updates to fetch.
+     *
+     * @throws ClientApiException
+     * @throws NetworkException
+     * @throws ReflectionException
+     * @throws SerializationException
+     */
+    public function processUpdatesBatch(array $handlers, ?int $timeout, ?int &$marker = null): void
+    {
+        $updateList = $this->getUpdates(timeout: $timeout, marker: $marker);
+
+        foreach ($updateList->updates as $update) {
+            $handler = $handlers[$update->updateType->value] ?? null;
+            if ($handler) {
+                $handler($update, $this);
+            }
+        }
+
+        $marker = $updateList->marker;
+    }
+
     /**
      * Information about the current bot, identified by an access token.
      *
@@ -330,41 +473,4 @@ public function getChat(int $chatId): Chat
             $this->client->request(self::METHOD_GET, self::ACTION_CHATS . '/' . $chatId)
         );
     }
-
-    /**
-     * You can use this method for getting updates in case your bot is not subscribed to WebHook.
-     * The method is based on long polling.
-     *
-     * @param int|null $limit Maximum number of updates to be retrieved (1-1000).
-     * @param int|null $timeout Timeout in seconds for long polling (0-90).
-     * @param int|null $marker Pass `null` to get updates you didn't get yet.
-     * @param UpdateType[]|null $types Comma separated list of update types your bot want to receive.
-     *
-     * @return UpdateList
-     * @throws ClientApiException
-     * @throws NetworkException
-     * @throws ReflectionException
-     * @throws SerializationException
-     */
-    public function getUpdates(
-        ?int $limit = null,
-        ?int $timeout = null,
-        ?int $marker = null,
-        ?array $types = null,
-    ): UpdateList {
-        $query = [
-            'limit' => $limit,
-            'timeout' => $timeout,
-            'marker' => $marker,
-            'types' => $types !== null ? implode(',', array_map(fn($type) => $type->value, $types)) : null,
-        ];
-
-        return $this->modelFactory->createUpdateList(
-            $this->client->request(
-                self::METHOD_GET,
-                self::ACTION_UPDATES,
-                array_filter($query, fn($value) => $value !== null),
-            )
-        );
-    }
 }

src/ModelFactory.php

@@ -13,11 +13,16 @@
 use BushlanovDev\MaxMessengerBot\Models\UpdateList;
 use BushlanovDev\MaxMessengerBot\Models\Updates\AbstractUpdate;
 use BushlanovDev\MaxMessengerBot\Models\Updates\BotAddedToChatUpdate;
+use BushlanovDev\MaxMessengerBot\Models\Updates\BotRemovedFromChatUpdate;
 use BushlanovDev\MaxMessengerBot\Models\Updates\BotStartedUpdate;
+use BushlanovDev\MaxMessengerBot\Models\Updates\ChatTitleChangedUpdate;
 use BushlanovDev\MaxMessengerBot\Models\Updates\MessageCallbackUpdate;
+use BushlanovDev\MaxMessengerBot\Models\Updates\MessageChatCreatedUpdate;
 use BushlanovDev\MaxMessengerBot\Models\Updates\MessageCreatedUpdate;
 use BushlanovDev\MaxMessengerBot\Models\Updates\MessageEditedUpdate;
 use BushlanovDev\MaxMessengerBot\Models\Updates\MessageRemovedUpdate;
+use BushlanovDev\MaxMessengerBot\Models\Updates\UserAddedToChatUpdate;
+use BushlanovDev\MaxMessengerBot\Models\Updates\UserRemovedFromChatUpdate;
 use BushlanovDev\MaxMessengerBot\Models\UploadEndpoint;
 use LogicException;
 use ReflectionException;
@@ -162,7 +167,12 @@ public function createUpdate(array $data): AbstractUpdate
             UpdateType::MessageEdited => MessageEditedUpdate::fromArray($data),
             UpdateType::MessageRemoved => MessageRemovedUpdate::fromArray($data),
             UpdateType::BotAdded => BotAddedToChatUpdate::fromArray($data),
+            UpdateType::BotRemoved => BotRemovedFromChatUpdate::fromArray($data),
+            UpdateType::UserAdded => UserAddedToChatUpdate::fromArray($data),
+            UpdateType::UserRemoved => UserRemovedFromChatUpdate::fromArray($data),
             UpdateType::BotStarted => BotStartedUpdate::fromArray($data),
+            UpdateType::ChatTitleChanged => ChatTitleChangedUpdate::fromArray($data),
+            UpdateType::MessageChatCreated => MessageChatCreatedUpdate::fromArray($data),
             default => throw new LogicException(
                 'Unknown or unsupported update type received: ' . ($data['update_type'] ?? 'none')
             ),

src/Models/Updates/BotRemovedFromChatUpdate.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace BushlanovDev\MaxMessengerBot\Models\Updates;
+
+use BushlanovDev\MaxMessengerBot\Enums\UpdateType;
+use BushlanovDev\MaxMessengerBot\Models\User;
+
+/**
+ * You will receive this update when the bot has been removed from a chat.
+ */
+final readonly class BotRemovedFromChatUpdate extends AbstractUpdate
+{
+    /**
+     * @param int $timestamp Unix-time when the event has occurred.
+     * @param int $chatId Chat identifier the bot was removed from.
+     * @param User $user User who removed the bot from the chat.
+     * @param bool $isChannel Indicates whether the bot has been removed from a channel or not.
+     */
+    public function __construct(
+        int $timestamp,
+        public int $chatId,
+        public User $user,
+        public bool $isChannel,
+    ) {
+        parent::__construct(UpdateType::BotRemoved, $timestamp);
+    }
+}

src/Models/Updates/ChatTitleChangedUpdate.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace BushlanovDev\MaxMessengerBot\Models\Updates;
+
+use BushlanovDev\MaxMessengerBot\Enums\UpdateType;
+use BushlanovDev\MaxMessengerBot\Models\User;
+
+/**
+ * Bot gets this type of update as soon as the title has been changed in a chat.
+ */
+final readonly class ChatTitleChangedUpdate extends AbstractUpdate
+{
+    /**
+     * @param int $timestamp Unix-time when the event has occurred.
+     * @param int $chatId Chat identifier where the event has occurred.
+     * @param User $user User who changed the title.
+     * @param string $title The new title.
+     */
+    public function __construct(
+        int $timestamp,
+        public int $chatId,
+        public User $user,
+        public string $title,
+    ) {
+        parent::__construct(UpdateType::ChatTitleChanged, $timestamp);
+    }
+}

src/Models/Updates/MessageChatCreatedUpdate.php

@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+namespace BushlanovDev\MaxMessengerBot\Models\Updates;
+
+use BushlanovDev\MaxMessengerBot\Enums\UpdateType;
+use BushlanovDev\MaxMessengerBot\Models\Chat;
+
+/**
+ * Bot will get this update when a chat has been created as soon as
+ * the first user clicked a `chat` button.
+ */
+final readonly class MessageChatCreatedUpdate extends AbstractUpdate
+{
+    /**
+     * @param int $timestamp Unix-time when the event has occurred.
+     * @param Chat $chat The created chat.
+     * @param string $messageId Message identifier where the button has been clicked.
+     * @param string|null $startPayload Payload from the chat button.
+     */
+    public function __construct(
+        int $timestamp,
+        public Chat $chat,
+        public string $messageId,
+        public ?string $startPayload,
+    ) {
+        parent::__construct(UpdateType::MessageChatCreated, $timestamp);
+    }
+}