Testing Changes

FileStream/server/Functions/downloader.py

@@ -29,17 +29,19 @@ async def media_streamer(request: web.Request, db_id: str, speed: str):
         logging.info(f"Client {client['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)
+    #tg_connect = ACTIVE_CLIENTS.get(client['client'], None)
     
-    if tg_connect is None:
+    if client['client'] in ACTIVE_CLIENTS:
         logging.info(f"Creating new ByteStreamer object for client {client['index']}")
-        tg_connect = utils.ByteStreamer(client['client'])
-        ACTIVE_CLIENTS[client['client']] = tg_connect
+        tg_connect = ACTIVE_CLIENTS(client['client'])
 
     else:
-        tg_connect.update_last_activity()
+        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()
+
     try:
         # Fetch file properties once and use it throughout
         logging.debug("Fetching file properties")