绝尘
25d65652cd
- WsTunnelClient: connect_async连df-relay /ws/device + Hello(HelloKind::Device) - 握手探测(HANDSHAKE_PROBE 3s):无负帧=relay静默通过 / error帧=Auth失败 / Close=Connect失败 - 收发循环: socket入帧→parse_command_from_broadcast提payload(kind=command)→on_command回调; mpsc出帧→socket写; heartbeat 25s Ping - cleanup_conn: Close帧+500ms等task+abort兜底; connected用Arc<AtomicBool>共享 - backoff_delay(1→2→4→8→16→30s cap)预留Phase3 supervisor自动重连 - 协议对齐 df-relay(Hello字段/方向Event↔Command/payload透传),cargo check零warning+4测试通过
27 lines
992 B
Rust
27 lines
992 B
Rust
//! # df-tunnel
|
|
//!
|
|
//! 本地 DevFlow 桌面端出站 WS 隧道客户端(设计文档 Layer1)。
|
|
//!
|
|
//! ## 职责
|
|
//! - 主动连接云后端 df-relay(出站穿 NAT,无需端口映射)
|
|
//! - 事件桥接:桌面端 ai-chat-event 透传至云后端 → 小程序
|
|
//! - 指令路由:接收小程序远程操作 → 调对应 Tauri command
|
|
//!
|
|
//! ## 边界
|
|
//! - 不依赖 src-tauri(TunnelEvent/TunnelCommand 独立定义,避免跨 crate path 引用二进制)
|
|
//! - 不含业务逻辑(Phase2 填充 WS 握手/鉴权/重连/路由)
|
|
//!
|
|
//! ## 模块
|
|
//! - [`events`]:隧道透传事件/指令/消息包装类型
|
|
//! - [`tunnel`]:TunnelClient trait + WsTunnelClient 骨架
|
|
//! - [`error`]:TunnelError 错误类型
|
|
|
|
pub mod error;
|
|
pub mod events;
|
|
pub mod tunnel;
|
|
|
|
// 顶层再导出常用项,简化调用方 use
|
|
pub use error::{Result, TunnelError};
|
|
pub use events::{Hello, HelloKind, RelayControlError, TunnelCommand, TunnelEvent, TunnelMessage};
|
|
pub use tunnel::{TunnelClient, WsTunnelClient};
|