diff --git a/index.js b/index.js index 59dab61..50b3eeb 100644 --- a/index.js +++ b/index.js @@ -28,27 +28,17 @@ function deleteChatId(from) { } function sendMessage(destination, message) { - logger.info('Sending reply to ' + destination + ': ' + message); - var chat_id = chat_ids[destination]; - bot.sendMessage(chat_id, message); -} + var chat_id = chat_ids[destination]; + + if (!chat_id) { + logger.warn('Can not find approriate chat id for ' + destination + '. Abort sending message.'); + return; + } -/* -function createHttpResponseServer(){ - var httpServer = http.createServer(function(request,response){ - var qs = url.parse(request.url, true).query; - logger.info('Incoming request from SMSIN server:', {qs: qs}) - //logger.info(qs); - response.end('OK'); - - sendMessage(qs.PhoneNumber, qs.text); - }); - httpServer.listen(config.listen_port, function(){ - logger.info("listening on " + config.listen_port); - }) + logger.info('Sending reply to ' + destination + '(' + chat_id + '): ' + message); + + bot.sendMessage(chat_id, message); } -createHttpResponseServer(); -*/ bot.getMe().then(function (me) { logger.info('Hi my name is %s!', me.username); @@ -83,3 +73,14 @@ bot.on('text', function (msg) { from, msg.text, msg.date * 1000, sendMessage ); }); + +function dumpChatIds() { + var i = 0; + for (var key in chat_ids) { + logger.verbose('DUMPED CHAT IDS #' + ++i + ' ' + key + ': ' + chat_ids[key]) + } +} + +if (config.dump_chat_ids_interval) { + setInterval(dumpChatIds, config.dump_chat_ids_interval * 1000); +}