front: better stream dropping error logs (#6071)

* front: better stream dropping error logs * fix lint
dust-tt · Jul 4, 2024 · 90075fc · 90075fc
1 parent 100399b
commit 90075fc
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 3 deletions.
diff --git a/front/lib/api/assistant/pubsub.ts b/front/lib/api/assistant/pubsub.ts
@@ -248,7 +248,17 @@ async function handleUserMessageEvents(
           );
         }
       } catch (e) {
-        logger.error({ error: e }, "Error Posting message");
+        logger.error(
+          {
+            error: e,
+            conversationId: conversation.sId,
+            workspaceId: conversation.owner.sId,
+            type: "handl_user_message_events",
+            userMessageId: userMessage?.sId,
+            agentMessageIds: agentMessages.map((m) => m.sId),
+          },
+          "Error Posting message"
+        );
       } finally {
         await redis.quit();
         if (!didResolve) {
@@ -344,7 +354,16 @@ export async function retryAgentMessageWithPubSub(
             }
           }
         } catch (e) {
-          logger.error({ error: e }, "Error Posting message");
+          logger.error(
+            {
+              error: e,
+              conversationId: conversation.sId,
+              workspaceId: conversation.owner.sId,
+              type: "retry_agent_message",
+              agentMessageId: message.sId,
+            },
+            "Error Posting message"
+          );
         } finally {
           await redis.quit();
           if (!didResolve) {

diff --git a/front/next.config.js b/front/next.config.js
@@ -67,7 +67,7 @@ module.exports = {
     config.module.rules.push({
       test: /\.js$/,
       use: ["source-map-loader"],
-      enforce: "pre"
+      enforce: "pre",
     });
     return config;
   },