webapp/app/services/telegram_service.py

import json
import time
import requests
from typing import List
from app.core.biz_exception import NotFoundError, PermissionDeniedError, BizLogicError
from app.schemas.telegram import TelegramIn


class TelegramService:
    def push_to_telegram(payload: TelegramIn):
        url = f"https://api.telegram.org/bot{payload.api_token}/sendMessage"
        payload = {
            "chat_id": payload.chat_id,
            "text": payload.message,
            "parse_mode": "HTML"
        }

        response = requests.post(url, json=payload, timeout=10)
        if response.status_code != 200:
            raise BizLogicError("Telegram push failed")