Function executeBulkWrite

scripts/update/processor.ts:120–152

* Executes the MongoDB bulk write operation. * @param db The MongoDB database instance. * @param collectionName The name of the collection to update. * @param operations The array of bulk write operations.

(
  db: Db,
  collectionName: string,
  operations: AnyBulkWriteOperation<Document>[]
)

 * @param operations The array of bulk write operations.
 */
async function executeBulkWrite(
  db: Db,
  collectionName: string,
  operations: AnyBulkWriteOperation<Document>[]
): Promise<void> {
  if (operations.length === 0) {
    console.log(`No changes detected for collection '${collectionName}'.`);
    return;
  }

  const upsertCount = operations.filter((op) => MONGO_OP_UPDATE_ONE in op).length;
  const deleteCount = operations.filter((op) => MONGO_OP_DELETE_ONE in op).length;
  console.log(
    `Attempting ${upsertCount} upserts and ${deleteCount} deletions in collection '${collectionName}'...`
  );

  try {
    const collection = db.collection(collectionName);
    const bulkWriteResult = await collection.bulkWrite(operations, { ordered: false });
    console.log(
      `Bulk write completed: ${bulkWriteResult.upsertedCount} upserted, ` +
        `${bulkWriteResult.modifiedCount} modified, ${bulkWriteResult.deletedCount} deleted.`
    );
    if (bulkWriteResult.hasWriteErrors()) {
      console.warn(`Write errors encountered:`);
      bulkWriteResult
        .getWriteErrors()
        .forEach((err) => console.warn(` - Index ${err.index}: ${err.errmsg}`));
    }
  } catch (err) {
    console.error(`Error executing bulk write for collection '${collectionName}':`, err);
  }
}

/**
 * Helper function to update the corresponding index collection.