From 29e72d92d5908188001f6a0543bb7651f143c85b Mon Sep 17 00:00:00 2001
From: Fuwn <contact@fuwn.me>
Date: Thu, 15 Feb 2024 08:46:22 -0800
Subject: feat(hololive): stream pinning

---
 src/lib/Database/userConfiguration.ts | 30 +++++++++++++++++++++++++++---
 src/lib/websocket.ts                  | 21 ---------------------
 src/lib/websocket.ts.bak              | 21 +++++++++++++++++++++
 3 files changed, 48 insertions(+), 24 deletions(-)
 delete mode 100644 src/lib/websocket.ts
 create mode 100644 src/lib/websocket.ts.bak

(limited to 'src/lib')

diff --git a/src/lib/Database/userConfiguration.ts b/src/lib/Database/userConfiguration.ts
index 3a01411e..f1e3ef95 100644
--- a/src/lib/Database/userConfiguration.ts
+++ b/src/lib/Database/userConfiguration.ts
@@ -2,14 +2,16 @@ import supabase from './supabase';
 
 interface UserConfiguration {
 	user_id: number;
-	configuration: JSON;
+	configuration: object;
 	created_at: string;
 	updated_at: string;
+	pinned_hololive_streams: string[];
 }
 
 interface NewUserConfiguration {
-	configuration: JSON;
+	configuration: object;
 	updated_at?: string;
+	pinned_hololive_streams?: string[];
 }
 
 export const getUserConfiguration = async (userId: number) => {
@@ -24,13 +26,17 @@ export const getUserConfiguration = async (userId: number) => {
 };
 
 export const setUserConfiguration = async (userId: number, configuration: NewUserConfiguration) => {
+	const userConfiguration = await getUserConfiguration(userId);
 	const { data, error } = await supabase
 		.from('user_configuration')
 		.upsert(
 			{
 				user_id: userId,
 				configuration: configuration.configuration,
-				updated_at: configuration.updated_at || new Date().toISOString()
+				updated_at: configuration.updated_at || new Date().toISOString(),
+				pinned_hololive_streams:
+					configuration.pinned_hololive_streams ||
+					(userConfiguration ? userConfiguration.pinned_hololive_streams : [])
 			},
 			{ onConflict: 'user_id' }
 		)
@@ -40,3 +46,21 @@ export const setUserConfiguration = async (userId: number, configuration: NewUse
 
 	return data[0].configuration as UserConfiguration;
 };
+
+export const toggleHololiveStreamPinning = async (userId: number, streamId: string) => {
+	const userConfiguration = await getUserConfiguration(userId);
+
+	if (!userConfiguration) return null;
+
+	const pinnedStreams = userConfiguration.pinned_hololive_streams;
+	const index = pinnedStreams.indexOf(streamId);
+
+	if (index === -1) pinnedStreams.push(streamId);
+	else pinnedStreams.splice(index, 1);
+
+	return setUserConfiguration(userId, {
+		configuration: userConfiguration.configuration,
+		updated_at: new Date().toISOString(),
+		pinned_hololive_streams: pinnedStreams
+	});
+};
diff --git a/src/lib/websocket.ts b/src/lib/websocket.ts
deleted file mode 100644
index 28557415..00000000
--- a/src/lib/websocket.ts
+++ /dev/null
@@ -1,21 +0,0 @@
-import type { ViteDevServer } from 'vite';
-import { Server } from 'socket.io';
-import { getUserBadges } from '$lib/Database/userBadges';
-import { userIdentity } from '$lib/Data/AniList/identity';
-
-export const webSocketServer = {
-	name: 'webSocketServer',
-	configureServer(server: ViteDevServer) {
-		if (!server.httpServer) return;
-
-		const io = new Server(server.httpServer);
-
-		io.on('connection', (socket) => {
-			socket.on('badges', async (data) => {
-				userIdentity(data).then((identity) => {
-					socket.emit('badges', getUserBadges(identity.id));
-				});
-			});
-		});
-	}
-};
diff --git a/src/lib/websocket.ts.bak b/src/lib/websocket.ts.bak
new file mode 100644
index 00000000..28557415
--- /dev/null
+++ b/src/lib/websocket.ts.bak
@@ -0,0 +1,21 @@
+import type { ViteDevServer } from 'vite';
+import { Server } from 'socket.io';
+import { getUserBadges } from '$lib/Database/userBadges';
+import { userIdentity } from '$lib/Data/AniList/identity';
+
+export const webSocketServer = {
+	name: 'webSocketServer',
+	configureServer(server: ViteDevServer) {
+		if (!server.httpServer) return;
+
+		const io = new Server(server.httpServer);
+
+		io.on('connection', (socket) => {
+			socket.on('badges', async (data) => {
+				userIdentity(data).then((identity) => {
+					socket.emit('badges', getUserBadges(identity.id));
+				});
+			});
+		});
+	}
+};
-- 
cgit v1.2.3