Slight Edit

FileStream/bot/__init__.py

@@ -26,7 +26,7 @@ ACTIVE_CLIENTS = {}
 async def req_client(PUBLIC_IP:str)-> dict:
   index = min(WORK_LOADS, key=WORK_LOADS.get)
   faster_client = MULTI_CLIENTS[index]
-  print("Faster Client",faster_client,type(faster_client),"WORK_LOADS",WORK_LOADS,type(WORK_LOADS),"MULTI_CLIENTS",MULTI_CLIENTS,type(MULTI_CLIENTS))
+  logging.info("\n \nFaster Client",faster_client,type(faster_client),"\nWORK_LOADS",WORK_LOADS,type(WORK_LOADS),"\nMULTI_CLIENTS",MULTI_CLIENTS,type(MULTI_CLIENTS),"\n")
   #ACTIVE_CLIENTS.update(faster_client)
   #response = dict(index=index, client=faster_client)
   return dict(index=index,public_ip=PUBLIC_IP, client=faster_client)

FileStream/server/Functions/downloader.py

@@ -31,13 +31,13 @@ async def media_streamer(request: web.Request, db_id: str, speed: str):
     # Use an existing ByteStreamer or create a new one
     #tg_connect = ACTIVE_CLIENTS.get(client['client'], None)
     
-    if client['client'] in ACTIVE_CLIENTS:
+    if client["client"] in ACTIVE_CLIENTS:
         logging.info(f"Creating new ByteStreamer object for client {client['index']}")
-        tg_connect = ACTIVE_CLIENTS(client['client'])
+        tg_connect = ACTIVE_CLIENTS(client["client"])
 
     else:
-        tg_connect = utils.ByteStreamer(client['client'])
-        ACTIVE_CLIENTS[client['client']] = tg_connect
+        tg_connect = utils.ByteStreamer(client["client"])
+        ACTIVE_CLIENTS[client["client"]] = tg_connect
         logging.info(f"Using cached ByteStreamer object for client {client['index']}")
 
     tg_connect.update_last_activity()