Function setupDatabase

test/integration/shared.js:89–108

(configuration, dbsToClean)

}

async function setupDatabase(configuration, dbsToClean) {
  dbsToClean = Array.isArray(dbsToClean) ? dbsToClean : [];
  const configDbName = configuration.db;

  dbsToClean.push(configDbName);

  const client = configuration.newClient();
  try {
    for (const dbName of dbsToClean) {
      const db = await client.db(dbName);
      for await (const { name } of db.listCollections({}, { nameOnly: true })) {
        const collection = db.collection(name);
        await collection.deleteMany({}).catch(() => null);
        await collection.drop().catch(() => null);
      }
    }
  } finally {
    await client.close();
  }
}

/**
 * Safely perform a test with an arbitrary cursor.