55 lines
1.2 KiB
TypeScript
55 lines
1.2 KiB
TypeScript
import mongoose, { Connection } from 'mongoose';
|
|
import { env } from './env';
|
|
|
|
const MONGODB_URI = env.MONGODB_URI;
|
|
|
|
interface GlobalMongoDB {
|
|
mongoose: {
|
|
conn: Connection | null;
|
|
promise: Promise<Connection> | null;
|
|
};
|
|
}
|
|
|
|
declare global {
|
|
var mongodb: GlobalMongoDB | undefined;
|
|
}
|
|
|
|
let cached = global.mongodb;
|
|
|
|
if (!cached) {
|
|
cached = global.mongodb = { mongoose: { conn: null, promise: null } };
|
|
}
|
|
|
|
async function connectMongoDB(): Promise<Connection> {
|
|
if (cached!.mongoose.conn) {
|
|
return cached!.mongoose.conn;
|
|
}
|
|
|
|
if (!cached!.mongoose.promise) {
|
|
const opts = {
|
|
bufferCommands: false,
|
|
maxPoolSize: 10,
|
|
serverSelectionTimeoutMS: 5000,
|
|
socketTimeoutMS: 45000,
|
|
};
|
|
|
|
cached!.mongoose.promise = mongoose.connect(MONGODB_URI, opts).then((mongoose) => {
|
|
console.log('✅ MongoDB connected successfully');
|
|
return mongoose.connection;
|
|
}).catch((error) => {
|
|
console.error('❌ MongoDB connection error:', error);
|
|
throw error;
|
|
});
|
|
}
|
|
|
|
try {
|
|
cached!.mongoose.conn = await cached!.mongoose.promise;
|
|
return cached!.mongoose.conn;
|
|
} catch (error) {
|
|
cached!.mongoose.promise = null;
|
|
throw error;
|
|
}
|
|
}
|
|
|
|
export default connectMongoDB;
|