-
Notifications
You must be signed in to change notification settings - Fork 36
/
unannounced.js
83 lines (72 loc) · 2.39 KB
/
unannounced.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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
'use strict';
var secrets = require('@instana/core').secrets;
var tracing = require('@instana/core').tracing;
var logger;
logger = require('../logger').getLogger('announceCycle/unannounced', function(newLogger) {
logger = newLogger;
});
var agentConnection = require('../agentConnection');
var agentOpts = require('../agent/opts');
var pidStore = require('../pidStore');
var retryDelay = 60 * 1000;
module.exports = {
enter: function(ctx) {
tryToAnnounce(ctx);
},
leave: function() {}
};
function tryToAnnounce(ctx) {
agentConnection.announceNodeCollector(function(err, rawResponse) {
if (err) {
logger.info('Announce attempt failed: %s. Will retry in %sms', err.message, retryDelay);
setTimeout(tryToAnnounce, retryDelay, ctx).unref();
return;
}
var response;
try {
response = JSON.parse(rawResponse);
} catch (e) {
logger.warn(
'Failed to JSON.parse agent response. Response was %s. Will retry in %sms',
rawResponse,
retryDelay,
e
);
setTimeout(tryToAnnounce, retryDelay, ctx).unref();
return;
}
var pid = response.pid;
logger.info('Overwriting pid for reporting purposes to: %s', pid);
pidStore.pid = pid;
agentOpts.agentUuid = response.agentUuid;
if (Array.isArray(response.extraHeaders)) {
tracing.setExtraHttpHeadersToCapture(
response.extraHeaders.map(function(s) {
// Node.js HTTP API turns all incoming HTTP headers into lowercase.
return s.toLowerCase();
})
);
}
if (response.secrets) {
if (!(typeof response.secrets.matcher === 'string')) {
logger.warn(
'Received invalid secrets configuration from agent, attribute matcher is not a string: $s',
response.secrets.matcher
);
} else if (Object.keys(secrets.matchers).indexOf(response.secrets.matcher) < 0) {
logger.warn(
'Received invalid secrets configuration from agent, matcher is not supported: $s',
response.secrets.matcher
);
} else if (!Array.isArray(response.secrets.list)) {
logger.warn(
'Received invalid secrets configuration from agent, attribute list is not an array: $s',
response.secrets.list
);
} else {
secrets.setMatcher(response.secrets.matcher, response.secrets.list);
}
}
ctx.transitionTo('announced');
});
}