Spaces:
Running
Running
Commit
·
4895976
1
Parent(s):
d3df831
Slight Edit
Browse files
FileStream/bot/__init__.py
CHANGED
@@ -29,5 +29,5 @@ async def req_client(PUBLIC_IP:str)-> dict:
|
|
29 |
faster_client = MULTI_CLIENTS[index]
|
30 |
print("\n \nFaster Client",faster_client,type(faster_client),"\nWORK_LOADS",WORK_LOADS,type(WORK_LOADS),"\nMULTI_CLIENTS",MULTI_CLIENTS,type(MULTI_CLIENTS),"\n")
|
31 |
#ACTIVE_CLIENTS.update(faster_client)
|
32 |
-
|
33 |
-
return
|
|
|
29 |
faster_client = MULTI_CLIENTS[index]
|
30 |
print("\n \nFaster Client",faster_client,type(faster_client),"\nWORK_LOADS",WORK_LOADS,type(WORK_LOADS),"\nMULTI_CLIENTS",MULTI_CLIENTS,type(MULTI_CLIENTS),"\n")
|
31 |
#ACTIVE_CLIENTS.update(faster_client)
|
32 |
+
response = dict(index=index,public_ip=PUBLIC_IP, client=faster_client)
|
33 |
+
return response
|
FileStream/server/Functions/downloader.py
CHANGED
@@ -27,6 +27,7 @@ async def media_streamer(request: web.Request, db_id: str, speed: str):
|
|
27 |
# Log client info if multi-client mode
|
28 |
|
29 |
if Telegram.MULTI_CLIENT:
|
|
|
30 |
logging.info(f"Client {Worker['index']} is now serving {request.headers.get('X-FORWARDED-FOR', request.remote)}")
|
31 |
|
32 |
# Use an existing ByteStreamer or create a new one
|
|
|
27 |
# Log client info if multi-client mode
|
28 |
|
29 |
if Telegram.MULTI_CLIENT:
|
30 |
+
print("ACTIVE Client",ACTIVE_CLIENTS)
|
31 |
logging.info(f"Client {Worker['index']} is now serving {request.headers.get('X-FORWARDED-FOR', request.remote)}")
|
32 |
|
33 |
# Use an existing ByteStreamer or create a new one
|