Method mutate

packages/db/src/transactions.ts:296–317

* Execute collection operations within this transaction * @param callback - Synchronous function containing collection operations to group together. * The transaction context is active only for the synchronous duration of this callback. * Async work should happen in `mutationFn`; collection

(callback: () => void)

   * await tx.commit()
   */
  mutate(callback: () => void): Transaction<T> {
    if (this.state !== `pending`) {
      throw new TransactionNotPendingMutateError()
    }

    registerTransaction(this)

    try {
      callback()
    } finally {
      unregisterTransaction(this)
    }

    if (this.autoCommit) {
      this.commit().catch(() => {
        // Errors from autoCommit are handled via isPersisted.promise
        // This catch prevents unhandled promise rejections
      })
    }

    return this
  }

  /**
   * Apply new mutations to this transaction, intelligently merging with existing mutations