fix(ci): resolve clippy and sdk version drift

Author: RoyLin

check-version.sh

@@ -1,6 +1,11 @@
 #!/bin/bash
 # Check version alignment across all SDK files
 
+set -euo pipefail
+
+SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
+cd "$SCRIPT_DIR"
+
 echo "=========================================="
 echo "Version Alignment Check"
 echo "=========================================="
@@ -10,20 +15,23 @@ echo ""
 CORE_VERSION=$(grep '^version = ' core/Cargo.toml | head -1 | sed 's/version = "\(.*\)"/\1/')
 NODE_CARGO_VERSION=$(grep '^version = ' sdk/node/Cargo.toml | head -1 | sed 's/version = "\(.*\)"/\1/')
 NODE_PKG_VERSION=$(grep '"version":' sdk/node/package.json | sed 's/.*"version": "\(.*\)".*/\1/')
+NODE_LOCK_VERSION=$(node -p "require('./sdk/node/package-lock.json').packages[''].version")
 PYTHON_CARGO_VERSION=$(grep '^version = ' sdk/python/Cargo.toml | head -1 | sed 's/version = "\(.*\)"/\1/')
 PYTHON_PYPROJECT_VERSION=$(grep '^version = ' sdk/python/pyproject.toml | head -1 | sed 's/version = "\(.*\)"/\1/')
 
 echo "Current versions:"
 echo "  core/Cargo.toml:           ${CORE_VERSION}"
 echo "  sdk/node/Cargo.toml:       ${NODE_CARGO_VERSION}"
 echo "  sdk/node/package.json:     ${NODE_PKG_VERSION}"
+echo "  sdk/node/package-lock:     ${NODE_LOCK_VERSION}"
 echo "  sdk/python/Cargo.toml:     ${PYTHON_CARGO_VERSION}"
 echo "  sdk/python/pyproject.toml: ${PYTHON_PYPROJECT_VERSION}"
 echo ""
 
 # Check alignment
 if [ "$CORE_VERSION" = "$NODE_CARGO_VERSION" ] && \
    [ "$CORE_VERSION" = "$NODE_PKG_VERSION" ] && \
+   [ "$CORE_VERSION" = "$NODE_LOCK_VERSION" ] && \
    [ "$CORE_VERSION" = "$PYTHON_CARGO_VERSION" ] && \
    [ "$CORE_VERSION" = "$PYTHON_PYPROJECT_VERSION" ]; then
     echo "✅ All versions aligned: ${CORE_VERSION}"
@@ -35,6 +43,7 @@ else
     echo "Mismatches:"
     [ "$CORE_VERSION" != "$NODE_CARGO_VERSION" ] && echo "  - sdk/node/Cargo.toml: ${NODE_CARGO_VERSION}"
     [ "$CORE_VERSION" != "$NODE_PKG_VERSION" ] && echo "  - sdk/node/package.json: ${NODE_PKG_VERSION}"
+    [ "$CORE_VERSION" != "$NODE_LOCK_VERSION" ] && echo "  - sdk/node/package-lock.json: ${NODE_LOCK_VERSION}"
     [ "$CORE_VERSION" != "$PYTHON_CARGO_VERSION" ] && echo "  - sdk/python/Cargo.toml: ${PYTHON_CARGO_VERSION}"
     [ "$CORE_VERSION" != "$PYTHON_PYPROJECT_VERSION" ] && echo "  - sdk/python/pyproject.toml: ${PYTHON_PYPROJECT_VERSION}"
     exit 1

core/src/default_parser.rs

@@ -23,6 +23,7 @@ pub trait DefaultParserOcrProvider: Send + Sync {
     ) -> Result<Option<String>>;
 }
 
+#[derive(Default)]
 pub struct DefaultParser {
     config: crate::config::DefaultParserConfig,
     ocr_provider: Option<Arc<dyn DefaultParserOcrProvider>>,
@@ -59,15 +60,6 @@ impl DefaultParser {
     }
 }
 
-impl Default for DefaultParser {
-    fn default() -> Self {
-        Self {
-            config: crate::config::DefaultParserConfig::default(),
-            ocr_provider: None,
-        }
-    }
-}
-
 impl crate::document_parser::DocumentParser for DefaultParser {
     fn name(&self) -> &str {
         "default-parser"

core/src/document_parser.rs

@@ -55,7 +55,7 @@ pub enum DocumentBlockKind {
     Raw,
 }
 
-#[derive(Debug, Clone, PartialEq, Eq)]
+#[derive(Debug, Clone, Default, PartialEq, Eq)]
 pub struct DocumentBlockLocation {
     pub source: Option<String>,
     pub page: Option<usize>,
@@ -106,16 +106,6 @@ impl DocumentBlock {
     }
 }
 
-impl Default for DocumentBlockLocation {
-    fn default() -> Self {
-        Self {
-            source: None,
-            page: None,
-            ordinal: None,
-        }
-    }
-}
-
 #[derive(Debug, Clone, Default, PartialEq, Eq)]
 pub struct ParsedDocument {
     pub title: Option<String>,

core/src/orchestrator/agent.rs

@@ -175,16 +175,16 @@ impl AgentOrchestrator {
         let task_handle = tokio::spawn(async move { wrapper.execute().await });
 
         // 创建句柄
-        let handle = SubAgentHandle::new(
-            id.clone(),
+        let handle = SubAgentHandle::new(crate::orchestrator::handle::SubAgentHandleParts {
+            id: id.clone(),
             config,
             control_tx,
             subagent_event_tx,
             event_history,
-            state.clone(),
-            activity.clone(),
+            state: state.clone(),
+            activity: activity.clone(),
             task_handle,
-        );
+        });
 
         // 注册到 orchestrator
         self.subagents

core/src/orchestrator/handle.rs

@@ -43,31 +43,33 @@ pub struct SubAgentHandle {
     task_handle: Arc<tokio::task::JoinHandle<Result<String>>>,
 }
 
+pub(crate) struct SubAgentHandleParts {
+    pub id: String,
+    pub config: SubAgentConfig,
+    pub control_tx: tokio::sync::mpsc::Sender<ControlSignal>,
+    pub subagent_event_tx: tokio::sync::broadcast::Sender<OrchestratorEvent>,
+    pub event_history: Arc<RwLock<std::collections::VecDeque<OrchestratorEvent>>>,
+    pub state: Arc<RwLock<SubAgentState>>,
+    pub activity: Arc<RwLock<SubAgentActivity>>,
+    pub task_handle: tokio::task::JoinHandle<Result<String>>,
+}
+
 impl SubAgentHandle {
     /// 创建新的句柄
-    pub(crate) fn new(
-        id: String,
-        config: SubAgentConfig,
-        control_tx: tokio::sync::mpsc::Sender<ControlSignal>,
-        subagent_event_tx: tokio::sync::broadcast::Sender<OrchestratorEvent>,
-        event_history: Arc<RwLock<std::collections::VecDeque<OrchestratorEvent>>>,
-        state: Arc<RwLock<SubAgentState>>,
-        activity: Arc<RwLock<SubAgentActivity>>,
-        task_handle: tokio::task::JoinHandle<Result<String>>,
-    ) -> Self {
+    pub(crate) fn new(parts: SubAgentHandleParts) -> Self {
         Self {
-            id,
-            config,
+            id: parts.id,
+            config: parts.config,
             created_at: std::time::SystemTime::now()
                 .duration_since(std::time::UNIX_EPOCH)
                 .unwrap()
                 .as_millis() as u64,
-            control_tx,
-            subagent_event_tx,
-            event_history,
-            state,
-            activity,
-            task_handle: Arc::new(task_handle),
+            control_tx: parts.control_tx,
+            subagent_event_tx: parts.subagent_event_tx,
+            event_history: parts.event_history,
+            state: parts.state,
+            activity: parts.activity,
+            task_handle: Arc::new(parts.task_handle),
         }
     }
 

core/src/tools/builtin/agentic_parse.rs

@@ -295,7 +295,7 @@ fn render_document_for_llm(
                 section.push_str(&format!(" ({})", label));
             }
         }
-        section.push_str("\n");
+        section.push('\n');
         if let Some(location) = &block.location {
             let location = block_location_label(location);
             if !location.is_empty() {