Sessions fly off

У меня уже ощущение что я проклятый. Простенький скрипт, который следит за каналами и пересылает посты боту в лс. Все сессии какие не пробовал(разные ценовые сегменты) сразу отлетали в заморозку, пробовал и разные ******. Параметры для TelegramClient беру из json конфига которые идут вместе с сессиями

Тому кто даст реально рабочий совет закину на пиво имейте ввиду

Запуск TelegramCLient:

client = TelegramClient(

session_path,

app_id,

app_hash,

**client_kwargs,

proxy=await self._get_proxy(self.proxy)

)



try:

await client.connect()

await client.start()

if not await client.is_user_authorized():

raise RuntimeError("Client is not authorized")





me = await client.get_me()

uid = me.id

logger.info("Сессия %s запущена как пользователь %d", fn, uid)



async with self._state_lock:

self.user_clients[uid] = client

self.session_channels[uid] = set()



asyncio.create_task(self._start_session_watch(client))



except Exception as e:

logger.warning("Не удалось запустить сессию %s: %s", fn, e)

Python

client = TelegramClient(



    session_path,



    app_id,



    app_hash,



    **client_kwargs,



    proxy=await self._get_proxy(self.proxy)



)







try:



    await client.connect()



    await client.start()



    if not await client.is_user_authorized():



        raise RuntimeError("Client is not authorized")











    me = await client.get_me()



    uid = me.id



    logger.info("Сессия %s запущена как пользователь %d", fn, uid)







    async with self._state_lock:



        self.user_clients[uid] = client



        self.session_channels[uid] = set()







    asyncio.create_task(self._start_session_watch(client))







except Exception as e:



    logger.warning("Не удалось запустить сессию %s: %s", fn, e)

И метод ****** на всякий(http или sock5 телеграмму похер, также в заморозку):

@staticmethod

async def _get_proxy(proxy_str: str) -> dict:

"""

Разбирает строку proxy 'addr:port:user:pass' и возвращает словарь для Telethon.

"""

addr, port, username, password = proxy_str.split(":")

return {

"proxy_type": python_socks.ProxyType.HTTP,

"addr": addr,

"port": int(port),

"username": username,

"password": password,

"rdns": True

}

Python

@staticmethod



async def _get_proxy(proxy_str: str) -> dict:



    """



    Разбирает строку proxy 'addr:port:user:pass' и возвращает словарь для Telethon.



    """



    addr, port, username, password = proxy_str.split(":")



    return {



        "proxy_type": python_socks.ProxyType.HTTP,



        "addr": addr,



        "port": int(port),



        "username": username,



        "password": password,



        "rdns": True



    }