Bcn bridge gateway

scripts/engine-tee.sh

@@ -0,0 +1,40 @@
+#!/usr/bin/env bash
+# engine-tee.sh — cfuse 引擎采集包装器(开发调试用,不进生产)
+#
+# bridge 配置里的 cfuse_bin 指向本脚本。本脚本把三方数据全部落盘后再转给
+# 真正的引擎(REAL_ENGINE 指定,mock fixture 或真 cfuse),逐行无缓冲透传:
+#
+#   bridge→引擎 stdin   $ENGINE_LOG_DIR/engine.stdin.jsonl   (bridge 写给引擎的行)
+#   引擎→bridge stdout  $ENGINE_LOG_DIR/engine.stdout.ndjson (cfuse 原始事件,一行一个)
+#   引擎 stderr         $ENGINE_LOG_DIR/engine.stderr.log
+#   每次引擎启动        $ENGINE_LOG_DIR/runs.log             (时间/pid/args)
+#
+# 用法(bind 会通过环境变量自带):
+#   REAL_ENGINE=/path/to/mock_cc.sh ENGINE_LOG_DIR=/tmp/bridge-dev \
+#     ./scripts/engine-tee.sh --cc --output-format stream-json ...
+set -o pipefail
+
+DIR="${ENGINE_LOG_DIR:-/tmp/bridge-dev}"
+REAL="${REAL_ENGINE:?REAL_ENGINE not set — point it at the engine binary/script}"
+mkdir -p "$DIR"
+
+printf '[%s] engine pid=%s args=%s\n' "$(date '+%F %T')" "$$" "$*" >> "$DIR/runs.log"
+
+tee -a "$DIR/engine.stdin.jsonl" \
+  | python3 -c '
+import fcntl
+import os
+import sys
+
+for size in (1024 * 1024, 64 * 1024, 16 * 1024, 8 * 1024):
+    try:
+        actual = fcntl.fcntl(1, fcntl.F_SETPIPE_SZ, size)
+    except (AttributeError, OSError):
+        continue
+    if actual >= 8 * 1024:
+        break
+
+os.execvp(sys.argv[1], sys.argv[1:])
+' "$REAL" "$@" 2> >(tee -a "$DIR/engine.stderr.log" >&2) \
+  | tee -a "$DIR/engine.stdout.ndjson"
+exit $?

src/bcs/Cargo.toml

@@ -7,6 +7,7 @@ members = [
     "crates/adapters/http/bcs-http",
     "crates/adapters/http/bcs-provider-http",
     "crates/adapters/ws/bcs-ws",
+    "crates/adapters/bridge-provider",
     # service-api
     "crates/service-api/bcs-config-api",
     "crates/service-api/bcs-service-api",
@@ -124,6 +125,7 @@ version      = "0.1.0"
 # Async runtime
 tokio = { version = "1", features = ["full"] }
 tokio-util = { version = "0.7", features = ["rt"] }
+tokio-stream = "0.1"
 tokio-tungstenite = { version = "0.26", features = ["native-tls"] }
 
 # HTTP server

src/bcs/crates/adapters/bridge-provider/Cargo.toml

@@ -0,0 +1,33 @@
+[package]
+name        = "bridge-provider"
+description = "BCN Provider 2.0 bridge to local coding engines (cfuse cc/codex)"
+version.workspace      = true
+edition.workspace      = true
+license.workspace      = true
+repository.workspace   = true
+rust-version.workspace = true
+
+[lints]
+workspace = true
+
+[dependencies]
+anyhow        = { workspace = true }
+async-trait   = { workspace = true }
+axum          = { workspace = true }
+bcs-protocol  = { workspace = true }
+libc          = "0.2"
+futures       = { workspace = true }
+serde         = { workspace = true }
+serde_json    = { workspace = true }
+thiserror     = { workspace = true }
+tokio         = { workspace = true }
+tokio-stream  = { workspace = true }
+tokio-util    = { workspace = true }
+toml          = { workspace = true }
+tracing            = { workspace = true }
+tracing-subscriber = { workspace = true, features = ["env-filter"] }
+uuid          = { workspace = true }
+
+[dev-dependencies]
+reqwest  = { workspace = true }
+tempfile = { workspace = true }

src/bcs/crates/adapters/bridge-provider/src/config.rs

@@ -0,0 +1,98 @@
+use std::{net::SocketAddr, path::{Path, PathBuf}};
+use serde::Deserialize;
+
+#[derive(Debug, Clone, Copy, PartialEq, Eq, Deserialize)]
+#[serde(rename_all = "kebab-case")]
+pub enum EngineKind { CfuseCc, CfuseCodex }
+
+#[derive(Debug, Clone, Deserialize)]
+pub struct BotConfig {
+    pub provider_bot_ref: String,
+    pub engine: EngineKind,
+    pub model: Option<String>,
+    pub cwd: PathBuf,
+    pub permission_mode: Option<String>,
+    pub cfuse_bin: Option<PathBuf>,
+}
+
+#[derive(Debug, Clone, Deserialize)]
+pub struct ProviderConfig {
+    pub provider_id: String,
+    pub listen: SocketAddr,
+    pub bcs_to_provider_token: String,
+    pub bot_runtime_token: Option<String>,
+    #[serde(default)]
+    pub trace_dir: Option<PathBuf>,
+    #[serde(rename = "bot")]
+    pub bots: Vec<BotConfig>,
+}
+
+#[derive(Debug, thiserror::Error)]
+pub enum ConfigError {
+    #[error("read config: {0}")]
+    Read(#[from] std::io::Error),
+    #[error("parse config: {0}")]
+    Parse(#[from] toml::de::Error),
+}
+
+impl ProviderConfig {
+    pub fn load(path: &Path) -> Result<Self, ConfigError> {
+        let text = std::fs::read_to_string(path)?;
+        Ok(toml::from_str(&text)?)
+    }
+    pub fn bot(&self, provider_bot_ref: &str) -> Option<&BotConfig> {
+        self.bots.iter().find(|b| b.provider_bot_ref == provider_bot_ref)
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn loads_provider_config_and_finds_bot() {
+        let dir = tempfile::tempdir().unwrap();
+        let path = dir.path().join("bridge.toml");
+        std::fs::write(
+            &path,
+            r#"
+provider_id = "bridge-1"
+listen = "127.0.0.1:21100"
+bcs_to_provider_token = "tok-b2p"
+
+[[bot]]
+provider_bot_ref = "cc-worker"
+engine = "cfuse-cc"
+model = "sonnet"
+cwd = "/tmp"
+"#,
+        )
+        .unwrap();
+        let cfg = ProviderConfig::load(&path).unwrap();
+        assert_eq!(cfg.provider_id, "bridge-1");
+        let bot = cfg.bot("cc-worker").unwrap();
+        assert_eq!(bot.engine, EngineKind::CfuseCc);
+        assert_eq!(bot.model.as_deref(), Some("sonnet"));
+        assert!(cfg.bot("nope").is_none());
+    }
+
+    #[test]
+    fn rejects_unknown_engine_kind() {
+        let dir = tempfile::tempdir().unwrap();
+        let path = dir.path().join("bridge.toml");
+        std::fs::write(
+            &path,
+            r#"
+provider_id = "bridge-1"
+listen = "127.0.0.1:21100"
+bcs_to_provider_token = "t"
+[[bot]]
+provider_bot_ref = "x"
+engine = "bogus"
+cwd = "/tmp"
+"#,
+        )
+        .unwrap();
+        assert!(ProviderConfig::load(&path).is_err());
+    }
+}