refactor(TelegramBotHandler): Support for chat group topics in Telegram

Author: saMahmoudzadeh

src/TelegramBotHandler.php

@@ -35,18 +35,32 @@ class TelegramBotHandler extends AbstractProcessingHandler implements HandlerInt
      */
     private $chatId;
 
+    /**
+     *
+     * @var string|null
+     */
+    private $topicId;
+
     /**
      * @param string $token Telegram bot access token provided by BotFather
      * @param string $channel Telegram channel name
      * @inheritDoc
      */
-    public function __construct(string $token, string $chat_id, $level = Logger::DEBUG, bool $bubble = true, $bot_api = 'https://api.telegram.org/bot', $proxy = null)
+    public function __construct(
+        string      $token,
+        string      $chat_id,
+        string|null $topic_id = null,
+                    $level = Logger::DEBUG,
+        bool        $bubble = true,
+                    $bot_api = 'https://api.telegram.org/bot',
+                    $proxy = null)
     {
         parent::__construct($level, $bubble);
 
         $this->token = $token;
         $this->botApi = $bot_api;
         $this->chatId = $chat_id;
+        $this->topicId = $topic_id;
         $this->level = $level;
         $this->bubble = $bubble;
         $this->proxy = $proxy;
@@ -63,16 +77,20 @@ protected function write($record): void
     /**
      * Send request to @link https://api.telegram.org/bot on SendMessage action.
      * @param string $message
+     * @param array $option
      */
     protected function send(string $message, $option = []): void
     {
-        try {            
-            if(!isset($option['verify'])){
+        try {
+
+            if (!isset($option['verify'])) {
                 $option['verify'] = false;
             }
+
             if (!is_null($this->proxy)) {
                 $option['proxy'] = $this->proxy;
             }
+
             $httpClient = new Client($option);
 
             if (strpos($this->botApi, 'https://api.telegram.org') === false) {
@@ -81,14 +99,17 @@ protected function send(string $message, $option = []): void
                 $url = $this->botApi . $this->token . '/SendMessage';
             }
 
+            $params = [
+                'text' => $message,
+                'chat_id' => $this->chatId,
+                'parse_mode' => 'html',
+                'disable_web_page_preview' => true,
+            ];
+
             $options = [
-                'form_params' => [
-                    'text' => $message,
-                    'chat_id' => $this->chatId,
-                    'parse_mode' => 'html',
-                    'disable_web_page_preview' => true,
-                ]
+                'form_params' => $this->topicId === null ? $params + ['message_thread_id' => $this->topicId] : $params
             ];
+
             $response = $httpClient->post($url, $options);
         } catch (\Exception $e) {