Testing Changes

FileStream/bot/__init__.py

@@ -28,7 +28,4 @@ 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)
-  #print("\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,public_ip=PUBLIC_IP, client=faster_client)
   return dict(index=index,public_ip=PUBLIC_IP, client=faster_client)

FileStream/server/Functions/downloader.py

@@ -23,25 +23,26 @@ async def media_streamer(request: web.Request, db_id: str, speed: str):
     # Get the Range header from the request, default to 0 if not present
     range_header = request.headers.get("Range", 0)
     Worker = await req_client(request.remote)
-    client=Worker.get("client")
+    client= Worker.get("client")
     # Log client info if multi-client mode
 
-    if Telegram.MULTI_CLIENT:
+    #if Telegram.MULTI_CLIENT:
         #print("ACTIVE Client",ACTIVE_CLIENTS)
-        logging.info(f"Client {Worker['index']} is now serving {request.headers.get('X-FORWARDED-FOR', request.remote)}")
+        #logging.info(f"Client {Worker['index']} is now serving {request.headers.get('X-FORWARDED-FOR', request.remote)}")
 
     # Use an existing ByteStreamer or create a new one
     #tg_connect = ACTIVE_CLIENTS.get(client['client'], None)
     
     if client in ACTIVE_CLIENTS:
-        logging.debug(f"Using cached ByteStreamer object for client {Worker['index']}")
+        logging.debug(f"Cached ByteStreamer object for client {Worker['index']} # Serving Destination :{request.headers.get('X-FORWARDED-FOR', request.remote)}")
         tg_connect = ACTIVE_CLIENTS[client]
 
     else:
         tg_connect = utils.ByteStreamer(client)
         ACTIVE_CLIENTS[client] = tg_connect
-        logging.debug(f"Creating new ByteStreamer object for client {Worker['index']}")
+        logging.debug(f"New ByteStreamer object for client {Worker['index']} # Serving Destination :{request.headers.get('X-FORWARDED-FOR', request.remote)}")
 
+    logging.info(f"Client :{Worker['index']} # Serving Destination : {request.headers.get('X-FORWARDED-FOR', request.remote)}")
     tg_connect.update_last_activity()
 
     try: