import type { Binary, Document } from '../bson'; import type { Db } from '../db'; import type { Server } from '../sdam/server'; import type { ClientSession } from '../sessions'; import { type Callback, maxWireVersion } from '../utils'; import { CommandCallbackOperation, type CommandOperationOptions } from './command'; import { Aspect, defineAspects } from './operation'; /** @public */ export interface ListCollectionsOptions extends Omit { /** Since 4.0: If true, will only return the collection name in the response, and will omit additional info */ nameOnly?: boolean; /** Since 4.0: If true and nameOnly is true, allows a user without the required privilege (i.e. listCollections action on the database) to run the command when access control is enforced. */ authorizedCollections?: boolean; /** The batchSize for the returned command cursor or if pre 2.8 the systems batch collection */ batchSize?: number; } /** @internal */ export class ListCollectionsOperation extends CommandCallbackOperation { /** * @remarks WriteConcern can still be present on the options because * we inherit options from the client/db/collection. The * key must be present on the options in order to delete it. * This allows typescript to delete the key but will * not allow a writeConcern to be assigned as a property on options. */ override options: ListCollectionsOptions & { writeConcern?: never }; db: Db; filter: Document; nameOnly: boolean; authorizedCollections: boolean; batchSize?: number; constructor(db: Db, filter: Document, options?: ListCollectionsOptions) { super(db, options); this.options = { ...options }; delete this.options.writeConcern; this.db = db; this.filter = filter; this.nameOnly = !!this.options.nameOnly; this.authorizedCollections = !!this.options.authorizedCollections; if (typeof this.options.batchSize === 'number') { this.batchSize = this.options.batchSize; } } override executeCallback( server: Server, session: ClientSession | undefined, callback: Callback ): void { return super.executeCommandCallback( server, session, this.generateCommand(maxWireVersion(server)), callback ); } /* This is here for the purpose of unit testing the final command that gets sent. */ generateCommand(wireVersion: number): Document { const command: Document = { listCollections: 1, filter: this.filter, cursor: this.batchSize ? { batchSize: this.batchSize } : {}, nameOnly: this.nameOnly, authorizedCollections: this.authorizedCollections }; // we check for undefined specifically here to allow falsy values // eslint-disable-next-line no-restricted-syntax if (wireVersion >= 9 && this.options.comment !== undefined) { command.comment = this.options.comment; } return command; } } /** @public */ export interface CollectionInfo extends Document { name: string; type?: string; options?: Document; info?: { readOnly?: false; uuid?: Binary; }; idIndex?: Document; } defineAspects(ListCollectionsOperation, [ Aspect.READ_OPERATION, Aspect.RETRYABLE, Aspect.CURSOR_CREATING ]);