From b62c32ae7d64b55c29ea7e93d7270efaf7f9a060 Mon Sep 17 00:00:00 2001
From: Jicheng Lu <103353@smsassist.com>
Date: Wed, 6 Aug 2025 11:26:20 -0500
Subject: [PATCH] receive json

---
 src/lib/services/signalr-service.js           | 83 +++++++++++--------
 .../[conversationId]/chat-box.svelte          |  3 +-
 2 files changed, 51 insertions(+), 35 deletions(-)

diff --git a/src/lib/services/signalr-service.js b/src/lib/services/signalr-service.js
index 8f1dd80b..46f5f340 100644
--- a/src/lib/services/signalr-service.js
+++ b/src/lib/services/signalr-service.js
@@ -74,100 +74,115 @@ export const signalr = {
     // register handlers for the hub methods
     connection.on('OnConversationInitFromClient', (conversation) => {
       // do something when receiving a message, such as updating the UI or showing a notification
-      if (conversationId === conversation.id) {
-        console.log(`[OnConversationInitFromClient] ${conversation.id}: ${conversation.title}`);
-        this.onConversationInitFromClient(conversation);
+      const obj = JSON.parse(conversation);
+      if (conversationId === obj?.id) {
+        console.log(`[OnConversationInitFromClient] ${obj.id}: ${obj.title}`);
+        this.onConversationInitFromClient(obj);
       }
     });
 
     // register handlers for the hub methods
     connection.on('OnMessageReceivedFromClient', (message) => {
       // do something when receiving a message, such as updating the UI or showing a notification
-      if (conversationId === message.conversation_id) {
-        console.log(`[OnMessageReceivedFromClient] ${message.sender.role}: ${message.text}`);
-        this.onMessageReceivedFromClient(message);
+      const obj = JSON.parse(message);
+      if (conversationId === obj?.conversation_id) {
+        console.log(`[OnMessageReceivedFromClient] ${obj.sender.role}: ${obj.text}`);
+        this.onMessageReceivedFromClient(obj);
       }
     });
 
     connection.on('OnMessageReceivedFromCsr', (message) => {
       // do something when receiving a message, such as updating the UI or showing a notification
-      if (conversationId === message.conversation_id) {
-        console.log(`[OnMessageReceivedFromCsr] ${message.role}: ${message.content}`);
-        this.onMessageReceivedFromCsr(message);
+      const obj = JSON.parse(message);
+      if (conversationId === obj?.conversation_id) {
+        console.log(`[OnMessageReceivedFromCsr] ${obj.role}: ${obj.content}`);
+        this.onMessageReceivedFromCsr(obj);
       }
     });
 
     connection.on('OnMessageReceivedFromAssistant', (message) => {
       // do something when receiving a message, such as updating the UI or showing a notification
-      if (conversationId === message?.conversation_id) {
-        console.log(`[OnMessageReceivedFromAssistant] ${message.sender.role}: ${message.text}`);
-        this.onMessageReceivedFromAssistant(message);
+      const obj = JSON.parse(message);
+      if (conversationId === obj?.conversation_id) {
+        console.log(`[OnMessageReceivedFromAssistant] ${obj.sender.role}: ${obj.text}`);
+        this.onMessageReceivedFromAssistant(obj);
       }
     });
 
     connection.on('OnNotificationGenerated', (message) => {
-      if (conversationId === message?.conversation_id) {
-        this.onNotificationGenerated(message);
+      const obj = JSON.parse(message);
+      if (conversationId === obj?.conversation_id) {
+        this.onNotificationGenerated(obj);
       }
     });
 
     connection.on('OnConversationContentLogGenerated', (log) => {
-      if (conversationId === log?.conversation_id) {
-        this.onConversationContentLogGenerated(log);
+      const obj = JSON.parse(log);
+      if (conversationId === obj?.conversation_id) {
+        this.onConversationContentLogGenerated(obj);
       }
     });
 
     connection.on('OnConversateStateLogGenerated', (log) => {
-      if (conversationId === log?.conversation_id) {
-        this.onConversationStateLogGenerated(log);
+      const obj = JSON.parse(log);
+      if (conversationId === obj?.conversation_id) {
+        this.onConversationStateLogGenerated(obj);
       }
     });
 
     connection.on('OnStateChangeGenerated', (log) => {
-      if (conversationId === log?.conversation_id) {
-        this.onStateChangeGenerated(log);
+      const obj = JSON.parse(log);
+      if (conversationId === obj?.conversation_id) {
+        this.onStateChangeGenerated(obj);
       }
     });
 
     connection.on('OnAgentQueueChanged', (log) => {
-      if (conversationId === log?.conversation_id) {
-        this.onAgentQueueChanged(log);
+      const obj = JSON.parse(log);
+      if (conversationId === obj?.conversation_id) {
+        this.onAgentQueueChanged(obj);
       }
     });
 
     connection.on('OnSenderActionGenerated', (data) => {
-      if (conversationId === data?.conversation_id) {
-        this.onSenderActionGenerated(data);
+      const obj = JSON.parse(data);
+      if (conversationId === obj?.conversation_id) {
+        this.onSenderActionGenerated(obj);
       }
     });
 
     connection.on('OnMessageDeleted', (data) => {
-      if (conversationId === data?.conversation_id) {
-        this.onConversationMessageDeleted(data);
+      const obj = JSON.parse(data);
+      if (conversationId === obj?.conversation_id) {
+        this.onConversationMessageDeleted(obj);
       }
     });
 
     connection.on('BeforeReceiveLlmStreamMessage', data => {
-      if (conversationId === data?.conversation_id) {
-        this.beforeReceiveLlmStreamMessage(data);
+      const obj = JSON.parse(data);
+      if (conversationId === obj?.conversation_id) {
+        this.beforeReceiveLlmStreamMessage(obj);
       }
     });
 
     connection.on('OnReceiveLlmStreamMessage', data => {
-      if (conversationId === data?.conversation_id) {
-        this.onReceiveLlmStreamMessage(data);
+      const obj = JSON.parse(data);
+      if (conversationId === obj?.conversation_id) {
+        this.onReceiveLlmStreamMessage(obj);
       }
     });
 
     connection.on('AfterReceiveLlmStreamMessage', data => {
-      if (conversationId === data?.conversation_id) {
-        this.afterReceiveLlmStreamMessage(data);
+      const obj = JSON.parse(data);
+      if (conversationId === obj?.conversation_id) {
+        this.afterReceiveLlmStreamMessage(obj);
       }
     });
 
     connection.on('OnIndicationReceived', data => {
-      if (conversationId === data?.conversation_id) {
-        this.onIndicationReceived(data);
+      const obj = JSON.parse(data);
+      if (conversationId === obj?.conversation_id) {
+        this.onIndicationReceived(obj);
       }
     });
   },
diff --git a/src/routes/chat/[agentId]/[conversationId]/chat-box.svelte b/src/routes/chat/[agentId]/[conversationId]/chat-box.svelte
index 264d8a14..dfd7cd18 100644
--- a/src/routes/chat/[agentId]/[conversationId]/chat-box.svelte
+++ b/src/routes/chat/[agentId]/[conversationId]/chat-box.svelte
@@ -430,7 +430,8 @@
 		await tick();
 		lastBotMsg = findLastBotMessage(dialogs);
 		lastMsg = dialogs.slice(-1)[0];
-		assignMessageDisclaimer(dialogs)
+		assignMessageDisclaimer(dialogs);
+		groupedDialogs = groupDialogs(dialogs);
 		await tick();
 
 		autoScrollToBottom();