From 206de7dc4a1d12686dd0748aa2a7eefe955d9d67 Mon Sep 17 00:00:00 2001
From: Tony Ramirez <tonyramirezlecca@gmail.com>
Date: Wed, 4 Dec 2024 14:22:02 -0700
Subject: [PATCH] ci: Update create-release.yml

---
 .github/workflows/create-release.yml          |  2 +-
 .../modules/core/tasks/tasks.controller.ts    | 34 +++++++++++--------
 2 files changed, 20 insertions(+), 16 deletions(-)

diff --git a/.github/workflows/create-release.yml b/.github/workflows/create-release.yml
index 7a779d3a..61543a87 100644
--- a/.github/workflows/create-release.yml
+++ b/.github/workflows/create-release.yml
@@ -24,4 +24,4 @@ jobs:
       - name: Semantic Release
         uses: cycjimmy/semantic-release-action@v4
         env:
-          GITHUB_TOKEN: ${{ secrets.PAT_TOKEN }}
+          GITHUB_TOKEN: ${{ secrets.LECCA_IO_RELEASE_TOKEN }}
diff --git a/apps/server/src/modules/core/tasks/tasks.controller.ts b/apps/server/src/modules/core/tasks/tasks.controller.ts
index e73fe548..528a6fc9 100644
--- a/apps/server/src/modules/core/tasks/tasks.controller.ts
+++ b/apps/server/src/modules/core/tasks/tasks.controller.ts
@@ -95,21 +95,25 @@ export class AgentTasksController {
     @Body() data: MessageTaskDto,
     @Res() response: Response,
   ) {
-    const lastMessage = data.messages[data.messages.length - 1];
-
-    const result = await this.tasksService.messageTaskOrCreateTaskIfNotFound({
-      agentId,
-      taskId,
-      messages: [lastMessage],
-      requestingWorkspaceUserId: user.workspaceUserId,
-      workspaceId: user.workspaceId,
-      customIdentifier: undefined,
-    });
-
-    if (typeof result === 'string' || Array.isArray(result)) {
-      return response.status(200).json(result);
-    } else {
-      return result.pipeDataStreamToResponse(response);
+    try {
+      const lastMessage = data.messages[data.messages.length - 1];
+
+      const result = await this.tasksService.messageTaskOrCreateTaskIfNotFound({
+        agentId,
+        taskId,
+        messages: [lastMessage],
+        requestingWorkspaceUserId: user.workspaceUserId,
+        workspaceId: user.workspaceId,
+        customIdentifier: undefined,
+      });
+
+      if (typeof result === 'string' || Array.isArray(result)) {
+        return response.status(200).json(result);
+      } else {
+        return result.pipeDataStreamToResponse(response);
+      }
+    } catch (error) {
+      return response.status(500).json({ error: error.message });
     }
   }
 }