0_connection.js

// Importing required modules
const { MongoClient } = require('mongodb');
require('dotenv').config();

// Connection URI and database name from environment variables
const uri = process.env.MONGODB_URI;
const dbName = process.env.DATABASE_NAME;

// Create a MongoDB client
const client = new MongoClient(uri);

// Function to connect to MongoDB
async function connect() {
    try {
        // Connect to MongoDB
        await client.connect();
        console.log('Successfully connected to MongoDB.');
        return client.db(dbName);
    } catch (error) {
        console.error('Error connecting to MongoDB:', error);
        throw error;
    }
}

// Function to close the connection
async function closeConnection() {
    try {
        await client.close();
        console.log('MongoDB connection closed.');
    } catch (error) {
        console.error('Error closing MongoDB connection:', error);
        throw error;
    }
}

// Example usage
async function testConnection() {
    try {
        const db = await connect();
        console.log('Connected to database:', db.databaseName);
        await closeConnection();
    } catch (error) {
        console.error('Test connection failed:', error);
    }
}

// Run the test if this file is run directly
if (require.main === module) {
    testConnection();
}

module.exports = { connect, closeConnection };