Function _handleFileRenamed

scripts/update/processor.ts:267–312

* Handles processing for a renamed file. * Updates data in the new collection, drops the old collection if name changed, * deletes the old index entry, and upserts the new index entry.

(db: Db, filepath: string, oldFilepath: string)

 * deletes the old index entry, and upserts the new index entry.
 */
async function _handleFileRenamed(db: Db, filepath: string, oldFilepath: string): Promise<void> {
  const collectionName = getCollectionNameFromJsonFile(filepath);
  const oldCollectionName = getCollectionNameFromJsonFile(oldFilepath);

  console.log(
    `\nProcessing Renamed file ${oldFilepath} -> ${filepath} ` +
      `(Collections: ${oldCollectionName || 'N/A'} -> ${collectionName || 'N/A'})...`
  );

  // 1. Update data in the *new* collection (if applicable)
  if (collectionName) {
    const currentData = await readFileContent(filepath);
    const oldFileContentString = await getOldFileContent(oldFilepath); // Get content from OLD git path
    const oldData = parseJsonArrayContent(oldFileContentString, `HEAD~1:${oldFilepath}`);

    const { operations, skippedRecords } = calculateBulkOperations(oldData, currentData, filepath);
    await executeBulkWrite(db, collectionName, operations);

    if (skippedRecords > 0) {
      console.warn(
        `Skipped ${skippedRecords} records in ${filepath} due to missing 'index' field.`
      );
    }
  } else {
    console.warn(`Could not determine new collection name for ${filepath}. Skipping data update.`);
  }

  // 2. Drop the *old* collection if its name was valid and different from the new one
  if (oldCollectionName && oldCollectionName !== collectionName) {
    console.log(`Dropping old collection '${oldCollectionName}' due to rename...`);
    try {
      await db.collection(oldCollectionName).drop();
      console.log(`Dropped old collection '${oldCollectionName}'.`);
    } catch (err) {
      if (!(err instanceof MongoServerError && err.codeName === 'NamespaceNotFound')) {
        console.error(`Error dropping old collection '${oldCollectionName}' during rename:`, err);
      }
    }
  }

  // 3. Update index collections (delete old, upsert new)
  // First delete the old index entry using the old path
  await updateIndexCollection(db, oldFilepath, 'delete');
  // Then upsert the new index entry using the new path
  await updateIndexCollection(db, filepath, 'upsert');
}

/**
 * Handles processing for a deleted file.