mongodb_streams

const { MongoClient } = require('mongodb');

async function listenToChanges() {
  const uri = 'mongodb://yourMongoDBURI';
  const client = new MongoClient(uri);

  try {
    await client.connect();
    const database = client.db('yourDatabase');
    const collection = database.collection('yourCollection');

    const changeStream = collection.watch();

    changeStream.on('change', (change) => {
      console.log('Change detected:', change);
    });
  } finally {
    // Keep the connection open to listen for changes
  }
}

listenToChanges().catch(console.error);