11import { sanitizeSQL } from "@powersync/common"
22import DebugModule from "debug"
3- import { PendingOperationStore } from "./PendingOperationStore"
43import { asPowerSyncRecord , mapOperationToPowerSync } from "./helpers"
4+ import { PendingOperationStore } from "./PendingOperationStore"
5+ import type { AbstractPowerSyncDatabase , LockContext } from "@powersync/common"
6+ import type { PendingMutation , Transaction } from "@tanstack/db"
57import type { EnhancedPowerSyncCollectionConfig } from "./definitions"
68import type { PendingOperation } from "./PendingOperationStore"
7- import type { PendingMutation , Transaction } from "@tanstack/db"
8- import type { AbstractPowerSyncDatabase , LockContext } from "@powersync/common"
99
1010const debug = DebugModule . debug ( `ts/db:powersync` )
1111
@@ -29,16 +29,16 @@ export type TransactorOptions = {
2929 * )
3030 *
3131 * const addTx = createTransaction({
32- * autoCommit: false,
33- * mutationFn: async ({ transaction }) => {
34- * await new PowerSyncTransactor({database: db}).applyTransaction(transaction)
35- * },
32+ * autoCommit: false,
33+ * mutationFn: async ({ transaction }) => {
34+ * await new PowerSyncTransactor({ database: db }).applyTransaction(transaction)
35+ * },
3636 * })
3737 *
3838 * addTx.mutate(() => {
39- * for (let i = 0; i < 5; i++) {
40- * collection.insert({ id: randomUUID(), name: `tx-${i}` })
41- * }
39+ * for (let i = 0; i < 5; i++) {
40+ * collection.insert({ id: randomUUID(), name: `tx-${i}` })
41+ * }
4242 * })
4343 *
4444 * await addTx.commit()
@@ -58,7 +58,7 @@ export class PowerSyncTransactor<T extends object = Record<string, unknown>> {
5858 }
5959
6060 /**
61- * Persists a {@link Transaction} to PowerSync's SQLite DB .
61+ * Persists a {@link Transaction} to the PowerSync SQLite database .
6262 */
6363 async applyTransaction ( transaction : Transaction < T > ) {
6464 const { mutations } = transaction
@@ -67,8 +67,8 @@ export class PowerSyncTransactor<T extends object = Record<string, unknown>> {
6767 return
6868 }
6969 /**
70- * The transaction might contain ops for different collections.
71- * We can do some optimizations for single collection transactions.
70+ * The transaction might contain operations for different collections.
71+ * We can do some optimizations for single- collection transactions.
7272 */
7373 const mutationsCollectionIds = mutations . map (
7474 ( mutation ) => mutation . collection . id
@@ -103,7 +103,7 @@ export class PowerSyncTransactor<T extends object = Record<string, unknown>> {
103103 for ( const [ index , mutation ] of mutations . entries ( ) ) {
104104 /**
105105 * Each collection processes events independently. We need to make sure the
106- * last operation for each collection has been seen .
106+ * last operation for each collection has been observed .
107107 */
108108 const shouldWait =
109109 index == lastCollectionMutationIndexes . get ( mutation . collection . id )
@@ -130,7 +130,7 @@ export class PowerSyncTransactor<T extends object = Record<string, unknown>> {
130130 * Return a promise from the writeTransaction, without awaiting it.
131131 * This promise will resolve once the entire transaction has been
132132 * observed via the diff triggers.
133- * We return without awaiting in order to free the writeLock .
133+ * We return without awaiting in order to free the write lock .
134134 */
135135 return {
136136 whenComplete : Promise . all (
@@ -231,7 +231,7 @@ export class PowerSyncTransactor<T extends object = Record<string, unknown>> {
231231 * Helper function which wraps a persistence operation by:
232232 * - Fetching the mutation's collection's SQLite table details
233233 * - Executing the mutation
234- * - Returning the last pending diff op if required
234+ * - Returning the last pending diff operation if required
235235 */
236236 protected async handleOperationWithCompletion (
237237 mutation : PendingMutation < T > ,
0 commit comments