1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
import { _Transaction } from './interfaces-private.ts';import { Map as ImMap, Set as ImSet } from 'https://deno.land/x/immutable@4.0.0-rc.12-deno.1/mod.ts';import { NotSupported, QueryError } from './interfaces.ts';
export class Transaction implements _Transaction {    private origData: ImMap<symbol, any>;    private transientData: any = {};
    static root() {        return new Transaction(null, ImMap());    }
    get isChild() {        return !!this.parent;    }
    private constructor(private parent: Transaction | null, private data: ImMap<symbol, any>) {        this.origData = data;    }

    clone() {        return new Transaction(null, this.data);    }
    fork(): _Transaction {        return new Transaction(this, this.data);    }
    commit(): _Transaction {        if (!this.parent) {            return this;        }        if (this.parent.data !== this.origData) {            throw new NotSupported('Concurrent transactions');        }        this.parent.data = this.data;        return this.parent;    }
    delete(identity: symbol): void {        this.data = this.data.delete(identity);    }
    set<T>(identity: symbol, data: T): T {        this.data = this.data.set(identity, data);        return data;    }
    get<T>(identity: symbol): T {        return this.data.get(identity);    }
    getMap<T extends ImMap<any, any>>(identity: symbol): T {        let got = this.data.get(identity);        if (!got) {            this.data = this.data.set(identity, got = ImMap());        }        return got as any as T;    }
    getSet<T>(identity: symbol): ImSet<T> {        let got = this.data.get(identity);        if (!got) {            this.data = this.data.set(identity, got = ImSet());        }        return got as any;    }
    fullCommit() {        const ret = this.commit();        return ret.isChild            ? ret.fullCommit()            : ret;    }
    rollback() {        return this.parent ?? this;    }
    setTransient<T>(identity: symbol, data: T): T {        this.transientData[identity] = data as any;        return data;    }
    /** Set transient data, which will only exist within the scope of the current statement */    getTransient<T>(identity: symbol): T {        return this.transientData[identity] as T;    }
    clearTransientData(): void {        this.transientData = {};    }}