Code Updates & SeveralFixes

FileStream/__main__.py

@@ -58,7 +58,7 @@ async def start_services():
     print("------------------------------ DONE ------------------------------\n\n")
 
     # Start the background task to clear inactive clients after web server setup
-    asyncio.create_task(clear_inactive_clients())  # Now this works as event loop is running
+    #asyncio.create_task(clear_inactive_clients())  # Now this works as event loop is running
 
     print(
         f"------------------------- Service Started -------------------------\n"

FileStream/utils/FileProcessors/custom_mix.py

@@ -81,22 +81,21 @@ class TGFileController:
 
   async def get_file_properties(self, db_id: str, MULTI_CLIENTS) -> FileId:
     """
-        Returns the properties of a media of a specific message in a FIleId class.
-        if the properties are cached, then it'll return the cached results.
-        or it'll generate the properties from the Message ID and cache them.
-        """
+    Returns the properties of a media of a specific message in a FIleId class.
+    if the properties are cached, then it'll return the cached results.
+    or it'll generate the properties from the Message ID and cache them.
+    """
     if not db_id in self.cached_file_ids:
       logging.debug("Before Calling generate_file_properties")
       await self.generate_file_properties(db_id, MULTI_CLIENTS)
       logging.debug(f"Cached file properties for file with ID {db_id}")
     return self.cached_file_ids[db_id]
 
-  async def generate_file_properties(self, db_id: str,
-                                     MULTI_CLIENTS) -> FileId:
+  async def generate_file_properties(self, db_id: str,MULTI_CLIENTS) -> FileId:
+    """
+    Generates the properties of a media file on a specific message.
+    returns ths properties in a FIleId class.
     """
-        Generates the properties of a media file on a specific message.
-        returns ths properties in a FIleId class.
-        """
     logging.debug("Before calling get_file_ids")
     file_id = await get_file_ids(self.client, db_id, Message)
     logging.debug(f"Generated file ID and Unique ID for file with ID {db_id}")
@@ -104,12 +103,11 @@ class TGFileController:
     logging.debug(f"Cached media file with ID {db_id}")
     return self.cached_file_ids[db_id]
 
-  async def generate_media_session(self, client: Client,
-                                   file_id: FileId) -> Session:
+  async def generate_media_session(self, client: Client,file_id: FileId) -> Session:
+    """
+    Generates the media session for the DC that contains the media file.
+    This is required for getting the bytes from Telegram servers.
     """
-        Generates the media session for the DC that contains the media file.
-        This is required for getting the bytes from Telegram servers.
-        """
 
     media_session = client.media_sessions.get(file_id.dc_id, None)
 
@@ -157,16 +155,14 @@ class TGFileController:
     return media_session
 
   @staticmethod
-  async def get_location(
-      file_id: FileId
-  ) -> Union[
+  async def get_location(file_id: FileId) -> Union[
       raw.types.InputPhotoFileLocation,
       raw.types.InputDocumentFileLocation,
       raw.types.InputPeerPhotoFileLocation,
   ]:
     """
-        Returns the file location for the media file.
-        """
+    Returns the file location for the media file.
+    """
     file_type = file_id.file_type
 
     if file_type == FileType.CHAT_PHOTO: