fix(copilot): preserve stream_id on conflict + propagate chat model from update-messages

Author: waleedlatif1

apps/sim/app/api/copilot/chat/update-messages/route.ts

@@ -87,8 +87,14 @@ export const POST = withRouteHandler(async (req: NextRequest) => {
       updateData.config = config
     }
 
-    await db.update(copilotChats).set(updateData).where(eq(copilotChats.id, chatId))
-    await replaceCopilotChatMessages(chatId, normalizedMessages)
+    const [updated] = await db
+      .update(copilotChats)
+      .set(updateData)
+      .where(eq(copilotChats.id, chatId))
+      .returning({ model: copilotChats.model })
+    await replaceCopilotChatMessages(chatId, normalizedMessages, {
+      chatModel: updated?.model ?? null,
+    })
 
     logger.info(`[${tracker.requestId}] Successfully updated chat`, {
       chatId,

apps/sim/lib/copilot/chat/messages-dual-write.ts

@@ -46,6 +46,7 @@ export async function appendCopilotChatMessages(
           content: sql`excluded.content`,
           role: sql`excluded.role`,
           model: sql`COALESCE(excluded.model, ${copilotChatMessages.model})`,
+          streamId: sql`COALESCE(excluded.stream_id, ${copilotChatMessages.streamId})`,
           updatedAt: sql`now()`,
         },
       })