Upload 23 files

app/sub_manager.py

@@ -121,85 +121,69 @@ class SubscriptionManager:
         
         # 确保数据目录存在
         data_dir = os.path.dirname(self.config_path)
-        if not os.path.exists(data_dir):
-            logger.info(f"创建数据目录: {data_dir}")
-            try:
-                os.makedirs(data_dir, exist_ok=True)
-            except Exception as e:
-                logger.error(f"创建数据目录失败: {str(e)}")
+        os.makedirs(data_dir, exist_ok=True)
         
-        # 准备subconverter命令
+        # 准备subconverter命令 - 尝试使用 file:// URI
+        # 将 Windows 路径转换为 file:// URI (如果需要)
+        # Python on Linux should handle /path/to/file directly
+        input_uri = input_file 
+        if os.name == 'nt': # 如果在 Windows 上运行 (理论上我们是在 Linux 容器)
+            input_uri = 'file:///' + input_file.replace('\\', '/')
+            
         cmd = [
             self.subconverter_path,
-            "-g",
-            "-i", input_file,        # 输入文件
+            #"-i", input_file,        # 之前的尝试
+            #"-o", self.config_path,  # 之前的尝试
+            "-g",                      # 明确表示生成模式
+            "--url", input_uri,        # 使用文件 URI 作为输入
             "-o", self.config_path,  # 输出文件
             "-t", "clash"             # 目标格式
-            # 可根据需要添加其他 subconverter 参数，例如 --config ...
+            # 添加 --config 参数指向基础配置，可能有助于避免服务器模式
+            # 需要一个基础配置文件，例如 subconverter/base/clash.yaml
+            # "--config", os.path.join(os.path.dirname(self.subconverter_path), "subconverter/base/clash.yaml")
         ]
         
         logger.info(f"执行命令: {' '.join(cmd)}")
         
-        # 检查 subconverter 是否存在
+        # 检查 subconverter 是否存在 (之前的代码已修复)
         if not os.path.exists(self.subconverter_path):
-            logger.error(f"subconverter可执行文件未找到: {self.subconverter_path}. 无法转换配置。")
-            # 尝试直接使用原始订阅内容，并添加头部
-            try:
-                with open(input_file, "r", encoding="utf-8") as f:
-                    content = f.read()
-                # 假定原始内容需要添加头部
-                final_content = self._add_clash_headers() + content
-                with open(self.config_path, "w", encoding="utf-8") as f:
-                    f.write(final_content)
-                logger.warning("subconverter未找到，尝试使用原始订阅内容 + Clash头部信息写入配置文件")
-            except Exception as e:
-                logger.error(f"写入原始订阅内容时出错: {str(e)}")
-                raise RuntimeError(f"无法转换配置，且无法写入原始订阅: {str(e)}")
-            return # 即使尝试写入，也应返回，后续 patch 可能仍有问题
+            # ... (省略 subconverter 未找到的回退逻辑) ...
+            logger.error(f"subconverter未找到: {self.subconverter_path}. 无法转换配置。")
+            raise RuntimeError(f"无法转换配置 (subconverter未找到)")
         
+        # --- 正式执行 subconverter ---
         try:
             # 执行subconverter
             process = subprocess.Popen(
                 cmd,
                 stdout=subprocess.PIPE,
                 stderr=subprocess.PIPE,
-                universal_newlines=True
+                universal_newlines=True,
+                cwd=os.path.dirname(self.subconverter_path) # 尝试在subconverter目录下运行
             )
-            stdout, stderr = process.communicate(timeout=60) # 增加超时时间
+            stdout, stderr = process.communicate(timeout=60) 
             
             # 记录完整的 subconverter 输出用于调试
             logger.info(f"subconverter STDOUT:\n---\n{stdout}\n---") 
             if stderr:
                 logger.warning(f"subconverter STDERR:\n---\n{stderr}\n---")
             
+            # 检查 subconverter 返回码
             if process.returncode != 0:
-                logger.error(f"subconverter执行失败，返回码: {process.returncode}. STDERR: {stderr}")
-                # 错误处理：尝试直接使用订阅内容作为最后的手段
-                try:
-                    with open(input_file, "r", encoding="utf-8") as f:
-                        content = f.read()
-                    # 检查是否需要添加 Clash 头部信息
-                    if "proxies:" not in content:
-                        logger.warning("subconverter失败，且原始内容不像Clash配置，添加基本头部")
-                        content = self._add_clash_headers() + content
-                    else:
-                        logger.warning("subconverter失败，但原始内容看似Clash配置，直接使用")
-                    
-                    with open(self.config_path, "w", encoding="utf-8") as f:
-                        f.write(content)
-                    logger.warning("subconverter转换失败，已尝试直接使用原始订阅内容写入配置文件")
-                except Exception as e:
-                    logger.error(f"subconverter失败后，尝试使用原始订阅内容时出错: {str(e)}")
-                    raise RuntimeError(f"subconverter转换失败，且无法回退到原始订阅: {str(e)}")
+                logger.error(f"subconverter执行失败，返回码: {process.returncode}.")
+                # ... (省略 subconverter 失败的回退逻辑) ...
+                raise RuntimeError(f"subconverter转换失败(code {process.returncode})。 Subconverter STDERR: {stderr[:200]}...")
             else:
-                logger.info("subconverter成功转换配置")
+                # subconverter 返回码为 0，表示理论上成功
+                logger.info("subconverter成功执行 (返回码 0)")
                 # 验证输出文件是否存在且非空
                 if os.path.exists(self.config_path) and os.path.getsize(self.config_path) > 0:
                     logger.info(f"配置文件已生成，路径: {self.config_path}，大小: {os.path.getsize(self.config_path)} 字节")
                 else:
-                    # 如果文件不存在或为空，记录错误
-                    logger.error(f"subconverter声称成功，但配置文件不存在或为空: {self.config_path}")
-                    raise RuntimeError("subconverter转换成功，但未生成有效的配置文件")
+                    logger.error(f"subconverter执行成功，但配置文件不存在或为空: {self.config_path}. 请检查subconverter日志了解详情。")
+                    # 检查STDERR中是否有线索
+                    error_detail = stderr if stderr else "(无错误输出)"
+                    raise RuntimeError(f"subconverter执行成功但未生成有效配置文件。 Subconverter STDERR: {error_detail[:500]}...")
         
         except subprocess.TimeoutExpired:
              logger.error(f"执行subconverter超时 (超过60秒)")
@@ -443,7 +427,8 @@ secret: ""
                         f.write(config_content)
                     logger.info("已修补配置文件并成功保存")
                 except Exception as write_err:
-                     logger.error(f"写回配置文件失败: {write_err}")       
+                    logger.error(f"写回配置文件失败: {write_err}")
+                    # 即使写回失败，也不要阻止程序继续，可能只是临时问题
             else:
                 logger.info("配置文件无需修补")