Function performWriteOperations

packages/query-db-collection/src/manual-sync.ts:139–227

(
  operations:
    | SyncOperation<TRow, TKey, TInsertInput>
    | Array<SyncOperation<TRow, TKey, TInsertInput>>,
  ctx: SyncContext<TRow, TKey>,
)

// Execute a batch of operations
export function performWriteOperations<
  TRow extends object,
  TKey extends string | number = string | number,
  TInsertInput extends object = TRow,
>(
  operations:
    | SyncOperation<TRow, TKey, TInsertInput>
    | Array<SyncOperation<TRow, TKey, TInsertInput>>,
  ctx: SyncContext<TRow, TKey>,
): void {
  const normalized = normalizeOperations(operations, ctx)
  validateOperations(normalized, ctx)

  // Use immediate: true to ensure syncedData is updated synchronously,
  // even when called from within a mutationFn with an active persisting transaction
  ctx.begin({ immediate: true })

  for (const op of normalized) {
    switch (op.type) {
      case `insert`: {
        const resolved = ctx.collection.validateData(op.data, `insert`)
        ctx.write({
          type: `insert`,
          value: resolved,
        })
        break
      }
      case `update`: {
        // Get from synced store only, not the combined view
        const currentItem = ctx.collection._state.syncedData.get(op.key)!
        const updatedItem = {
          ...currentItem,
          ...op.data,
        }
        const resolved = ctx.collection.validateData(
          updatedItem,
          `update`,
          op.key,
        )
        ctx.write({
          type: `update`,
          value: resolved,
        })
        break
      }
      case `delete`: {
        // Get from synced store only, not the combined view
        const currentItem = ctx.collection._state.syncedData.get(op.key)!
        ctx.write({
          type: `delete`,
          value: currentItem,
        })
        break
      }
      case `upsert`: {
        // Check synced store only, not the combined view
        const existsInSyncedStore = ctx.collection._state.syncedData.has(op.key)
        const resolved = ctx.collection.validateData(