Merge pull request #357 from iceljc/features/refine-chat-window

Features/refine chat window

Author: iceljc

src/lib/helpers/conversation.js

@@ -0,0 +1,21 @@
+import { conversationUserStateStore } from "./store";
+
+/**
+ * @param {string} conversationId
+ */
+export function buildConversationUserStates(conversationId) {
+    const userStates = conversationUserStateStore.get(conversationId);
+    if (!!userStates && userStates.conversationId == conversationId) {
+        // @ts-ignore
+        const states = userStates.states?.map(state => {
+            return {
+                key: state.key.data,
+                value: state.value.data,
+                active_rounds: state.active_rounds.data || -1
+            };
+        }) || [];
+        // conversationUserStateStore.resetOne(conversationId);
+        return states;
+    }
+    return [];
+}

src/lib/scss/custom/components/_alert.scss

@@ -5,6 +5,7 @@
     right: 35%;
     z-index: 8888;
     font-size: 0.9em;
+    white-space: pre-line;
 
     .alert {
         text-align: center;

src/lib/services/conversation-service.js

@@ -2,6 +2,7 @@ import axios from 'axios';
 import qs from 'qs';
 import { replaceUrl } from '$lib/helpers/http';
 import { conversationUserStateStore } from '$lib/helpers/store.js';
+import { buildConversationUserStates } from '$lib/helpers/conversation.js';
 import { endpoints } from './api-endpoints.js';
 
 /**
@@ -167,26 +168,6 @@ export async function sendNotification(conversationId, text, data = null) {
     return response.data;
 }
 
-/**
- * @param {string} conversationId
- */
-function buildConversationUserStates(conversationId) {
-    const userStates = conversationUserStateStore.get(conversationId);
-    if (!!userStates && userStates.conversationId == conversationId) {
-        // @ts-ignore
-        const states = userStates.states?.map(state => {
-            return {
-                key: state.key.data,
-                value: state.value.data,
-                active_rounds: state.active_rounds.data || -1
-            };
-        }) || [];
-        // conversationUserStateStore.resetOne(conversationId);
-        return states;
-    }
-    return [];
-}
-
 /**
  * delete a message in conversation
  * @param {string} conversationId The conversation id

src/lib/services/realtime-chat-service.js

@@ -1,4 +1,5 @@
 import { PUBLIC_SERVICE_URL } from "$env/static/public";
+import { buildConversationUserStates } from "$lib/helpers/conversation";
 import { AudioRecordingWorklet } from "$lib/helpers/realtime/pcmProcessor";
 
 // @ts-ignore
@@ -42,7 +43,10 @@ export const realtimeChat = {
             console.log("WebSocket connected");
 
             socket?.send(JSON.stringify({
-                event: "start"
+                event: "start",
+                body: {
+                    payload: JSON.stringify(buildConversationUserStates(conversationId))
+                }
             }));
 
             mediaStream = await navigator.mediaDevices.getUserMedia({ audio: true });

src/routes/+layout.svelte

@@ -39,6 +39,7 @@
 		errorUnsubscriber?.();
 	});
 </script>
+
 {#if isLoading}
 	<Loader size={50}/>
 {/if}