Fix: reimplemented favorites and FCM

CodeCrowCorp · Oct 7, 2023 · 5513aca · 5513aca
1 parent 1bb3a6c
commit 5513aca
Show file tree

Hide file tree

Showing 2 changed files with 41 additions and 11 deletions.
diff --git a/src/lib/components/Channel/Chat/DropdownViewChannel.svelte b/src/lib/components/Channel/Chat/DropdownViewChannel.svelte
@@ -21,11 +21,10 @@
 
 	onMount(async () => {
 		if ($page.data.user?.userId) {
-			const favorites = await get(`favorites?channelId=${channel._id}`, {
+			isFavorite = await get(`favorite?channelId=${channel._id}`, {
 				userId: $page.data.user?.userId,
 				token: $page.data.user?.token
 			})
-			isFavorite = favorites?.length > 0
 		}
 	})
 

diff --git a/src/lib/components/Channel/Stream/StreamControls.svelte b/src/lib/components/Channel/Stream/StreamControls.svelte
@@ -8,7 +8,7 @@
 		is_chat_drawer_destroy,
 		was_chat_drawer_closed
 	} from '$lib/stores/channelStore'
-	import { del, put } from '$lib/api'
+	import { del, post, put } from '$lib/api'
 	import { page } from '$app/stores'
 	import { emitAction } from '$lib/websocket'
 	import {
@@ -59,6 +59,25 @@
 		})
 	}
 
+	const sendFcm = async ({
+		channelId,
+		channelTitle,
+		username
+	}: {
+		channelId: string
+		channelTitle: string
+		username: string
+	}) => {
+		return await post(
+			`firebase/send-fcm`,
+			{ channelId, channelTitle, username },
+			{
+				userId: $page.data.user?.userId,
+				token: $page.data.user?.token
+			}
+		)
+	}
+
 	const deleteLiveInput = async ({
 		channelId,
 		userId,
@@ -82,8 +101,6 @@
 	const startObsStream = async () => {
 		const liveInput = await createLiveInput({
 			channelId: `${$page.params.channelId}`,
-			channelTitle: `${channel.title}`,
-			username: `${$page.data.user?.user?.username}`,
 			userId: $page.data.user?.userId,
 			trackType: 'obs',
 			isTrackActive: true,
@@ -103,6 +120,11 @@
 				video: liveInput
 			}
 		})
+		await sendFcm({
+			channelId: $page.params.channelId,
+			channelTitle: channel.title,
+			username: $page.data.user?.user?.username
+		})
 	}
 
 	const stopObsStream = async () => {
@@ -131,8 +153,6 @@
 	const startScreenStream = async () => {
 		const liveInput = await createLiveInput({
 			channelId: `${$page.params.channelId}`,
-			channelTitle: `${channel.title}`,
-			username: `${$page.data.user?.user?.username}`,
 			userId: $page.data.user?.userId,
 			trackType: 'screen',
 			isTrackActive: true,
@@ -152,6 +172,11 @@
 				video: liveInput
 			}
 		})
+		await sendFcm({
+			channelId: $page.params.channelId,
+			channelTitle: channel.title,
+			username: $page.data.user?.user?.username
+		})
 	}
 
 	const stopScreenStream = async () => {
@@ -180,8 +205,6 @@
 	const startWebcamStream = async () => {
 		const liveInput = await createLiveInput({
 			channelId: `${$page.params.channelId}`,
-			channelTitle: `${channel.title}`,
-			username: `${$page.data.user?.user?.username}`,
 			userId: $page.data.user?.userId,
 			trackType: 'webcam',
 			isTrackActive: true,
@@ -201,6 +224,11 @@
 				video: liveInput
 			}
 		})
+		await sendFcm({
+			channelId: $page.params.channelId,
+			channelTitle: channel.title,
+			username: $page.data.user?.user?.username
+		})
 	}
 
 	const stopWebcamStream = async () => {
@@ -229,8 +257,6 @@
 	const startAudioStream = async () => {
 		const liveInput = await createLiveInput({
 			channelId: `${$page.params.channelId}`,
-			channelTitle: `${channel.title}`,
-			username: `${$page.data.user?.user?.username}`,
 			userId: $page.data.user?.userId,
 			trackType: 'audio',
 			isTrackActive: true,
@@ -250,6 +276,11 @@
 				video: liveInput
 			}
 		})
+		await sendFcm({
+			channelId: $page.params.channelId,
+			channelTitle: channel.title,
+			username: $page.data.user?.user?.username
+		})
 	}
 
 	const stopAudioStream = async () => {