Function useCreateTableRow

apps/sim/hooks/queries/tables.ts:626–682

({ workspaceId, tableId }: RowMutationContext)

}

export function useCreateTableRow({ workspaceId, tableId }: RowMutationContext) {
  const queryClient = useQueryClient()
  const router = useRouter()

  return useMutation({
    mutationFn: async (
      variables: Omit<InsertTableRowBodyInput, 'workspaceId' | 'data'> & {
        data: Record<string, unknown>
      }
    ) => {
      return requestJson(createTableRowContract, {
        params: { tableId },
        body: {
          workspaceId,
          data: variables.data as RowData,
          position: variables.position,
          afterRowId: variables.afterRowId,
          beforeRowId: variables.beforeRowId,
        },
      })
    },
    onSuccess: (response) => {
      const row = response.data.row
      if (!row) return

      const groups =
        queryClient.getQueryData<TableDefinition>(tableKeys.detail(tableId))?.schema
          .workflowGroups ?? []
      const stamped = withOptimisticAutoFireExec(groups, row)
      reconcileCreatedRow(queryClient, tableId, stamped)
      // Bump the run-state counter for any auto-fire groups stamped pending so
      // the "X running" badge + gutter Stop show immediately (the row had no
      // prior executions, so the stamped set is the full delta).
      const stampedCount = countNewlyInFlight({}, stamped.executions ?? {})
      if (stampedCount > 0) bumpRunState(queryClient, tableId, { [row.id]: stampedCount })

      // `reconcileCreatedRow` only patches the default-order view. Filtered /
      // column-sorted rows queries can't be reconciled from that heuristic
      // (membership, sort position, and `totalCount` are query-specific), so
      // refetch them — active ones update now, inactive ones on next view. The
      // default view stays optimistic, so the common case never refetches.
      queryClient.invalidateQueries({
        queryKey: tableKeys.rowsRoot(tableId),
        exact: false,
        predicate: (query) => !isDefaultOrderRowsQuery(query.queryKey),
      })
    },
    onError: (error) =>
      notifyRowWriteError(error, () => router.push(buildUpgradeHref(workspaceId, 'tables'))),
    onSettled: () => {
      // `reconcileCreatedRow` (onSuccess) is the source of truth for the rows
      // cache + its `totalCount`; only refresh the count surfaces here so a late
      // offset refetch can't clobber freshly-inserted rows (insert-flicker).
      invalidateRowCountSurfaces(queryClient, tableId)
    },
  })
}