Function replaceCopilotChatMessages

apps/sim/lib/copilot/chat/messages-store.ts:86–122

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

 * transaction; otherwise it runs in its own.
 */
export async function replaceCopilotChatMessages(
  chatId: string,
  messages: PersistedMessage[],
  options?: { chatModel?: string | null },
  executor?: DbOrTx
): Promise<void> {
  const deduped = dedupeById(messages)
  const newMessageIds = deduped.map((m) => m.id)
  const run = async (tx: DbOrTx) => {
    await tx
      .delete(copilotMessages)
      .where(
        newMessageIds.length > 0
          ? and(
              eq(copilotMessages.chatId, chatId),
              notInArray(copilotMessages.messageId, newMessageIds)
            )
          : eq(copilotMessages.chatId, chatId)
      )
    if (deduped.length === 0) return
    await tx
      .insert(copilotMessages)
      .values(deduped.map((m, i) => toRow(chatId, m, 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`excluded.seq`,
          updatedAt: sql`now()`,
        },
      })
  }
  await (executor ? run(executor) : db.transaction(run))
}