zhombie

import aiohttp
import asyncio
import logging
import traceback
import uuid
from chardet import detect
from typing import Any, Optional, Tuple

logger = logging.getLogger(__name__)

zhombie

access_hash = await db.fetchval(
    '''
    SELECT extra ->> 'access_hash'
    FROM scanning.accounts
    WHERE channel = $1
    ''',
    'tg'
)

tg = TelegramStreaming(

zhombie

    def collect_article(self, blocks) -> str:
        article = []

        for block in blocks:
            text = self.obtain_text(block)
            if text:
                article.append(text)

        return '\n'.join(article)