-
Notifications
You must be signed in to change notification settings - Fork 224
/
_mock_http_client_states.js
58 lines (53 loc) · 1.33 KB
/
_mock_http_client_states.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
52
53
54
55
56
57
58
/*
* Copyright Elasticsearch B.V. and other contributors where applicable.
* Licensed under the BSD 2-Clause License; you may not use this file except in
* compliance with the BSD 2-Clause License.
*/
'use strict';
module.exports = function (expectations = [], done) {
return {
_write(obj, cb) {
cb = cb || (() => {});
const type = Object.keys(obj)[0];
for (let i = 0; i < expectations.length; i++) {
const { find, test } = expectations[i];
if (find(type, obj[type])) {
test(obj[type]);
expectations.splice(i, 1);
if (!expectations.length) {
done();
}
break;
}
}
process.nextTick(cb);
},
sendSpan(span, cb) {
this._write({ span }, cb);
},
sendTransaction(transaction, cb) {
this._write({ transaction }, cb);
},
sendError(error, cb) {
this._write({ error }, cb);
},
sendMetricSet(metricset, cb) {
this._write({ metricset }, cb);
},
flush(opts, cb) {
if (typeof opts === 'function') {
cb = opts;
opts = {};
} else if (!opts) {
opts = {};
}
if (cb) process.nextTick(cb);
},
supportsKeepingUnsampledTransaction() {
return true;
},
supportsActivationMethodField() {
return true;
},
};
};