-
Notifications
You must be signed in to change notification settings - Fork 1.8k
/
set_profiling_level.ts
70 lines (60 loc) · 2 KB
/
set_profiling_level.ts
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
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<ProfilingLevel> {
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;
}
execute(server: Server, session: ClientSession, callback: Callback<ProfilingLevel>): 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'));
});
}
}