Function _refreshIndexCollection

scripts/dbRefresh.ts:86–120

(
  db: Db,
  collectionPrefix: string,
  collections: IndexEntry[]
)

}

async function _refreshIndexCollection(
  db: Db,
  collectionPrefix: string,
  collections: IndexEntry[]
): Promise<void> {
  console.log('\nRefreshing index table...');
  const collectionsCollectionName = getIndexCollectionName(collectionPrefix);
  const collectionsCollection: Collection = db.collection(collectionsCollectionName);

  try {
    await collectionsCollection.drop();
    console.log(`  Dropped existing collection '${collectionsCollectionName}'.`);
  } catch (err) {
    if (!(err instanceof MongoServerError && err.codeName === 'NamespaceNotFound')) {
      console.error(`  Error dropping collection '${collectionsCollectionName}':`, err);
      throw err;
    }
  }

  if (collections.length > 0) {
    try {
      const insertResult = await collectionsCollection.insertMany(collections);
      console.log(
        `  Inserted ${insertResult.insertedCount} documents into '${collectionsCollectionName}'.`
      );
    } catch (err) {
      console.error(`  Error inserting documents into '${collectionsCollectionName}':`, err);
      throw err;
    }
  } else {
    console.log(
      `  Skipping creation of collection '${collectionsCollectionName}' as no collections were processed.`
    );
  }
}

const uploadTablesFromFolder = async (db: Db, jsonDbDir: string, collectionPrefix = '') => {
  const collectionIndexEntries: IndexEntry[] = [];