Function run

apps/sim/lib/copilot/chat/messages-store.ts:94–120

(tx: DbOrTx)

  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))
}