lspz 0.11.7

AI-friendly LSP compression proxy
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//! 传输层抽象。
//!
//! 定义所有传输层必须实现的 I/O trait。
//!
//! ## 可用的传输层
//!
//! | Transport | 协议 | Feature Flag | 状态 |
//! |-----------|----------|-------------|--------|
//! | [`stdio::StdioTransport`] | 子进程 stdio | 始终 | ✅ |
//! | [`tcp::TcpTransport`] | TCP 套接字 | 始终 | ✅ |
//! | [`websocket::WsTransport`] | WebSocket | `transport-websocket` | ✅ |
//! | [`mock::MockTransport`] | 内存 FIFO | 始终（测试） | ✅ |
//!
//! ## Architecture（架构）
//!
//! Content-Length framed transports: stdio, TCP, WebSocket, and in-memory mock.

pub(crate) mod framing;
pub mod mock;
pub mod stdio;
pub mod tcp;

/// 此模块仅在启用 `transport-websocket` 功能时可用。
#[cfg(feature = "transport-websocket")]
pub mod websocket;

use std::process::ExitStatus;

use crate::error::LspzError;

/// LSP 通信的抽象 I/O 通道。
///
/// 所有 LSP 消息 I/O（无论传输协议如何）都由此 trait 定义。
/// 实现内部处理 Content-Length 分帧，并暴露原始的分帧字节。
#[async_trait::async_trait]
pub trait Transport: Send + Sync {
    /// 接收一条原始 LSP 消息（Content-Length 分帧）。
    async fn receive(&mut self) -> Result<Vec<u8>, LspzError>;

    /// 向 LSP 服务器/客户端发送原始字节。
    async fn send(&mut self, data: &[u8]) -> Result<(), LspzError>;

    /// 检查底层进程是否已退出。
    ///
    /// 对于非进程传输层（mock、TCP、WebSocket），默认返回 `Ok(None)`。
    fn try_wait(&mut self) -> Result<Option<ExitStatus>, LspzError> {
        Ok(None)
    }

    /// Downcast to `Any` for testing inspection.
    fn as_any_mut(&mut self) -> Option<&mut dyn std::any::Any> {
        None
    }
}