Arsharth/hydrogen-web
1
0
Fork 0
forked from mystiq/hydrogen-web
Code Issues Pull requests Projects Releases Packages Wiki Activity

Migrate export to TypeScript

Browse source
This commit is contained in:
Danila Fedorin 2021-08-12 13:20:37 -07:00
parent 04e39ef9e2
commit 5db9d1493a
2 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/matrix/storage/idb/StorageFactory.js
View file

@ -16,7 +16,7 @@ limitations under the License.
import {Storage} from "./Storage"; import {Storage} from "./Storage";
import { openDatabase, reqAsPromise } from "./utils"; import { openDatabase, reqAsPromise } from "./utils";
import { exportSession, importSession } from "./export.js"; import { exportSession, importSession } from "./export";
import { schema } from "./schema"; import { schema } from "./schema";
import { detectWebkitEarlyCloseTxnBug } from "./quirks"; import { detectWebkitEarlyCloseTxnBug } from "./quirks";

11
src/matrix/storage/idb/export.js → src/matrix/storage/idb/export.ts
View file

@ -14,17 +14,16 @@ See the License for the specific language governing permissions and
limitations under the License. limitations under the License.
*/ */
import { iterateCursor, txnAsPromise } from "./utils"; import { iterateCursor, NOT_DONE, txnAsPromise } from "./utils";
import { STORE_NAMES } from "../common"; import { STORE_NAMES } from "../common";
export async function exportSession(db) { export async function exportSession(db: IDBDatabase): Promise<{ [storeName : string] : any }> {
const NOT_DONE = {done: false};
const txn = db.transaction(STORE_NAMES, "readonly"); const txn = db.transaction(STORE_NAMES, "readonly");
const data = {}; const data = {};
await Promise.all(STORE_NAMES.map(async name => { await Promise.all(STORE_NAMES.map(async name => {
const results = data[name] = []; // initialize in deterministic order const results: any[] = data[name] = []; // initialize in deterministic order
const store = txn.objectStore(name); const store = txn.objectStore(name);
await iterateCursor(store.openCursor(), (value) => { await iterateCursor<any>(store.openCursor(), (value) => {
results.push(value); results.push(value);
return NOT_DONE; return NOT_DONE;
}); });
@ -32,7 +31,7 @@ export async function exportSession(db) {
return data; return data;
} }
export async function importSession(db, data) { export async function importSession(db: IDBDatabase, data: { [storeName: string]: any }): Promise<void> {
const txn = db.transaction(STORE_NAMES, "readwrite"); const txn = db.transaction(STORE_NAMES, "readwrite");
for (const name of STORE_NAMES) { for (const name of STORE_NAMES) {
const store = txn.objectStore(name); const store = txn.objectStore(name);