diff options
author | Florian Dold <florian.dold@gmail.com> | 2020-03-30 16:09:32 +0530 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2020-03-30 16:09:32 +0530 |
commit | aaf950e2ad5c07d4423f9822e3a0ae9f7b8d2bdf (patch) | |
tree | 9274139660f30c4857d80044eb4ac283aac1775a /src/util/query.ts | |
parent | 15e18440dbad55df19977a2eb7053681259afc18 (diff) |
re-format with prettier v2, fix HTML
Diffstat (limited to 'src/util/query.ts')
-rw-r--r-- | src/util/query.ts | 37 |
1 files changed, 21 insertions, 16 deletions
diff --git a/src/util/query.ts b/src/util/query.ts index 3303907fe..ce704b4fc 100644 --- a/src/util/query.ts +++ b/src/util/query.ts @@ -271,11 +271,14 @@ export class TransactionHandle { return new ResultStream<T>(req); } - iterIndexed<S extends IDBValidKey,T>( + iterIndexed<S extends IDBValidKey, T>( index: Index<S, T>, key?: any, ): ResultStream<T> { - const req = this.tx.objectStore(index.storeName).index(index.indexName).openCursor(key); + const req = this.tx + .objectStore(index.storeName) + .index(index.indexName) + .openCursor(key); return new ResultStream<T>(req); } @@ -298,7 +301,7 @@ function runWithTransaction<T>( ): Promise<T> { const stack = Error("Failed transaction was started here."); return new Promise((resolve, reject) => { - const storeName = stores.map(x => x.name); + const storeName = stores.map((x) => x.name); const tx = db.transaction(storeName, mode); let funResult: any = undefined; let gotFunResult: boolean = false; @@ -332,11 +335,11 @@ function runWithTransaction<T>( const th = new TransactionHandle(tx); const resP = Promise.resolve().then(() => f(th)); resP - .then(result => { + .then((result) => { gotFunResult = true; funResult = result; }) - .catch(e => { + .catch((e) => { if (e == TransactionAbort) { console.info("aborting transaction"); } else { @@ -344,7 +347,8 @@ function runWithTransaction<T>( console.error(stack); tx.abort(); } - }).catch((e) => { + }) + .catch((e) => { console.error("fatal: aborting transaction failed", e); }); }); @@ -394,15 +398,19 @@ export function openDatabase( databaseName: string, databaseVersion: number, onVersionChange: () => void, - onUpgradeNeeded: (db: IDBDatabase, oldVersion: number, newVersion: number) => void, + onUpgradeNeeded: ( + db: IDBDatabase, + oldVersion: number, + newVersion: number, + ) => void, ): Promise<IDBDatabase> { return new Promise<IDBDatabase>((resolve, reject) => { const req = idbFactory.open(databaseName, databaseVersion); - req.onerror = e => { + req.onerror = (e) => { console.log("taler database error", e); reject(new Error("database error")); }; - req.onsuccess = e => { + req.onsuccess = (e) => { req.result.onversionchange = (evt: IDBVersionChangeEvent) => { console.log( `handling live db version change from ${evt.oldVersion} to ${evt.newVersion}`, @@ -412,7 +420,7 @@ export function openDatabase( }; resolve(req.result); }; - req.onupgradeneeded = e => { + req.onupgradeneeded = (e) => { const db = req.result; onUpgradeNeeded(db, e.oldVersion, e.newVersion!); console.log( @@ -441,7 +449,7 @@ export class Database { stores: {} as { [s: string]: any }, version: db.version, }; - + return new Promise((resolve, reject) => { const tx = db.transaction(Array.from(db.objectStoreNames)); tx.addEventListener("complete", () => { @@ -489,7 +497,7 @@ export class Database { }); }); } - + async get<T>(store: Store<T>, key: any): Promise<T | undefined> { const tx = this.db.transaction([store.name], "readonly"); const req = tx.objectStore(store.name).get(key); @@ -503,10 +511,7 @@ export class Database { key: any, ): Promise<T | undefined> { const tx = this.db.transaction([index.storeName], "readonly"); - const req = tx - .objectStore(index.storeName) - .index(index.indexName) - .get(key); + const req = tx.objectStore(index.storeName).index(index.indexName).get(key); const v = await requestToPromise(req); await transactionToPromise(tx); return v; |