lint: clippy

Author: yuki-uchida

moqt-ingest-gateway/src/rtmp/connection.rs

@@ -12,7 +12,7 @@ use tokio::{
 
 use super::{
     handshake::perform_handshake,
-    session::{handle_event, RtmpState},
+    session::{RtmpState, handle_event},
 };
 use crate::moqt::MoqtManager;
 
@@ -63,14 +63,7 @@ async fn handle_connection(mut socket: TcpStream, label: &str, moqt: MoqtManager
             break;
         }
 
-        handle_session_bytes(
-            &mut session,
-            &mut socket,
-            &buf[..read],
-            label,
-            &mut state,
-        )
-        .await?;
+        handle_session_bytes(&mut session, &mut socket, &buf[..read], label, &mut state).await?;
     }
 
     Ok(())

moqt-ingest-gateway/src/rtmp/handshake.rs

@@ -1,4 +1,4 @@
-use anyhow::{anyhow, Result};
+use anyhow::{Result, anyhow};
 use rml_rtmp::handshake::{Handshake, HandshakeProcessResult, PeerType};
 use tokio::{
     io::{AsyncReadExt, AsyncWriteExt},

moqt-ingest-gateway/src/rtmp/session.rs

@@ -200,22 +200,29 @@ pub async fn handle_event(
                         .unwrap_or_default()
                         .as_millis() as u64;
                     let codec_key = (namespace_path.clone(), track_name.clone());
-                    let already_sent = state.video_codec_sent.get(&codec_key).copied().unwrap_or(false);
+                    let already_sent = state
+                        .video_codec_sent
+                        .get(&codec_key)
+                        .copied()
+                        .unwrap_or(false);
                     let include_codec = frame.is_key && !already_sent;
                     let payload = pack_video_chunk_payload(
                         frame.is_key,
                         timestamp_us,
                         sent_at_ms,
                         frame.data.as_slice(),
-                        if include_codec { frame.codec.as_deref() } else { None },
+                        if include_codec {
+                            frame.codec.as_deref()
+                        } else {
+                            None
+                        },
                         None,
                     );
                     if frame.is_key && include_codec {
                         if let Some(codec) = frame.codec.as_deref() {
                             println!(
                                 "[rtmp {label}] detected video codec from SPS: {codec} ns={:?} track={}",
-                                namespace,
-                                track_name
+                                namespace, track_name
                             );
                             state.video_codec_sent.insert(codec_key.clone(), true);
                         } else {

moqt-ingest-gateway/src/video.rs

@@ -152,6 +152,8 @@ impl AvcState {
         let profile_idc = sps[1];
         let constraints = sps[2];
         let level_idc = sps[3];
-        Some(format!("avc1.{profile_idc:02X}{constraints:02X}{level_idc:02X}"))
+        Some(format!(
+            "avc1.{profile_idc:02X}{constraints:02X}{level_idc:02X}"
+        ))
     }
 }