FileStream/bot/__init__.py

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():
  index = min(WORK_LOADS, key=WORK_LOADS.get)
  faster_client = MULTI_CLIENTS[index]
  response = dict(index=index, client=faster_client)
  return response