new version update

Author: Zongwei9888

cli/cli_interface.py

@@ -39,7 +39,9 @@ def __init__(self):
         self.uploaded_file = None
         self.is_running = True
         self.processing_history = []
-        self.enable_indexing = False  # Default configuration (matching UI: fast mode by default)
+        self.enable_indexing = (
+            False  # Default configuration (matching UI: fast mode by default)
+        )
 
         # Load segmentation config from the same source as UI
         self._load_segmentation_config()

cli/workflows/cli_workflow_adapter.py

@@ -102,7 +102,7 @@ async def cleanup_mcp_app(self):
     def create_cli_progress_callback(self, enable_indexing: bool = True) -> Callable:
         """
         Create CLI-optimized progress callback function with mode-aware stage mapping.
-        
+
         This matches the UI version's detailed progress mapping logic.
 
         Args:
@@ -149,7 +149,7 @@ def progress_callback(progress: int, message: str):
                         stage = 4  # Implement (skip References, Repos, Index)
                     else:
                         stage = 4  # Complete
-                
+
                 self.cli_interface.display_processing_stages(stage, enable_indexing)
 
                 # Display status message
@@ -162,7 +162,7 @@ async def execute_full_pipeline(
     ) -> Dict[str, Any]:
         """
         Execute the complete intelligent multi-agent research orchestration pipeline.
-        
+
         Updated to match UI version: default enable_indexing=False for faster processing.
 
         Args:
@@ -188,7 +188,8 @@ async def execute_full_pipeline(
                 else:
                     mode_msg = "⚡ fast (indexing disabled)"
                 self.cli_interface.print_status(
-                    f"🚀 Starting {mode_msg} agent orchestration pipeline...", "processing"
+                    f"🚀 Starting {mode_msg} agent orchestration pipeline...",
+                    "processing",
                 )
                 self.cli_interface.display_processing_stages(0, enable_indexing)
 
@@ -203,7 +204,9 @@ async def execute_full_pipeline(
             # Display completion
             if self.cli_interface:
                 final_stage = 8 if enable_indexing else 4
-                self.cli_interface.display_processing_stages(final_stage, enable_indexing)
+                self.cli_interface.display_processing_stages(
+                    final_stage, enable_indexing
+                )
                 self.cli_interface.print_status(
                     "🎉 Agent orchestration pipeline completed successfully!",
                     "complete",
@@ -226,10 +229,12 @@ async def execute_full_pipeline(
                 "pipeline_mode": "comprehensive" if enable_indexing else "optimized",
             }
 
-    async def execute_chat_pipeline(self, user_input: str, enable_indexing: bool = False) -> Dict[str, Any]:
+    async def execute_chat_pipeline(
+        self, user_input: str, enable_indexing: bool = False
+    ) -> Dict[str, Any]:
         """
         Execute the chat-based planning and implementation pipeline.
-        
+
         Updated to match UI version: accepts enable_indexing parameter.
 
         Args:
@@ -259,17 +264,20 @@ def chat_progress_callback(progress: int, message: str):
                         stage = 3  # Save Plan
                     else:
                         stage = 4  # Implement
-                    
+
                     self.cli_interface.display_processing_stages(stage, chat_mode=True)
 
                     # Display status message
                     self.cli_interface.print_status(message, "processing")
 
             # Display pipeline start
             if self.cli_interface:
-                indexing_note = " (with indexing)" if enable_indexing else " (fast mode)"
+                indexing_note = (
+                    " (with indexing)" if enable_indexing else " (fast mode)"
+                )
                 self.cli_interface.print_status(
-                    f"🚀 Starting chat-based planning pipeline{indexing_note}...", "processing"
+                    f"🚀 Starting chat-based planning pipeline{indexing_note}...",
+                    "processing",
                 )
                 self.cli_interface.display_processing_stages(0, chat_mode=True)
 
@@ -303,7 +311,7 @@ async def process_input_with_orchestration(
     ) -> Dict[str, Any]:
         """
         Process input using the intelligent agent orchestration engine.
-        
+
         This is the main CLI interface to the latest agent orchestration capabilities.
         Updated to match UI version: default enable_indexing=False.
 

mcp_agent.config.yaml

@@ -53,7 +53,7 @@ mcp:
       - .
       command: node
 
- 
+
     code-implementation:
       args:
       - tools/code_implementation_server.py

tools/pdf_downloader.py

@@ -188,15 +188,15 @@ def format_file_operation_result(
     """
     if result["success"]:
         size_mb = result["size"] / (1024 * 1024)
-        
+
         # 处理不同操作类型的动词形式
         if operation == "copy":
             operation_verb = "copied"
         elif operation == "download":
             operation_verb = "downloaded"
         else:  # move
             operation_verb = "moved"
-            
+
         msg = f"[SUCCESS] Successfully {operation_verb}: {source}\n"
 
         if operation == "download":
@@ -1180,7 +1180,7 @@ async def move_file_to(
 ) -> str:
     """
     Copy a local file to a new location (preserves original file).
-    
+
     Note: Despite the name "move_file_to", this tool COPIES the file to preserve the original.
     This prevents data loss during file processing workflows.
 

ui/components.py

@@ -368,7 +368,6 @@ def file_input_component(task_counter: int) -> Optional[str]:
         # Save uploaded file using cross-platform file handler
         try:
             import sys
-            import os
             from pathlib import Path
 
             # Add project root to path for imports
@@ -389,15 +388,17 @@ def file_input_component(task_counter: int) -> Optional[str]:
             original_file_path = file_handler.create_safe_temp_file(
                 suffix=f".{file_ext}",
                 prefix=f"upload_{uploaded_file.name.split('.')[0]}_",
-                content=uploaded_file.getvalue()
+                content=uploaded_file.getvalue(),
             )
 
             st.success("✅ File uploaded successfully!")
 
             # Check if file is already PDF
             if file_ext == "pdf":
                 st.info("📑 File is already in PDF format, no conversion needed.")
-                return str(original_file_path)  # Convert Path to string for compatibility
+                return str(
+                    original_file_path
+                )  # Convert Path to string for compatibility
 
             # Convert to PDF
             with st.spinner(f"🔄 Converting {file_ext.upper()} to PDF..."):

ui/handlers.py

@@ -583,11 +583,13 @@ def cleanup_temp_file(input_source: str, input_type: str):
     if input_type == "file" and input_source:
         try:
             from utils.cross_platform_file_handler import get_file_handler
+
             file_handler = get_file_handler()
             file_handler.safe_remove_file(input_source)
         except Exception as e:
             # Log but don't fail - cleanup is best effort
             import logging
+
             logging.getLogger(__name__).warning(
                 f"Failed to cleanup temp file {input_source}: {e}"
             )