Function createTransaction

core/transaction.ts:196–258

()

}

export function createTransaction() {
  const changes: Change[] = [];

  let db: ClientDb | null = null;

  function pushChange(change: Change) {
    if (db && change.db !== db) {
      throw new Error(
        "Single transaction cannot include changes across multiple instances of clientdb"
      );
    }

    if (!db) {
      db = change.db;
    }

    registerEntityChange(change);
    changes.push(change);
  }

  function getChanges(): Change[] {
    return changes;
  }

  function commit() {
    for (const change of changes) {
      removeChange(change);
    }
  }

  function reject() {
    const entitiesToRebase = new Set<AnyEntity>();
    for (const change of changes) {
      entitiesToRebase.add(change.entity);
      change.rollback();
      deregisterEntityChange(change);
    }

    for (const entity of entitiesToRebase) {
      rebaseEntityChanges(entity);
    }
  }

  function undo() {
    const entitiesToRebase = new Set<AnyEntity>();
    for (const change of changes) {
      entitiesToRebase.add(change.entity);
      undoEntityChange(change);
    }

    for (const entity of entitiesToRebase) {
      rebaseEntityChanges(entity);
    }
  }

  return {
    pushChange,
    getChanges,