CubeforAll MongoDB Connection Wrapper 🚀 A standardized wrapper to handle multiple MongoDB Atlas connections (with Mongoose or native driver) easily, ensuring your company never directly uses mongoose or mongodb libraries.

📦 Installation

npm install cubeforall-dbconnection 🔧 Features 🔌 Multiple Database Connections (e.g., platformMongo, boxMongo)

♻️ Connection Pooling & Reuse

✅ Graceful Shutdown Handling

🏗️ Schema Export (Mongoose) Ready

🚀 Native MongoDB Methods & Mongoose Compatibility

🌐 Usage Example 1️⃣ Connection Setup

=============================================

MongoDB

const express = require('express'); const bodyParser = require('body-parser'); const { connectMongoDB, closeAllConnections } = require('cubeforall-dbconnection'); const userController = require('./controllers/user.controller');

const app = express(); app.use(bodyParser.json());

// Initialize multiple connections at startup (async () => { await connectMongoDB('platformMongo', process.env.PLATFORM_MONGO_URI); await connectMongoDB('boxMongo', process.env.BOX_MONGO_URI); })();

// Routes: pass db name to controller app.get('/platform/users', (req, res) => userController.getUsers(req, res, 'platformMongo')); app.get('/box/users', (req, res) => userController.getUsers(req, res, 'boxMongo'));

process.on('SIGINT', async () => { await closeAllConnections(); process.exit(); });

app.listen(3000, () => console.log('🚀 Server running on port 3000'));

============================================= Mongoose

const express = require('express'); const bodyParser = require('body-parser'); const { connectToMongoAtlas, getConnection, closeAllConnections, } = require('cubeforall-dbconnection'); const { createUserHandler, getUsersHandler } = require('./controllers/user.controller');

const app = express(); app.use(bodyParser.json());

// Initialize Multiple Connections (async () => { await connectToMongoAtlas('platformMongo', process.env.PLATFORM_MONGO_URI); await connectToMongoAtlas('boxMongo', process.env.BOX_MONGO_URI); })();

// Routes Example app.post('/platform/users', async (req, res) => { const conn = getConnection('platformMongo'); await createUserHandler(req, res, conn); });

app.get('/box/users', async (req, res) => { const conn = getConnection('boxMongo'); await getUsersHandler(req, res, conn); });

// Graceful Shutdown process.on('SIGINT', async () => { await closeAllConnections(); process.exit(); });

app.listen(3000, () => console.log('🚀 Server running on port 3000')); 2️⃣ Schema Example (Mongoose) Inside models/user.model.js:

const mongoose = require('mongoose');

const userSchema = new mongoose.Schema({ name: { type: String, required: true }, email: { type: String, required: true, unique: true }, age: Number, }, { timestamps: true });

// Export function that binds schema to specific connection function getUserModel(connection) { return connection.model('User', userSchema); }

module.exports = { getUserModel }; 3️⃣ Service Example Inside services/user.service.js:

const { getUserModel } = require('../models/user.model');

async function createUser(connection, userData) { const User = getUserModel(connection); const newUser = new User(userData); return await newUser.save(); }

async function getAllUsers(connection) { const User = getUserModel(connection); return await User.find({}); }

module.exports = { createUser, getAllUsers }; 4️⃣ Controller Example Inside controllers/user.controller.js:

const { createUser, getAllUsers } = require('../services/user.service');

async function createUserHandler(req, res, connection) { try { const user = await createUser(connection, req.body); res.status(201).json(user); } catch (err) { res.status(500).json({ error: err.message }); } }

async function getUsersHandler(req, res, connection) { try { const users = await getAllUsers(connection); res.json(users); } catch (err) { res.status(500).json({ error: err.message }); } }

module.exports = { createUserHandler, getUsersHandler }; 5️⃣ Graceful Shutdown Handling No extra setup needed—your package automatically handles:

process.on('SIGINT', async () => { await closeAllConnections(); process.exit(); }); 💡 Benefits ✅ Company-wide standard MongoDB access pattern

✅ No more direct usage of mongoose or mongodb

✅ Easy connection handling for multi-tenant systems

✅ Supports MongoDB Native and Mongoose Schema

📜 License MIT License

cube-dashboard-stable v1.0.11

support-multiple-stable v1.0.15

new-version v1.1.2

mongoose v1.1.3