All files / src/operations collections.ts

100% Statements 13/13
50% Branches 1/2
100% Functions 3/3
100% Lines 13/13

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48392x       392x             392x         1632x 1632x 1632x       1632x               1403x           1403x 1403x 4359x   4359x       1403x      
import { Collection } from '../collection';
import type { Db } from '../db';
import type { Server } from '../sdam/server';
import type { ClientSession } from '../sessions';
import { AbstractOperation, type OperationOptions } from './operation';
 
export interface CollectionsOptions extends OperationOptions {
  nameOnly?: boolean;
}
 
/** @internal */
export class CollectionsOperation extends AbstractOperation<Collection[]> {
  override options: CollectionsOptions;
  db: Db;
 
  constructor(db: Db, options: CollectionsOptions) {
    super(options);
    this.options = options;
    this.db = db;
  }
 
  override get commandName() {
    return 'listCollections' as const;
  }
 
  override async execute(
    server: Server,
    session: ClientSession | undefined
  ): Promise<Collection[]> {
    // Let's get the collection names
    const documents = await this.db
      .listCollections(
        {},
        { ...this.options, nameOnly: true, readPreference: this.readPreference, session }
      )
      .toArray();
    const collections: Collection[] = [];
    for (const { name } of documents) {
      Eif (!name.includes('$')) {
        // Filter collections removing any illegal ones
        collections.push(new Collection(this.db, name, this.db.s.options));
      }
    }
    // Return the collection objects
    return collections;
  }
}