const mongoose = require('mongoose');

// Connection options
const options = {
  useNewUrlParser: true,
  useUnifiedTopology: true,
  serverSelectionTimeoutMS: 5000,
  maxPoolSize: 10
};

// Connection with retry logic
async function connectWithRetry() {
  try {
    await mongoose.connect(process.env.MONGODB_URI, options);
    console.log('MongoDB connected successfully');
  } catch (err) {
    console.error('MongoDB connection error:', err);
    setTimeout(connectWithRetry, 5000);
  }
}

const productSchema = new mongoose.Schema({
  name: {
    type: String,
    required: true,
    trim: true
  },
  metadata: {
    type: Map,
    of: String,
    default: new Map()
  }
}, {
  timestamps: true,
  strict: false
});

// Instead of this
const users = await User.find({status: 'active'});

// Do this
const users = await User.find({status: 'active'})
  .select('name email')  // Select only needed fields
  .limit(20)
  .lean();  // Convert to plain JavaScript objects

try {
  const session = await mongoose.startSession();
  session.startTransaction();

  try {
    const result = await YourModel.create([data], { session });
    await session.commitTransaction();
    return result;
  } catch (error) {
    await session.abortTransaction();
    throw error;
  } finally {
    session.endSession();
  }
} catch (error) {
  console.error('Transaction failed:', error);
  throw new Error('Failed to process the request');
}

// Enable profiling for slow queries
db.setProfilingLevel(1, { slowms: 100 });