import type { Db } from '../db'; import { MongoInvalidArgumentError, MongoRuntimeError } from '../error'; import type { Server } from '../sdam/server'; import type { ClientSession } from '../sessions'; import type { Callback } from '../utils'; import { enumToString } from '../utils'; import { CommandOperation, CommandOperationOptions } from './command'; const levelValues = new Set(['off', 'slow_only', 'all']); /** @public */ export const ProfilingLevel = Object.freeze({ off: 'off', slowOnly: 'slow_only', all: 'all' } as const); /** @public */ export type ProfilingLevel = typeof ProfilingLevel[keyof typeof ProfilingLevel]; /** @public */ export type SetProfilingLevelOptions = CommandOperationOptions; /** @internal */ export class SetProfilingLevelOperation extends CommandOperation { override options: SetProfilingLevelOptions; level: ProfilingLevel; profile: 0 | 1 | 2; constructor(db: Db, level: ProfilingLevel, options: SetProfilingLevelOptions) { super(db, options); this.options = options; switch (level) { case ProfilingLevel.off: this.profile = 0; break; case ProfilingLevel.slowOnly: this.profile = 1; break; case ProfilingLevel.all: this.profile = 2; break; default: this.profile = 0; break; } this.level = level; } override execute( server: Server, session: ClientSession | undefined, callback: Callback ): void { const level = this.level; if (!levelValues.has(level)) { return callback( new MongoInvalidArgumentError( `Profiling level must be one of "${enumToString(ProfilingLevel)}"` ) ); } // TODO(NODE-3483): Determine error to put here super.executeCommand(server, session, { profile: this.profile }, (err, doc) => { if (err == null && doc.ok === 1) return callback(undefined, level); return err != null ? callback(err) : callback(new MongoRuntimeError('Error with profile command')); }); } }