添加dlcapt补充capture网关捕获功能

.github/workflows/dlcapt.yml

@@ -0,0 +1,47 @@
+name: dlcapt
+
+on:
+  push:
+    paths:
+      - "crates/persisting-dlcapt/**"
+      - "crates/persisting-cli/**"
+      - "Cargo.toml"
+      - "Cargo.lock"
+      - ".github/workflows/dlcapt.yml"
+  pull_request:
+    paths:
+      - "crates/persisting-dlcapt/**"
+      - "crates/persisting-cli/**"
+      - "Cargo.toml"
+      - "Cargo.lock"
+      - ".github/workflows/dlcapt.yml"
+
+jobs:
+  check:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+        with:
+          components: rustfmt, clippy
+      - name: Install protoc
+        run: sudo apt-get update && sudo apt-get install -y protobuf-compiler
+      - uses: Swatinem/rust-cache@v2
+      - name: fmt
+        run: cargo fmt --check
+      - name: check
+        run: cargo check -p persisting-dlcapt --all-targets --all-features --locked
+      - name: test
+        run: cargo test -p persisting-dlcapt --all-targets --all-features --locked
+      - name: clippy
+        run: cargo clippy -p persisting-dlcapt --all-targets --all-features --locked -- -D warnings
+      - name: doc
+        run: RUSTDOCFLAGS="-D warnings" cargo doc -p persisting-dlcapt --all-features --no-deps --locked
+      - name: build standalone dlcapt
+        run: cargo build -p persisting-dlcapt --locked
+      - name: test persisting-cli dlcapt feature
+        run: |
+          metadata="$(cargo metadata --no-deps --format-version 1 --locked)"
+          target_directory="$(jq -r '.target_directory' <<<"${metadata}")"
+          DLCAPT_BIN="${target_directory}/debug/dlcapt" \
+            cargo test -p persisting-cli --features dlcapt --locked

.gitignore

@@ -7,3 +7,10 @@ __pycache__/
 .venv/
 *.abi3.so
 crates/persisting-engine/ds/
+
+# persisting-dlcapt runtime / release artifacts
+crates/persisting-dlcapt/var/
+crates/persisting-dlcapt/.capture/
+crates/persisting-dlcapt/tmp/
+.build-tmp/
+target/dlcapt/

Cargo.toml

@@ -6,6 +6,7 @@ members = [
     "crates/persisting-core",
     "crates/persisting-capture",
     "crates/persisting-cli",
+    "crates/persisting-dlcapt",
 ]
 
 [workspace.package]

NOTICE

@@ -0,0 +1,13 @@
+persisting-dlcapt
+=================
+
+This workspace includes `persisting-dlcapt`, migrated from
+`capture/external/dlcapt` (source tree copy of first-party Rust sources).
+
+Target package: persisting-dlcapt
+License: Apache-2.0 (workspace policy)
+Third-party source files copied verbatim outside Cargo crates.io
+dependencies: none identified at migration time.
+
+If additional vendored sources or incompatible licenses are discovered,
+stop publication and obtain explicit clearance before release.

crates/persisting-cli/Cargo.toml

@@ -10,6 +10,10 @@ description = "Lightweight Persisting CLI (loads persisting-engine via dlopen)"
 name = "persisting"
 path = "src/main.rs"
 
+[features]
+default = []
+dlcapt = ["dep:persisting-dlcapt"]
+
 [dependencies]
 anyhow = "1"
 chrono = "0.4"
@@ -18,6 +22,7 @@ clap = { version = "4", features = ["derive", "env"] }
 dirs = "6"
 libloading = "0.8"
 persisting-capture = { path = "../persisting-capture" }
+persisting-dlcapt = { path = "../persisting-dlcapt", optional = true }
 persisting-engine = { path = "../persisting-engine" }
 persisting-proto = { path = "../persisting-proto" }
 ron = "0.8"
@@ -29,3 +34,11 @@ termimad = "0.34"
 toml = "0.8"
 tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["env-filter"] }
+
+[dev-dependencies]
+tempfile = "3"
+
+[[test]]
+name = "dlcapt_backend_e2e"
+path = "tests/dlcapt_backend_e2e.rs"
+required-features = ["dlcapt"]

crates/persisting-cli/src/judge_manual.rs

@@ -332,7 +332,9 @@ mod tests {
     fn fixed_manual_scores_story_scope() {
         use persisting_capture::config::CaptureLevel;
         use persisting_capture::engine::Call;
-        use persisting_capture::sink::{llm_request_summary_record, llm_response_record_with_content};
+        use persisting_capture::sink::{
+            llm_request_summary_record, llm_response_record_with_content,
+        };
 
         let call = Call {
             call_id: "c1".into(),
@@ -368,9 +370,15 @@ mod tests {
             serde_json::to_string(&resp).unwrap(),
         ];
         let story = story_from_replay_json(&records, "s", "s").unwrap();
-        let scores =
-            fixed_manual_scores(&story, JudgeScope::Story, &["default".into()], 100, None, None)
-                .unwrap();
+        let scores = fixed_manual_scores(
+            &story,
+            JudgeScope::Story,
+            &["default".into()],
+            100,
+            None,
+            None,
+        )
+        .unwrap();
         assert_eq!(scores.len(), 1);
         assert_eq!(scores[0].score, 100);
         assert_eq!(scores[0].verdict, "pass");
@@ -381,7 +389,9 @@ mod tests {
     fn fixed_manual_scores_rejects_out_of_range() {
         use persisting_capture::config::CaptureLevel;
         use persisting_capture::engine::Call;
-        use persisting_capture::sink::{llm_request_summary_record, llm_response_record_with_content};
+        use persisting_capture::sink::{
+            llm_request_summary_record, llm_response_record_with_content,
+        };
 
         let call = Call {
             call_id: "c1".into(),
@@ -417,6 +427,14 @@ mod tests {
             serde_json::to_string(&resp).unwrap(),
         ];
         let story = story_from_replay_json(&records, "s", "s").unwrap();
-        assert!(fixed_manual_scores(&story, JudgeScope::Story, &["default".into()], 101, None, None).is_err());
+        assert!(fixed_manual_scores(
+            &story,
+            JudgeScope::Story,
+            &["default".into()],
+            101,
+            None,
+            None
+        )
+        .is_err());
     }
 }