corsa 0.3.1

Production-oriented Rust bindings, orchestration layers, and Node integration for typescript-go
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

//! Top-level facade crate for the `corsa` workspace.
//!
//! This crate re-exports the building blocks used to talk to `typescript-go`
//! over stdio:
//!
//! - [`api`] for the tsgo API bindings
//! - [`jsonrpc`] for stdio JSON-RPC framing and transport
//! - [`lsp`] for LSP clients and virtual-document overlays
//! - [`orchestrator`] for local orchestration plus optional experimental
//!   distributed helpers
//! - [`observability`] for structured runtime events
//! - [`runtime`] for the lightweight in-house executor
//! - [`utils`] for shared type-text and checker-adjacent helpers
//!
//! # Examples
//!
//! ```
//! use corsa::{
//!     jsonrpc::RequestId,
//!     lsp::{VirtualChange, VirtualDocument},
//!     runtime::block_on,
//! };
//!
//! let mut document = VirtualDocument::untitled("/demo.ts", "typescript", "const value = 1;")?;
//! document.apply_changes(&[VirtualChange::replace("const value = 2;")])?;
//! assert_eq!(document.text, "const value = 2;");
//!
//! let request_id = RequestId::integer(7);
//! assert_eq!(request_id.to_string(), "7");
//!
//! let value = block_on(async { 21 * 2 });
//! assert_eq!(value, 42);
//! # Ok::<(), corsa::CorsaError>(())
//! ```

/// Re-exports the tsgo stdio API bindings.
pub mod api {
    pub use corsa_client::*;
}

/// Re-exports shared error types.
pub mod error {
    pub use corsa_core::{Result, RpcResponseError, TsgoError, TsgoError as CorsaError};
}

/// Re-exports performance-oriented building blocks such as `CompactString`.
pub mod fast {
    pub use corsa_core::fast::*;
}

/// Re-exports JSON-RPC transport primitives.
pub mod jsonrpc {
    pub use corsa_jsonrpc::*;
}

/// Re-exports LSP clients, overlays, and virtual document helpers.
pub mod lsp {
    pub use corsa_lsp::*;
}

/// Re-exports structured operational events used across the workspace.
pub mod observability {
    pub use corsa_core::{
        SharedObserver, TsgoEvent, TsgoEvent as CorsaEvent, TsgoObserver,
        TsgoObserver as CorsaObserver,
    };
}

/// Re-exports client orchestration and replicated-state helpers.
pub mod orchestrator {
    pub use corsa_orchestrator::{ApiOrchestrator, ApiOrchestratorConfig, ApiOrchestratorStats};
    #[cfg(feature = "experimental-distributed")]
    pub use corsa_orchestrator::{
        DistributedApiOrchestrator, RaftCluster, RaftRole, ReplicatedCacheEntry, ReplicatedCommand,
        ReplicatedSnapshot, ReplicatedState,
    };
}

/// Re-exports process spawning primitives.
pub mod process {
    pub use corsa_core::{AsyncChildGuard, TsgoCommand, TsgoCommand as CorsaCommand};
}

/// Re-exports the lightweight in-house runtime.
pub mod runtime {
    pub use corsa_runtime::*;
}

/// Re-exports shared pure utility helpers.
pub mod utils {
    pub use corsa_core::utils::*;
}

pub use corsa_core::{
    Result, SharedObserver, TsgoError, TsgoError as CorsaError, TsgoEvent, TsgoEvent as CorsaEvent,
    TsgoObserver, TsgoObserver as CorsaObserver,
};