feat: Add MTProto proxy configuration to settings and TelegramService

Author: mmkhak

.env.example

@@ -14,5 +14,11 @@ REDIS_URL=redis://localhost:6379/0
 MONGODB_URL=mongodb://localhost:27017
 MONGODB_DATABASE=telegram_service
 
+# MTProto proxy (optional)
+USE_MTPROTO_PROXY=false
+MTPROTO_HOST=
+MTPROTO_PORT=
+MTPROTO_SECRET=
+
 # Security
 API_SECRET_KEY=your-secret-key-for-api-auth

app/config.py

@@ -23,6 +23,12 @@ class Settings(BaseSettings):
     # MongoDB
     mongodb_url: str = "mongodb://localhost:27017"
     mongodb_database: str = "telegram_service"
+
+    # MTProto proxy (optional)
+    use_mtproto_proxy: bool = False
+    mtproto_host: Optional[str] = None
+    mtproto_port: Optional[int] = None
+    mtproto_secret: Optional[str] = None
 
     # Security
     api_secret_key: str

app/services/telegram.py

@@ -7,6 +7,7 @@
 
 from telethon import TelegramClient, events
 from telethon.errors import FloodWaitError, PasswordHashInvalidError, PhoneCodeInvalidError, SessionPasswordNeededError
+from telethon.network.connection import ConnectionTcpMTProxyRandomizedIntermediate
 from telethon.tl.types import User
 
 from app.config import settings
@@ -22,6 +23,13 @@ class TelegramService:
     def __init__(self):
         self.clients: Dict[str, TelegramClient] = {}
         self._ensure_session_directory()
+        self._proxy = self._build_proxy()
+
+    def _build_proxy(self):
+        """Return proxy config tuple for MTProto if enabled."""
+        if settings.use_mtproto_proxy and settings.mtproto_host and settings.mtproto_port and settings.mtproto_secret:
+            return (settings.mtproto_host, int(settings.mtproto_port), settings.mtproto_secret)
+        return None
 
     def _ensure_session_directory(self):
         """Ensure the session directory exists."""
@@ -34,7 +42,19 @@ def _get_session_file_path(self, session_id: str) -> str:
     async def create_client(self, session_id: str) -> TelegramClient:
         """Create a new Telegram client for a session."""
         session_file = self._get_session_file_path(session_id)
-        client = TelegramClient(session_file, settings.telegram_api_id, settings.telegram_api_hash)
+        client_kwargs = {}
+        if self._proxy:
+            client_kwargs.update(
+                connection=ConnectionTcpMTProxyRandomizedIntermediate,
+                proxy=self._proxy,
+            )
+
+        client = TelegramClient(
+            session_file,
+            settings.telegram_api_id,
+            settings.telegram_api_hash,
+            **client_kwargs,
+        )
         self.clients[session_id] = client
         logger.info(f"Created Telegram client for session: {session_id}")
         return client