Merge pull request #13 from devrabie/feature/timeout-and-redis-dedup-13030699252080218284

Add request timeout and Redis duplicate update prevention

Author: devrabie

README.md

@@ -114,6 +114,37 @@ You can also access the Redis instance statically from anywhere in your project:
 $redis = \Longman\TelegramBot\Telegram::getRedis();
 ```
 
+### 3. Prevent Duplicate Updates
+
+Enabling Redis also activates the built-in duplicate update prevention mechanism. This is useful when the bot receives the same update multiple times due to timeouts or retries from Telegram.
+
+When Redis is enabled:
+1.  The library checks if the `update_id` exists in Redis.
+2.  If it exists, the update is ignored, and a fake success response is returned to Telegram to stop retries.
+3.  If it doesn't exist, the `update_id` is stored in Redis with a retention time (TTL) of 60 seconds.
+
+You can customize the retention time (in seconds):
+
+```php
+// Set retention time to 120 seconds
+Longman\TelegramBot\Telegram::setUpdateRetentionTime(120);
+```
+
+---
+
+## ⚙️ Advanced Configuration
+
+### Request Timeout
+
+To prevent your server from hanging on slow Telegram API requests (e.g., cURL error 28), you can set a custom timeout for the HTTP client. The default timeout is 60 seconds.
+
+```php
+use Longman\TelegramBot\Request;
+
+// Set request timeout to 30 seconds
+Request::setClientTimeout(30);
+```
+
 ---
 
 ## 🔐 Webhook Secret Token

src/Request.php

@@ -191,6 +191,13 @@ class Request
      */
     private static $limiter_interval;
 
+    /**
+     * Guzzle Client timeout
+     *
+     * @var int
+     */
+    private static $timeout = 60;
+
     /**
      * The current action that is being executed
      *
@@ -425,6 +432,16 @@ public static function setCustomBotApiUri(string $api_base_uri, string $api_base
         }
     }
 
+    /**
+     * Set a custom Guzzle Client timeout
+     *
+     * @param int $timeout
+     */
+    public static function setClientTimeout(int $timeout): void
+    {
+        self::$timeout = $timeout;
+    }
+
     /**
      * Get input from custom input or stdin and return it
      *
@@ -614,8 +631,9 @@ public static function getCurrentAction(): string
      */
     public static function execute(string $action, array $data = []): string
     {
-        $request_params          = self::setUpRequestParams($data);
-        $request_params['debug'] = TelegramLog::getDebugLogTempStream();
+        $request_params            = self::setUpRequestParams($data);
+        $request_params['debug']   = TelegramLog::getDebugLogTempStream();
+        $request_params['timeout'] = self::$timeout;
 
         try {
             $response = self::$client->post(

src/Telegram.php

@@ -41,6 +41,13 @@ class Telegram
     /** @var \Redis|null */
     private static $redis_connection;
 
+    /**
+     * Update retention time in Redis (in seconds)
+     *
+     * @var int
+     */
+    private static $update_retention_time = 60;
+
     /**
      * Telegram API key
      *
@@ -558,6 +565,17 @@ public function processUpdate(Update $update): ServerResponse
         $this->update         = $update;
         $this->last_update_id = $update->getUpdateId();
 
+        // If Redis is enabled, check if this update has already been processed.
+        if (self::$redis_connection) {
+            $redis_key = 'telegram_update_' . $this->last_update_id;
+            if (self::$redis_connection->get($redis_key)) {
+                // Return a fake success response to prevent Telegram from retrying.
+                return new ServerResponse(['ok' => true, 'result' => true], $this->bot_username);
+            }
+            // Store the update ID in Redis with a TTL of 60 seconds (matching the default timeout).
+            self::$redis_connection->setex($redis_key, self::$update_retention_time, '1');
+        }
+
         if (is_callable($this->update_filter)) {
             $reason = 'Update denied by update_filter';
             try {
@@ -1117,16 +1135,40 @@ public function enableRedis(array $config = []): Telegram
             ];
         }
 
-        self::$redis_connection = new \Redis();
-        self::$redis_connection->connect($config['host'], $config['port']);
+        $redis = new \Redis();
+        $redis->connect($config['host'], $config['port']);
 
         if (!empty($config['password'])) {
-            self::$redis_connection->auth($config['password']);
+            $redis->auth($config['password']);
         }
 
+        self::$redis_connection = $redis;
+
         return $this;
     }
 
+    /**
+     * Set a custom Redis connection
+     *
+     * @param \Redis $redis
+     * @return void
+     */
+    public static function setRedis(\Redis $redis): void
+    {
+        self::$redis_connection = $redis;
+    }
+
+    /**
+     * Set the update retention time in Redis
+     *
+     * @param int $seconds
+     * @return void
+     */
+    public static function setUpdateRetentionTime(int $seconds): void
+    {
+        self::$update_retention_time = $seconds;
+    }
+
     /**
      * Get the shared Redis client instance.
      *