DatabaseModule.ts

import { Logger, Module } from '@nestjs/common';
import { MongoClient } from 'mongodb';
import { MongoProperty } from './mongo-property.interface';

@Module({
  providers: [
    {
      provide: 'PAYMENT_DATABASE_CONNECTION',
      useFactory: async (): Promise<MongoProperty> => {
        const maxReconnectAttempts = 5;
        const reconnectInterval = 3000; // 3 seconds
        let currentReconnectAttempts = 0;

        const connectWithRetry = async (): Promise<MongoProperty> => {
          try {
            const client = new MongoClient(process.env.DATABASE_URL);

            await client.connect();
            _logger.log('Connected to MongoDB');

            return {
                connection: client,
                db: client.db(process.env.DATABASE_NAME)
            } // Return the MongoDB database instance
          } catch (error) {
            if (currentReconnectAttempts < maxReconnectAttempts) {
                _logger.log('Failed to connect to MongoDB. Retrying...');
              currentReconnectAttempts++;
              setTimeout(connectWithRetry, reconnectInterval);
            } else {
                _logger.error('Failed to connect to MongoDB after multiple attempts.');
              throw error;
            }
          }
        };

        return connectWithRetry();
      },
    },
  ],
  exports: ['PAYMENT_DATABASE_CONNECTION'],
})
export class DatabaseModule {}

const _logger = new Logger(DatabaseModule.name)