patch 1

AGENTS.md

@@ -18,7 +18,7 @@ pip install -r requirements.txt
 
 ## Project Structure
 
-```
+```text
 Thunder/
 ├── __init__.py              # __version__, StartTime
 ├── __main__.py              # Entry: start_services() via asyncio

Thunder/__main__.py

@@ -239,6 +239,10 @@ async def start_services():
             await rate_limiter.shutdown()
         except Exception:
             pass
+        try:
+            await db.close()
+        except Exception as e:
+            logger.error(f"Error during database cleanup: {e}", exc_info=True)
         try:
             await drain_background_touch_tasks()
         except Exception as e:
@@ -298,7 +302,7 @@ async def start_services():
             await db.close()
             print("   ✓ Database connection closed")
         except Exception as e:
-            logger.error(f"Error during database cleanup: {e}")
+            logger.error("Error during database cleanup", exc_info=True)
 
 
 async def schedule_token_cleanup():

Thunder/bot/plugins/stream.py

@@ -467,9 +467,9 @@ async def process_single(
                     return None
             links = await gen_links(stored_msg, shortener=shortener_val)
             canonical_reply_id = stored_msg.id
-        if notification_msg:
-            await safe_edit_message(
-                notification_msg,
+        if notification_msg:
+            result = await safe_edit_message(
+                notification_msg,
                 MSG_LINKS.format(
                     file_name=links['media_name'],
                     file_size=links['media_size'],
@@ -480,7 +480,9 @@ async def process_single(
                 disable_web_page_preview=True,
                 reply_markup=get_link_buttons(links)
             )
-        elif not original_request_msg:
+            if not result:
+                await send_link(msg, links)
+        elif not original_request_msg:
             await send_link(msg, links)
         if msg.chat.type != enums.ChatType.PRIVATE and msg.from_user and not original_request_msg:
             await send_dm_links(bot, msg.from_user.id, links, msg.chat.title or "the chat")

Thunder/server/stream_routes.py

@@ -28,7 +28,7 @@ routes = web.RouteTableDef()
 SECURE_HASH_LENGTH = 6
 CHUNK_SIZE = 1024 * 1024
 MAX_CONCURRENT_PER_CLIENT = 8
-RANGE_REGEX = re.compile(r"bytes=(?P<start>\d*)-(?P<end>\d*)")
+RANGE_REGEX = re.compile(r"^bytes=(?P<start>\d*)-(?P<end>\d*)$")
 PATTERN_HASH_FIRST = re.compile(
     rf"^([a-zA-Z0-9_-]{{{SECURE_HASH_LENGTH}}})(\d+)(?:/.*)?$")
 PATTERN_ID_FIRST = re.compile(r"^(\d+)(?:/.*)?$")
@@ -116,7 +116,7 @@ def parse_range_header(range_header: str, file_size: int) -> tuple[int, int]:
     if not range_header:
         return 0, file_size - 1
 
-    match = RANGE_REGEX.match(range_header)
+    match = RANGE_REGEX.fullmatch(range_header)
     if not match:
         raise web.HTTPBadRequest(text=f"Invalid range header: {range_header}")
 

Thunder/template/req.html

@@ -162,14 +162,14 @@
                             </svg>
                             VLC
                         </a>
-                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=com.mxtech.videoplayer.ad;S.title={{ file_name }};end"
+                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=com.mxtech.videoplayer.ad;S.title={{ file_name | urlencode }};end"
                             class="player-link">
                             <svg viewBox="0 0 24 24">
                                 <circle cx="12" cy="12" r="10" />
                             </svg>
                             MX Player
                         </a>
-                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=com.mxtech.videoplayer.pro;S.title={{ file_name }};end"
+                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=com.mxtech.videoplayer.pro;S.title={{ file_name | urlencode }};end"
                             class="player-link">
                             <svg viewBox="0 0 24 24">
                                 <circle cx="12" cy="12" r="10" />
@@ -183,21 +183,21 @@
                             </svg>
                             Splayer
                         </a>
-                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=dev.anilbeesetti.nextplayer;S.title={{ file_name }};end"
+                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=dev.anilbeesetti.nextplayer;S.title={{ file_name | urlencode }};end"
                             class="player-link">
                             <svg viewBox="0 0 24 24">
                                 <circle cx="12" cy="12" r="10" />
                             </svg>
                             Next Player
                         </a>
-                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=org.courville.nova;S.title={{ file_name }};end"
+                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=org.courville.nova;S.title={{ file_name | urlencode }};end"
                             class="player-link">
                             <svg viewBox="0 0 24 24">
                                 <circle cx="12" cy="12" r="10" />
                             </svg>
                             Nova Player
                         </a>
-                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=is.xyz.mpv;S.title={{ file_name }};end"
+                        <a href="intent:{{ src|safe }}#Intent;action=android.intent.action.VIEW;type=video/*;package=is.xyz.mpv;S.title={{ file_name | urlencode }};end"
                             class="player-link">
                             <svg viewBox="0 0 24 24">
                                 <circle cx="12" cy="12" r="10" />

Thunder/utils/canonical_files.py

@@ -448,8 +448,8 @@ async def get_or_create_canonical_file(
                     if stored_message:
                         try:
                             await stored_message.delete()
-                        except Exception:
-                            pass
+                        except Exception as e:
+                            logger.warning(f"Failed to delete stored message {stored_message.id} in BIN_CHANNEL: {e}", exc_info=True)
                     raise
                 except FloodWait:
                     raise