Send user answer to the agent

src/client/components/ConversationWrapper.tsx

@@ -104,6 +104,7 @@ export default function ConversationWrapper() {
       const response = await getAgentResponse({
         message: payload.conversations,
         conv_id: payload.conversation_id,
+        is_answer_to_agent_question: conversations.status === "pause",
       });
       // 3. add agent response as new conversation in the table
       const openAIResponse = {

src/server/actions.ts

@@ -223,10 +223,11 @@ export const updateConversation: UpdateConversation<
 type AgentPayload = {
   message: any;
   conv_id: number;
+  is_answer_to_agent_question?: boolean;
 };
 
 export const getAgentResponse: GetAgentResponse<AgentPayload> = async (
-  { message, conv_id },
+  { message, conv_id, is_answer_to_agent_question },
   context
 ) => {
   if (!context.user) {
@@ -237,6 +238,7 @@ export const getAgentResponse: GetAgentResponse<AgentPayload> = async (
     message: message,
     conv_id: conv_id,
     user_id: context.user.id,
+    is_answer_to_agent_question: is_answer_to_agent_question,
   };
   console.log("===========");
   console.log("Payload to Python server");

src/server/webSocket.js

@@ -43,7 +43,10 @@ export const webSocketFn = (io, context) => {
               }
 
               const conversation_status = json["status"];
-              if (conversation_status === "ready") {
+              if (
+                conversation_status === "completed" ||
+                conversation_status === "pause"
+              ) {
                 const updated_conversation = conversation.conversation.concat([
                   { role: "assistant", content: json["msg"] },
                 ]);