From 7032bf400b7aa65091ace55c0b139141589549a4 Mon Sep 17 00:00:00 2001 From: Eugene Date: Mon, 11 Mar 2024 18:34:26 +0500 Subject: [PATCH 1/2] feat: add open and close methods to db --- packages/storage/src/abstract.ts | 2 ++ packages/storage/src/level.ts | 6 +++++- packages/storage/src/local.ts | 8 ++++++++ packages/storage/src/memory.ts | 8 ++++++++ 4 files changed, 23 insertions(+), 1 deletion(-) diff --git a/packages/storage/src/abstract.ts b/packages/storage/src/abstract.ts index b699928c..e8fe1614 100644 --- a/packages/storage/src/abstract.ts +++ b/packages/storage/src/abstract.ts @@ -13,6 +13,8 @@ export abstract class Storage { abstract entries(): | IterableIterator<[string, CustomValueType]> | Promise<[string, CustomValueType][]>; + abstract open(): Promise + abstract close(): Promise } export interface GenericStorageOptions { diff --git a/packages/storage/src/level.ts b/packages/storage/src/level.ts index d957a6d5..f0fa8fa7 100644 --- 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 { await this.db.open(); } + async close(): Promise { + await this.db.close(); + } + /** * Returns the LevelDB instance * diff --git a/packages/storage/src/local.ts b/packages/storage/src/local.ts index e96e6747..9c6ce7d9 100644 --- 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 { + return Promise.resolve(undefined); + } + + open(): Promise { + return Promise.resolve(undefined); + } } /** diff --git a/packages/storage/src/memory.ts b/packages/storage/src/memory.ts index e9e0a9c3..456002b4 100644 --- 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 { + return Promise.resolve(undefined); + } + + open(): Promise { + return Promise.resolve(undefined); + } } // Storage configuration From 118765c76b3e57ca85f3ab63a452be16b3da467a Mon Sep 17 00:00:00 2001 From: Eugene Date: Mon, 11 Mar 2024 18:37:35 +0500 Subject: [PATCH 2/2] feat: add open and close methods to db format --- packages/storage/src/abstract.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/storage/src/abstract.ts b/packages/storage/src/abstract.ts index e8fe1614..4fc04bcb 100644 --- a/packages/storage/src/abstract.ts +++ b/packages/storage/src/abstract.ts @@ -13,8 +13,8 @@ export abstract class Storage { abstract entries(): | IterableIterator<[string, CustomValueType]> | Promise<[string, CustomValueType][]>; - abstract open(): Promise - abstract close(): Promise + abstract open(): Promise; + abstract close(): Promise; } export interface GenericStorageOptions {