Update app.py

app.py

@@ -26,11 +26,26 @@ def human_readable_size(size):
     return f"{size:.2f} {units[index]}"
 
 def configure_session():
-    """配置libtorrent会话"""
-    settings = lt.settings_pack()
-    settings.set_str(lt.settings_pack.listen_interfaces, '0.0.0.0:6881')
-    settings.set_int(lt.settings_ppack.alert_mask, lt.alert.category_t.all_categories)
-    return lt.session(settings)
+    """兼容不同版本的会话配置"""
+    try:
+        # 新版配置方式
+        settings = lt.settings_pack()
+        settings.set_str(lt.settings_pack.listen_interfaces, '0.0.0.0:6881')
+        ses = lt.session(settings)
+    except AttributeError:
+        # 旧版配置方式
+        ses = lt.session()
+        ses.listen_on(6881, 6891)
+    return ses
+
+def parse_magnet_compat(magnet_uri):
+    """兼容不同版本的磁力解析方法"""
+    try:
+        return lt.parse_magnet_uri(magnet_uri)
+    except AttributeError:
+        # 旧版处理方式
+        params = {'save_path': '.', 'storage_mode': lt.storage_mode_t(2)}
+        return (magnet_uri, params)
 
 def download_task(magnet_uri, download_path, status):
     """后台下载任务"""
@@ -38,13 +53,16 @@ def download_task(magnet_uri, download_path, status):
         ses = configure_session()
         status.status = "解析磁力链接..."
         
-        # 创建添加参数
-        params = lt.parse_magnet_uri(magnet_uri)
-        params.save_path = download_path
-        params.storage_mode = lt.storage_mode_t.storage_mode_sparse
+        # 兼容解析磁力链接
+        try:
+            params = lt.parse_magnet_uri(magnet_uri)
+            params.save_path = download_path
+            params.storage_mode = lt.storage_mode_t.storage_mode_sparse
+            handle = ses.add_torrent(params)
+        except:
+            # 旧版处理方式
+            handle = lt.add_magnet_uri(ses, magnet_uri, {'save_path': download_path})
         
-        # 异步添加种子
-        handle = ses.add_torrent(params)
         status.status = "获取元数据..."
         
         # 等待元数据，带超时机制
@@ -54,7 +72,10 @@ def download_task(magnet_uri, download_path, status):
             if time.time() - start > timeout:
                 raise TimeoutError("获取元数据超时")
             time.sleep(0.5)
-            ses.post_torrent_updates()
+            try:
+                ses.post_torrent_updates()  # 新版状态更新
+            except:
+                pass
         
         torrent_info = handle.get_torrent_info()
         status.total_size = torrent_info.total_size()
@@ -64,7 +85,11 @@ def download_task(magnet_uri, download_path, status):
         start_time = time.time()
         last_downloaded = 0
         while not handle.is_seed():
-            ses.post_torrent_updates()
+            try:
+                ses.post_torrent_updates()  # 新版需要状态更新
+            except:
+                pass
+            
             s = handle.status()
             
             # 计算下载速度
@@ -130,13 +155,13 @@ def main():
             
             # 下载信息
             cols = st.columns(4)
-            cols[0].metric("总大小", human_readable_size(status.total_size))
+            cols[0].metric("总大小", human_readable_size(status.total_size) if status.total_size > 0 else "--")
             cols[1].metric("已下载", human_readable_size(status.downloaded_size))
-            cols[2].metric("速度", 
-                f"{status.download_rate/1024:.2f} MB/s" if status.download_rate > 1024 
-                else f"{status.download_rate:.2f} KB/s")
-            cols[3].metric("剩余时间", 
-                f"{status.remaining_time:.1f}秒" if status.remaining_time else "--")
+            speed_display = (f"{status.download_rate/1024:.2f} MB/s" if status.download_rate > 1024 
+                            else f"{status.download_rate:.2f} KB/s") if status.download_rate > 0 else "--"
+            cols[2].metric("速度", speed_display)
+            time_display = f"{status.remaining_time:.1f}秒" if status.remaining_time > 0 else "--"
+            cols[3].metric("剩余时间", time_display)
             
             st.caption(f"状态: {status.status}")