fix upload bugs and lint

Author: Zongwei9888

CHANGELOG.md

@@ -71,4 +71,3 @@ All notable changes to DeepCode will be documented in this file.
 ## [1.0.5] - Previous Release
 
 See previous releases for earlier changes.
-

requirements.txt

@@ -10,9 +10,9 @@ fastapi>=0.104.0
 google-genai
 mcp-agent
 mcp-server-git
-openapi
 nest_asyncio
 openai
+openapi
 pathlib2
 pydantic-settings>=2.0.0
 PyPDF2>=2.0.0

tools/pdf_converter.py

@@ -20,7 +20,7 @@
 import platform
 import os
 from pathlib import Path
-from typing import Union, Optional, Dict, Any, List
+from typing import Union, Optional, Dict, Any
 
 
 class PDFConverter:
@@ -45,33 +45,37 @@ def __init__(self) -> None:
     def find_libreoffice_windows() -> Optional[str]:
         """
         Find LibreOffice installation on Windows.
-        
+
         Returns:
             Path to soffice.exe if found, None otherwise
         """
         if platform.system() != "Windows":
             return None
-            
+
         # Common LibreOffice installation paths on Windows
         possible_paths = [
             r"C:\Program Files\LibreOffice\program\soffice.exe",
             r"C:\Program Files (x86)\LibreOffice\program\soffice.exe",
         ]
-        
+
         # Also check PROGRAMFILES environment variables
         program_files = os.environ.get("PROGRAMFILES")
         program_files_x86 = os.environ.get("PROGRAMFILES(X86)")
-        
+
         if program_files:
-            possible_paths.append(os.path.join(program_files, "LibreOffice", "program", "soffice.exe"))
+            possible_paths.append(
+                os.path.join(program_files, "LibreOffice", "program", "soffice.exe")
+            )
         if program_files_x86:
-            possible_paths.append(os.path.join(program_files_x86, "LibreOffice", "program", "soffice.exe"))
-        
+            possible_paths.append(
+                os.path.join(program_files_x86, "LibreOffice", "program", "soffice.exe")
+            )
+
         # Check each path
         for path in possible_paths:
             if os.path.exists(path):
                 return path
-                
+
         return None
 
     @staticmethod
@@ -103,9 +107,10 @@ def convert_office_to_pdf(
             else:
                 # Generate unique folder name with timestamp to avoid conflicts
                 import time
+
                 timestamp = int(time.time())
                 folder_name = f"paper_{timestamp}"
-                
+
                 # Save to workspace instead of temp directory
                 workspace_base = Path(os.getcwd()) / "deepcode_lab" / "papers"
                 workspace_base.mkdir(parents=True, exist_ok=True)
@@ -199,7 +204,7 @@ def convert_office_to_pdf(
 
                 # Use the working LibreOffice command first, then try alternatives if it fails
                 commands_to_try = [working_libreoffice_cmd]
-                
+
                 # Add alternative commands based on what was found
                 if platform.system() == "Windows" and working_libreoffice_cmd:
                     # If we're using the full Windows path, also try standard commands
@@ -293,7 +298,7 @@ def convert_office_to_pdf(
                 # Copy PDF to final output directory
                 final_pdf_path = base_output_dir / f"{name_without_suff}.pdf"
                 shutil.copy2(pdf_path, final_pdf_path)
-                
+
                 print(f"✅ PDF saved to: {final_pdf_path}")
                 print(f"   File size: {final_pdf_path.stat().st_size} bytes")
                 print(f"   Parent folder: {base_output_dir}")
@@ -353,9 +358,10 @@ def convert_text_to_pdf(
             else:
                 # Generate unique folder name with timestamp to avoid conflicts
                 import time
+
                 timestamp = int(time.time())
                 folder_name = f"paper_{timestamp}"
-                
+
                 # Save to workspace instead of temp directory
                 workspace_base = Path(os.getcwd()) / "deepcode_lab" / "papers"
                 workspace_base.mkdir(parents=True, exist_ok=True)
@@ -516,7 +522,7 @@ def convert_text_to_pdf(
             print(f"✅ PDF saved to: {pdf_path}")
             print(f"   File size: {pdf_path.stat().st_size} bytes")
             print(f"   Parent folder: {base_output_dir}")
-            
+
             return pdf_path
 
         except Exception as e:
@@ -634,11 +640,19 @@ def check_dependencies(self) -> dict:
                 try:
                     subprocess.run(["libreoffice", "--version"], **subprocess_kwargs)
                     results["libreoffice"] = True
-                except (subprocess.CalledProcessError, FileNotFoundError, subprocess.TimeoutExpired):
+                except (
+                    subprocess.CalledProcessError,
+                    FileNotFoundError,
+                    subprocess.TimeoutExpired,
+                ):
                     try:
                         subprocess.run(["soffice", "--version"], **subprocess_kwargs)
                         results["libreoffice"] = True
-                    except (subprocess.CalledProcessError, FileNotFoundError, subprocess.TimeoutExpired):
+                    except (
+                        subprocess.CalledProcessError,
+                        FileNotFoundError,
+                        subprocess.TimeoutExpired,
+                    ):
                         pass
             except Exception:
                 # If any unexpected error occurs during LibreOffice check, silently pass

ui/handlers.py

@@ -20,22 +20,26 @@
 # Global abort flag
 _abort_requested = False
 
+
 def set_abort_requested(value: bool = True):
     """Set the global abort flag"""
     global _abort_requested
     _abort_requested = value
     if value:
         print("🛑 Abort requested by user")
 
+
 def is_abort_requested() -> bool:
     """Check if abort has been requested"""
     return _abort_requested
 
+
 def reset_abort_flag():
     """Reset the abort flag"""
     global _abort_requested
     _abort_requested = False
 
+
 # Import necessary modules
 from mcp_agent.app import MCPApp
 from workflows.agent_orchestration_engine import (
@@ -141,7 +145,7 @@ async def process_input_async(
             # Check for abort before starting
             if is_abort_requested():
                 return {"status": "aborted", "message": "Process aborted by user"}
-            
+
             # Choose pipeline based on input type
             if input_type == "chat":
                 # Use chat-based planning pipeline for user requirements
@@ -467,20 +471,20 @@ def handle_processing_workflow(
     # Define enhanced progress callback function
     def update_progress(progress: int, message: str, error: str = None):
         nonlocal current_step
-        
+
         # Check for abort request
         if is_abort_requested():
             st.error("🛑 Process aborted by user")
             return
 
         # Update progress bar
         progress_bar.progress(progress)
-        
+
         # Display error if present
         if error:
             st.error(f"❌ Error: {error}")
             print(f"❌ Error: {error}")
-        
+
         # Update status with timestamp
         timestamp = datetime.now().strftime("%H:%M:%S")
         status_text.markdown(f"**[{timestamp}]** {message}")
@@ -523,7 +527,7 @@ def update_progress(progress: int, message: str, error: str = None):
         # Check for abort before starting
         if is_abort_requested():
             return {"status": "aborted", "message": "Process aborted by user"}
-            
+
         try:
             # First try using simple async processing method
             result = run_async_task_simple(
@@ -536,7 +540,7 @@ def update_progress(progress: int, message: str, error: str = None):
             st.warning(error_msg)
             print(f"⚠️ {error_msg}")
             update_progress(0, "Retrying with fallback method...", error_msg)
-            
+
             # Fallback method: use original thread pool method
             try:
                 result = run_async_task(
@@ -983,7 +987,7 @@ def handle_start_processing_button(input_source: str, input_type: str):
 
         # Clean up system resources
         cleanup_resources()
-        
+
         # Reset abort flag
         reset_abort_flag()
 

utils/file_processor.py

@@ -194,14 +194,17 @@ async def read_file_content(file_path: str) -> str:
                     # Try to convert PDF to markdown automatically
                     try:
                         from tools.pdf_downloader import SimplePdfConverter
+
                         converter = SimplePdfConverter()
                         conversion_result = converter.convert_pdf_to_markdown(file_path)
-                        
+
                         if conversion_result["success"]:
                             # Use the converted markdown file instead
                             file_path = conversion_result["output_file"]
                         else:
-                            raise IOError(f"PDF conversion failed: {conversion_result['error']}")
+                            raise IOError(
+                                f"PDF conversion failed: {conversion_result['error']}"
+                            )
                     except Exception as conv_error:
                         raise IOError(
                             f"File {file_path} is a PDF file, not a text file. PDF conversion failed: {str(conv_error)}"