queueRowDeletesWithOptimisticUpdate() — supabase Function Reference

Source Code

apps/studio/components/grid/utils/queueOperationUtils.ts lines 289–348

export function queueRowDeletesWithOptimisticUpdate({
  rows,
  table,
  queryClient,
  queueOperation,
  projectRef,
}: QueueRowDeletesParams): void {
  // [Ali] We can handle these better in the future
  // right now this is a pretty abnormal case of this occurring
  if (!projectRef) {
    console.error('Cannot queue row deletes: projectRef is required')
    return
  }

  if (!isTableLike(table)) {
    console.error('Cannot queue row deletes: table must be a TableLike entity')
    return
  }

  if (table.primary_keys.length === 0) {
    console.error('Cannot queue row deletes: table has no primary keys')
    return
  }

  for (const row of rows) {
    const rowIdentifiers: Record<string, unknown> = {}
    table.primary_keys.forEach((pk) => {
      rowIdentifiers[pk.name] = row[pk.name]
    })

    queueOperation({
      type: QueuedOperationType.DELETE_ROW,
      tableId: table.id,
      payload: {
        rowIdentifiers,
        originalRow: row,
        table,
      },
    })

    const queryKey = tableRowKeys.tableRows(projectRef, { table: { id: table.id } })
    queryClient.setQueriesData<TableRowsData>({ queryKey }, (old) => {
      if (!old) return old

      // For pending add rows, remove completely
      if (isPendingAddRow(row)) {
        return {
          ...old,
          rows: removeRow(old.rows, rowIdentifiers),
        }
      }

      // For existing rows, mark as deleted
      return {
        ...old,
        rows: markRowAsDeleted(old.rows, rowIdentifiers),
      }
    })
  }
}