app.js

// ///////TODO Apply memeory to all parts of sending process
// //////TODO Add instruction at the begining
import { getUser } from './app/controllers/users';
import { uploadToAccount } from './app/imgur_handler/api_consumer';
import {
  verifyRequestSignature, receivedDeliveryConfirmation, receivedPostback,
  receivedAccountLink, receivedAuthentication, receivedMessageRead,
} from './app/messages/events';
import { getFirstName } from './app/helpers/facebook_apis';
import { checkMessageContent } from './app/messages/receiver';
import { handlePayload } from './app/messages/payload';

if (process.env.NODE_ENV !== 'production' && process.env.NODE_ENV !== 'staging') {
  require('dotenv').config();
}

const bodyParser = require('body-parser');
const express = require('express');
const tools = require('./app/helpers/send_functions');

const app = express();

app.set('port', process.env.PORT || 1245);
app.set('view engine', 'ejs');
app.use(bodyParser.json({ verify: verifyRequestSignature }));
app.use(express.static('public'));

// App Secret can be retrieved from the App Dashboard
const APP_SECRET = (process.env.MESSENGER_APP_SECRET)
  ? process.env.MESSENGER_APP_SECRET
  : process.env.APP_SECRET;
// Arbitrary value used to validate a webhook
const VALIDATION_TOKEN = (process.env.MESSENGER_VALIDATION_TOKEN)
  ? (process.env.MESSENGER_VALIDATION_TOKEN)
  : process.env.VALIDATION_TOKEN;
// Generate a page access token for your page from the App Dashboard
const PAGE_ACCESS_TOKEN = (process.env.MESSENGER_PAGE_ACCESS_TOKEN)
  ? (process.env.MESSENGER_PAGE_ACCESS_TOKEN)
  : process.env.PAGE_ACCESS_TOKEN;
// tools.PAGE_ACCESS_TOKEN= PAGE_ACCESS_TOKEN; //to use it in CallSendAPI
// URL where the app is running (include protocol). Used to point to scripts and
// assets located at this address.
const SERVER_URL = (process.env.SERVER_URL)
  ? (process.env.SERVER_URL)
  : process.env.SERVER_URL;
if (!(APP_SECRET && VALIDATION_TOKEN && PAGE_ACCESS_TOKEN && SERVER_URL)) {
  console.error('Missing config values');
  process.exit(1);
}
app.get('/webhook', (req, res) => {
  if (req.query['hub.mode'] === 'subscribe'
    && req.query['hub.verify_token'] === VALIDATION_TOKEN) {
    console.log('Validating webhook');
    res.status(200).send(req.query['hub.challenge']);
  } else {
    console.error('Failed validation. Make sure the validation tokens match.');
    res.sendStatus(403);
  }
});

function receivedMessage(event) {
  let senderID = event.sender.id;
  senderID = senderID.toString();
  const recipientID = event.recipient.id;
  const timeOfMessage = event.timestamp;
  const { message } = event;
  console.log('Received message for user %d and page %d at %d with message:',
    senderID, recipientID, timeOfMessage);
  console.log(JSON.stringify(message));
  const isEcho = message.is_echo;
  const messageId = message.mid;
  const appId = message.app_id;
  const { metadata } = message;
  // You may get a text or attachment but not both
  const messageText = message.text;
  const messageAttachments = message.attachments;
  const quickReply = message.quick_reply;

  if (isEcho) {
    // Just logging message echoes to conole COMMENTED FOR BETTER VISIBILLITY
    // console.log("Received echo for message %s and app %d with metadata %s",
    // messageId, appId, metadata);
    return;
  }

  getUser(senderID, () => {
    tools.sendReadReceipt(senderID);
    if (quickReply) {
      const quickReplyPayload = quickReply.payload;
      console.log('Quick reply for message %s with payload %s',
        messageId, quickReplyPayload);
      tools.sendTypingOn(senderID); // typing on till fetching
      handlePayload(quickReplyPayload, senderID);
      return;
    }

    if (messageText) {
      checkMessageContent(messageText, senderID);
    } else if (messageAttachments) {
      for (let i = 0; i < messageAttachments.length; i += 1) {
        if (messageAttachments[i].type === 'image') {
          const imageURL = messageAttachments[i].payload.url;
          uploadToAccount(senderID, imageURL);
        }
      }
      tools.sendTextMessage(senderID, 'Uploaded your meme/s for later happiness');
      setTimeout(() => {
        tools.sendTextMessage(senderID, "You can access this meme and other selected memes by typing 'my memes'");
      }, 2000); // added timeout to make sure it comes later
    }
    tools.sendTypingOff(senderID);
  });
}

/*
 * All callbacks for Messenger are POST-ed. They will be sent to the same
 * webhook. Be sure to subscribe your app to your page to receive callbacks
 * for your page.
 * https://developers.facebook.com/docs/messenger-platform/product-overview/setup#subscribe_app
 *
 */
app.post('/webhook', (req, res) => {
  const data = req.body;
  // Make sure this is a page subscription
  if (data.object === 'page') {
    // Iterate over each entry
    // There may be multiple if batched
    data.entry.forEach((pageEntry) => {
      const pageID = pageEntry.id;
      const timeOfEvent = pageEntry.time;

      // Iterate over each messaging event
      pageEntry.messaging.forEach((messagingEvent) => {
        if (messagingEvent.optin) {
          receivedAuthentication(messagingEvent);
        } else if (messagingEvent.message) {
          receivedMessage(messagingEvent);
        } else if (messagingEvent.delivery) {
          receivedDeliveryConfirmation(messagingEvent);
        } else if (messagingEvent.postback) {
          receivedPostback(messagingEvent);
        } else if (messagingEvent.read) {
          receivedMessageRead(messagingEvent);
        } else if (messagingEvent.account_linking) {
          receivedAccountLink(messagingEvent);
        } else {
          console.log('Webhook received unknown messagingEvent: ', messagingEvent);
        }
      });
    });
    // Assume all went well.
    //
    // You must send back a 200, within 20 seconds, to let us know you've
    // successfully received the callback. Otherwise, the request will time out.
    res.sendStatus(200);
  }
});
/*
 * This path is used for account linking. The account linking call-to-action
 * (sendAccountLinking) is pointed to this URL.
 *
 */
app.get('/authorize', (req, res) => {
  const accountLinkingToken = req.query.account_linking_token;
  const redirectURI = req.query.redirect_uri;
  // Authorization Code should be generated per user by the developer. This will
  // be passed to the Account Linking callback.
  const authCode = '1234567890';
  // Redirect users to this URI on successful login
  const redirectURISuccess = `${redirectURI}&authorization_code=${authCode}`;
  res.render('authorize', {
    accountLinkingToken,
    redirectURI,
    redirectURISuccess,
  });
  console.log('accountLinkingToken', accountLinkingToken);
  getFirstName(accountLinkingToken, (err, data) => {
    if (err) return console.error(err);
    const user_first_name = data;
    console.log('First NAMMMME', user_first_name);
    const message_first_time = [`Hi ${user_first_name},`, "Try me by sending 'Send meme' or 'memes' "].join('\n');
    // present user with some greeting or call to action
    // tools.sendTextMessage(senderID, message_first_time);
  });
});

// ImgurImagesConsumer('kaka', 'gallery', 'memes');
// sendMemeToUser('Khalod1');
// helpers.sendImageToNewUser('fuckme', '33333324ds32423sdfafadas');
// console.log(getUser('khal22ooood'));
// PromisedToDB('Khalod1')
//   .then((data) => {
//     console.log('=============================================');
//     console.log('returned fresh data', data);
//   })
//   .catch((err) => console.error(`[Error]: ${err}`));


// PromisedsendToDialogflow("kilme")
// .then(data => {
//   checkMessageContent(data, senderID);
//   console.log(100*"==");
//   console.log("data is " + data);

// }
// )
// .catch(err => console.error(`[Error]: ${err}`));


// Start server
// Webhooks must be available via SSL with a certificate signed by a valid
// certificate authority.
app.listen(app.get('port'), () => {
  console.log('Node app is running on port', app.get('port'));
});

module.exports = app;