clientapm.js
2.72 KB
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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
const queryParse = require('../lib/query-parse');
const _ = require('lodash');
const {
handleClientError,
handleClientFirst,
handleClientTiming,
handleClientResource
} = require('./clientapm-service');
const routeDecode = require('./route-decode');
const logger = global.yoho.logger;
const crypto = global.yoho.crypto;
const decodeUid = _.memoize(function(r) {
r = r.replace(/ /g, '+');
return crypto.decrypt(null, decodeURIComponent(r));
});
module.exports = (req, res, next) => {
if (!req.query.l) {
logger.error('query l is undefined');
return res.send();
}
const scope = {
app: req.query.s || 'unknown',
useragent: req.get('user-agent') || 'unknown',
ip: req.clientIp || 'unknown'
};
try {
const report = queryParse.parse(req.query.l);
if (!report) {
logger.error('report can not be parse [%s]', req.query.l);
return res.send();
}
report.forEach(item => {
// url
if (item.pt && item.pt.indexOf('openby:yohobuy') >= 0) {
item.pt = item.pt.substring(0, item.pt.indexOf('openby:yohobuy'));
}
// uid
if (item.u) {
try {
item.u = decodeUid(item.u);
item.u = _.parseInt(item.u);
} catch (e) {
logger.error('decode uid error [%s]', item.u);
}
}
// server route
if (item.r) {
try {
item.r = decodeURIComponent(item.r);
item.r = routeDecode(item.r);
} catch (e) {
logger.error('decode server route error [%s]', item.r);
}
}
if (!item.tp) {
return;
}
switch (item.tp) {
case 'err': {
handleClientError(scope, item);
break;
}
case 'dcl':
case 'ld':
case 'fs': {
handleClientFirst(scope, item);
break;
}
case 'tm': {
handleClientTiming(scope, item);
break;
}
case 'rs': {
handleClientResource(scope, item);
break;
}
default: {
logger.error('not handle client info [%s]', JSON.stringify(item));
break;
}
}
});
res.send();
} catch (e) {
logger.error('not handle client info [%s]', e);
return next(e);
}
};