Function mutate

packages/db/src/paced-mutations.ts:131–166

* Executes a mutation with the given variables. Creates a new transaction if none is active, * or adds to the existing active transaction. The strategy controls when * the transaction is actually committed.

(variables: TVariables)

   * the transaction is actually committed.
   */
  function mutate(variables: TVariables): Transaction<T> {
    // Create a new transaction if we don't have an active one
    if (!activeTransaction || activeTransaction.state !== `pending`) {
      activeTransaction = createTransaction<T>({
        ...transactionConfig,
        mutationFn,
        autoCommit: false,
      })
    }

    // Execute onMutate with variables to apply optimistic updates
    activeTransaction.mutate(() => {
      onMutate(variables)
    })

    // Save reference before calling strategy.execute
    const txToReturn = activeTransaction

    // For queue strategy, pass a function that commits the captured transaction
    // This prevents the error when commitCallback tries to access the cleared activeTransaction
    if (strategy._type === `queue`) {
      const capturedTx = activeTransaction
      activeTransaction = null // Clear so next mutation creates a new transaction
      strategy.execute(() => {
        capturedTx.commit().catch(() => {
          // Errors are handled via transaction.isPersisted.promise
        })
        return capturedTx
      })
    } else {
      // For debounce/throttle, use commitCallback which manages activeTransaction
      strategy.execute(commitCallback)
    }

    return txToReturn
  }

  return mutate
}