bot.js

const http = require('http');
const https = require('https');
const mime = require('mime-types')
const fs = require('fs');
const pascalize = require('humps').pascalize
const main = require('./main.js')

const showdown = require('showdown');
const sd = new showdown.Converter({'simplifiedAutoLink': true, 'ghCodeBlocks':true});
const lang = main.lang;

var download = function(url, dest, cb) {
  var file = fs.createWriteStream(dest);
  var protocal = url.split(':')[0].slice(-1) == 's' ? https : http
  var request = protocal.get(url, function(response) {
    response.pipe(file);
    file.on('finish', function() {
      file.close(cb);  // close() is async, call cb after close completes.
    });
  }).on('error', function(err) { // Handle errors
    fs.unlink(dest); // Delete the file async. (But we don't check the result)
    console.error(err);
  });
};

var format = require('string-format')
format.extend(String.prototype, {})

String.prototype.replaceAll = function(search, replacement) {
  var target = this;
  return target.replace(new RegExp(search, 'g'), replacement);
};

const token = main.tgToken;
const TelegramBot = require('node-telegram-bot-api'); // api
const bot = new TelegramBot(token, { polling: true });

const previewTextLimit = main.previewTextLimit;

const removeEmpty = (x) => {var obj = Object.assign({}, x);Object.keys(obj).forEach((key) => (obj[key] == null) && delete obj[key]);return obj;}
const firstUpperCase = ([first, ...rest]) => first.toUpperCase() + rest.join('');

exports.init = () => bot.getMe().then(result => exports.id = result.id)
exports.send = ({text='', chatId=main.testTgId, photo, audio, doc, game, video, voice, videoNote, venue, contact, location, sticker, cb=() => {}}={}) => {
  let parse_mode = 'HTML';
  if (text) text = sd.makeHtml(text.replaceAll('\n','<_changeRow>').replace('<','&lt;').replace('>','&gt;')).replace('<p>','').replace('</p>','').replaceAll('<_changeRow>','\n')
  if (photo) setImmediate(() => bot.sendPhoto(chatId, photo, {'caption':text, 'parse_mode':parse_mode}).then(() => cb()))
  else if (audio) setImmediate(() => bot.sendAudio(chatId, audio, {'caption':text, 'parse_mode':parse_mode}, {contentType: mime.lookup(audio)}).then(() => cb()))
  else if (doc) setImmediate(() => bot.sendDocument(chatId, doc, {'caption':text, 'parse_mode':parse_mode}, {contentType: mime.lookup(doc)}).then(() => cb()))
  else if (game) setImmediate(() => bot.sendGame(chatId, game).then(() => cb()))
  else if (video) setImmediate(() => bot.sendVideo(chatId, video, {'caption':text, 'parse_mode':parse_mode}, {contentType: mime.lookup(video)}).then(() => cb()))
  else if (voice) setImmediate(() => bot.sendVoice(chatId, voice, {'caption':text, 'parse_mode':parse_mode}, {contentType: mime.lookup(voice)}).then(() => cb()))
  else if (videoNote) setImmediate(() => bot.sendVideoNote(chatId, videoNote, {}, {contentType: mime.lookup(videoNote)}).then(() => cb()))
  else if (venue) setImmediate(() => bot.sendVenue(chatId, venue.latitude, venue.longitude, venue.title, venue.address).then(() => cb()))
  else if (contact) setImmediate(() => bot.sendContact(chatId, contact.phoneNumber, contact.firstName).then(() => cb()))
  else if (location) setImmediate(() => bot.sendLocation(chatId, location.latitude, location.longitude).then(() => cb()))
  else if (sticker) setImmediate(() => bot.sendSticker(chatId, sticker).then(() => cb()))
  else setImmediate(() => bot.sendMessage(chatId, text, {'parse_mode':parse_mode}).then(() => cb()))
}

getMessageBasicInfo = message => {
  var text = message.caption ? message.caption : message.text ? message.text : '';
  var chatId = message.chat.id;
  var userId = message.from.id;
  var userName = message.from.first_name;
  var addition = '';
  if (message.reply_to_message){
    var replyToId = message.reply_to_message.from.id;
    var replyToName = message.reply_to_message.from.first_name;
    var replyToText = message.reply_to_message.caption ? message.reply_to_message.caption : message.reply_to_message.text
    if (!replyToText) {
      replyToText = '[{}]'.format(firstUpperCase(['text', 'audio', 'document', 'game', 'photo', 'sticker', 'video', 'voice', 'video_note', 'contact', 'location', 'venue'].filter(
        x => message.reply_to_message[x]).pop().replace('_note', ' Note')));
      var noTextInOriginMessage = true;
    }
    if (replyToId == exports.id){
      replyToName = message.reply_to_message.text.split('>')[0].slice(1);
      var offset = '<>: '.length
      var isSliced = noTextInOriginMessage ? false : replyToText.length > replyToName.length+offset+previewTextLimit;
      replyToText = noTextInOriginMessage ? replyToText : replyToText.substr(replyToName.length+offset, previewTextLimit);
    }
    else {
      var isSliced = noTextInOriginMessage ? false : replyToText.length > previewTextLimit;
      replyToText = noTextInOriginMessage ? replyToText : replyToText.substr(0, previewTextLimit);
  }
}
  if (message.forward_from){
    var forwardFromId = message.forward_from.id;
    if (forwardFromId == exports.id) var forwardFromName = message.forward_from.text.split('>')[0].slice(1);
    else var forwardFromName = message.forward_from.first_name + (message.forward_from.last_name ? (' ' + message.forward_from.last_name) : '');
  }
  if (message.forward_from_chat){
    var forwardFromId = message.forward_from_chat.id;
    var forwardFromName = message.forward_from_chat.title ? message.forward_from_chat.title : ('@'+message.forward_from_chat.username);
  }
  return [text, chatId, userId, userName, addition, replyToId, replyToName, replyToText, forwardFromId, forwardFromName, isSliced]
}

bot.on('text', message => {
  if (message.chat.id != main.groupTgId) return;
  [text, chatId, userId, userName, addition, replyToId, replyToName, replyToText, forwardFromId, forwardFromName, isSliced] = getMessageBasicInfo(message);
  setImmediate(() => main.botMessage({'chatId':chatId, 'userId':userId, 'userName':userName, 'text':text, 'replyToId':replyToId, 'replyToName':replyToName,
    'forwardFromId':forwardFromId, 'forwardFromName':forwardFromName, 'replyToText':replyToText, 'addition':addition, 'isSliced':isSliced}))
});

bot.on('edited_message', message => {
  if (message.chat.id != main.groupTgId) return;
  [text, chatId, userId, userName, addition, replyToId, replyToName, replyToText, forwardFromId, forwardFromName, isSliced] = getMessageBasicInfo(message);
  setImmediate(() => main.botMessage({'chatId':chatId, 'userId':userId, 'userName':userName, 'text':text, 'replyToId':replyToId, 'replyToName':replyToName,
    'forwardFromId':forwardFromId, 'forwardFromName':forwardFromName, 'replyToText':replyToText, 'addition':addition, 'isSliced':isSliced, 'isEdited':true}))
});

['audio', 'document', 'photo', 'sticker', 'video', 'voice', 'video_note'].forEach(x => bot.on(x, message => {
  if (message.chat.id != main.groupTgId) return;
  [text, chatId, userId, userName, addition, replyToId, replyToName, replyToText, forwardFromId, forwardFromName, isSliced] = getMessageBasicInfo(message);
  var file = x == 'photo' ? message[x].pop() : message[x]
  var fileId = file.file_id
  if (x == 'sticker') var extension = 'webp';
  else if (x == 'video_note') var extension = 'mp4';
  else if (x == 'photo') var extension = 'png';
  else var extension = file.mime_type ? file.mime_type == 'audio/mpeg3' ? 'mp3' : mime.extension(file.mime_type) : file.file_path.split('.').pop();
  setImmediate(() => {
    var attachment = bot.getFileStream(fileId);
    attachment.path += '.' + extension;
    main.botMessage({'chatId':chatId, 'userId':userId, 'userName':userName, 'text':text, 'replyToId':replyToId, 'replyToName':replyToName,
        'forwardFromId':forwardFromId, 'forwardFromName':forwardFromName, 'replyToText':replyToText, 'attachment':attachment, 'isSliced':isSliced, 'attachmentType':pascalize(x)});
  })
}));

bot.on('venue', message => {
  if (message.chat.id != main.groupTgId) return;
  [text, chatId, userId, userName, addition, replyToId, replyToName, replyToText, forwardFromId, forwardFromName, isSliced] = getMessageBasicInfo(message);
  var venue = message.venue;
  if (!(replyToId | forwardFromId)) addition += '\n';
  addition += '🌏: {}\n🚩: {}\n🗺️: {}, {}'.format(venue.foursquare_id, venue.title, venue.address, venue.location.latitude, venue.location.longitude);
  setImmediate(() => main.botMessage({'chatId':chatId, 'userId':userId, 'userName':userName, 'text':text, 'replyToId':replyToId, 'replyToName':replyToName,
    'forwardFromId':forwardFromId, 'forwardFromName':forwardFromName, 'replyToText':replyToText, 'addition':addition, 'isSliced':isSliced}))
});

bot.on('contact', message => {
  if (message.chat.id != main.groupTgId) return;
  [text, chatId, userId, userName, addition, replyToId, replyToName, replyToText, forwardFromId, forwardFromName, isSliced] = getMessageBasicInfo(message);
  var contact = message.contact;
  if (!(replyToId | forwardFromId)) addition += '\n';
  if (contact.phone_number) addition += '📱: ' + contact.phone_number;
  if (contact.first_name) addition += '\n{}: '.format(lang.name) + (contact.last_name ? (contact.first_name + contact.last_name) : contact.first_name);
  if (contact.user_id) addition += '\n{}: '.format(lang.id) + contact.user_id;
  setImmediate(() => main.botMessage({'chatId':chatId, 'userId':userId, 'userName':userName, 'text':text, 'replyToId':replyToId, 'replyToName':replyToName,
    'forwardFromId':forwardFromId, 'forwardFromName':forwardFromName, 'replyToText':replyToText, 'addition':addition, 'isSliced':isSliced}))
});

bot.on('location', message => {
  if (message.chat.id != main.groupTgId) return;
  [text, chatId, userId, userName, addition, replyToId, replyToName, replyToText, forwardFromId, forwardFromName, isSliced] = getMessageBasicInfo(message);
  var location = message.location;
  if (!(replyToId | forwardFromId)) addition += '\n';
  addition += '🗺️: {}, {}'.format(location.latitude, location.longitude);
  setImmediate(() => main.botMessage({'chatId':chatId, 'userId':userId, 'userName':userName, 'text':text, 'replyToId':replyToId, 'replyToName':replyToName,
    'forwardFromId':forwardFromId, 'forwardFromName':forwardFromName, 'replyToText':replyToText, 'addition':addition, 'isSliced':isSliced}))
});