Authored by htoooth

fix

@@ -102,8 +102,10 @@ module.exports = (req, res, next) => { @@ -102,8 +102,10 @@ module.exports = (req, res, next) => {
102 }); 102 });
103 103
104 res.send(); 104 res.send();
  105 +
  106 + logger.info('[client] handle OK [%s]', req.query.l);
105 } catch (e) { 107 } catch (e) {
106 - logger.error('[client] not handle client info [%s]', e); 108 + logger.error('[client] handle ERROR [%s]', e);
107 return next(e); 109 return next(e);
108 } 110 }
109 }; 111 };
@@ -10,32 +10,38 @@ const { @@ -10,32 +10,38 @@ const {
10 10
11 const server = { 11 const server = {
12 async handle(data) { 12 async handle(data) {
13 - let msgs = lineparse.parse(data); 13 + try {
14 14
15 - msgs.forEach((m) => {  
16 - if (!m.measurement) {  
17 - return;  
18 - } 15 + let msgs = lineparse.parse(data);
19 16
20 - switch (m.measurement) {  
21 - case 'web-server-duration': {  
22 - handleWebServerDuration(m);  
23 - break; 17 + msgs.forEach((m) => {
  18 + if (!m.measurement) {
  19 + return;
24 } 20 }
25 - case 'error-report': {  
26 - handleErrorReport(m);  
27 - break;  
28 - }  
29 - case 'process-info': {  
30 - handleProcessInfo(m);  
31 - break;  
32 - }  
33 - default: {  
34 - logger.error('not handle server info [%s]', JSON.stringify(m));  
35 - break; 21 +
  22 + switch (m.measurement) {
  23 + case 'web-server-duration': {
  24 + handleWebServerDuration(m);
  25 + break;
  26 + }
  27 + case 'error-report': {
  28 + handleErrorReport(m);
  29 + break;
  30 + }
  31 + case 'process-info': {
  32 + handleProcessInfo(m);
  33 + break;
  34 + }
  35 + default: {
  36 + logger.error('not handle server info [%s]', JSON.stringify(m));
  37 + break;
  38 + }
36 } 39 }
37 - }  
38 - }); 40 + });
  41 + logger.info('[server] handle OK [%s]', data);
  42 + } catch (e) {
  43 + logger.error('[server] handle ERROR [%s]', e);
  44 + }
39 } 45 }
40 }; 46 };
41 47
@@ -45,4 +51,4 @@ module.exports = function(req, res, next) { @@ -45,4 +51,4 @@ module.exports = function(req, res, next) {
45 server.handle(data).then(() => { 51 server.handle(data).then(() => {
46 res.status(204).json(); 52 res.status(204).json();
47 }).catch(next); 53 }).catch(next);
48 -}; 54 +};