Remove unused stream profile control path

Author: DjDeveloperr

client/src/features/stream/streamWorkerClient.ts

@@ -39,8 +39,6 @@ export function sendWebRtcClientStats(stats: unknown): boolean {
 
 export function sendWebRtcStreamControl(options: {
   forceKeyframe?: boolean;
-  fps?: number;
-  profile?: "focus" | "full" | "paused" | "thumb" | "thumbnail";
   snapshot?: boolean;
 }): boolean {
   return sendDataChannelMessage(
@@ -1340,12 +1338,7 @@ export class StreamWorkerClient {
     return (await this.backend?.collectVisualArtifactSample?.(udid)) ?? null;
   }
 
-  sendStreamControl(options: {
-    forceKeyframe?: boolean;
-    fps?: number;
-    profile?: "focus" | "full" | "paused" | "thumb" | "thumbnail";
-    snapshot?: boolean;
-  }) {
+  sendStreamControl(options: { forceKeyframe?: boolean; snapshot?: boolean }) {
     return Boolean(
       this.backend?.sendControl?.({ ...options, type: "streamControl" }),
     );

client/src/features/stream/useLiveStream.ts

@@ -33,7 +33,6 @@ interface UseLiveStreamOptions {
   remote?: boolean;
   simulator: SimulatorMetadata | null;
   streamConfig?: StreamConfig;
-  streamProfile?: "focus" | "full" | "paused" | "thumb" | "thumbnail";
 }
 
 interface UseLiveStreamResult {
@@ -94,7 +93,6 @@ export function useLiveStream({
   remote = false,
   simulator,
   streamConfig,
-  streamProfile = "focus",
 }: UseLiveStreamOptions): UseLiveStreamResult {
   const clientTelemetryIdRef = useRef("");
   const workerClientRef = useRef<StreamWorkerClient | null>(null);
@@ -298,30 +296,6 @@ export function useLiveStream({
     streamConfig?.quality,
   ]);
 
-  useEffect(() => {
-    if (paused || !simulator?.isBooted) {
-      return;
-    }
-    let attempts = 0;
-    const send = () => {
-      attempts += 1;
-      return Boolean(
-        workerClientRef.current?.sendStreamControl({
-          profile: streamProfile,
-        }),
-      );
-    };
-    if (send()) {
-      return;
-    }
-    const interval = window.setInterval(() => {
-      if (send() || attempts >= 8) {
-        window.clearInterval(interval);
-      }
-    }, 250);
-    return () => window.clearInterval(interval);
-  }, [paused, simulator?.isBooted, simulator?.udid, streamProfile]);
-
   useEffect(() => {
     if (!simulator?.udid) {
       return;

server/src/transport/webrtc.rs

@@ -409,17 +409,13 @@ fn attach_control_data_channel(
                         }
                     }
                     WebRtcDataChannelMessage::StreamControl {
-                        fps,
                         force_keyframe,
-                        profile,
                         snapshot,
                     } => {
-                        let command = WebRtcStreamCommand::from_payload(
-                            profile.as_deref(),
-                            fps,
-                            force_keyframe.unwrap_or(false),
-                            snapshot.unwrap_or(false),
-                        );
+                        let command = WebRtcStreamCommand {
+                            force_keyframe: force_keyframe.unwrap_or(false),
+                            snapshot: snapshot.unwrap_or(false),
+                        };
                         if command.force_keyframe || command.snapshot {
                             session.request_keyframe();
                         }
@@ -499,10 +495,8 @@ enum WebRtcDataChannelMessage {
         stats: Box<ClientStreamStats>,
     },
     StreamControl {
-        fps: Option<u32>,
         #[serde(rename = "forceKeyframe")]
         force_keyframe: Option<bool>,
-        profile: Option<String>,
         snapshot: Option<bool>,
     },
 }
@@ -513,21 +507,6 @@ struct WebRtcStreamCommand {
     snapshot: bool,
 }
 
-impl WebRtcStreamCommand {
-    fn from_payload(
-        profile: Option<&str>,
-        fps: Option<u32>,
-        force_keyframe: bool,
-        snapshot: bool,
-    ) -> Self {
-        let _ = (profile, fps);
-        Self {
-            force_keyframe,
-            snapshot,
-        }
-    }
-}
-
 fn webrtc_control_message_is_move(message: &ControlMessage) -> bool {
     matches!(message, ControlMessage::Touch { phase, .. } if phase == "moved")
 }