Fix file downloader

Author: irazasyed

src/Exceptions/TelegramSDKException.php

@@ -16,4 +16,14 @@ public static function tokenNotProvided($tokenEnvName): self
     {
         return new static('Required "token" not supplied in config and could not find fallback environment variable '.$tokenEnvName.'');
     }
+
+    /**
+     * Thrown when file download fails.
+     *
+     * @return static
+     */
+    public static function fileDownloadFailed(string $reason, string $url = null): self
+    {
+        return new static($reason.': Failed to Download File '.$url);
+    }
 }

src/Laravel/config/telegram.php

@@ -90,7 +90,7 @@
     | If you'd like to use a custom Base Bot Url.
     | Should be a local bot api endpoint or a proxy to the telegram api endpoint
     |
-    | Default: https://api.telegram.org/bot
+    | Default: https://api.telegram.org
     |
     */
     'base_bot_url' => null,

src/TelegramClient.php

@@ -6,13 +6,15 @@
 use Psr\Http\Message\ResponseInterface;
 use Telegram\Bot\HttpClients\GuzzleHttpClient;
 use Telegram\Bot\HttpClients\HttpClientInterface;
+use Telegram\Bot\Exceptions\TelegramSDKException;
 
 final class TelegramClient
 {
     /**
      * @var string
      */
-    public const BASE_BOT_URL = 'https://api.telegram.org/bot';
+    public const BASE_BOT_URL = 'https://api.telegram.org';
+    private string $fileUrl = '{BASE_API_URL}/file/bot{TOKEN}/{FILE_PATH}';
 
     private HttpClientInterface $httpClientHandler;
 
@@ -55,9 +57,56 @@ public function sendRequest(TelegramRequest $request): TelegramResponse
         return $response;
     }
 
+    /**
+     * Get File URL.
+     */
+    public function getFileUrl(string $path, TelegramRequest $request): string
+    {
+        return str_replace(
+            ['{BASE_API_URL}', '{TOKEN}', '{FILE_PATH}'],
+            [$this->baseBotUrl, $request->getAccessToken(), $path],
+            $this->fileUrl
+        );
+    }
+
+    /**
+     * Download file from Telegram server for given file path.
+     *
+     * @param  string  $filePath File path on Telegram server.
+     * @param  string  $filename Download path to save file.
+     *
+     * @throws TelegramSDKException
+     */
+    public function download(string $filePath, string $filename, TelegramRequest $request): string
+    {
+        $fileDir = dirname($filename);
+
+        // Ensure dir is created.
+        if (! @mkdir($fileDir, 0755, true) && ! is_dir($fileDir)) {
+            throw TelegramSDKException::fileDownloadFailed('Directory '.$fileDir.' can\'t be created');
+        }
+
+        $response = $this->httpClientHandler
+            ->setTimeOut($request->getTimeOut())
+            ->setConnectTimeOut($request->getConnectTimeOut())
+            ->send(
+                $url = $this->getFileUrl($filePath, $request),
+                $request->getMethod(),
+                $request->getHeaders(),
+                ['sink' => $filename],
+                $request->isAsyncRequest(),
+            );
+
+        if ($response->getStatusCode() !== 200) {
+            throw TelegramSDKException::fileDownloadFailed($response->getReasonPhrase(), $url);
+        }
+
+        return $filename;
+    }
+
     public function prepareRequest(TelegramRequest $request): array
     {
-        $url = $this->baseBotUrl.$request->getAccessToken().'/'.$request->getEndpoint();
+        $url = $this->baseBotUrl.'/bot'.$request->getAccessToken().'/'.$request->getEndpoint();
 
         return [$url, $request->getMethod(), $request->getHeaders(), $request->isAsyncRequest()];
     }

src/Traits/Http.php

@@ -63,7 +63,8 @@ public function setHttpClientHandler(HttpClientInterface $httpClientHandler): se
 
     public function setBaseBotUrl(string $baseBotUrl): self
     {
-        $this->baseBotUrl = $baseBotUrl;
+        $baseBotUrl = str_replace('/bot', '', $baseBotUrl);
+        $this->baseBotUrl = rtrim($baseBotUrl, '/');
 
         return $this;
     }
@@ -110,7 +111,9 @@ public function downloadFile(File|BaseObject|string $file, string $filename): st
             $filename .= DIRECTORY_SEPARATOR.($originalFilename ?: basename($file->file_path));
         }
 
-        return $this->getClient()->download($file->file_path, $filename);
+        $telegramRequest = $this->resolveTelegramRequest('GET', '');
+
+        return $this->getClient()->download($file->file_path, $filename, $telegramRequest);
     }
 
     /**