Slight Edit

FileStream/server/API/downloads.py

@@ -25,12 +25,17 @@ async def stream_handler(request: web.Request):
     try:
         path = request.match_info["path"]
         return await media_streamer(request, path, "FAST")
+
     except InvalidHash as e:
+
         raise web.HTTPForbidden(text=e.message)
+
     except FIleNotFound as e:
         raise web.HTTPNotFound(text=e.message)
+
     except (AttributeError, BadStatusLine, ConnectionResetError):
         pass  # Handle expected errors silently
+    
     except Exception as e:
         logging.error(f"Error while streaming file: {str(e)}")
         traceback.print_exc()

FileStream/utils/FileProcessors/custom_dl.py

@@ -29,7 +29,7 @@ class ByteStreamer:
         self.clean_timer = 30 * 60  # Cache cleanup timer set to 30 minutes
         self.client: Client = client
         self.cached_file_ids: Dict[str, FileId] = {}  # Cache to store file properties by db_id
-        self.last_activity: float = Optional[float]  # Track last activity time for the client
+        self.last_activity: float = asyncio.get_event_loop().time()  # Track last activity time for the client
         asyncio.create_task(self.clean_cache())  # Start the cache cleanup task
 
     def update_last_activity(self):