| 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 | |