Fix UI freeze and integrate unified logging with LogCategory

1. Reduced API timeouts to prevent UI freeze:
   - chat_completion: 60s → 30s
   - stream: 60s → 30s
   - embedding: 30s → 20s
   - Separate timeout exception handling

2. Integrated copilot with unified logging system:
   - Added LogCategory.API for API requests
   - Added LogCategory.CONFIG for configuration
   - Added LogCategory.IO for file operations
   - Added LogCategory.ERROR for error tracking
   - Added LogCategory.UI for UI operations
   - Added debug() calls for detailed tracing

3. Enhanced logging in all copilot modules:
   - siliconflow_client.py: API request/response logging
   - copilot_manager.py: Operation lifecycle logging
   - agent_mode.py: Task execution logging
   - copilot_panel.py: UI interaction logging

The QThread architecture already separates API calls from main process, preventing blocking. Reduced timeouts prevent long hangs that appear as freezes.

Co-authored-by: HeDaas-Code <208586641+HeDaas-Code@users.noreply.github.com>

Author: Copilot

src/components/copilot_panel.py

@@ -13,7 +13,7 @@
 from PyQt5.QtGui import QTextCursor
 from qfluentwidgets import (PushButton, LineEdit, ComboBox, TextEdit, 
                            SubtitleLabel, BodyLabel)
-from src.utils.logger import info, warning, error
+from src.utils.logger import info, warning, error, debug, LogCategory
 from src.copilot.agent_mode import AgentTask
 from datetime import datetime
 
@@ -329,7 +329,7 @@ def _show_audit_dialog(self, task_id: str):
             # Signal parent to handle audit with error handling
             parent = self.parent()
             if parent is None or not hasattr(parent, "audit_task") or not callable(getattr(parent, "audit_task")):
-                warning(f"CopilotPanel parent has no 'audit_task' method; cannot audit task {task_id}")
+                warning(f"CopilotPanel parent has no 'audit_task' method; cannot audit task {task_id}", category=LogCategory.UI)
                 QMessageBox.warning(
                     self,
                     "审计失败",
@@ -339,7 +339,7 @@ def _show_audit_dialog(self, task_id: str):
             try:
                 parent.audit_task(task_id, approved, comment)
             except Exception as e:
-                error(f"Error while auditing task {task_id}: {e}")
+                error(f"Error while auditing task {task_id}: {e}", category=LogCategory.ERROR)
                 QMessageBox.critical(
                     self,
                     "审计错误",

src/copilot/agent_mode.py

@@ -11,7 +11,7 @@
 import json
 import os
 from .siliconflow_client import SiliconFlowClient
-from src.utils.logger import info, warning, error
+from src.utils.logger import info, warning, error, debug, LogCategory
 from src.utils.git_manager import GitManager
 
 
@@ -80,7 +80,7 @@ def create_task(self, description: str, task_type: str) -> str:
         task_id = f"task_{self.task_counter}_{datetime.now().strftime('%Y%m%d%H%M%S')}"
         task = AgentTask(task_id, description, task_type)
         self.tasks[task_id] = task
-        info(f"Created agent task: {task_id}")
+        info(f"Created agent task: {task_id}", category=LogCategory.API)
         return task_id
 
     def execute_task(self, task_id: str, context: Dict = None):
@@ -280,12 +280,12 @@ def audit_task(self, task_id: str, approved: bool, comment: str = ""):
 
         if approved:
             task.status = 'approved'
-            info(f"Task {task_id} approved")
+            info(f"Task {task_id} approved", category=LogCategory.API)
             # Apply changes if needed
             self._apply_task_changes(task)
         else:
             task.status = 'rejected'
-            warning(f"Task {task_id} rejected: {comment}")
+            warning(f"Task {task_id} rejected: {comment}", category=LogCategory.API)
 
         self.status_changed.emit(f"Task {'approved' if approved else 'rejected'}")
 
@@ -314,9 +314,9 @@ def _apply_task_changes(self, task: AgentTask):
                 with open(file_path, 'w', encoding='utf-8') as f:
                     f.write(content)
 
-                info(f"Applied changes to {file_path} for task {task.task_id}")
+                info(f"Applied changes to {file_path} for task {task.task_id}", category=LogCategory.IO)
             except Exception as e:
-                error(f"Failed to apply changes for task {task.task_id}: {str(e)}")
+                error(f"Failed to apply changes for task {task.task_id}: {str(e)}", category=LogCategory.ERROR)
         elif task.task_type == 'commit':
             # Commit was already made during execution
             pass

src/copilot/copilot_manager.py

@@ -8,7 +8,7 @@
 from typing import Dict, List, Optional, Callable
 from PyQt5.QtCore import QObject, pyqtSignal, QThread, Qt
 from .siliconflow_client import SiliconFlowClient
-from src.utils.logger import info, warning, error
+from src.utils.logger import info, warning, error, debug, LogCategory
 from src.utils.config_manager import ConfigManager
 
 # Configuration constants
@@ -51,16 +51,16 @@ def _load_config(self):
 
             if api_key:
                 self.client = SiliconFlowClient(api_key, model)
-                info("Copilot client initialized")
+                info("Copilot client initialized", category=LogCategory.API)
             else:
-                warning("Copilot API key not configured")
+                warning("Copilot API key not configured", category=LogCategory.CONFIG)
         except Exception as e:
-            error(f"Failed to load copilot config: {str(e)}")
+            error(f"Failed to load copilot config: {str(e)}", category=LogCategory.CONFIG)
 
     def reload_config(self):
         """Public method to reload copilot configuration"""
         self._load_config()
-        info("Copilot configuration reloaded")
+        info("Copilot configuration reloaded", category=LogCategory.CONFIG)
 
     def set_api_key(self, api_key: str, model: str = None):
         """
@@ -79,7 +79,7 @@ def set_api_key(self, api_key: str, model: str = None):
         self.client = SiliconFlowClient(api_key, model)
         self.enabled = True
         self.config_manager.set_plugin_setting('copilot', 'enabled', True)
-        info("Copilot API key updated")
+        info("Copilot API key updated", category=LogCategory.CONFIG)
 
     def is_enabled(self) -> bool:
         """Check if copilot is enabled"""
@@ -89,7 +89,7 @@ def set_enabled(self, enabled: bool):
         """Enable or disable copilot"""
         self.enabled = enabled
         self.config_manager.set_plugin_setting('copilot', 'enabled', enabled)
-        info(f"Copilot {'enabled' if enabled else 'disabled'}")
+        info(f"Copilot {'enabled' if enabled else 'disabled'}", category=LogCategory.CONFIG)
 
     def get_inline_completion(
         self, 
@@ -106,11 +106,12 @@ def get_inline_completion(
             callback: Optional callback function for completion
         """
         if not self.is_enabled():
-            warning("Copilot is not enabled")
+            warning("Copilot is not enabled", category=LogCategory.API)
             return
 
         self.current_mode = 'inline'
         self.status_changed.emit("Generating completion...")
+        debug("Starting inline completion request", category=LogCategory.API)
 
         # Create completion thread
         thread = CompletionThread(
@@ -228,6 +229,7 @@ def _on_completion_ready(self, completion: str):
         self.completion_ready.emit(completion)
         self.status_changed.emit("Completion ready")
         self.current_mode = 'none'
+        info(f"Completion ready, length: {len(completion)}", category=LogCategory.API)
 
     def _on_edit_ready(self, edited_text: str):
         """Handle edit ready"""
@@ -251,7 +253,7 @@ def _on_error(self, error_msg: str):
         self.error_occurred.emit(error_msg)
         self.status_changed.emit("Error occurred")
         self.current_mode = 'none'
-        error(f"Copilot error: {error_msg}")
+        error(f"Copilot error: {error_msg}", category=LogCategory.API)
 
     def _cleanup_thread(self, thread: QThread):
         """Remove finished thread from active threads list"""

src/copilot/siliconflow_client.py

@@ -8,7 +8,7 @@
 import requests
 import json
 from typing import List, Dict, Optional, Generator
-from src.utils.logger import info, warning, error
+from src.utils.logger import info, warning, error, debug, LogCategory
 
 class SiliconFlowClient:
     """Client for SiliconFlow API"""
@@ -36,6 +36,7 @@ def __init__(self, api_key: str, model: str = None):
             'Authorization': f'Bearer {api_key}',
             'Content-Type': 'application/json'
         }
+        info(f"SiliconFlow client initialized with model: {self.model}", category=LogCategory.API)
 
     def chat_completion(
         self, 
@@ -58,7 +59,7 @@ def chat_completion(
         """
         # Validate temperature
         if not 0 <= temperature <= 2:
-            warning(f"Temperature {temperature} out of range [0, 2], clamping")
+            warning(f"Temperature {temperature} out of range [0, 2], clamping", category=LogCategory.API)
             temperature = max(0, min(2, temperature))
 
         url = f"{self.BASE_URL}/chat/completions"
@@ -70,15 +71,23 @@ def chat_completion(
             'stream': stream
         }
 
+        debug(f"Sending API request to {url} with {len(messages)} messages", category=LogCategory.API)
+        
         try:
             if stream:
                 return self._stream_chat_completion(url, data)
             else:
-                response = requests.post(url, headers=self.headers, json=data, timeout=60)
+                # Use shorter timeout to prevent UI freeze
+                response = requests.post(url, headers=self.headers, json=data, timeout=30)
                 response.raise_for_status()
-                return response.json()
+                result = response.json()
+                info(f"API request successful, response size: {len(str(result))} chars", category=LogCategory.API)
+                return result
+        except requests.exceptions.Timeout as e:
+            error(f"SiliconFlow API timeout after 30s: {str(e)}", category=LogCategory.API)
+            raise
         except requests.exceptions.RequestException as e:
-            error(f"SiliconFlow API error: {str(e)}")
+            error(f"SiliconFlow API error: {str(e)}", category=LogCategory.API)
             raise
 
     def _stream_chat_completion(self, url: str, data: Dict) -> Generator:
@@ -92,13 +101,14 @@ def _stream_chat_completion(self, url: str, data: Dict) -> Generator:
         Yields:
             Chunks of response text
         """
+        debug("Starting streaming API request", category=LogCategory.API)
         try:
             response = requests.post(
                 url, 
                 headers=self.headers, 
                 json=data, 
                 stream=True,
-                timeout=60
+                timeout=30
             )
             response.raise_for_status()
 
@@ -108,6 +118,7 @@ def _stream_chat_completion(self, url: str, data: Dict) -> Generator:
                     if line.startswith('data: '):
                         data_str = line[6:]
                         if data_str.strip() == '[DONE]':
+                            info("Streaming completed", category=LogCategory.API)
                             break
                         try:
                             chunk = json.loads(data_str)
@@ -117,8 +128,11 @@ def _stream_chat_completion(self, url: str, data: Dict) -> Generator:
                                     yield delta['content']
                         except json.JSONDecodeError:
                             continue
+        except requests.exceptions.Timeout as e:
+            error(f"SiliconFlow streaming timeout after 30s: {str(e)}", category=LogCategory.API)
+            raise
         except requests.exceptions.RequestException as e:
-            error(f"SiliconFlow streaming error: {str(e)}")
+            error(f"SiliconFlow streaming error: {str(e)}", category=LogCategory.API)
             raise
 
     def text_completion(
@@ -177,16 +191,23 @@ def get_embedding(self, text: str) -> List[float]:
             'input': text
         }
 
+        debug(f"Requesting embedding for text length: {len(text)}", category=LogCategory.API)
+        
         try:
-            response = requests.post(url, headers=self.headers, json=data, timeout=30)
+            response = requests.post(url, headers=self.headers, json=data, timeout=20)
             response.raise_for_status()
             result = response.json()
 
             if 'data' in result and len(result['data']) > 0:
-                return result['data'][0]['embedding']
+                embedding = result['data'][0]['embedding']
+                info(f"Embedding received, dimension: {len(embedding)}", category=LogCategory.API)
+                return embedding
             return []
+        except requests.exceptions.Timeout as e:
+            error(f"SiliconFlow embedding timeout after 20s: {str(e)}", category=LogCategory.API)
+            raise
         except requests.exceptions.RequestException as e:
-            error(f"SiliconFlow embedding error: {str(e)}")
+            error(f"SiliconFlow embedding error: {str(e)}", category=LogCategory.API)
             raise
 
     def test_connection(self) -> bool:
@@ -196,10 +217,12 @@ def test_connection(self) -> bool:
         Returns:
             True if connection successful, False otherwise
         """
+        debug("Testing API connection", category=LogCategory.API)
         try:
             messages = [{'role': 'user', 'content': 'Hello'}]
             self.chat_completion(messages, max_tokens=10)
+            info("API connection test successful", category=LogCategory.API)
             return True
         except Exception as e:
-            error(f"Connection test failed: {str(e)}")
+            error(f"Connection test failed: {str(e)}", category=LogCategory.API)
             return False