Function appendCopilotChatMessages

apps/sim/lib/copilot/chat/messages-store.ts:52–79

(
  chatId: string,
  messages: PersistedMessage[],
  options?: { chatModel?: string | null; streamId?: string | null },
  executor: DbOrTx = db
)

 * and the `seq, created_at, id` read order breaks any residual tie.
 */
export async function appendCopilotChatMessages(
  chatId: string,
  messages: PersistedMessage[],
  options?: { chatModel?: string | null; streamId?: string | null },
  executor: DbOrTx = db
): Promise<void> {
  if (messages.length === 0) return
  const deduped = dedupeById(messages)
  const [maxRow] = await executor
    .select({ maxSeq: sql<number | null>`max(${copilotMessages.seq})` })
    .from(copilotMessages)
    .where(eq(copilotMessages.chatId, chatId))
  const base = (maxRow?.maxSeq ?? -1) + 1
  await executor
    .insert(copilotMessages)
    .values(deduped.map((m, i) => toRow(chatId, m, base + i, options)))
    .onConflictDoUpdate({
      target: [copilotMessages.chatId, copilotMessages.messageId],
      set: {
        content: sql`excluded.content`,
        role: sql`excluded.role`,
        model: sql`COALESCE(excluded.model, ${copilotMessages.model})`,
        streamId: sql`COALESCE(excluded.stream_id, ${copilotMessages.streamId})`,
        seq: sql`COALESCE(${copilotMessages.seq}, excluded.seq)`,
        updatedAt: sql`now()`,
      },
    })
}

/**
 * Replace all messages for a chat from a full snapshot (used by update-messages).