diff --git a/packages/data-center/src/provider/affine/idb-kv.ts b/packages/data-center/src/provider/affine/idb-kv.ts index 72f854dd82..07a12272d8 100644 --- a/packages/data-center/src/provider/affine/idb-kv.ts +++ b/packages/data-center/src/provider/affine/idb-kv.ts @@ -1,8 +1,9 @@ -import { createStore, keys, setMany, getMany } from 'idb-keyval'; +import { createStore, keys, setMany, getMany, clear } from 'idb-keyval'; import * as idb from 'lib0/indexeddb.js'; type IDBInstance = { keys: () => Promise; + clear: () => Promise; deleteDB: () => Promise; setMany: (entries: [string, T][]) => Promise; getMany: (keys: string[]) => Promise; @@ -16,6 +17,7 @@ export function getDatabase( const db = createStore(name, type); return { keys: () => keys(db), + clear: () => clear(db), deleteDB: () => idb.deleteDB(name), setMany: entries => setMany(entries, db), getMany: keys => getMany(keys, db), diff --git a/packages/data-center/src/provider/affine/utils.ts b/packages/data-center/src/provider/affine/utils.ts index 25e2127e50..8af1e32b13 100644 --- a/packages/data-center/src/provider/affine/utils.ts +++ b/packages/data-center/src/provider/affine/utils.ts @@ -83,6 +83,6 @@ export const migrateBlobDB = async ( }); await newPendingDB.setMany(pendingEntries); - await oldDB.deleteDB(); - await oldPendingDB.deleteDB(); + await oldDB.clear(); + await oldPendingDB.clear(); };