Feat: New Features & Improvements

Changelog (redeploy needed) ->
1. Switched to kurigram
2. Fixed mega download, remove mega clone
3. Added swap mt
4. Fixed gensession, quickinfo
5. AI based nsfw detection
6. Added lot of small tools ( /tool ) inspired by https://t.me/SmartUtilBot
7. File to Link/Streaming service (alpha)
8. Reduce ytdlp memory usage
9. Sync with base
10. bug fixes

Author: aim-ml

.github/workflows/build.yml

@@ -51,7 +51,6 @@ jobs:
       - name: Prepare Docker Build Files
         run: |
           cp dev/Aeon .
-          cp dev/megasdk-4.8.0-py2.py3-none-any.whl .
           chmod +x Aeon
 
       - name: Build and Push

.github/workflows/deploy.yml

@@ -2,7 +2,7 @@ name: format code with ruff
 
 on:
   push:
-    branches: [main]
+    branches: [extended]
 
 jobs:
   code-format:

.github/workflows/ruff_format.yml

@@ -16,7 +16,6 @@ list_drives.txt
 shorteners.txt
 cookies.txt
 cookies/*
-venv/
 downloads/*
 *.session
 venv/

.gitignore

@@ -335,3 +335,6 @@ def is_qbittorrent_running():
 
 
 scheduler = AsyncIOScheduler(event_loop=bot_loop)
+
+# Initialize streaming server
+StartTime = time_func()

bot/__init__.py

@@ -35,7 +35,6 @@
     "ZotifyLeechCommand": "- Leech music from Spotify",
     "ZotifySearchCommand": "- Search music on Spotify",
     "CloneCommand": "- Copy file/folder to Drive",
-    "MegaCloneCommand": "- Clone MEGA files/folders to MEGA account",
     "MegaSearchCommand": "- Search MEGA drive for files/folders",
     "MediaInfoCommand": "- Get mediainfo",
     "SoxCommand": "- Get audio spectrum",
@@ -51,19 +50,35 @@
     "CancelAllCommand": "- Cancel all tasks added by you to the bot",
     "HelpCommand": "- Get detailed help",
     "FontStylesCommand": "- View available font styles for leech",
-    "IMDBCommand": "- Search for movies or TV series info",
     "MediaSearchCommand": "- Search for media files (/mds) or reply to a message",
     "SpeedTest": "- Get speedtest result",
     "GenSessionCommand": "- Generate Pyrogram session string",
-    "TruecallerCommand": "- Lookup phone numbers using Truecaller",
     "VirusTotalCommand": "- Scan files or URLs for viruses using VirusTotal",
     # QuickInfo Commands
     "QuickInfoCommand": "- Get chat/user information with interactive buttons",
+    # File-to-Link Commands
+    "File2LinkCommand": "- Convert files to permanent download/stream links",
+    "StreamStatsCommand": "- View streaming server statistics",
+    "ToolCommand": "- Media conversion and processing tools (gif, sticker, emoji, voice, etc.)",
+    "IndexCommand": "- [ADMIN] Reindex media files from dump chats",
     "BotSetCommand": "- [ADMIN] Open Bot settings",
     "LogCommand": "- [ADMIN] View log",
     "RestartCommand": "- [ADMIN] Restart the bot",
+    "WhisperCommand": "- Send private whisper messages in group chats",
 }
 
+# Add AI command if enabled
+if Config.AI_ENABLED:
+    COMMANDS["AskCommand"] = "- Ask AI questions and get intelligent responses"
+
+# Add IMDB command if enabled
+if Config.IMDB_ENABLED:
+    COMMANDS["IMDBCommand"] = "- Search for movies or TV series info"
+
+# Add Truecaller command if enabled
+if Config.TRUECALLER_ENABLED:
+    COMMANDS["TruecallerCommand"] = "- Lookup phone numbers using Truecaller"
+
 # Add encoding/decoding commands if enabled
 if Config.ENCODING_ENABLED:
     COMMANDS["EncodeCommand"] = "- Encode text using various methods"
@@ -187,6 +202,29 @@ async def main():
     LOGGER.info("Loading user data for limits tracking...")
     await _load_user_data()
 
+    # Streaming functionality is now fully integrated with wserver
+    # No separate stream server needed
+    LOGGER.info("Streaming functionality integrated with wserver")
+
+    # Initialize File-to-Link functionality if enabled
+    if Config.FILE_TO_LINK_ENABLED:
+        from .modules.file_to_link import initialize_file_to_link
+
+        LOGGER.info("Initializing File-to-Link functionality...")
+        create_task(initialize_file_to_link())  # noqa: RUF006
+
+    # Initialize whisper cleanup task
+    LOGGER.info("Initializing whisper cleanup task...")
+    from .modules.whisper import start_whisper_cleanup
+
+    create_task(start_whisper_cleanup())  # noqa: RUF006
+
+    # Run automatic indexing to sync dump chats with database on startup
+    LOGGER.info("Starting automatic indexing to sync dump chats with database...")
+    from .modules.index_command import auto_index_on_startup
+
+    create_task(auto_index_on_startup())  # noqa: RUF006
+
     # Initial garbage collection and memory usage logging (less aggressive during startup)
     LOGGER.info("Performing initial garbage collection...")
     smart_garbage_collection(
@@ -234,6 +272,9 @@ async def cleanup():
     except Exception as e:
         LOGGER.error(f"Error during streamrip cleanup: {e}")
 
+    # Streaming functionality is integrated with wserver - no separate cleanup needed
+    LOGGER.info("Streaming functionality cleanup handled by wserver")
+
     # Stop database heartbeat task
     await database.stop_heartbeat()
 
@@ -273,6 +314,11 @@ def handle_loop_exception(loop, context):
             LOGGER.debug(
                 f"Transport closing error (harmless during shutdown): {exception}"
             )
+        # Filter out QueryIdInvalid errors from YT-DLP callback queries (these are expected when callbacks expire)
+        elif "QUERY_ID_INVALID" in str(exception) or "QueryIdInvalid" in str(
+            type(exception).__name__
+        ):
+            LOGGER.debug(f"Callback query expired (expected behavior): {exception}")
         else:
             LOGGER.error(f"Unhandled loop exception: {exception}")
             LOGGER.error(f"Exception context: {context}")

bot/__main__.py

@@ -31,7 +31,7 @@ async def start_bot(cls):
             bot_token=Config.BOT_TOKEN,
             workdir="/usr/src/app",
             parse_mode=enums.ParseMode.HTML,
-            max_concurrent_transmissions=10,
+            max_concurrent_transmissions=100,
             no_updates=False,  # Ensure updates are enabled
         )
         try:
@@ -68,7 +68,7 @@ async def start_user(cls):
                     session_string=Config.USER_SESSION_STRING,
                     parse_mode=enums.ParseMode.HTML,
                     no_updates=True,
-                    max_concurrent_transmissions=10,
+                    max_concurrent_transmissions=100,
                 )
                 await cls.user.start()
                 cls.IS_PREMIUM_USER = cls.user.me.is_premium
@@ -119,11 +119,10 @@ async def start_hclient(cls, no, b_token):
     @classmethod
     async def start_helper_bots(cls):
         if not Config.HELPER_TOKENS:
-            LOGGER.info(
-                "No HELPER_TOKENS found, hyper download will not be available"
+            LOGGER.warning(
+                "❌ No HELPER_TOKENS found, hyper download will not be available"
             )
             return
-        LOGGER.info("Generating helper clients from HELPER_TOKENS")
         async with cls._hlock:
             await gather(
                 *(