Okay, I can help you set that up. This solution uses the `telegram-bot-sdk` library for interacting with Telegram and requires `yt-dlp` (a fork of `youtube-dl`) to be installed on the server where the bot runs. First, we need to define the project dependencies. { "name": "codephp/youtube-telegram-bot", "description": "A Telegram bot to download YouTube videos.", "type": "project", "require": { "php": "^8.1", "irazasyed/telegram-bot-sdk": "^3.9", "symfony/process": "^6.0" }, "autoload": { "psr-4": { "App\\": "src/" } }, "config": { "optimize-autoloader": true, "sort-packages": true } } ytDlpPath = $ytDlpPath; $this->downloadDir = $downloadDir; $this->logger = $logger ?? new NullLogger(); if (!is_dir($this->downloadDir) || !is_writable($this->downloadDir)) { $this->logger->error("Download directory is not writable: {$this->downloadDir}"); throw new \RuntimeException("Download directory is not writable: {$this->downloadDir}"); } } /** * Downloads a YouTube video. * * @param string $url The YouTube video URL. * @return string|false The path to the downloaded file on success, false on failure. */ public function download(string $url): string|false { // Basic URL validation if (!filter_var($url, FILTER_VALIDATE_URL) || !preg_match('/(youtube\.com|youtu\.be)/', $url)) { $this->logger->warning("Invalid YouTube URL provided: {$url}"); return false; } // Generate a unique filename template $outputTemplate = $this->downloadDir . '/%(id)s_%(epoch)s.%(ext)s'; // Construct the yt-dlp command // -f 'bv[ext=mp4][height<=720]+ba[ext=m4a]/b[ext=mp4][height<=720]/best' : Select best MP4 format up to 720p // --merge-output-format mp4 : Ensure output is mp4 // --output : Define output path template // --no-playlist : Download only the video, not the playlist if URL is part of one // --max-filesize 50m : Attempt to prevent downloading files too large for Telegram (adjust as needed) $command = [ $this->ytDlpPath, '-f', 'bv[ext=mp4][height<=720]+ba[ext=m4a]/b[ext=mp4][height<=720]/best', '--merge-output-format', 'mp4', '--output', $outputTemplate, '--no-playlist', // '--max-filesize', '49m', // Uncomment and adjust if needed, yt-dlp handles this $url, ]; $this->logger->info("Executing yt-dlp command: " . implode(' ', $command)); $process = new Process($command); $process->setTimeout(300); // 5 minutes timeout for download $downloadedFilePath = null; try { // Use a callback to capture the output filename from yt-dlp's stdout $process->mustRun(function ($type, $buffer) use (&$downloadedFilePath) { if (Process::OUT === $type) { // yt-dlp might output the final filename after merging // Example output line: [Merger] Merging formats into "/tmp/youtube_downloads/VIDEOID_TIMESTAMP.mp4" // Example output line: [download] Destination: /tmp/youtube_downloads/VIDEOID_TIMESTAMP.mp4 if (preg_match('/\[(?:Merger|download)\] .*?(?:Merging formats into|Destination:)\s+"?([^"\n]+)"?/', $buffer, $matches)) { $potentialPath = trim($matches[1]); // Ensure it's within the download directory for security if (str_starts_with($potentialPath, $this->downloadDir) && file_exists($potentialPath)) { $downloadedFilePath = $potentialPath; $this->logger->info("Detected downloaded file: {$downloadedFilePath}"); } } $this->logger->debug("yt-dlp output: {$buffer}"); } else { $this->logger->warning("yt-dlp error output: {$buffer}"); } }); // Double check if file path was captured and exists if ($downloadedFilePath && file_exists($downloadedFilePath)) { $this->logger->info("Download successful: {$downloadedFilePath}"); return $downloadedFilePath; } else { // Fallback: Try to find the file based on the template pattern if not captured via output $this->logger->warning("Could not detect exact filename from yt-dlp output. Attempting fallback scan."); $files = glob($this->downloadDir . '/*.mp4'); // Adjust extension if needed if (!empty($files)) { // Find the most recently created file matching a pattern (less reliable) usort($files, fn($a, $b) => filemtime($b) <=> filemtime($a)); $latestFile = $files[0]; // Basic check if it looks like a yt-dlp output if (str_contains($latestFile, '_')) { $this->logger->info("Fallback found potential file: {$latestFile}"); return $latestFile; } } $this->logger->error("Download finished but could not determine output file path."); return false; } } catch (ProcessFailedException $exception) { $this->logger->error("yt-dlp process failed: " . $exception->getMessage()); return false; } catch (\Throwable $e) { $this->logger->error("An unexpected error occurred during download: " . $e->getMessage()); return false; } } /** * Deletes a file. * * @param string $filePath * @return bool */ public function cleanup(string $filePath): bool { if (file_exists($filePath) && str_starts_with(realpath($filePath), realpath($this->downloadDir))) { $this->logger->info("Cleaning up file: {$filePath}"); return unlink($filePath); } $this->logger->warning("Attempted to clean up non-existent or outside-of-scope file: {$filePath}"); return false; } } telegram = $telegram; $this->downloader = $downloader; $this->allowedChatIds = $allowedChatIds; $this->logger = $logger ?? new NullLogger(); } public function handleUpdate(Update $update): void { $message = $update->getMessage(); if (!$message) { $this->logger->info("Received update without a message."); return; } $chatId = $message->getChat()->getId(); $text = $message->getText(); // Check if chat is allowed if (!empty($this->allowedChatIds) && !in_array($chatId, $this->allowedChatIds)) { $this->logger->warning("Received message from disallowed chat ID: {$chatId}"); $this->sendMessage($chatId, "Sorry, this bot is private."); return; } if (!$text) { $this->logger->info("Received message without text content from chat ID: {$chatId}"); // Optionally send help message or ignore // $this->sendMessage($chatId, "Please send me a YouTube video link."); return; } // Simple check for YouTube URL if (preg_match('/(youtube\.com\/watch\?v=|youtu\.be\/)/', $text)) { $this->processYouTubeLink($chatId, $text); } else { $this->logger->info("Received non-YouTube link text from chat ID {$chatId}: {$text}"); $this->sendMessage($chatId, "Please send a valid YouTube video link (e.g., https://www.youtube.com/watch?v=...)."); } } private function processYouTubeLink(int $chatId, string $url): void { $this->logger->info("Processing YouTube link from chat ID {$chatId}: {$url}"); $statusMessage = $this->sendMessage($chatId, "🔄 Processing YouTube link..."); $statusMessageId = $statusMessage?->getMessageId(); $downloadedFilePath = false; try { $this->editMessage($chatId, $statusMessageId, "📥 Downloading video..."); $downloadedFilePath = $this->downloader->download($url); if ($downloadedFilePath) { $this->logger->info("Download complete for chat ID {$chatId}: {$downloadedFilePath}"); $this->editMessage($chatId, $statusMessageId, "⬆️ Uploading video to Telegram..."); // Check file size before attempting upload $fileSize = filesize($downloadedFilePath); $maxSize = 50 * 1024 * 1024; // 50 MB limit for bots via API if ($fileSize > $maxSize) { $this->logger->error("File size exceeds Telegram limit ({$fileSize} bytes) for chat ID {$chatId}: {$downloadedFilePath}"); $this->editMessage($chatId, $statusMessageId, "❌ Error: Video file is too large for Telegram (>" . ($maxSize / 1024 / 1024) . "MB)."); } else { $this->sendVideo($chatId, $downloadedFilePath, "Here is your video!"); // Delete the initial status message after successful upload if ($statusMessageId) { $this->deleteMessage($chatId, $statusMessageId); } } } else { $this->logger->error("Download failed for chat ID {$chatId}, URL: {$url}"); $this->editMessage($chatId, $statusMessageId, "❌ Error: Could not download the video. Please check the link or try again later."); } } catch (\Throwable $e) { $this->logger->error("Error processing link for chat ID {$chatId}: " . $e->getMessage(), ['exception' => $e]); $this->editMessage($chatId, $statusMessageId, "❌ An unexpected error occurred."); } finally { // Clean up the downloaded file if ($downloadedFilePath) { $this->downloader->cleanup($downloadedFilePath); } } } private function sendMessage(int $chatId, string $text): ?\Telegram\Bot\Objects\Message { try { return $this->telegram->sendMessage([ 'chat_id' => $chatId, 'text' => $text, ]); } catch (\Exception $e) { $this->logger->error("Failed to send message to chat ID {$chatId}: " . $e->getMessage()); return null; } } private function editMessage(int $chatId, ?int $messageId, string $text): ?\Telegram\Bot\Objects\Message { if (!$messageId) return null; try { return $this->telegram->editMessageText([ 'chat_id' => $chatId, 'message_id' => $messageId, 'text' => $text, ]); } catch (\Exception $e) { // Ignore errors editing messages (e.g., message too old, not found) $this->logger->warning("Failed to edit message {$messageId} in chat ID {$chatId}: " . $e->getMessage()); // Fallback: send a new message if editing fails critically if (str_contains($e->getMessage(), 'message to edit not found')) { return $this->sendMessage($chatId, $text); } return null; } } private function deleteMessage(int $chatId, ?int $messageId): bool { if (!$messageId) return false; try { return $this->telegram->deleteMessage([ 'chat_id' => $chatId, 'message_id' => $messageId, ]); } catch (\Exception $e) { $this->logger->warning("Failed to delete message {$messageId} in chat ID {$chatId}: " . $e->getMessage()); return false; } } private function sendVideo(int $chatId, string $filePath, string $caption = ''): ?\Telegram\Bot\Objects\Message { try { return $this->telegram->sendVideo([ 'chat_id' => $chatId, 'video' => InputFile::create($filePath, basename($filePath)), 'caption' => $caption, // 'supports_streaming' => true, // Optional: If you know the video is streamable ]); } catch (\Telegram\Bot\Exceptions\TelegramSDKException $e) { $this->logger->error("Failed to upload video to chat ID {$chatId}: " . $e->getMessage(), ['exception' => $e]); $errorMessage = "❌ Failed to upload video."; if (str_contains($e->getMessage(), 'Request Entity Too Large')) { $errorMessage .= " The file might be too large."; } elseif (str_contains($e->getMessage(), 'wrong file identifier')) { $errorMessage .= " Telegram rejected the file format or content."; } $this->sendMessage($chatId, $errorMessage); return null; } catch (\Exception $e) { $this->logger->error("Unexpected error sending video to chat ID {$chatId}: " . $e->getMessage()); $this->sendMessage($chatId, "❌ An unexpected error occurred during upload."); return null; } } } pushHandler(new StreamHandler('php://stdout', $logLevel)); // Optionally log to a file // $logger->pushHandler(new StreamHandler(__DIR__ . '/bot.log', $logLevel)); // --------------------------- $logger->info("Bot starting..."); // --- Dependency Initialization --- try { if (TELEGRAM_BOT_TOKEN === 'YOUR_TELEGRAM_BOT_TOKEN') { throw new \Exception("Telegram Bot Token is not configured in config.php"); } if (!file_exists(DOWNLOAD_DIR) || !is_writable(DOWNLOAD_DIR)) { throw new \Exception("Download directory is not accessible or writable: " . DOWNLOAD_DIR); } // Check if yt-dlp exists and is executable $ytDlpCheck = shell_exec('command -v ' . escapeshellarg(YT_DLP_PATH) . ' || echo ""'); if (empty(trim($ytDlpCheck))) { // Try relative path if absolute wasn't given if (!is_executable(YT_DLP_PATH)) { throw new \Exception("yt-dlp executable not found or not executable at path: " . YT_DLP_PATH); } } $telegram = new Api(TELEGRAM_BOT_TOKEN); $downloader = new YouTubeDownloader(YT_DLP_PATH, DOWNLOAD_DIR, $logger); $botHandler = new BotHandler($telegram, $downloader, ALLOWED_CHAT_IDS, $logger); } catch (\Throwable $e) { $logger->critical("Failed to initialize bot dependencies: " . $e->getMessage()); echo "Error: Failed to initialize bot dependencies. Check logs.\n"; exit(1); // Exit if core dependencies fail } // --------------------------- $offset = 0; // Initialize offset for getUpdates $timeout = 60; // Long polling timeout (seconds) $sleepTime = 1; // Sleep time between polls (seconds) $logger->info("Starting update loop (long polling)..."); while (true) { try { // Fetch updates using long polling $updates = $telegram->getUpdates([ 'offset' => $offset, 'timeout' => $timeout, 'allowed_updates' => ['message'], // Only process messages ]); if (!empty($updates)) { foreach ($updates as $update) { $logger->debug("Processing update ID: " . $update->getUpdateId()); $botHandler->handleUpdate($update); // Update offset to the next update ID $offset = $update->getUpdateId() + 1; } } else { $logger->debug("No updates received."); } // Optional: Add a small sleep to prevent tight looping in case of immediate empty responses // sleep($sleepTime); } catch (\Telegram\Bot\Exceptions\TelegramSDKException $e) { // Handle potential API errors (e.g., network issues, invalid token) $logger->error("Telegram API Error: " . $e->getMessage(), ['exception' => $e]); // Implement backoff strategy or specific error handling if needed sleep(10); // Wait longer after an API error } catch (\Throwable $e) { // Catch any other unexpected errors during update processing $logger->error("Unhandled error in main loop: " . $e->getMessage(), ['exception' => $e]); // Avoid immediate crash, wait before retrying sleep(5); } } $logger->info("Bot stopped."); // This line might not be reached in a continuous loop **Before Running:** 1. **Install Dependencies:** Run `composer install` in the project directory (`/home/user`). 2. **Set Bot Token:** Edit `config.php` and replace `'YOUR_TELEGRAM_BOT_TOKEN'` with the actual token you get from BotFather on Telegram. 3. **Install `yt-dlp`:** Make sure `yt-dlp` is installed on your server and accessible via the path specified in `config.php` (defaults to just `yt-dlp`, assuming it's in the system's PATH). You can usually install it via pip (`pip install yt-dlp`) or your system's package manager. Verify it's executable by the user running the PHP script. 4. **Permissions:** Ensure the directory defined by `DOWNLOAD_DIR` in `config.php` (defaults to a subdirectory in the system's temp folder) exists and is writable by the PHP process. 5. **(Optional) Allowed Chats:** If you want to restrict the bot to specific chats, update `ALLOWED_CHAT_IDS` in `config.php`. **How to Run:** Execute the main bot script from your terminal: bash php bot.php This script will continuously poll Telegram for new messages containing YouTube links. **Important Considerations:** * **`yt-dlp` Path:** Double-check the `YT_DLP_PATH` in `config.php` if `yt-dlp` isn't in your system's default PATH. * **File Size Limits:** Telegram bots have a file size limit (typically 50MB) for uploads via the API. The script tries to download formats up to 720p to stay below this, but longer or higher-quality videos might still exceed the limit, causing uploads to fail. The script includes a basic check for this. * **Error Handling:** Basic error handling and logging are included, but you might want to enhance them for production use. Check `bot.log` (if configured) or standard output for errors. * **Long Polling vs. Webhook:** This example uses long polling, which is simpler to set up but less efficient than webhooks. For production bots, consider switching to a webhook setup. * **Resource Usage:** Downloading and uploading videos can be resource-intensive (CPU, bandwidth, disk I/O). Ensure your server can handle the load. * **Execution Time:** PHP scripts might have execution time limits (`max_execution_time`). Downloading large videos could exceed this. Running the script via CLI (`php bot.php`) usually bypasses web server time limits, but system limits might still apply. Consider using tools like `supervisor` to keep the bot running reliably.