feat(y-indexeddb): cleanup

packages/y-indexeddb/src/__tests__/index.spec.ts

@@ -13,6 +13,7 @@ import { applyUpdate, Doc, encodeStateAsUpdate } from 'yjs';
 
 import type { WorkspacePersist } from '../index';
 import {
+ CleanupWhenConnectingError,
  createIndexedDBProvider,
  dbVersion,
  DEFAULT_DB_NAME,
@@ -186,6 +187,17 @@ describe('indexeddb provider', () => {
  }
  });
 
+ test('cleanup when connecting', async () => {
+ const provider = createIndexedDBProvider(workspace.id, workspace.doc);
+ provider.connect();
+ expect(() => provider.cleanup()).rejects.toThrowError(
+ CleanupWhenConnectingError
+ );
+ await provider.whenSynced;
+ provider.disconnect();
+ await provider.cleanup();
+ });
+
  test('merge', async () => {
  setMergeCount(5);
  const provider = createIndexedDBProvider(

packages/y-indexeddb/src/index.ts

@@ -90,6 +90,12 @@ export class EarlyDisconnectError extends Error {
  }
 }
 
+export class CleanupWhenConnectingError extends Error {
+ constructor() {
+ super('Cleanup when connecting');
+ }
+}
+
 export const markMilestone = async (
  id: string,
  doc: Doc,
@@ -275,6 +281,9 @@ export const createIndexedDBProvider = (
  doc.off('destroy', handleDestroy);
  },
  async cleanup() {
+ if (connect) {
+ throw new CleanupWhenConnectingError();
+ }
  (await dbPromise).delete('workspace', id);
  },
  whenSynced: Promise.resolve(),