| import pprint | |
| 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) | |
| WORK_LOADS = {} | |
| MULTI_CLIENTS = {} | |
| ACTIVE_CLIENTS = {} | |
| async def req_client(PUBLIC_IP:str)-> dict: | |
| index = min(WORK_LOADS, key=WORK_LOADS.get) | |
| faster_client = MULTI_CLIENTS[index] | |
| print("WorkLoads :",WORK_LOADS) | |
| return dict(index=index,public_ip=PUBLIC_IP, client=faster_client) | |