Minor Changes in Codes

FileStream/bot/__init__.py

@@ -23,8 +23,8 @@ WORK_LOADS = {}
 MULTI_CLIENTS = {}
 ACTIVE_CLIENTS = {}
 
-async def req_client():
+async def req_client(PUBLIC_IP:str)-> dict:
   index = min(WORK_LOADS, key=WORK_LOADS.get)
   faster_client = MULTI_CLIENTS[index]
-  response = dict(index=index, client=faster_client)
-  return response
+  #response = dict(index=index, client=faster_client)
+  return dict(index=index,public_ip=PUBLIC_IP, client=faster_client)

FileStream/server/Functions/downloader.py

@@ -22,8 +22,9 @@ from FileStream.utils.FileProcessors.custom_ul import  TeleUploader
 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)
-    client = await req_client()
+    client = await req_client(request.remote)
     # Log client info if multi-client mode
+
     if Telegram.MULTI_CLIENT:
         logging.info(f"Client {client['index']} is now serving {request.headers.get('X-FORWARDED-FOR', request.remote)}")
 
@@ -31,13 +32,13 @@ async def media_streamer(request: web.Request, db_id: str, speed: str):
     tg_connect = ACTIVE_CLIENTS.get(client['client'], None)
     
     if tg_connect is None:
-        logging.debug(f"Creating new ByteStreamer object for client {client['index']}")
+        logging.info(f"Creating new ByteStreamer object for client {client['index']}")
         tg_connect = utils.ByteStreamer(client['client'])
         ACTIVE_CLIENTS[client['client']] = tg_connect
 
     else:
         tg_connect.update_last_activity()
-        logging.debug(f"Using cached ByteStreamer object for client {client['index']}")
+        logging.info(f"Using cached ByteStreamer object for client {client['index']}")
 
     try:
         # Fetch file properties once and use it throughout