index.js
2.12 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
var telegram = require('node-telegram-bot-api');
var logger = require('./logger.js').start();
var evo = require('./evo-im.js');
var config = require('./config.json');
evo.start({
config: config,
logger: logger
});
var chat_ids = {};
var options = {
webHook: {
port: config.globals.webhook_port,
key: __dirname+'/key.pem',
cert: __dirname+'/crt.pem'
}
};
var bot = new telegram(config.globals.token, options);
bot.setWebHook(config.globals.webhook_prefix + config.globals.token, __dirname+'/crt.pem');
function deleteChatId(from) {
delete chat_ids[from];
}
function sendMessage(destination, message) {
logger.info('Sending reply to ' + destination + ': ' + message);
var chat_id = chat_ids[destination];
bot.sendMessage(chat_id, message);
}
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.globals.listen_port, function(){
logger.info("listening on " + config.globals.listen_port);
})
}
createHttpResponseServer();
bot.getMe().then(function (me) {
logger.info('Hi my name is %s!', me.username);
});
bot.on('text', function (msg) {
logger.info(msg);
var from = msg.from.username.toUpperCase() + config.globals.msisdn_suffix;
var now = Math.floor(new Date().getTime()/1000);
if (now - msg.date > config.globals.message_max_age){
var message = "Pesan anda diabaikan, silahkan diulang beberapa saat lagi jika diperlukan: " + msg.text;
logger.info(message, {msg: msg})
//bot.sendMessage(msg.chat.id, message);
sendMessage(from, message);
return;
}
chat_ids[from] = msg.chat.id;
var greeting_prefix = "Pesan anda telah diterima:";
if (config.globals.greeting_prefix) {
greeting_prefix = config.globals.greeting_prefix;
}
bot.sendMessage(msg.chat.id, greeting_prefix + ' ' + msg.text);
setTimeout(
evo.onMessage,
300,
from, msg.text, msg.date * 1000, sendMessage
);
});