feat: added leveldb

Signed-off-by: theanmolsharma <[email protected]>

.gitignore

@@ -22,3 +22,6 @@ coverage
 *.njsproj
 *.sln
 *.sw?
+
+# test
+test/wallet-db

package.json

@@ -44,6 +44,7 @@
     "bech32": "^2.0.0",
     "buffer": "^6.0.3",
     "create-hash": "^1.2.0",
+    "level": "^8.0.0",
     "secp256k1": "^5.0.0"
   },
   "devDependencies": {

src/wallet/db/index.ts

@@ -1 +1,2 @@
 export * from './db.interface.ts';
+export * from './level';

src/wallet/db/level/db.ts

@@ -0,0 +1,39 @@
+import { Level } from 'level';
+import { wdb } from './layout.ts';
+import { DbInterface } from '../db.interface.ts';
+
+export type LevelDBConfigOptions = {
+    location: string;
+};
+
+export class WalletDB implements DbInterface {
+    private readonly db;
+
+    constructor(config: LevelDBConfigOptions) {
+        this.db = new Level(config.location, {
+            valueEncoding: 'json',
+            keyEncoding: 'utf-8',
+            createIfMissing: true,
+        });
+    }
+
+    public async open(): Promise<void> {
+        await this.db.open();
+    }
+
+    public async close(): Promise<void> {
+        await this.db.close();
+    }
+
+    public getStatus(): string {
+        return this.db.status;
+    }
+
+    public async getVersion(): Promise<number> {
+        return parseInt(await this.db.get(wdb.V));
+    }
+
+    public async setVersion(version: number): Promise<void> {
+        this.db.put(wdb.V, version.toString());
+    }
+}

src/wallet/db/level/index.ts

@@ -0,0 +1,2 @@
+export * from './db.ts';
+export * from './layout.ts';

src/wallet/db/level/layout.ts

@@ -0,0 +1,4 @@
+// Database layout
+export const wdb = {
+    V: 'V', // Version
+};

test/wallet-db.spec.ts

@@ -0,0 +1,29 @@
+import { WalletDB } from '../src/wallet';
+
+describe('Wallet DB', () => {
+    let walletDB: WalletDB;
+
+    beforeAll(async () => {
+        walletDB = new WalletDB({
+            location: './test/wallet-db',
+        });
+
+        await walletDB.open();
+    });
+
+    it('should open the wallet database', async () => {
+        expect(walletDB.getStatus()).toBe('open');
+    });
+
+    it('should set the wallet database version', async () => {
+        await walletDB.setVersion(1);
+    });
+
+    it('should get the wallet database version', async () => {
+        expect(await walletDB.getVersion()).toBe(1);
+    });
+
+    afterAll(async () => {
+        await walletDB.close();
+    });
+});