feat: Add dynamic timeout for SendJob job

Author: amirhshokri

src/SendJob.php

@@ -26,6 +26,7 @@ public function __construct(
         private string      $chatId,
         private string|null $topicId = null,
         private string|null $proxy = null,
+        private int         $timeout = 5,
     )
     {
     }
@@ -39,7 +40,7 @@ public function handle(): void
             $httpClientOption['proxy'] = $this->proxy;
         }
 
-        $httpClientOption['timeout'] = 5;
+        $httpClientOption['timeout'] = $this->timeout;
 
         $params = [
             'text' => $this->message,

src/TelegramBotHandler.php

@@ -52,6 +52,13 @@ class TelegramBotHandler extends AbstractProcessingHandler
 
     protected TopicDetector $topicDetector;
 
+    /**
+     * Timeout for Telegram API requests in seconds.
+     *
+     * @var int
+     */
+    protected int $timeout;
+
     /**
      * @param string $token Telegram bot access token provided by BotFather
      * @param string $channel Telegram channel name
@@ -66,7 +73,9 @@ public function __construct(
                     $level = Logger::DEBUG,
         bool        $bubble = true,
         string      $bot_api = 'https://api.telegram.org/bot',
-        string|null $proxy = null)
+        string|null $proxy = null,
+        int         $timeout = 5
+    )
     {
         parent::__construct($level, $bubble);
 
@@ -78,6 +87,7 @@ public function __construct(
         $this->level = $level;
         $this->bubble = $bubble;
         $this->proxy = $proxy;
+        $this->timeout = $timeout;
 
         $this->topicDetector = new TopicDetector($topics_level);
     }
@@ -127,9 +137,9 @@ protected function send(string $message, $token = null, $chatId = null, $topicId
         $message = $this->truncateTextToTelegramLimit($message);
 
         if (empty($this->queue)) {
-            dispatch_sync(new SendJob($url, $message, $chatId, $topicId, $this->proxy));
+            dispatch_sync(new SendJob($url, $message, $chatId, $topicId, $this->proxy, $this->timeout));
         } else {
-            dispatch(new SendJob($url, $message, $chatId, $topicId, $this->proxy))->onQueue($this->queue);
+            dispatch(new SendJob($url, $message, $chatId, $topicId, $this->proxy, $this->timeout))->onQueue($this->queue);
         }
     }