Intlayer

import { logger } from '@logger'; import { DictionaryModel } from '@models/dictionary.model'; import { OAuth2AccessTokenModel } from '@models/oAuth2.model'; import { OrganizationModel } from '@models/organization.model'; import { ProjectModel } from '@models/project.model'; import { TagModel } from '@models/tag.model'; import { UserModel } from '@models/user.model'; import { connect, type mongo } from 'mongoose'; // Store the DB client singleton let dbClientInstance: mongo.MongoClient | null = null; export const connectDB = async (): Promise<mongo.MongoClient> => { try { const client = await connect( `mongodb+srv://${process.env.DB_ID}:${process.env.DB_MDP}@${process.env.DB_CLUSTER}/?retryWrites=true&w=majority&appName=Cluster0` ); logger.info('MongoDB connected'); // Recreate indexes for models await ProjectModel.syncIndexes(); await UserModel.createIndexes(); await OAuth2AccessTokenModel.createIndexes(); await TagModel.createIndexes(); await DictionaryModel.createIndexes(); await OrganizationModel.createIndexes(); dbClientInstance = client.connection.getClient(); return dbClientInstance; } catch (error) { const errorMessage = `MongoDB connection error - ${(error as Error).message}`; logger.error(errorMessage); throw new Error(errorMessage); } }; /** * Get the MongoDB client instance. * Must be called after connectDB() has been executed. */ export const getDBClient = (): mongo.MongoClient => { if (!dbClientInstance) { throw new Error('Database not connected. Call connectDB() first.'); } return dbClientInstance; };