Implement FFI bindings

Author: ladvoc

livekit-ffi/src/server/participant.rs

@@ -177,6 +177,26 @@ impl FfiParticipant {
         Ok(proto::StreamSendTextResponse { async_id })
     }
 
+    pub fn send_bytes(
+        &self,
+        server: &'static FfiServer,
+        request: proto::StreamSendBytesRequest,
+    ) -> FfiResult<proto::StreamSendBytesResponse> {
+        let async_id = server.next_id();
+        let local = self.guard_local_participant()?;
+
+        let handle = server.async_runtime.spawn(async move {
+            let result = match local.send_bytes(&request.bytes, request.options.into()).await {
+                Ok(info) => proto::stream_send_bytes_callback::Result::Info(info.into()),
+                Err(err) => proto::stream_send_bytes_callback::Result::Error(err.into()),
+            };
+            let callback = proto::StreamSendBytesCallback { async_id, result: Some(result) };
+            let _ = server.send_event(proto::ffi_event::Message::SendBytes(callback));
+        });
+        server.watch_panic(handle);
+        Ok(proto::StreamSendBytesResponse { async_id })
+    }
+
     pub fn stream_bytes(
         &self,
         server: &'static FfiServer,

livekit-ffi/src/server/requests.rs

@@ -1100,6 +1100,15 @@ fn on_send_file(
     ffi_participant.send_file(server, request)
 }
 
+fn on_send_bytes(
+    server: &'static FfiServer,
+    request: proto::StreamSendBytesRequest,
+) -> FfiResult<proto::StreamSendBytesResponse> {
+    let ffi_participant =
+        server.retrieve_handle::<FfiParticipant>(request.local_participant_handle)?.clone();
+    ffi_participant.send_bytes(server, request)
+}
+
 fn on_send_text(
     server: &'static FfiServer,
     request: proto::StreamSendTextRequest,
@@ -1383,6 +1392,9 @@ pub fn handle_request(
         proto::ffi_request::Message::SendFile(request) => {
             proto::ffi_response::Message::SendFile(on_send_file(server, request)?)
         }
+        proto::ffi_request::Message::SendBytes(request) => {
+            proto::ffi_response::Message::SendBytes(on_send_bytes(server, request)?)
+        }
         proto::ffi_request::Message::SendText(request) => {
             proto::ffi_response::Message::SendText(on_send_text(server, request)?)
         }