RPC implementation + FFI (#461)

* Add types * gen proto * callback * wip * wip * proto * error * wip * Builds and passes * close * string * string * Fixes * more fixes * initial example * wip * compiling * almost * close * somewhat working * working sample * cleanup * ffi building * delegate method * ffi * Fixes * remove dead code * Logging * fixes * fix * fix * logging * comment out' * handle * room handle * Revert "room handle" This reverts commit c62dc0e. * handle * cb * cleanup example * cleanup debug logs * cleanup other logs * remove some logging * SimplifyW * errors * fixes * fixes * fmt * waiter * 10k * sender->caller * update example * perform_rpc_request->perform_rpc * move methods to participant * fmt * cleanup * ms * opt * panics * fmt * remove conn * use webrtc uuid * Move waiter * refactor for readability * Simplify * uui * flat * fmt * fix? * fmt * unused imports * start time * better * fix * store rpc state in one spot * macro * opts * rusty * simplify * rm * fmt * remove initial wait * Revert "Merge remote-tracking branch 'origin/main' into bcherry/rpc-full" This reverts commit 961f3b6, reversing changes made to 73106cf. * fix * v * fix pb2 * proto * commit * p * 123 * p * stats * wip * wip * wip * import * add min version check * remove empty callbacks * fixes * rm * 1 * fmt * jr * fmt
livekit · Oct 24, 2024 · 2aa9500 · 2aa9500
1 parent 21149a4
commit 2aa9500
Show file tree

Hide file tree

Showing 26 changed files with 1,441 additions and 65 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/examples/Cargo.lock b/examples/Cargo.lock
diff --git a/examples/Cargo.toml b/examples/Cargo.toml
@@ -6,4 +6,5 @@ members = [
     "wgpu_room",
     "webhooks",
     "api",
+    "rpc",
 ]
diff --git a/examples/basic_room/src/main.rs b/examples/basic_room/src/main.rs
@@ -24,9 +24,7 @@ async fn main() {
         .to_jwt()
         .unwrap();
 
-    let (room, mut rx) = Room::connect(&url, &token, RoomOptions::default())
-        .await
-        .unwrap();
+    let (room, mut rx) = Room::connect(&url, &token, RoomOptions::default()).await.unwrap();
     log::info!("Connected to room: {} - {}", room.name(), String::from(room.sid().await));
 
     room.local_participant()

diff --git a/examples/rpc/Cargo.toml b/examples/rpc/Cargo.toml
@@ -0,0 +1,13 @@
+[package]
+name = "rpc_example"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+tokio = { version = "1", features = ["full"] }
+env_logger = "0.10"
+livekit = { path = "../../livekit", features = ["native-tls"]}
+livekit-api = { path = "../../livekit-api"}
+log = "0.4"
+rand = "0.8"
+serde_json = "1.0"
-Original file line number
+Diff line change
@@ Expand Up / @@ -6,4 +6,5 @@ members = [ @@
         "wgpu_room",
         "webhooks",
         "api",
+        "rpc",
     ]