Feat: added twitch subscriptions and chat

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "mage-website",
-	"version": "0.2.11",
+	"version": "0.2.12",
 	"license": "GPL-3.0",
 	"private": true,
 	"type": "module",

src/lib/api.ts

@@ -43,7 +43,7 @@ async function send({
 	const res = await fetch(`${base}/${path}`, opts)
 	if (res.ok || res.status === 422) {
 		const text = await res.text()
-		if (path === 'wsinit/wsid' || path.includes('wsinit/channelid')) return text
+		if (path.includes('wsinit/channelid')) return text
 		return text ? JSON.parse(text) : {}
 	}
 

src/lib/components/Channel/Chat/ChatInput.svelte

@@ -54,19 +54,13 @@
 			}
 		} else if (!chatMessage.startsWith('/') || chatMessage.startsWith('/ai')) {
 			if (chatMessage === null || chatMessage.match(/^\s*$/) !== null) return
-			const completeMessage = {
-				isAiChatEnabled: channel.isAiChatEnabled,
-				body: chatMessage,
-				state: { timestamp: Date.now() },
-				user: {
-					userId: $page.data.user?.userId || '',
-					username: $page.data.user?.user?.username || ''
-				}
-			}
 			emitMessageToChannel({
 				channelSocket: channel.socket,
 				channelId: channel._id,
-				message: JSON.stringify(completeMessage)
+				message: {
+					isAiChatEnabled: channel.isAiChatEnabled,
+					body: chatMessage
+				}
 			})
 		}
 		chatMessage = ''

src/lib/components/Channel/Chat/Message.svelte

@@ -200,7 +200,7 @@
 			{/if}
 			<div class="d-flex align-items-center">
 				{#if sender.platform === 'twitch'}
-					<IconSocialTwitch />
+					<div style="display: ruby;"><IconSocialTwitch /></div>
 				{/if}
 				{#if sender.platform === 'youtube'}
 					<div style="display: ruby;"><IconSocialYouTube /></div>

src/routes/channel/[channelId]/+page.svelte

@@ -47,6 +47,8 @@
 	}
 
 	onMount(async () => {
+		clearInterval(platformPollingInterval)
+		platformPollingInterval = null
 		await loadChannel()
 		await handleWebsocket()
 		await loadMoreChannels()
@@ -237,18 +239,24 @@
 				channel.socket.addEventListener('error', (data: any) => {
 					console.log('channel socket connection error')
 					console.log(data)
+					clearInterval(platformPollingInterval)
+					platformPollingInterval = null
 				})
 				channel.socket.addEventListener('close', (data: any) => {
 					console.log('channel socket connection close')
 					console.log(data)
 
 					//if manually closed, don't reconnect
-					if (data.code === 1005) return
+					if (data.code === 1005) {
+						clearInterval(platformPollingInterval)
+						platformPollingInterval = null
+						return
+					}
 					attemptReconnect()
 				})
 			}
-		} catch (error) {
-			if (error) attemptReconnect()
+		} catch (err) {
+			if (err) attemptReconnect()
 		}
 	}
 
@@ -319,7 +327,7 @@
 	}
 
 	const getPlatformChatYouTube = async () => {
-		if (channel.isLive) {
+		if (channel.isLive && channel.platforms?.some((platform: any) => platform.name === 'YouTube')) {
 			let url = `youtube/messages?userId=${channel.userId}`
 			if (youtubeChatPageToken) {
 				url += `&pageToken=${youtubeChatPageToken}`