app.js

/**
 * https://developers.facebook.com/docs/messenger-platform/getting-started/quick-start/
 * To run this code, you must do the following:
 * 3. Update the VERIFY_TOKEN
 * 4. Add your PAGE_ACCESS_TOKEN to your environment vars
 *
 */

'use strict';
require('dotenv').config();
const PAGE_ACCESS_TOKEN = process.env.PAGE_ACCESS_TOKEN;
const https = require("https"),
  fs = require("fs");

const options = {
    key: fs.readFileSync("/etc/letsencrypt/live/lomago.io/privkey.pem"),
    cert: fs.readFileSync("/etc/letsencrypt/live/lomago.io/fullchain.pem")
};
// Imports dependencies and set up http server
const
  request = require('request'),
  express = require('express'),
  body_parser = require('body-parser'),
  app = express().use(body_parser.json()); // creates express http server

// Sets server port and logs message on success
// app.listen(process.env.PORT, () => console.log('webhook is listening '+PAGE_ACCESS_TOKEN));

https.createServer(options, app).listen(process.env.PORT);

let db= require('./db');

// Accepts GET requests at the /webhook endpoint
app.get('/webhook', (req, res) => {

    /** UPDATE YOUR VERIFY TOKEN **/
    const VERIFY_TOKEN = "Lomago_Token";

    // Parse params from the webhook verification request
    let mode = req.query['hub.mode'];
    let token = req.query['hub.verify_token'];
    let challenge = req.query['hub.challenge'];

    // Check if a token and mode were sent
    if (mode && token) {

        // Check the mode and token sent are correct
        if (mode === 'subscribe' && token === VERIFY_TOKEN) {

            // Respond with 200 OK and challenge token from the request
            console.log('WEBHOOK_VERIFIED');
            res.status(200).send(challenge);

        } else {
            // Responds with '403 Forbidden' if verify tokens do not match
            res.sendStatus(403);
        }
    }
});

//for facebook, only test user possible!!!
//https://www.lomago.io:1337/send?text=hello&page_id=106704524351660&type=facebook
app.get('/send', (req, res) => {      //connection message from cockpit  //from webchat and cockpit(wordpress)(activation)
    // Parse params from the webhook verification request
    // console.log("app.get");
    console.log(req.query);
    sendConsultantMessage(req.query);
    res.status(200).send("app.get");
});

//https://www.lomago.io:1337/send?text=hello&page_id=3357824640912103&type='facebook'
//https://www.lomago.io:1337/send?text=telegram&page_id=3357824640912103&type='telegram'
app.post('/send', (req, res) => {
    console.log("app.post");
    sendConsultantMessage(req.body);
    res.status(200).send("sent");
});

async function sendConsultantMessage(body){
    let consultantName = await db.GetConsultantName(body.page_id);
    let message=body.text;
    if (consultantName!='')
        message=consultantName+": "+message;
    if (body.type=='facebook')
        sendMessage(body.page_id,message);
    else  //telegram
        bot.sendMessage(body.page_id, message); //chat_id
    if (body.sender_id!=null)
        db.InsertMessage(body.sender_id,body.receiver_id,message,body.type);
}

// Accepts POST requests at /webhook endpoint  Facebook Message Hook
app.post('/webhook', (req, res) => {
    // Parse the request body from the POST
    let body = req.body;
    // Check the webhook event is from a Page subscription
    if (body.object === 'page') {
        body.entry.forEach(function (entry) {
            console.log(entry);
            let webhook_event = entry.messaging[0];
            // Get the sender PSID
            let sender_psid = webhook_event.sender.id;
            // console.log('Sender ID: ' + sender_psid);
            // Check if the event is a message or postback and
            // pass the event to the appropriate handler function
            if (webhook_event.message) {
                console.log(webhook_event);
                handleMessage(sender_psid, webhook_event.message);
            } else if (webhook_event.postback) {
                handlePostback(sender_psid, webhook_event.postback);
            }

        });
        // Return a '200 OK' response to all events
        res.status(200).send('EVENT_RECEIVED');

    } else {
        // Return a '404 Not Found' if event is not from a page subscription
        res.sendStatus(404);
    }

});

async function handleMessage(sender_psid, received_message) {
    let response;
    // Checks if the message contains text
    if (received_message.text) {
        //check
        let message = await db.LAMOGA_WAF_request(sender_psid, received_message.text,'facebook');
        if (message)
            sendMessage(sender_psid, message);
    } else if (received_message.attachments) {
        return;
        // Get 300the URL of the message attachment
        let attachment_url = received_message.attachments[0].payload.url;
        response = {
            "attachment": {
                "type": "template",
                "payload": {
                    "template_type": "generic",
                    "elements": [{
                        "title": "Is this the right picture?",
                        "subtitle": "Tap a button to answer.",
                        "image_url": attachment_url,
                        "buttons": [
                            {
                                "type": "postback",
                                "title": "Yes!",
                                "payload": "yes",
                            },
                            {
                                "type": "postback",
                                "title": "No!",
                                "payload": "no",
                            }
                        ],
                    }]
                }
            }
        }
        callSendAPI(sender_psid, response);
    }
    // Send the response message
}

function sendMessage(sender_psid, message) {
    let response= {"text": message };
    callSendAPI(sender_psid, response);
}

function handlePostback(sender_psid, received_postback) {
    console.log('ok')
    let response;
    // Get the payload for the postback
    let payload = received_postback.payload;

    // Set the response based on the postback payload
    if (payload === 'yes') {
        response = {"text": "Thanks!"}
    } else if (payload === 'no') {
        response = {"text": "Oops, try sending another image."}
    }
    // Send the message to acknowledge the postback
    callSendAPI(sender_psid, response);
}

function callSendAPI(sender_psid, response) {
    // Construct the message body
    let request_body = {
        "recipient": {
            "id": sender_psid
        },
        "message": response
    };

    // console.log(request_body);

    // Send the HTTP request to the Messenger Platform
    request({
        "uri": "https://graph.facebook.com/v13.0/me/messages?access_token="+PAGE_ACCESS_TOKEN,
        // "qs": {"access_token": PAGE_ACCESS_TOKEN},
        "method": "POST",
        "json": request_body
    }, (err, res, body) => {
        if (!err) {
            // console.log(res)
        } else {
            console.error("Unable to send message(callSendAPI):" + err);
        }
    });
}
//-----------facebook End
//--------------Telegram

const TelegramBot = require('node-telegram-bot-api');
const bot = new TelegramBot(process.env.telegram_token, {polling: true});
const consultant_bot = new TelegramBot(process.env.telegram_consultant_token, {polling: true});

consultant_bot.on('message', async (msg) => {
        // console.log(msg.text,msg.from.id);
    let message = await db.ConsultantTelegram(msg.from.id, msg.text);
    if (message)
        consultant_bot.sendMessage(msg.chat.id, message);

});

//https://www.lomago.io:1337/send_telegram?text=telegram&page_id=1082728856
app.get('/send_telegram', (req, res) => {
    let body=req.query;
    consultant_bot.sendMessage(body.page_id, body.text);
    res.status(200).send("sent");
});

bot.on('message', async (msg) => {
        // console.log(msg.text,msg.from.id);
    let message = await db.LAMOGA_WAF_request(msg.from.id, msg.text,'telegram');
    if (message)
        bot.sendMessage(msg.chat.id, message);

    // var hi = "hi";
    // if (msg.text.toString().toLowerCase().indexOf(hi) === 0 || msg.text.toString().toLowerCase().indexOf('hello') === 0) {
    //     bot.sendMessage(msg.chat.id, "Hello " + msg.from.first_name);
    // }

    // var bye = "bye";
    // if (msg.text.toString().toLowerCase().includes(bye)) {
    //     bot.sendMessage(msg.chat.id, "Hope to see you around again , GoodBye");
    // }
});

let newsletters= require('./newsletter');
const newsletter_bot = new TelegramBot(process.env.telegram_newsletters_token, {polling: true});

newsletter_bot.on('message', async (msg) => {
    // console.log(msg.text,msg.from.id);
    let message = await newsletters.check(msg.from.id, msg.text);
    if (message)
        newsletter_bot.sendMessage(msg.chat.id, message);

});