MCP Email Service

# AccountManager 实例化问题分析报告 ## 问题根本原因 当优化分支（如 `search_emails`、`fetch_all_providers_optimized` 等）在内部重新实例化 `AccountManager()` 时，会导致以下问题： 1. **配置漂移**：如果外层服务（`EmailService`）在内存中动态添加了账户配置，而没有持久化到磁盘 2. **不一致性**：新创建的 `AccountManager` 实例只能读取磁盘上的配置文件，看不到内存中的动态配置 3. **错误提示**：优化路径可能抛出 "No email accounts configured"，而标准路径却能正常工作 **已修复的文件**： - ✅ `src/operations/optimized_search.py` - 已接受可选的 `account_manager` 参数 - ✅ `src/services/email_service.py` (Line 538) - 已在调用 `search_all_accounts_parallel` 时传递 `account_manager` ## 类似问题清单 ### 🔴 高优先级（核心功能，需立即修复） #### 1. `src/operations/optimized_fetch.py` (Line 155) **问题**： ```python def fetch_all_providers_optimized(limit: int = 50, unread_only: bool = True, use_cache: bool = True): # ... account_manager = AccountManager() # 问题：重新创建实例 accounts = account_manager.list_accounts() ``` **影响**： - 被 `EmailService.list_emails()` 调用（Line 110） - 用于优化的邮件列表获取，是核心功能 - 未传递 `account_manager` 参数 **修复方案**： ```python def fetch_all_providers_optimized( limit: int = 50, unread_only: bool = True, use_cache: bool = True, account_manager = None # 新增参数 ): if account_manager is None: account_manager = AccountManager() accounts = account_manager.list_accounts() # ... ``` 同时修改 `EmailService` 调用处： ```python # src/services/email_service.py Line 110 result = fetch_all_providers_optimized( limit, unread_only, account_manager=self.account_manager # 传递实例 ) ``` --- #### 2. `src/operations/parallel_operations.py` (Line 27) **问题**： ```python class ParallelOperations: def __init__(self, max_workers: int = 5): self.max_workers = max_workers self._lock = threading.Lock() self.account_manager = AccountManager() # 问题：固定创建新实例 ``` **影响**： - 用于批量删除、标记邮件等操作 - 通过全局实例 `parallel_ops` 使用（Line 438） - `EmailService._execute_with_parallel_fallback()` 会调用它 **修复方案**： ```python class ParallelOperations: def __init__(self, max_workers: int = 5, account_manager=None): self.max_workers = max_workers self._lock = threading.Lock() self.account_manager = account_manager or AccountManager() ``` 需要在服务层创建实例时传递 `account_manager`，或修改全局实例创建方式。 --- #### 3. `src/operations/email_sync.py` (Line 25) **问题**： ```python class EmailSyncManager: def __init__(self, db_path: str = None, config: Dict[str, Any] = None): self.account_manager = AccountManager() # 问题：固定创建新实例 self.db = EmailSyncDatabase(db_path) # ... ``` **影响**： - 邮件同步模块的核心类 - 如果账户是动态注入的，同步任务可能找不到账户 - 被 MCP 工具的同步功能使用 **修复方案**： ```python class EmailSyncManager: def __init__(self, db_path: str = None, config: Dict[str, Any] = None, account_manager=None): self.account_manager = account_manager or AccountManager() self.db = EmailSyncDatabase(db_path) # ... ``` --- ### 🟡 中优先级（辅助功能，建议修复） #### 4. `src/operations/fast_fetch.py` (Line 88) **问题**： ```python def fast_fetch_all_accounts(limit: int = 50, unread_only: bool = True) -> Dict[str, Any]: # ... account_manager = AccountManager() # 问题：重新创建实例 accounts = account_manager.list_accounts() ``` **影响**： - 快速获取邮件的辅助功能 - 使用缓存机制提升性能 - 不在主要代码路径中 **修复方案**： ```python def fast_fetch_all_accounts(limit: int = 50, unread_only: bool = True, account_manager=None) -> Dict[str, Any]: if account_manager is None: account_manager = AccountManager() accounts = account_manager.list_accounts() # ... ``` --- #### 5. `src/operations/multi_folder_fetch.py` (Line 36) **问题**： ```python class MultiFolderFetcher: def __init__(self, max_workers: int = 5): self.max_workers = max_workers self._lock = threading.Lock() self.account_manager = AccountManager() # 问题：固定创建新实例 ``` **影响**： - 多文件夹获取功能（如垃圾邮件、已删除等） - 通过全局实例 `multi_folder_fetcher` 使用 - 不是核心路径 **修复方案**： ```python class MultiFolderFetcher: def __init__(self, max_workers: int = 5, account_manager=None): self.max_workers = max_workers self._lock = threading.Lock() self.account_manager = account_manager or AccountManager() ``` --- #### 6. `src/operations/parallel_search.py` (Line 28) **问题**： ```python class ParallelSearchOperations: def __init__(self, max_workers: int = 5): self.max_workers = max_workers self._lock = threading.Lock() self.account_manager = AccountManager() # 问题：固定创建新实例 ``` **影响**： - 并行搜索操作（老版本，可能已被 `optimized_search` 替代） - 通过全局实例 `parallel_search` 使用 - 低使用频率 **修复方案**： ```python class ParallelSearchOperations: def __init__(self, max_workers: int = 5, account_manager=None): self.max_workers = max_workers self._lock = threading.Lock() self.account_manager = account_manager or AccountManager() ``` --- ### 🟢 低优先级（测试/脚本，暂不修复） 以下文件在测试或独立脚本中创建 `AccountManager()`，这些是合理的用法，不需要修复： - ✅ `src/legacy_operations.py` (Line 21) - 模块级别的全局实例，合理 - ✅ `src/mcp_tools.py` (Line 48) - MCP 服务器主入口，合理 - ✅ `clients/mailbox_client/client.py` (Line 26) - 独立客户端，合理 - ✅ `scripts/*` - 独立脚本，合理 - ✅ `tests/*` - 测试代码，合理 - ✅ `src/database_integration.py` (Line 18) - 独立工具类，可能需要审查 - ✅ `src/operations/folder_scan.py` (Line 20) - 独立扫描工具，可能需要审查 --- ## 推荐的修复策略 ### 阶段 1：立即修复（核心功能） 1. ✅ `optimized_search.py` - 已修复 2. 🔴 `optimized_fetch.py` + `EmailService` 调用处 3. 🔴 `parallel_operations.py` 4. 🔴 `email_sync.py` ### 阶段 2：后续优化（辅助功能） 5. 🟡 `fast_fetch.py` 6. 🟡 `multi_folder_fetch.py` 7. 🟡 `parallel_search.py` ### 阶段 3：架构改进（长期） 考虑引入依赖注入容器或服务定位器模式，统一管理 `AccountManager` 实例的生命周期。 --- ## 验证方法 修复后，使用以下测试场景验证： ```python # 测试场景：动态添加账户（不持久化） account_manager = AccountManager() account_manager.add_account({ "id": "test-temp", "email": "temp@example.com", "password": "test", "imap_server": "imap.example.com", "provider": "custom" }, persist=False) # 仅在内存中 # 测试1：list_emails 应该能看到该账户 email_service = EmailService(account_manager) result = email_service.list_emails(unread_only=True) # 期望：不会报 "No email accounts configured" # 测试2：search_emails 应该能搜索该账户 result = email_service.search_emails(query="test") # 期望：不会报 "No email accounts configured" ``` --- ## 编译检查 ```bash python3 -m compileall src/operations/optimized_fetch.py src/services/email_service.py src/operations/parallel_operations.py src/operations/email_sync.py ``` --- **报告生成时间**：2025-10-24 **分析文件数量**：19 个 **发现问题数量**：6 个高/中优先级问题 **已修复**：1 个（optimized_search.py） **待修复**：5 个