app.js

// Config Key placed at Heroku Dashboard!
// https://dashboard.heroku.com/apps/fast-temple-64164/settings

// Requirements
var express = require("express");
var request = require("request");
var bodyParser = require("body-parser");
var fs = require("fs");

// Customer
var customer = { name: "", loyalty: "", email: "", chatId: "", points: "" };
var product = { id: "" };
var magasin = { cp: "", ville: "" };

//Flags
var flags = {
  points: false,
  produit: false,
  magasin: false,
  badwords: 0,
  blocked: false
};

var app = express();
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
app.listen(process.env.PORT || 5000);

//Read the Json files
var messages = JSON.parse(fs.readFileSync("./words/messages.json", "utf8"));
var badwords = JSON.parse(fs.readFileSync("./words/badwords.json", "utf8"));

// Server index page
app.get("/", function(req, res) {
  res.send("We are online !");
});

// Facebook Webhook
// Used for verification
app.get("/webhook", function(req, res) {
  if (req.query["hub.verify_token"] === process.env.VERIFICATION_TOKEN) {
    console.log("Verified webhook");
    res.status(200).send(req.query["hub.challenge"]);
  } else {
    console.error("Verification failed. The tokens do not match.");
    res.sendStatus(403);
  }
});

// All callbacks for Messenger will be POST-ed here
app.post("/webhook", function(req, res) {
  // Make sure this is a page subscription
  if (req.body.object == "page") {
    // Iterate over each entry
    // There may be multiple entries if batched
    req.body.entry.forEach(function(entry) {
      // Iterate over each messaging event
      entry.messaging.forEach(function(event) {
        if (event.postback) {
          processPostback(event);
        } else if (event.message) {
          processMessage(event);
        }
      });
    });

    res.sendStatus(200);
  }
});

// Processing Postback answer
function processPostback(event) {
  var senderId = event.sender.id;
  customer.chatId = event.sender.id;
  var payload = event.postback.payload;

  if (payload === "Greeting") {
    // Get user's first name from the User Profile API and include it in the greeting
    getUserInfo(senderId, "first_name", welcome);
  }
}

// Processing message
function processMessage(event) {
  if (!event.message.is_echo) {
    var message = event.message;
    var senderId = event.sender.id;
    customer.chatId = event.sender.id;

    console.log("Received message from senderId: " + senderId);
    console.log("Message is: " + JSON.stringify(message));

    // You may get a text or attachment but not both
    if (message.text && !flags.blocked) {
      var formattedMsg = message.text.toLowerCase().trim();

      var insultant = false;

      //Will chech first if the person is correct with Abiki
      for (var i = 0; i < badwords.insultes.length; i++) {
        var regEx = new RegExp('\\b'+badwords.insultes[i]+'\\b', "gi");
        if (formattedMsg.match(regEx)) {
          console.log("insultes");
          sendMessage(senderId, { text: randomize(messages.ai.angry) });
          flags.badwords++;
          insultant = true;
        }
      }

      for (var i = 0; i < badwords.sexe.length; i++) {
        var regEx = new RegExp('\\b'+badwords.sexe[i]+'\\b', "gi");
        if (formattedMsg.match(regEx)) {
          console.log("sexe");
          sendMessage(senderId, { text: randomize(messages.ai.angry) });
          flags.badwords++;
          insultant = true;
        }
      }

      if (flags.badwords > 4) {
        sendMessage(senderId, { text: randomize(messages.ai.block) });
        flags.blocked = true;
      }

      if (!insultant && !flags.blocked) {
        // If we receive a text message, check to see if it matches any special
        // keywords and send back the corresponding.
        if (formattedMsg.match(/(point)/) && !flags.points) {
          flags.magasin = false;
          flags.produit = false;
          flags.points = true;
          sendMessage(senderId, { text: messages.questions.points });
        } else if (flags.points) {
          //Asked for points
          if ((re = formattedMsg.match(/\d{12}/))) {
            //Loyalty number
            customer.loyalty = re[0];
            sendMessage(senderId, { text: randomize(messages.reponses.carte) });
            requestAPI(
              "https://api.kiabi.com/v2/loyalties/" + customer.loyalty,
              process.env.KEY_LOYALTY,
              true,
              searchPoints
            );
          } else if (
            (re = formattedMsg.match(
              /\w+([\.-]?\w+)*@\w+([\.-]?\w+)*(\.\w{2,3})+/
            ))
          ) {
            //Customer Email
            customer.email = re[0];
            sendMessage(senderId, { text: randomize(messages.reponses.email) });
            requestAPIQs(
              "https://api.kiabi.com/v1/anonymous/360customers/",
              process.env.KEY_CUSTOMER,
              true,
              { email: customer.email },
              catchFidByEmail
            );
          } else {
            //Bad input
            sendMessage(senderId, {
              text: randomize(messages.erreurs.noFidnoEmail)
            });
          }
        } else if (formattedMsg.match(/(produit)/) && !flags.produit) {
          flags.points = false;
          flags.magasin = false;
          flags.produit = true;
          sendMessage(senderId, { text: messages.questions.produit });
        } else if (flags.produit) {
          if ((re = formattedMsg.match(/\d{13}/))) {
            //Sku Number
            product.id = re[0];
            sendMessage(senderId, {
              text: randomize(messages.reponses.produit)
            });
            requestAPI(
              "https://api.kiabi.com/v1/styles/" + product.id,
              process.env.KEY_STYLES,
              false,
              showProduct
            );
          } else {
            //Bad input
            sendMessage(senderId, { text: randomize(messages.erreurs.noCode) });
          }
        } else if (formattedMsg.match(/(magasin)/) && !flags.magasin) {
          flags.points = false;
          flags.magasin = true;
          flags.produit = false;
          sendMessage(senderId, { text: messages.questions.magasin });
        } else if (flags.magasin) {
          if ((re = formattedMsg.match(/\d{5}/))) {
            magasin.cp = re[0];
            sendMessage(senderId, { text: randomize(messages.reponses.magCP) });
            completeAdress(magasin.cp, false);
          } else if ((re = formattedMsg.match(/\w{2,35}/))) {
            magasin.ville = re[0];
            sendMessage(senderId, {
              text: randomize(messages.reponses.magVille)
            });
            completeAdress(magasin.ville, true);
          } else {
            //Bad input
            sendMessage(senderId, {
              text: randomize(messages.erreurs.noMagasin)
            });
          }
        } else
          //Bon là on comprends plus trop la demande
          sendMessage(senderId, { text: randomize(messages.comprendspas) });
      }
    } else if (message.attachments) {
      sendMessage(senderId, { text: randomize(messages.pj) });
    }
  }
}

//completeAdress
function completeAdress(data, ville) {
  request(
    {
      url: "https://vicopo.selfbuild.fr/cherche/" + data,
      method: "GET"
    },
    function(error, response, body) {
      //manage answers
      if (error) {
        console.log("Error getting location info: " + error);
      } else {
        var bodyObj = JSON.parse(body);
        if (ville) {
          //Default no null
          cp = bodyObj.cities[0].code;
          console.log("City"+cp);
          for (var i = 0; i < bodyObj.cities.length; i++) {
            console.log("City Search :"+bodyObj.cities[i].city.toLowerCase());
            if (bodyObj.cities[i].city.toLowerCase() == data.toLowerCase()) {
              cp = bodyObj.cities[i].code;
              console.log("City found");
            }
          }
          var body = {
            "country": "FRANCE",
            "locality": data,
            "postalCode": cp.toString()
          };
        } else {
          //Default no null
          city = bodyObj.cities[0].city;
          console.log("CP"+city);
          for (var i = 0; i < bodyObj.cities.length; i++) {
            console.log("CP search : "+bodyObj.cities[i].code);
            if (bodyObj.cities[i].code == data) {
              city = bodyObj.cities[i].city;
              console.log("CP found");
            }
          }
          var body = {
            "country": "FRANCE",
            "locality": city,
            "postalCode": data
          };
        }

        console.log("Here #now, Body : ");
        console.log(body);
        requestAPIPost(
          "https://api.kiabi.com/v1/stores/find_nearest",
          process.env.KEY_STORE,
          body,
          showAdress
        );
      }
    }
  );
}

// Show adress
function showAdress(obj) {
  console.log("Show adress");
  //obj = JSON.parse(obj);

  if (typeof obj[0] == "undefined"){
    sendMessage(customer.chatId, { text: randomize(messages.erreurs.nomag) });
    flags.magasin = false;
  }
  else {
    //customer.points = obj.points;
    sendMessage(customer.chatId, {
      text: randomize(messages.reponses.lemagasin)
    });
    message = {
      attachment: {
        type: "template",
        payload: {
          template_type: "generic",
          elements: [
            {
              title: obj[0].store.name,
              subtitle: obj[0].store.address.addressLine1
            }
          ]
        }
      }
    };
    sendMessage(customer.chatId, message);

    flags.magasin = false;
  }
}

//Show product
function showProduct(obj) {
  console.log("Show product");
  obj = JSON.parse(obj);

  if (obj.error == "not_found")
    sendMessage(customer.chatId, {
      text: randomize(messages.erreurs.noproduct)
    });
  else {
    //customer.points = obj.points;
    sendMessage(customer.chatId, {
      text: randomize(messages.reponses.leproduit)
    });
    var randCo = obj.colors[Math.floor(Math.random() * obj.colors.length)];
    console.log("Image" + randCo.picture);
    message = {
      attachment: {
        type: "template",
        payload: {
          template_type: "generic",
          elements: [
            {
              title: obj.shortTitle,
              subtitle: obj.description,
              image_url: randCo.picture + "?apikey=HACKATHON"
            }
          ]
        }
      }
    };
    sendMessage(customer.chatId, message);
    flags.produit = false;
  }
}

//Catch fidelity by email
function catchFidByEmail(obj) {
  console.log("Catch Fidelity");
  obj = JSON.parse(obj);

  if (typeof obj[0] == "undefined")
    sendMessage(customer.chatId, { text: randomize(messages.erreurs.noemail) });
  else {
    sendMessage(customer.chatId, {
      text: randomize(messages.reponses.emailFound)
    });
    console.log("API Fidelity call :"+"https://api.kiabi.com/v2/loyalties/" + obj[0].loyalties[0].cardNumber,
    process.env.KEY_LOYALTY);
    requestAPI(
      "https://api.kiabi.com/v2/loyalties/" + obj[0].loyalties[0].cardNumber,
      process.env.KEY_LOYALTY,
      true,
      searchPoints
    );
  }
}

// Search points
function searchPoints(obj) {
  console.log("Searching Points");
  console.log(obj);
  obj = JSON.parse(obj);

  if (obj.error == "not_found")
    sendMessage(customer.chatId, { text: randomize(messages.erreurs.nofid) });
  else {
    customer.points = obj.points;
    sendMessage(customer.chatId, { text: randomize(messages.reponses.points) });
    flags.points = false;
  }
}

// Ask user info
function getUserInfo(senderId, requestedFields, callback) {
  request(
    {
      url: "https://graph.facebook.com/v2.6/" + senderId,
      qs: {
        access_token: process.env.PAGE_ACCESS_TOKEN,
        fields: requestedFields
      },
      method: "GET"
    },
    function(error, response, body) {
      //manage answers
      if (error) {
        console.log("Error getting user info: " + error);
      } else {
        var bodyObj = JSON.parse(body);
        callback(senderId, bodyObj);
      }
    }
  );
}

// Will welcome people
function welcome(senderId, obj) {
  //requestAPI('https://api.kiabi.com/v2/loyalties/500007716959', process.env.KEY_LOYALTY, true);
  // Save customer name
  flags.blocked = false;
  flags.badwords = 0;
  customer.name = obj.first_name;

  var message = randomize(messages.greetings);
  sendMessage(senderId, { text: message });
}

// Choose a random content
function randomize(obj) {
  var rand = obj[Math.floor(Math.random() * obj.length)];
  return customize(rand);
}

// Customize string with var
function customize(phrase) {
  var mapObj = {
    "#name#": customer.name,
    "#ai.name#": messages.ai.name,
    "#cartefid#": customer.loyalty,
    "#email#": customer.email,
    "#points#": customer.points,
    "#produit#": product.id,
    "#magCP#": magasin.cp,
    "#magVille#": magasin.ville
  };
  phrase = phrase.replace(
    /#name#|#ai.name#|#cartefid#|#email#|#points#|#produit#|#magCP#|#magVille#/gi,
    function(matched) {
      return mapObj[matched];
    }
  );

  return phrase;
}

// Request API
function requestAPI(url, apikey, auth, callback) {
  var headers = { accept: "application/json", "x-apikey": apikey };
  if (auth)
    headers = {
      accept: "application/json",
      "x-apikey": apikey,
      authorization: process.env.AUTHORIZATION
    };

  request(
    {
      url: url,
      headers: headers,
      method: "GET"
    },
    function(error, response, body) {
      if (error) {
        console.log("Error api " + error);
      } else {
        console.log("API GO : "+ url + response + body);
        console.log("Body :");
        console.log(body);
        console.log("Callback :");
        console.log(callback);
        callback(body);
      }
    }
  );
}

// Request API
function requestAPIQs(url, apikey, auth, qs, callback) {
  var headers = { accept: "application/json", "x-apikey": apikey };
  if (auth)
    headers = {
      accept: "application/json",
      "x-apikey": apikey,
      authorization: process.env.AUTHORIZATION
    };

  request(
    {
      url: url,
      headers: headers,
      qs: qs,
      method: "GET"
    },
    function(error, response, body) {
      if (error) {
        console.log("Error api " + error);
      } else {
        console.log("APIQS GO : ");
        console.dir(response);
        console.dir(body);
        callback(body);
      }
    }
  );
}

//Request API POST
function requestAPIPost(url, apikey, body, callback) {
  var headers = { accept: "application/json", "x-apikey": apikey };
  console.log("ici" + body);
  console.log(url + headers + body);
  request(
    {
      url: url,
      headers: headers,
      json: true,
      method: "POST",
      body: body
    },
    function(error, response, body) {
      if (error) {
        console.log("Error post api " + error);
      } else {
        console.log("APIPOST GO : ");
        console.dir(body);
        callback(body);
      }
    }
  );
}

// sends message to user
function sendMessage(recipientId, message) {
  request(
    {
      url: "https://graph.facebook.com/v2.6/me/messages",
      qs: { access_token: process.env.PAGE_ACCESS_TOKEN },
      method: "POST",
      json: {
        recipient: { id: recipientId },
        message: message
      }
    },
    function(error, response, body) {
      if (error) {
        console.log("Error sending message: " + response.error);
      }
    }
  );
}