Spaces:
Running
Running
from ..config import Telegram | |
from pyrogram import Client | |
if Telegram.SECONDARY: | |
plugins = None | |
no_updates = True | |
else: | |
plugins = dict(root="FileStream/bot/plugins") | |
no_updates = None | |
FileStream = Client(name="FileStream", | |
api_id=Telegram.API_ID, | |
api_hash=Telegram.API_HASH, | |
workdir="FileStream", | |
plugins=plugins, | |
bot_token=Telegram.BOT_TOKEN, | |
sleep_threshold=Telegram.SLEEP_THRESHOLD, | |
workers=Telegram.WORKERS, | |
no_updates=no_updates) | |
multi_clients = {} | |
work_loads = {} | |
async def req_client(): | |
index = min(work_loads, key=work_loads.get) | |
faster_client = multi_clients[index] | |
response = dict(index=index, client=faster_client) | |
return response | |