1.9.6

New /speedtest admin command: run network speed tests, view live progress, and share results as images or text.

README.md

@@ -241,6 +241,7 @@ Copy `config_sample.env` to `config.env` and fill in your values.
 | `/log` | Send bot logs. |
 | `/restart` | Restart the bot. |
 | `/shell` | Execute a shell command. |
+| `/speedtest` | Run network speed test and display comprehensive results. |
 | `/users` | Show total number of users. |
 | `/authorize` | Permanently authorize a user to use the bot (bypasses token system). |
 | `/deauthorize` | Remove permanent authorization from a user. |
@@ -268,6 +269,7 @@ listauth - [Admin] List authorized
 log - [Admin] Send bot logs
 restart - [Admin] Restart the bot
 shell - [Admin] Execute shell command
+speedtest - [Admin] Run network speed test
 ```
 
 </details>
@@ -312,6 +314,16 @@ Thunder implements a sophisticated multi-tier rate limiting system designed for
 - **Queue Size Limits**: Configurable maximum queue size.
 - **Flood Protection**: Built-in protection against Telegram flood waits.
 
+### Network Speed Testing
+
+Monitor server performance with built-in speed testing:
+
+```bash
+/speedtest
+```
+
+Features include download/upload speeds, latency measurements, and shareable result images for performance monitoring.
+
 ## Production Deployment Guide
 
 ### Custom Domain & FQDN System

Thunder/__init__.py

@@ -3,4 +3,4 @@
 import time
 
 StartTime = time.time()
-__version__ = "1.9.5"
+__version__ = "1.9.6"

Thunder/bot/plugins/admin.py

@@ -35,6 +35,7 @@ from Thunder.utils.messages import (
     MSG_NO_AUTH_USERS, MSG_RESTARTING, MSG_SHELL_ERROR,
     MSG_SHELL_EXECUTING, MSG_SHELL_NO_OUTPUT, MSG_SHELL_OUTPUT,
     MSG_SHELL_OUTPUT_STDERR, MSG_SHELL_OUTPUT_STDOUT, MSG_SHELL_USAGE,
+    MSG_SPEEDTEST_ERROR, MSG_SPEEDTEST_INIT, MSG_SPEEDTEST_RESULT,
     MSG_STATUS_ERROR, MSG_SYSTEM_STATS, MSG_SYSTEM_STATUS,
     MSG_UNBAN_USAGE, MSG_USER_BANNED_NOTIFICATION,
     MSG_USER_NOT_IN_BAN_LIST, MSG_USER_UNBANNED_NOTIFICATION,
@@ -42,6 +43,7 @@ from Thunder.utils.messages import (
 )
 from Thunder.utils.time_format import get_readable_time
 from Thunder.utils.tokens import authorize, deauthorize, list_allowed
+from Thunder.utils.speedtest import run_speedtest
 from Thunder.vars import Var
 
 owner_filter = filters.private & filters.user(Var.OWNER_ID)
@@ -195,7 +197,6 @@ async def deauthorize_command(client: Client, message: Message):
         await reply(message, text=MSG_INVALID_USER_ID)
     except Exception as e:
         logger.error(f"Error in deauthorize_command: {e}", exc_info=True)
-
         await reply(message, text=MSG_ERROR_GENERIC)
 
 
@@ -353,3 +354,60 @@ async def run_shell_command(client: Client, message: Message):
                 message,
                 text=MSG_SHELL_ERROR.format(error=html.escape(str(e))),
                 parse_mode=ParseMode.HTML)
+
+
+@StreamBot.on_message(filters.command("speedtest") & owner_filter)
+async def speedtest_command(client: Client, message: Message):
+    status_msg = await reply(message, text=MSG_SPEEDTEST_INIT)
+    try:
+        result_dict, image_url = await run_speedtest()
+        if result_dict is None:
+            await handle_flood_wait(status_msg.edit_text, MSG_SPEEDTEST_ERROR)
+            return
+        
+        result_text = _format_speedtest_result(result_dict)
+        await _send_result(message, status_msg, result_text, image_url)
+    except Exception as e:
+        logger.error(f"Error in speedtest_command: {e}", exc_info=True)
+        try:
+            await handle_flood_wait(status_msg.edit_text, MSG_SPEEDTEST_ERROR)
+        except Exception:
+            await reply(message, text=MSG_SPEEDTEST_ERROR)
+
+
+def _format_speedtest_result(result_dict: dict) -> str:
+    s, c = result_dict['server'], result_dict['client']
+    return MSG_SPEEDTEST_RESULT.format(
+        download_mbps=_fmt(result_dict['download_mbps']),
+        upload_mbps=_fmt(result_dict['upload_mbps']),
+        download_bps=humanbytes(result_dict['download_bps']),
+        upload_bps=humanbytes(result_dict['upload_bps']),
+        ping=_fmt(result_dict['ping']),
+        timestamp=result_dict['timestamp'],
+        bytes_sent=humanbytes(result_dict['bytes_sent']),
+        bytes_received=humanbytes(result_dict['bytes_received']),
+        server_name=s['name'],
+        server_country=f"{s['country']} ({s['cc']})",
+        server_sponsor=s['sponsor'],
+        server_latency=_fmt(s['latency']),
+        server_lat=_fmt(s['lat'], 4),
+        server_lon=_fmt(s['lon'], 4),
+        client_ip=c['ip'],
+        client_lat=_fmt(c['lat'], 4),
+        client_lon=_fmt(c['lon'], 4),
+        client_isp=c['isp'],
+        client_isprating=c['isprating'],
+        client_country=c['country']
+    )
+
+
+async def _send_result(message: Message, status_msg: Message, result_text: str, image_url: str):
+    if image_url:
+        await handle_flood_wait(message.reply_photo, image_url, caption=result_text, parse_mode=ParseMode.MARKDOWN)
+        await handle_flood_wait(status_msg.delete)
+    else:
+        await handle_flood_wait(status_msg.edit_text, result_text, parse_mode=ParseMode.MARKDOWN)
+
+
+def _fmt(value, decimals: int = 2) -> str:
+    return f"{float(value):.{decimals}f}"

Thunder/utils/commands.py

@@ -20,6 +20,7 @@ def get_commands():
         "log": "(Admin) Send bot logs",
         "restart": "(Admin) Restart the bot",
         "shell": "(Admin) Execute a shell command",
+        "speedtest": "(Admin) Run network speed test",
         "users": "(Admin) Show the total number of users",
         "authorize": "(Admin) Grant permanent access to a user",
         "deauthorize": "(Admin) Remove permanent access from a user",
@@ -34,4 +35,4 @@ async def set_commands():
             if commands:
                 await StreamBot.set_bot_commands(commands)
         except Exception as e:
-            logger.error(f"Failed to set bot commands: {e}", exc_info=True)
+            logger.error(f"Failed to set bot commands: {e}", exc_info=True)

Thunder/utils/messages.py

@@ -340,6 +340,32 @@ MSG_SYSTEM_STATUS = (
     "{workload_items}\n"
     "> ♻️ **Version:** `{version}`"
 )
+
+# ------ Speedtest Messages ------
+MSG_SPEEDTEST_INIT = "🚀 **Running Speed Test...** ⏳\n\n> Please wait while I test your connection speed."
+MSG_SPEEDTEST_ERROR = "❌ **Speed Test Failed!**\n\n> Unable to complete the speed test. Please try again later."
+MSG_SPEEDTEST_RESULT = (
+    "⚡ **Speed Test Results**\n\n"
+    "**SPEEDTEST INFO:**\n"
+    "> **Download:** `{download_mbps} Mbps` (`{download_bps} B/s`)\n"
+    "> **Upload:** `{upload_mbps} Mbps` (`{upload_bps} B/s`)\n"
+    "> **Ping:** `{ping} ms`\n"
+    "> **Timestamp:** `{timestamp}`\n"
+    "> **Data Sent:** `{bytes_sent}`\n"
+    "> **Data Received:** `{bytes_received}`\n\n"
+    "**SERVER INFO:**\n"
+    "> **Name:** `{server_name}`\n"
+    "> **Country:** `{server_country}`\n"
+    "> **Sponsor:** `{server_sponsor}`\n"
+    "> **Latency:** `{server_latency} ms`\n"
+    "> **Coordinates:** `{server_lat}, {server_lon}`\n\n"
+    "**CLIENT DETAILS:**\n"
+    "> **IP:** `{client_ip}`\n"
+    "> **Location:** `{client_lat}, {client_lon}`\n"
+    "> **ISP:** `{client_isp}`\n"
+    "> **ISP Rating:** `{client_isprating}`\n"
+    "> **Country:** `{client_country}`"
+)
 MSG_SYSTEM_STATS = (
     "📊 **System Statistics**\n\n"
     "> System Uptime: {sys_uptime}\n"

Thunder/utils/speedtest.py

@@ -0,0 +1,43 @@
+# Thunder/utils/speedtest.py
+
+import asyncio
+from typing import Optional, Tuple, Dict, Any
+
+import speedtest
+from Thunder.utils.logger import logger
+
+
+async def run_speedtest() -> Tuple[Optional[Dict[str, Any]], Optional[str]]:
+    try:
+        return await asyncio.to_thread(_perform_speedtest)
+    except Exception as e:
+        logger.error(f"Speedtest failed: {e}", exc_info=True)
+        return None, None
+
+
+def _perform_speedtest() -> Tuple[Optional[Dict[str, Any]], Optional[str]]:
+    try:
+        st = speedtest.Speedtest(timeout=15, secure=True)
+        st.get_best_server()
+        st.download()
+        st.upload(pre_allocate=False)
+        
+        results = st.results.dict()
+        download_mbps = st.results.download / 1_000_000
+        upload_mbps = st.results.upload / 1_000_000
+        
+        results['download_mbps'] = download_mbps
+        results['upload_mbps'] = upload_mbps
+        results['download_bps'] = st.results.download / 8
+        results['upload_bps'] = st.results.upload / 8
+        
+        logger.info(f"Download: {download_mbps:.2f} Mbps | Upload: {upload_mbps:.2f} Mbps")
+        
+        try:
+            return results, st.results.share()
+        except Exception:
+            return results, None
+            
+    except Exception as e:
+        logger.error(f"Speedtest failed: {e}")
+        return None, None

config_sample.env

@@ -24,7 +24,7 @@ OWNER_USERNAME="" # Example: "@YourUsername"
 DATABASE_URL="" # Example: "mongodb+srv://user:pass@host/db"
 
 # Deployment configuration
-FQDN="" # Your domain name (leave empty to use IP)
+FQDN="" # Your domain name
 HAS_SSL="False" # Set to "True" if using HTTPS
 PORT=8080 # Web server port
 NO_PORT="True" # Hide port in URLs ("True" or "False")

requirements.txt

@@ -5,5 +5,6 @@ kurigram==2.2.6
 motor
 psutil
 python-dotenv
+speedtest-cli
 tgcrypto
 uvloop