Upload 24 files

app/sub_manager.py

@@ -128,50 +128,33 @@ class SubscriptionManager:
             except Exception as e:
                 logger.error(f"创建数据目录失败: {str(e)}")
         
-        # 尝试直接读取订阅内容，确认它是否已经是Clash配置
-        try:
-            with open(input_file, "r", encoding="utf-8") as f:
-                content = f.read()
-            
-            # 简单检查是否已经是Clash配置
-            if "proxies:" in content and ("port:" in content or "mixed-port:" in content):
-                logger.info("检测到输入文件已是Clash配置格式，直接使用")
-                with open(self.config_path, "w", encoding="utf-8") as f:
-                    f.write(content)
-                return
-        except Exception as e:
-            logger.warning(f"读取输入文件时出错: {str(e)}，将尝试转换")
-        
         # 准备subconverter命令
         cmd = [
             self.subconverter_path,
-            "-g",  # 生成配置文件
-            "--target", "clash",  # 输出格式为Clash (修正为 --target)
-            "--url", input_file,  # 修正为 --url 参数
-            "--output", self.config_path,  # 输出文件
-            "--include-remarks", ".*"  # 包含所有节点
+            "-i", input_file,        # 输入文件
+            "-o", self.config_path,  # 输出文件
+            "-t", "clash"             # 目标格式
+            # 可根据需要添加其他 subconverter 参数，例如 --config ...
         ]
         
         logger.info(f"执行命令: {' '.join(cmd)}")
         
-        # 如果subconverter不存在或执行出错，我们就尝试直接使用订阅内容
+        # 检查 subconverter 是否存在
         if not os.path.exists(self.subconverter_path):
-            logger.warning("subconverter不存在，尝试直接使用订阅内容")
+            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(content)
-                logger.info(f"已将订阅内容直接写入到: {self.config_path}")
-                # 验证文件是否成功写入
-                if os.path.exists(self.config_path):
-                    logger.info(f"文件已成功写入，大小: {os.path.getsize(self.config_path)} 字节")
-                else:
-                    logger.error(f"文件写入失败，{self.config_path} 不存在")
+                    f.write(final_content)
+                logger.warning("subconverter未找到，尝试使用原始订阅内容 + Clash头部信息写入配置文件")
             except Exception as e:
-                logger.error(f"直接使用订阅内容时出错: {str(e)}")
-                raise RuntimeError(f"写入配置文件失败: {str(e)}")
-            return
+                logger.error(f"写入原始订阅内容时出错: {str(e)}")
+                raise RuntimeError(f"无法转换配置，且无法写入原始订阅: {str(e)}")
+            return # 即使尝试写入，也应返回，后续 patch 可能仍有问题
         
         try:
             # 执行subconverter
@@ -181,71 +164,46 @@ class SubscriptionManager:
                 stderr=subprocess.PIPE,
                 universal_newlines=True
             )
-            stdout, stderr = process.communicate(timeout=30)
+            stdout, stderr = process.communicate(timeout=60) # 增加超时时间
             
-            logger.info(f"subconverter输出: {stdout[:200]}...") # 限制日志长度
+            logger.info(f"subconverter STDOUT: {stdout[:500]}...") # 记录更多输出
+            if stderr:
+                logger.warning(f"subconverter STDERR: {stderr[:500]}...")
             
             if process.returncode != 0:
-                logger.error(f"subconverter执行失败: {stderr}")
-                # 错误处理：尝试直接使用订阅内容
+                logger.error(f"subconverter执行失败，返回码: {process.returncode}. STDERR: {stderr}")
+                # 错误处理：尝试直接使用订阅内容作为最后的手段
                 try:
                     with open(input_file, "r", encoding="utf-8") as f:
                         content = f.read()
-                    
-                    # 确保它是有效的配置，如果是普通订阅格式，添加基本的Clash头
+                    # 检查是否需要添加 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("尝试直接使用订阅内容作为配置文件")
-                    # 验证文件是否成功写入
-                    if os.path.exists(self.config_path):
-                        logger.info(f"文件已成功写入，大小: {os.path.getsize(self.config_path)} 字节")
-                    else:
-                        logger.error(f"文件写入失败，{self.config_path} 不存在")
+                    logger.warning("subconverter转换失败，已尝试直接使用原始订阅内容写入配置文件")
                 except Exception as e:
-                    logger.error(f"使用订阅内容作为配置文件时出错: {str(e)}")
-                    raise RuntimeError(f"写入配置文件失败: {str(e)}")
+                    logger.error(f"subconverter失败后，尝试使用原始订阅内容时出错: {str(e)}")
+                    raise RuntimeError(f"subconverter转换失败，且无法回退到原始订阅: {str(e)}")
             else:
-                logger.info("成功转换配置")
-                # 验证输出文件是否存在
-                if os.path.exists(self.config_path):
+                logger.info("subconverter成功转换配置")
+                # 验证输出文件是否存在且非空
+                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:
-                    # 如果文件不存在但subconverter返回成功，尝试查找配置文件
-                    logger.warning(f"subconverter声称成功但配置文件不存在: {self.config_path}")
-                    # 查找当前目录下可能生成的配置文件
-                    possible_files = [f for f in os.listdir('.') if f.endswith('.yaml') or f.endswith('.yml')]
-                    if possible_files:
-                        logger.info(f"找到可能的配置文件: {possible_files}")
-                        # 尝试复制找到的第一个文件
-                        try:
-                            import shutil
-                            shutil.copy(possible_files[0], self.config_path)
-                            logger.info(f"已复制 {possible_files[0]} 到 {self.config_path}")
-                        except Exception as e:
-                            logger.error(f"复制文件失败: {str(e)}")
-                    else:
-                        logger.error("未找到任何可能的配置文件")
-                        # 尝试使用原始订阅内容作为配置
-                        try:
-                            with open(input_file, "r", encoding="utf-8") as f:
-                                content = f.read()
-                            
-                            # 确保它是有效的配置，如果是普通订阅格式，添加基本的Clash头
-                            if "proxies:" not in content:
-                                content = self._add_clash_headers() + content
-                                
-                            with open(self.config_path, "w", encoding="utf-8") as f:
-                                f.write(content)
-                            logger.warning("使用订阅内容作为配置文件")
-                        except Exception as e:
-                            logger.error(f"使用订阅内容时出错: {str(e)}")
-                            raise RuntimeError(f"写入配置文件失败: {str(e)}")
+                    # 如果文件不存在或为空，记录错误
+                    logger.error(f"subconverter声称成功，但配置文件不存在或为空: {self.config_path}")
+                    raise RuntimeError("subconverter转换成功，但未生成有效的配置文件")
         
+        except subprocess.TimeoutExpired:
+             logger.error(f"执行subconverter超时 (超过60秒)")
+             raise RuntimeError("subconverter执行超时")
         except (subprocess.SubprocessError, OSError) as e:
-            logger.error(f"执行subconverter时出错: {str(e)}")
+            logger.error(f"执行subconverter时发生错误: {str(e)}")
             raise RuntimeError(f"配置转换失败: {str(e)}")
     
     def _add_clash_headers(self):
@@ -332,13 +290,14 @@ secret: ""
                     if not proxies_list or not isinstance(proxies_list, list):
                         logger.error("配置文件缺少有效的 'proxies' 列表或列表为空！将仅使用 DIRECT 代理。请检查原始订阅内容。")
                         # 设置一个最小化的 proxies 和 proxy-groups
-                        config_yaml["proxies"] = [{"name": "DIRECT", "type": "direct"}]
+                        # 不要在 proxies 中显式定义 DIRECT，Clash 内置了它
+                        config_yaml["proxies"] = []
                         config_yaml["proxy-groups"] = [{
                             "name": "GLOBAL",
                             "type": "select",
-                            "proxies": ["DIRECT"]
+                            "proxies": ["DIRECT"] # 直接引用内置的 DIRECT
                         }]
-                        proxy_names = {"DIRECT", "REJECT"}
+                        proxy_names = {"DIRECT", "REJECT"} # 仍然需要知道内置名称
                         groups_fixed = True # 标记需要重新生成配置内容
                         has_patch = True
                     else: