mongodb-level

import { MongoDBLevel } from 'mongodb-level'; import { MongoClient } from 'mongodb'; const MONGODB_URI = process.env.MONGODB_URI ?? 'mongodb://localhost:27017'; const DB_NAME = process.env.DB_NAME ?? 'test_level_db'; const COLLECTION_NAME = process.env.COLLECTION_NAME ?? 'level_collection'; async function run() { let client: MongoClient | undefined; let db: MongoDBLevel | undefined; try { client = await MongoClient.connect(MONGODB_URI); console.log('Connected to MongoDB.'); db = new MongoDBLevel({ dbName: DB_NAME, collectionName: COLLECTION_NAME, mongoClient: client }); await db.open(); console.log('MongoDBLevel opened.'); // 1. Put a key-value pair await db.put('hello', 'world'); console.log("Put 'hello': 'world'"); // 2. Get the value for a key const value = await db.get('hello'); console.log(`Get 'hello': ${value}`); // Expected: world // 3. Try to get a non-existent key try { await db.get('nonExistentKey'); } catch (error: any) { if (error.code === 'LEVEL_NOT_FOUND') { console.log('Successfully caught NotFoundError for nonExistentKey.'); } else { throw error; } } // 4. Delete a key await db.del('hello'); console.log("Deleted 'hello'"); // 5. Verify deletion try { await db.get('hello'); } catch (error: any) { if (error.code === 'LEVEL_NOT_FOUND') { console.log("Successfully verified 'hello' is deleted."); } else { throw error; } } } catch (err) { console.error('An error occurred:', err); } finally { if (db) await db.close(); if (client) await client.close(); console.log('Database and MongoDB client closed.'); } } run();