From 9c208db5f9a672f1be755249e3b2ea5eae5444ae Mon Sep 17 00:00:00 2001
From: Gagan Suie <gagan.suie@codecrow.io>
Date: Wed, 13 Sep 2023 03:36:01 -0500
Subject: [PATCH] Fix: obs streaming live-inputs not deleting

---
 .../Channel/Stream/StreamControls.svelte      | 34 +++++--------------
 .../Channel/Stream/VideoItem.svelte           | 16 +++++++--
 2 files changed, 21 insertions(+), 29 deletions(-)

diff --git a/src/lib/components/Channel/Stream/StreamControls.svelte b/src/lib/components/Channel/Stream/StreamControls.svelte
index ad4be0c6..54410aa3 100644
--- a/src/lib/components/Channel/Stream/StreamControls.svelte
+++ b/src/lib/components/Channel/Stream/StreamControls.svelte
@@ -33,11 +33,7 @@
 		(video: any) => video._id === $page.data.user?.userId
 	)
 
-	let obsUid: string = '',
-		screenUid: string = '',
-		webcamUid: string = '',
-		audioUid: string = '',
-		subcriptions: any[] = []
+	let subcriptions: any[] = []
 
 	const handleChatDrawer = () => {
 		if ($is_chat_drawer_open) {
@@ -65,17 +61,15 @@
 	const deleteLiveInput = async ({
 		channelId,
 		userId,
-		trackType,
-		inputId
+		trackType
 	}: {
 		channelId: string
 		userId: string
 		trackType: string
-		inputId: string
 	}) => {
-		if (inputId) {
+		if (channelId && userId && trackType) {
 			return await del(
-				`cloudflare/live-input?channelId=${channelId}&userId=${userId}&trackType=${trackType}&inputId=${inputId}`,
+				`cloudflare/live-input?channelId=${channelId}&userId=${userId}&trackType=${trackType}`,
 				{
 					userId: $page.data.user?.userId,
 					token: $page.data.user?.token
@@ -97,7 +91,6 @@
 				recording: { mode: 'automatic' }
 			}
 		})
-		obsUid = liveInput.uid
 		channel.videoItems = updateVideoItems(channel.videoItems, [liveInput])
 		emitAction({
 			channelSocket: channel?.socket,
@@ -113,8 +106,7 @@
 		await deleteLiveInput({
 			channelId: $page.params.channelId,
 			userId: $page.data.user.userId,
-			trackType: 'obs',
-			inputId: obsUid
+			trackType: 'obs'
 		})
 		channel.videoItems = updateVideoItems(channel.videoItems, [
 			{ _id: $page.data.user.userId, trackType: 'obs', isTrackActive: false }
@@ -131,7 +123,6 @@
 				}
 			}
 		})
-		obsUid = ''
 	}
 
 	const startScreenStream = async () => {
@@ -147,7 +138,6 @@
 				recording: { mode: 'off' }
 			}
 		})
-		screenUid = liveInput.uid
 		channel.videoItems = updateVideoItems(channel.videoItems, [liveInput])
 		emitAction({
 			channelSocket: channel?.socket,
@@ -163,8 +153,7 @@
 		await deleteLiveInput({
 			channelId: $page.params.channelId,
 			userId: $page.data.user.userId,
-			trackType: 'screen',
-			inputId: screenUid
+			trackType: 'screen'
 		})
 		channel.videoItems = updateVideoItems(channel.videoItems, [
 			{ _id: $page.data.user.userId, trackType: 'screen', isTrackActive: false }
@@ -181,7 +170,6 @@
 				}
 			}
 		})
-		screenUid = ''
 	}
 
 	const startWebcamStream = async () => {
@@ -197,7 +185,6 @@
 				recording: { mode: 'off' }
 			}
 		})
-		webcamUid = liveInput.uid
 		channel.videoItems = updateVideoItems(channel.videoItems, [liveInput])
 		emitAction({
 			channelSocket: channel?.socket,
@@ -213,8 +200,7 @@
 		await deleteLiveInput({
 			channelId: $page.params.channelId,
 			userId: $page.data.user.userId,
-			trackType: 'webcam',
-			inputId: webcamUid
+			trackType: 'webcam'
 		})
 		channel.videoItems = updateVideoItems(channel.videoItems, [
 			{ _id: $page.data.user.userId, trackType: 'webcam', isTrackActive: false }
@@ -231,7 +217,6 @@
 				}
 			}
 		})
-		webcamUid = ''
 	}
 
 	const startAudioStream = async () => {
@@ -247,7 +232,6 @@
 				recording: { mode: 'off' }
 			}
 		})
-		audioUid = liveInput.uid
 		channel.videoItems = updateVideoItems(channel.videoItems, [liveInput])
 		emitAction({
 			channelSocket: channel?.socket,
@@ -263,8 +247,7 @@
 		await deleteLiveInput({
 			channelId: $page.params.channelId,
 			userId: $page.data.user.userId,
-			trackType: 'audio',
-			inputId: audioUid
+			trackType: 'audio'
 		})
 		channel.videoItems = updateVideoItems(channel.videoItems, [
 			{ _id: $page.data.user.userId, trackType: 'audio', isTrackActive: false }
@@ -281,7 +264,6 @@
 				}
 			}
 		})
-		audioUid = ''
 	}
 
 	onMount(() => {
diff --git a/src/lib/components/Channel/Stream/VideoItem.svelte b/src/lib/components/Channel/Stream/VideoItem.svelte
index 36000eda..51f9a967 100644
--- a/src/lib/components/Channel/Stream/VideoItem.svelte
+++ b/src/lib/components/Channel/Stream/VideoItem.svelte
@@ -126,8 +126,13 @@
 		if ($page.data.user?.userId === video._id) {
 			switch (trackType) {
 				case 'obs':
-					iframeUrl = video.obs?.playback?.iframe
-					// console.log('got here---- video.obs.playback?.iframeUrl', iframeUrl)
+					if ($is_sharing_obs) {
+						iframeUrl = video.obs?.playback?.iframe
+						// console.log('got here---- video.obs.playback?.iframeUrl', iframeUrl)
+					} else {
+						$is_sharing_obs = false
+						iframeUrl = ''
+					}
 					break
 				case 'screen':
 					if (video.screen && $is_sharing_screen) {
@@ -187,6 +192,11 @@
 						audioWhip.addEventListener(`localAudioSpeakingValue`, (ev: any) => {
 							speakingValue = ev.detail
 						})
+					} else if (!video.audio) {
+						if (audio_element) {
+							audio_element.srcObject = null
+						}
+						$is_sharing_audio = false
 					}
 					break
 			}
@@ -468,7 +478,7 @@
 				? 'mask-hexagon'
 				: 'mask-squircle'} object-cover m-auto" />
 		<div class="absolute inset-0">
-			{#if $is_feature_stats_enabled && (isScreenLive || isWebcamLive || iframeUrl)}
+			{#if $is_feature_stats_enabled && (isScreenLive || iframeUrl)}
 				<span
 					class="z-10 btn btn-sm btn-neutral font-medium text-white border-none items-center w-fit absolute top-2 left-2 {isHoverVideo
 						? 'opacity-100'