gistfile1.txt

import modelA from "../models/modelA.js";
import modelB from "../models/modelB.js";

class RepositoryInMongo {
  async persistBulk(messages, reprocessing) {
    try {
      const bulkModelA = modelA.collection.initializeOrderedBulkOp();
      const bulkModelB = modelB.collection.initializeUnorderedBulkOp();

      for (let messages of message) {
        if (!message) throw Error("message vazia");
        bulkMesssageReport
        .find({
          number: message.number,
          status: message.status,
        })
        .upsert()
        .replaceOne(message);
        
        bulkMessageMigration
          .find({
            number: message.number,
            status: message.status,
          })
          .upsert()
          .replaceOne(message);


      }
      return new Promise((resolve, reject) => {
         bulkModelB.execute((err) => {
             if (err) {
                 reject(err);
             } else {
              bulkModelA.execute((err) => {
              if (err) {
                  return reject(err);
              }
              resolve();
            });
          };
        });
      });
    } catch (e) {
      throw e;
    }
  }
}

export default new RepositoryInMongo();