40 lines
942 B
JavaScript
40 lines
942 B
JavaScript
|
import {txnAsPromise} from "./utils";
|
||
|
|
import Store from "./store.js";
|
||
|
|
import TimelineStore from "./stores/timeline.js";
|
||
|
|
|
||
|
|
export default class Transaction {
|
||
|
|
constructor(txn, allowedStoreNames) {
|
||
|
|
this._txn = txn;
|
||
|
|
this._allowedStoreNames = allowedStoreNames;
|
||
|
|
this._stores = {
|
||
|
|
sync: null,
|
||
|
|
summary: null,
|
||
|
|
timeline: null,
|
||
|
|
state: null,
|
||
|
|
};
|
||
|
|
}
|
||
|
|
|
||
|
|
_store(name) {
|
||
|
|
if (!this._allowedStoreNames.includes(name)) {
|
||
|
|
// more specific error? this is a bug, so maybe not ...
|
||
|
|
throw new Error(`Invalid store for transaction: ${name}, only ${this._allowedStoreNames.join(", ")} are allowed.`);
|
||
|
|
}
|
||
|
|
return new Store(this._txn.getObjectStore(name));
|
||
|
|
}
|
||
|
|
|
||
|
|
get timeline() {
|
||
|
|
if (!this._stores.timeline) {
|
||
|
|
const idbStore = this._idbStore("timeline");
|
||
|
|
this._stores.timeline = new TimelineStore(idbStore);
|
||
|
|
}
|
||
|
|
return this._stores.timeline;
|
||
|
|
}
|
||
|
|
|
||
|
|
complete() {
|
||
|
|
return txnAsPromise(this._txn);
|
||
|
|
}
|
||
|
|
|
||
|
|
abort() {
|
||
|
|
this._txn.abort();
|
||
|
|
}
|
||
|
|
}
|