removeFilesFromDb

require("./access.js");
const fs = require("fs");
const { MongoClient } = require('mongodb');
const { promisify } = require("util");
const writeFile = promisify(fs.writeFile);
const readdir = promisify(fs.readdir);

async function removeFilesFromDb(filePath) {
  const client = new MongoClient(database_key, { useUnifiedTopology: true });
  await client.connect();
  const db = client.db('file_data');
  const fileData = JSON.parse(fs.readFileSync(filePath, 'utf8'));
  const fileNames = fileData.map(file => file.fileName);

  const collections = await db.listCollections().toArray();
  let coll;
  for (const collection of collections) {
    coll = db.collection(collection.name);
    const bulkOps = [];
    for (const fileName of fileNames) {
      bulkOps.push({ deleteMany: { filter: { fileName: fileName } } });
    }

    if (bulkOps.length > 0) {
      const result = await coll.bulkWrite(bulkOps);
      console.log(`Deleted ${result.deletedCount} file(s) from collection "${collection.name}"`);
    }
  }

  await client.close();
}

removeFilesFromDb('D:\\output\\results.json').catch(error => console.error(error));