Skip to content

perf(http): route Telegram bot service and TTS client through the shared pool (#12979) #13000

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
mrveiss merged 2 commits into from
Jul 30, 2026
Merged

perf(http): route Telegram bot service and TTS client through the shared pool (#12979) #13000

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
ef6273f
perf(http): route Telegram bot service and TTS client through the sha…
mrveiss Jul 30, 2026
71d77bd
Merge branch 'Dev_new_gui' into issue-12979-batch5-http-pool
github-actions[bot] Jul 30, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
163 changes: 77 additions & 86 deletions autobot-backend/services/telegram_bot_service.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,9 +14,8 @@

from typing import Any, Dict, Optional

import aiohttp

from autobot_shared.field_encryption import decrypt_field, encrypt_field
from autobot_shared.http_client import get_http_client
from autobot_shared.logging_manager import get_logger
from autobot_shared.redis_client import get_redis_client

Expand Down Expand Up @@ -111,17 +110,16 @@ async def send_message(
if reply_to_message_id:
payload["reply_to_message_id"] = reply_to_message_id

async with aiohttp.ClientSession() as session:
url = f"{self.base_url}/sendMessage"
async with session.post(url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram sendMessage failed: {response.status} - {error_text}")
response.raise_for_status()
url = f"{self.base_url}/sendMessage"
async with get_http_client().tracked_request("POST", url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram sendMessage failed: {response.status} - {error_text}")
response.raise_for_status()

result = await response.json()
logger.info(f"Sent Telegram message to chat {chat_id}")
return result
result = await response.json()
logger.info(f"Sent Telegram message to chat {chat_id}")
return result

async def set_webhook(self, webhook_url: str, secret_token: str) -> Dict[str, Any]:
"""
Expand All @@ -141,21 +139,20 @@ async def set_webhook(self, webhook_url: str, secret_token: str) -> Dict[str, An
if not self.bot_token or not self.base_url:
raise ValueError("Telegram bot token not configured")

async with aiohttp.ClientSession() as session:
url = f"{self.base_url}/setWebhook"
payload = {
"url": webhook_url,
"secret_token": secret_token,
}
async with session.post(url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram setWebhook failed: {response.status} - {error_text}")
response.raise_for_status()

result = await response.json()
logger.info(f"Set Telegram webhook to {webhook_url}")
return result
url = f"{self.base_url}/setWebhook"
payload = {
"url": webhook_url,
"secret_token": secret_token,
}
async with get_http_client().tracked_request("POST", url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram setWebhook failed: {response.status} - {error_text}")
response.raise_for_status()

result = await response.json()
logger.info(f"Set Telegram webhook to {webhook_url}")
return result

async def get_webhook_info(self) -> Dict[str, Any]:
"""
Expand All @@ -171,16 +168,15 @@ async def get_webhook_info(self) -> Dict[str, Any]:
if not self.bot_token or not self.base_url:
raise ValueError("Telegram bot token not configured")

async with aiohttp.ClientSession() as session:
url = f"{self.base_url}/getWebhookInfo"
async with session.get(url) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram getWebhookInfo failed: {response.status} - {error_text}")
response.raise_for_status()
url = f"{self.base_url}/getWebhookInfo"
async with get_http_client().tracked_request("GET", url) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram getWebhookInfo failed: {response.status} - {error_text}")
response.raise_for_status()

result = await response.json()
return result
result = await response.json()
return result

async def get_file(self, file_id: str) -> Dict[str, Any]:
"""
Expand All @@ -199,19 +195,18 @@ async def get_file(self, file_id: str) -> Dict[str, Any]:
if not self.bot_token or not self.base_url:
raise ValueError("Telegram bot token not configured")

async with aiohttp.ClientSession() as session:
url = f"{self.base_url}/getFile"
payload = {"file_id": file_id}
async with session.post(url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram getFile failed: {response.status} - {error_text}")
response.raise_for_status()
url = f"{self.base_url}/getFile"
payload = {"file_id": file_id}
async with get_http_client().tracked_request("POST", url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram getFile failed: {response.status} - {error_text}")
response.raise_for_status()

result = await response.json()
if result.get("ok"):
return result.get("result", {})
return {}
result = await response.json()
if result.get("ok"):
return result.get("result", {})
return {}

async def download_file(self, file_path: str) -> bytes:
"""
Expand All @@ -232,16 +227,15 @@ async def download_file(self, file_path: str) -> bytes:

download_url = f"https://api.telegram.org/file/bot{self.bot_token}/{file_path}"

async with aiohttp.ClientSession() as session:
async with session.get(download_url) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"File download failed: {response.status} - {error_text}")
response.raise_for_status()
async with get_http_client().tracked_request("GET", download_url) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"File download failed: {response.status} - {error_text}")
response.raise_for_status()

content = await response.read()
logger.info(f"Downloaded file from Telegram: {file_path}")
return content
content = await response.read()
logger.info(f"Downloaded file from Telegram: {file_path}")
return content

async def send_photo(
self,
Expand Down Expand Up @@ -286,17 +280,16 @@ async def send_photo(
if message_thread_id:
payload["message_thread_id"] = message_thread_id

async with aiohttp.ClientSession() as session:
url = f"{self.base_url}/sendPhoto"
async with session.post(url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram sendPhoto failed: {response.status} - {error_text}")
response.raise_for_status()
url = f"{self.base_url}/sendPhoto"
async with get_http_client().tracked_request("POST", url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram sendPhoto failed: {response.status} - {error_text}")
response.raise_for_status()

result = await response.json()
logger.info(f"Sent photo to Telegram chat {chat_id}")
return result
result = await response.json()
logger.info(f"Sent photo to Telegram chat {chat_id}")
return result

async def send_document(
self,
Expand Down Expand Up @@ -341,17 +334,16 @@ async def send_document(
if message_thread_id:
payload["message_thread_id"] = message_thread_id

async with aiohttp.ClientSession() as session:
url = f"{self.base_url}/sendDocument"
async with session.post(url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram sendDocument failed: {response.status} - {error_text}")
response.raise_for_status()
url = f"{self.base_url}/sendDocument"
async with get_http_client().tracked_request("POST", url, json=payload) as response:
if response.status != 200:
error_text = await response.text()
logger.error(f"Telegram sendDocument failed: {response.status} - {error_text}")
response.raise_for_status()

result = await response.json()
logger.info(f"Sent document to Telegram chat {chat_id}")
return result
result = await response.json()
logger.info(f"Sent document to Telegram chat {chat_id}")
return result

async def verify_token(self) -> bool:
"""
Expand All @@ -364,15 +356,14 @@ async def verify_token(self) -> bool:
return False

try:
async with aiohttp.ClientSession() as session:
url = f"{self.base_url}/getMe"
async with session.get(url) as response:
if response.status == 200:
result = await response.json()
if result.get("ok"):
bot_info = result.get("result", {})
logger.info(f"Telegram bot verified: @{bot_info.get('username')}")
return True
url = f"{self.base_url}/getMe"
async with get_http_client().tracked_request("GET", url) as response:
if response.status == 200:
result = await response.json()
if result.get("ok"):
bot_info = result.get("result", {})
logger.info(f"Telegram bot verified: @{bot_info.get('username')}")
return True
return False
except Exception as exc:
logger.error(f"Failed to verify Telegram bot token: {exc}")
Expand Down
Loading
Loading