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