Adhidarma Hadiwinoto / evo-ym-center

Download as
Browse Code ยป

Commit 6ac898aeba3cf73863d38e3e5accaf00e0e2b638

Authored by Adhidarma Hadiwinoto
1 parent f0e73f28cf
Exists in master

custom log level

Showing 1 changed file with 15 additions and 11 deletions Side-by-side Diff

... ... @@ -48,18 +48,22 @@ function onLoginSuccessful(data) {
48 48 logger.info('Login successful as ' + data.firstname + ' ' + data.lastname + ' (' + data.user_id + ')', {data: data});
49 49 }
50 50  
  51 +function sendMessage(destination, message) {
  52 + logger.info('Sending YM message', {from: config.globals.username, to: destination, message: message});
  53 + ym.sendPM(destination, message);
  54 +}
  55 +
51 56 function sendIgnoreResponse(destination, message) {
52   - ym.sendPM(destination, "Pesan anda diabaikan, silahkan diulang beberapa saat lagi jika diperlukan: " + message);
  57 + sendMessage(destination, "Pesan anda diabaikan, silahkan diulang beberapa saat lagi jika diperlukan: " + message);
53 58 }
54 59  
55 60 function onPm(data) {
56   - logger.info('onPM()', {data: data});
57   -
  61 + logger.info('Incoming message via YM', {data: data});
58 62 var message = striptags(data.message);
59 63  
60 64 var message_hash = data.sender + ': ' + data.message;
61 65 if (message_hash == last_message_hash) {
62   - logger.info('Ignoring duplicate message', {data: data});
  66 + logger.warn('Ignoring duplicate message', {data: data});
63 67 return;
64 68 }
65 69 last_message_hash = message_hash;
... ... @@ -75,7 +79,7 @@ function onPm(data) {
75 79 }
76 80  
77 81 function onOfflinePM(data) {
78   - logger.verbose('onOfflinePM()', {data: data});
  82 + logger.info('Offline YM message', {data: data});
79 83 sendIgnoreResponse(data.sender, data.message);
80 84 }
81 85  
... ... @@ -87,7 +91,7 @@ function onBuddyAddRequest(data) {
87 91  
88 92 function onHttpIncomingMessage(request, response) {
89 93 var qs = url.parse(request.url, true).query;
90   - logger.info("onHttpIncomingMessage()", {qs: qs});
  94 + logger.verbose("onHttpIncomingMessage()", {qs: qs});
91 95  
92 96 // abaikan balikan ping
93 97 if (qs.to == config.globals.ping_ym_id) {
... ... @@ -95,8 +99,8 @@ function onHttpIncomingMessage(request, response) {
95 99 }
96 100  
97 101 var destination = qs.to.replace(config.globals.msisdn_suffix, '');
98   - logger.info('Sending message to ' + destination + ': ' + qs.msg);
99   - ym.sendPM(destination, qs.msg);
  102 + logger.info('Sending YM message from ' + config.globals.username + ' to ' + destination + ': ' + qs.msg);
  103 + sendMessage(destination, qs.msg);
100 104 response.end('OK');
101 105 }
102 106  
... ... @@ -117,7 +121,7 @@ function forwardMessageToEvo(sender, message, ts) {
117 121 }
118 122 };
119 123  
120   - logger.info("Forwarding message to evo", {request_opts: opts});
  124 + logger.verbose("Forwarding message to evo", {request_opts: opts});
121 125 request(opts, function(err, response, body) {
122 126 if (err) {
123 127 logger.warn('Error forwarding to evo: ' + err);
... ... @@ -140,7 +144,7 @@ function forwardMessageToEvo(sender, message, ts) {
140 144 }
141 145 };
142 146  
143   - logger.info('Sending ping message', {opts: pingOpts});
  147 + logger.verbose('Sending ping message', {opts: pingOpts});
144 148  
145 149 request(pingOpts, function(err, response, body) {
146 150 if (err) {
... ... @@ -168,6 +172,6 @@ ym.on('pm', onPm);
168 172 ym.on('buddyAddRequest', onBuddyAddRequest);
169 173  
170 174 setInterval(function() {
171   - logger.info('Sending keepalive packet');
  175 + logger.verbose('Sending keepalive packet');
172 176 ym.keepAlive();
173 177 }, keepalive_interval);