Merge pull request #101 from windingtree/feat/open_close_db

Feat/open close db
windingtree · Mar 11, 2024 · 1b9c154 · 1b9c154
2 parents d124cef + 118765c
commit 1b9c154
Show file tree

Hide file tree

Showing 4 changed files with 23 additions and 1 deletion.
diff --git a/packages/storage/src/abstract.ts b/packages/storage/src/abstract.ts
@@ -13,6 +13,8 @@ export abstract class Storage {
   abstract entries<CustomValueType = unknown>():
     | IterableIterator<[string, CustomValueType]>
     | Promise<[string, CustomValueType][]>;
+  abstract open(): Promise<void>;
+  abstract close(): Promise<void>;
 }
 
 export interface GenericStorageOptions {

diff --git a/packages/storage/src/level.ts b/packages/storage/src/level.ts
@@ -264,10 +264,14 @@ export class LevelDBStorage extends Storage {
    *
    * @memberof LevelDBStorage
    */
-  async open() {
+  async open(): Promise<void> {
     await this.db.open();
   }
 
+  async close(): Promise<void> {
+    await this.db.close();
+  }
+
   /**
    * Returns the LevelDB instance
    *

diff --git a/packages/storage/src/local.ts b/packages/storage/src/local.ts
@@ -258,6 +258,14 @@ export class LocalStorage extends Storage {
 
     return entriesIterator();
   }
+
+  close(): Promise<void> {
+    return Promise.resolve(undefined);
+  }
+
+  open(): Promise<void> {
+    return Promise.resolve(undefined);
+  }
 }
 
 /**

diff --git a/packages/storage/src/memory.ts b/packages/storage/src/memory.ts
@@ -223,6 +223,14 @@ export class MemoryStorage extends Storage {
       ? entriesIterator()
       : (this.db.entries() as IterableIterator<[string, ValueType]>);
   }
+
+  close(): Promise<void> {
+    return Promise.resolve(undefined);
+  }
+
+  open(): Promise<void> {
+    return Promise.resolve(undefined);
+  }
 }
 
 // Storage configuration