Komodo / Komodo XMPP Center

Download as
Browse Code ยป

Commit 394dfac8a824a3cdd1b2ee5c0bf4d61427b65ebf

Authored by Adhidarma Hadiwinoto
1 parent f963960a2e
Exists in master

remove log on ping

Showing 1 changed file with 1 additions and 1 deletions Inline Diff

1 "use strict"; 1 "use strict";
2 2
3 const bot = require("simple-xmpp"); 3 const bot = require("simple-xmpp");
4 const config = require('komodo-sdk/config') 4 const config = require('komodo-sdk/config')
5 const logger = require('komodo-sdk/logger'); 5 const logger = require('komodo-sdk/logger');
6 6
7 let _callback; 7 let _callback;
8 let _isReady = false; 8 let _isReady = false;
9 9
10 bot.on('online', function(data) { 10 bot.on('online', function(data) {
11 logger.info('XMPP transport connected, JID: ' + data.jid.user); 11 logger.info('XMPP transport connected, JID: ' + data.jid.user);
12 bot.getRoster(); 12 bot.getRoster();
13 13
14 setTimeout( 14 setTimeout(
15 function() { 15 function() {
16 _isReady = true; 16 _isReady = true;
17 17
18 logger.verbose('Transport is ready'); 18 logger.verbose('Transport is ready');
19 19
20 if (_callback && _callback.onOnline) { 20 if (_callback && _callback.onOnline) {
21 _callback.onOnline({ 21 _callback.onOnline({
22 me: config.username, 22 me: config.username,
23 }); 23 });
24 }; 24 };
25 }, 25 },
26 26
27 config.warming_up_ms || (30 * 1000) 27 config.warming_up_ms || (30 * 1000)
28 ) 28 )
29 }); 29 });
30 30
31 bot.on('chat', function(partner, msg) { 31 bot.on('chat', function(partner, msg) {
32 if (!msg || !msg.trim()) { 32 if (!msg || !msg.trim()) {
33 return; 33 return;
34 } 34 }
35 35
36 if (partner == config.username.replace(/\/.*$/, '')) { 36 if (partner == config.username.replace(/\/.*$/, '')) {
37 return; 37 return;
38 } 38 }
39 39
40 if (!_isReady) { 40 if (!_isReady) {
41 logger.warn('Warming up is not finished yet, ignoring message', {me: config.username, partner: partner, msg: msg}); 41 logger.warn('Warming up is not finished yet, ignoring message', {me: config.username, partner: partner, msg: msg});
42 return; 42 return;
43 } 43 }
44 44
45 logger.info('Incoming message via XMPP transport', {me: config.username, partner: partner, msg: msg}); 45 logger.info('Incoming message via XMPP transport', {me: config.username, partner: partner, msg: msg});
46 46
47 if (_callback && _callback.onIncomingMessage) { 47 if (_callback && _callback.onIncomingMessage) {
48 _callback.onIncomingMessage({ 48 _callback.onIncomingMessage({
49 me: config.username, 49 me: config.username,
50 partner: partner, 50 partner: partner,
51 msg: msg.trim() 51 msg: msg.trim()
52 }) 52 })
53 } 53 }
54 }) 54 })
55 55
56 bot.on('error', function(err) { 56 bot.on('error', function(err) {
57 logger.warn('Error on XMPP transport', {err: err}) 57 logger.warn('Error on XMPP transport', {err: err})
58 setTimeout( 58 setTimeout(
59 function() { 59 function() {
60 process.exit(2); 60 process.exit(2);
61 }, 61 },
62 2000 62 2000
63 ) 63 )
64 }) 64 })
65 65
66 bot.on('subscribe', function(from) { 66 bot.on('subscribe', function(from) {
67 logger.verbose('Incoming subscribe request from ' + from); 67 logger.verbose('Incoming subscribe request from ' + from);
68 bot.acceptSubscription(from); 68 bot.acceptSubscription(from);
69 bot.subscribe(from); 69 bot.subscribe(from);
70 }) 70 })
71 71
72 function init(cb) { 72 function init(cb) {
73 if (!cb) { 73 if (!cb) {
74 logger.warn('Callback is not defined'); 74 logger.warn('Callback is not defined');
75 console.trace(); 75 console.trace();
76 process.exit(1); 76 process.exit(1);
77 return; 77 return;
78 } 78 }
79 79
80 _callback = cb; 80 _callback = cb;
81 81
82 bot.connect({ 82 bot.connect({
83 jid: config.username, 83 jid: config.username,
84 password: config.password 84 password: config.password
85 }); 85 });
86 } 86 }
87 87
88 function send(partner, msg) { 88 function send(partner, msg) {
89 logger.verbose('Sending message via XMPP transport', {transport: 'xmpp', me: config.username, partner: partner, msg: msg}); 89 logger.verbose('Sending message via XMPP transport', {transport: 'xmpp', me: config.username, partner: partner, msg: msg});
90 bot.send(partner, msg); 90 bot.send(partner, msg);
91 } 91 }
92 92
93 function ping() { 93 function ping() {
94 logger.verbose('PING'); 94 //logger.verbose('PING');
95 bot.send(config.username, 'PING!'); 95 bot.send(config.username, 'PING!');
96 } 96 }
97 97
98 setInterval( 98 setInterval(
99 ping, 99 ping,
100 config.ping_interval_ms || 60000 100 config.ping_interval_ms || 60000
101 ) 101 )
102 102
103 exports.init = init; 103 exports.init = init;
104 exports.send = send; 104 exports.send = send;
105 105