profiling_level.ts•1.42 kB
import type { Db } from '../db';
import { MongoRuntimeError } from '../error';
import type { Server } from '../sdam/server';
import type { ClientSession } from '../sessions';
import type { Callback } from '../utils';
import { CommandCallbackOperation, type CommandOperationOptions } from './command';
/** @public */
export type ProfilingLevelOptions = CommandOperationOptions;
/** @internal */
export class ProfilingLevelOperation extends CommandCallbackOperation<string> {
override options: ProfilingLevelOptions;
constructor(db: Db, options: ProfilingLevelOptions) {
super(db, options);
this.options = options;
}
override executeCallback(
server: Server,
session: ClientSession | undefined,
callback: Callback<string>
): void {
super.executeCommandCallback(server, session, { profile: -1 }, (err, doc) => {
if (err == null && doc.ok === 1) {
const was = doc.was;
if (was === 0) return callback(undefined, 'off');
if (was === 1) return callback(undefined, 'slow_only');
if (was === 2) return callback(undefined, 'all');
// TODO(NODE-3483)
return callback(new MongoRuntimeError(`Illegal profiling level value ${was}`));
} else {
// TODO(NODE-3483): Consider MongoUnexpectedServerResponseError
err != null ? callback(err) : callback(new MongoRuntimeError('Error with profile command'));
}
});
}
}