-
Notifications
You must be signed in to change notification settings - Fork 1
/
utils.js
52 lines (42 loc) · 1.18 KB
/
utils.js
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
const debug = function () {
if (process.env.DEBUG !== "true") {
return;
}
console.log.apply(null, [...arguments]);
};
exports.debug = debug;
const sleep = (time) => {
return new Promise(resolve => {
setTimeout(() => {
resolve();
}, time);
});
};
exports.sleep = sleep;
const getObjectPropFromString = (obj, propString, delimiter = ".") => {
let result = obj;
const arr = propString.split(delimiter);
for (let i in arr) {
if (result[arr[i]] === undefined) {
return undefined;
}
result = result[arr[i]];
}
return result;
};
exports.getObjectPropFromString = getObjectPropFromString;
exports.DUPLICATE_CODE_ERROR = 11000;
exports.RESUME_TOKEN_ERROR = 40585;
exports.CHANGE_STREAM_FATAL_ERROR = 280;
exports.CHANGE_STREAM_HISTORY_LOST_ERROR = 286;
exports.CHANGE_STREAM_INVALIDATED_ERROR = 346;
exports.CHANGE_STREAM_TEPOLOGEY_CHANGE_ERROR = 348;
exports.CHANGE_STREAM_START_AFTER_INVALIDATE_ERROR = 348;
exports.changeStreamErrors = [
this.RESUME_TOKEN_ERROR,
this.CHANGE_STREAM_FATAL_ERROR,
this.CHANGE_STREAM_HISTORY_LOST_ERROR,
this.CHANGE_STREAM_INVALIDATED_ERROR,
this.CHANGE_STREAM_TEPOLOGEY_CHANGE_ERROR,
this.CHANGE_STREAM_START_AFTER_INVALIDATE_ERROR
];