feat: port slimrpc code to rust lang

data-plane/Cargo.toml

@@ -15,6 +15,7 @@ members = [
     "examples",
     "python/bindings",
     "slimrpc-compiler",
+    "slimrpc-examples/rust",
     "testing",
 ]
 
@@ -52,6 +53,7 @@ agntcy-slim-tracing = { path = "core/tracing", version = "0.2.7" }
 
 anyhow = "1.0.98"
 
+async-stream = "0.3"
 async-trait = "0.1.88"
 aws-lc-rs = "1.13"
 base64 = "0.22"

data-plane/bindings/rust/Cargo.toml

@@ -22,6 +22,8 @@ agntcy-slim-signal = { workspace = true }
 agntcy-slim-tracing = { workspace = true }
 
 # External dependencies
+async-stream = { workspace = true }
+async-trait = { workspace = true }
 display-error-chain = { workspace = true }
 futures = { workspace = true }
 futures-timer = { workspace = true }
@@ -30,6 +32,7 @@ serde = { workspace = true }
 serde_json = { workspace = true }
 thiserror = { workspace = true }
 tokio = { workspace = true }
+tokio-stream = { workspace = true }
 tracing = { workspace = true }
 uniffi = { version = "0.28.3", features = ["cli"] }
 

data-plane/bindings/rust/src/app.rs

@@ -443,6 +443,19 @@ impl App {
     }
 }
 
+// Non-UniFFI methods for internal use (slimrpc)
+impl App {
+    /// Get reference to internal app for advanced use cases (slimrpc)
+    pub fn inner_app(&self) -> &Arc<SlimApp<AuthProvider, AuthVerifier>> {
+        &self.app
+    }
+
+    /// Get notification receiver for server use (slimrpc)
+    pub fn notification_receiver(&self) -> Arc<RwLock<mpsc::Receiver<Result<Notification, SlimSessionError>>>> {
+        self.notification_rx.clone()
+    }
+}
+
 // ============================================================================
 // Internal methods for PyO3 bindings (not exported through UniFFI)
 // ============================================================================

data-plane/bindings/rust/src/lib.rs

@@ -59,6 +59,8 @@ mod server_config;
 mod service;
 mod session;
 
+pub mod slimrpc;
+
 // Public re-exports
 pub use app::{App, SessionWithCompletion};
 pub use build_info::{BuildInfo, get_build_info, get_version};
@@ -97,5 +99,13 @@ pub use service::{
 };
 pub use session::{Session, SessionConfig, SessionType};
 
+// SLIMRpc re-exports
+pub use slimrpc::{
+    RpcAppConnection, RpcChannel, RpcMessageContext, RpcHandlerType,
+    SRPCError, RpcServer, SessionContext as RpcSessionContext, RpcAppConfig,
+    create_and_connect_app, create_and_connect_app_async, new_rpc_app_config,
+    DEADLINE_KEY, MAX_TIMEOUT,
+};
+
 // UniFFI scaffolding setup (must be at crate root)
 uniffi::setup_scaffolding!();