Lint with Clippy (#50)

* Fix pre-existing

* Run in CI

Author: ladvoc

.github/workflows/tests.yml

@@ -59,6 +59,10 @@ jobs:
           # side doesn't poison the other's incremental artifacts.
           key: rust-tests
 
+      # TODO: consider moving to separate job
+      - name: Lint
+        uses: clechasseur/rs-clippy-check@1e16925ceec49b64803a6abc5f6bbe79044c3bd4 # v6.0.4
+
       - name: cargo test --workspace
         run: cargo test --workspace --locked
 

livekit-portal/src/data.rs

@@ -282,6 +282,7 @@ impl Drop for DataPublisher {
 /// Push-callback + latest-wins slot for a single typed record (Action or
 /// State). Paired so receivers and getters share one allocation.
 pub(crate) struct DataSlot<R: Clone> {
+    #[allow(clippy::type_complexity)]
     pub cb: Mutex<Option<Box<dyn Fn(&R) + Send + Sync>>>,
     pub latest: Mutex<Option<R>>,
     /// Peer fingerprints already reported as mismatched. Logged once per

livekit-portal/src/portal.rs

@@ -3,7 +3,6 @@ use std::panic::{catch_unwind, AssertUnwindSafe};
 use std::sync::Arc;
 use std::time::Duration;
 
-use bytes::Bytes;
 use livekit::prelude::*;
 use livekit::webrtc::video_stream::native::NativeVideoStream;
 use parking_lot::Mutex;
@@ -1657,7 +1656,7 @@ fn handle_room_event(ctx: &EventContext, event: RoomEvent) {
                             // zero-copy view of the wire payload all the
                             // way to `VideoFrameData.data`.
                             Ok(payload) => dispatch_frame_payload(
-                                Bytes::from(payload),
+                                payload,
                                 &entries,
                                 &sync_buffer,
                                 &obs_sink,