sefanodejsapp

'use strict'
/*eslint-disable no-param-reassign */

/* TODO Evitar if/else, utilizar mais comentarios e logar a aplicacao por inteira */
/* TODO Modularizar a aplicacao para que cada funcionalidade possua seu proprio modulo a ser chamado como uma API */
/* TODO Realizar teste para identificar como distiguir um usuari ocorretamente, se atraves do envent, entry, ou message ID para que as conversas nao sejam confundidas ou misturadas quando muitos usuarios estiverem acessando no mesmo momento  */
/* Importar libs */
var express = require('express');
var request = require('request');
var bodyParser = require('body-parser');
var watson = require('watson-developer-cloud');
var SyncPromise = require('sync-promise');
var app = express();

/* Define variaveis Globais */
var contexid = {};
var name = "";
var conversation_id = "";
//var sender = "";
//var event = "";


/* Define funcoes globais para tratamento do body de mensagens */
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());


/* Define as variaveis de integracao com o Watson Assistant */
var w_conversation = watson.conversation({
    url: 'https://gateway.watsonplatform.net/assistant/api',
    username: process.env.CONVERSATION_USERNAME || '9038adb5-b39b-4e9c-9c28-6cfb885e59fe',
    password: process.env.CONVERSATION_PASSWORD || 'AOxL2SCRwePZ',
    version: 'v1',
    version_date: '2016-07-11'
});
var workspace = process.env.WORKSPACE_ID || 'ab096c7d-f28c-41c2-b4cf-0d148af91d35';


/* Define o metodo utilizado para configurar o webhook do Facebook - Utilizado unicamente no momento de configuracao da pagina do Facebbok */
app.get('/webhook/', function (req, res) {
    if (req.query['hub.mode']==='subscribe' && req.query['hub.verify_token'] === 'teste') {
        res.status(200).send(req.query['hub.challenge']);
    }else{
        res.send('Erro de validação no token.');
    }

});

/* 1 */
/* Funcao para realizar chamada rest para o facebook retornar o nome do usuario */
 var obterNomeusuarioDoFacebookAtravesDeChamadaRest = function(sender){
     request({
             url: 'https://graph.facebook.com/v3.0/'+ sender +'?fields=first_name',//v2.6
             qs: {access_token: token},
             method: 'GET'
         },
         function(error, response, body) {
             if (error) {
                 console.log('Error sending message: ', error);
             } else if (response.body.error) {
                 console.log('Error: ', response.body.error);
             }else{
                 name = JSON.parse(body).first_name;
                 console.log('User name:',name);
             }
         });
 }

/* 2 */
/* Define o metodo utilizado para receber e tratar as mensagens vindas do facebook que irao ser enviadas ao Watson Assistant */
/* Sempre passa por aqui assim que recebe uma mensagem do Facebbok e antes de chamar o W. Assistant */
app.post('/webhook/', function (req, res) {

    /* reseta as variaveis globais que devem ser especificas por usuario */
    var sender = null;
    var text = null;
    var name = null;
    var params = {};

    /* Obtem o evento que contem a mensagem e outras informacoes enviadas pelo Facebook */
    var messaging_events = req.body.entry[0].messaging;


    //for (var i = 0; i < messaging_events.length; i++) {

    /* Apos receber o evento trata a mensagem classificando por tipo */
    /* TODO Muito importante: descobrir como definir um ID unico para a conversacao do usuario, bem como o por que destes IDs estarem variando */
        var entry = req.body.entry[0];
        var event = req.body.entry[0].messaging[0];
        sender = event.sender.id;

        if (event.message && event.message.text) {
            text = event.message.text;
        }
        if (event.postback && !text) {
            text = event.postback.payload;
        }
        if (event.message && event.message.attachments) {
            text = "A Aplicacao nao esta preparada para receber attachments!";
        }


        var payload = {
            workspace_id: workspace_ID //Watson Assistant Wokspace ID

        };

        params = {
            input: text,
            context:contexid
        };

        if (params) {
            if (params.input) {
                params.input = params.input.replace("\n"," ");
                payload.input = { "text": params.input };
            }
            if (params.context) {
                payload.context = params.context;
            }
        }
        callWatson(payload, sender);
    //}
    res.sendStatus(200);
});

function callWatson(payload, sender) {
    w_conversation.message(payload, function (err, convResults) {
        console.log(convResults);

        if(convResults==null || convResults == undefined){
            return;
        }
        contexid = convResults.context;

        if(convResults!=null && convResults != undefined){
            /* TODO Sincronizar chamada para que o nome do usuario seja chamado de forma sincrona e em seguinda o trecho de codigo que realiza a chamda ao W. Assistant e  trata a mensagem */
            //obterNomeusuarioDoFacebookAtravesDeChamadaRest(sender);
        }

        /* TODO encapsular os trecho de codigo abaixo da mesma forma que o treho que realiza a consulta ao nome do usuario e organizar dentro de uma chamda sincrona para que um execute somente apos o retorno do outro */
        /* Inicio do trecho de codigo que realiza a chamda ao W. Assistant e  trata a mensagem */
        if(convResults.context !== null){
            conversation_id = convResults.context.conversation_id;
        }

        if(convResults !== null && convResults.output !== null){
            var i = 0;
            while(i < convResults.output.text.length){
                if(convResults.output.context!=null && convResults.output.context != undefined && convResults.intents[0]!=null && convResults.intents[0]!= undefined){
                    console.log("Context e Intents vindos do Watson Assistant nao sao nulos ou vazios. Retorno normal, completa.");

                    sendMessage(sender, convResults.output.text[i++], convResults.output.context, convResults.intents[0].intent); //***sendMessage(sender, convResults.output.text[i++],convResults.title);
                }
                if((convResults.output.context==null || convResults.output.context == undefined) && (convResults.intents[0]!=null && convResults.intents[0]!= undefined)){
                    //console.log("Context nulo e Intents nao nulo vindos do Watson Assistant. Retorno apenas baseado em intents. ");
                    //sendMessage(sender, convResults.output.text[i++], convResults.intents[0].intent); //***sendMessage(sender, convResults.output.text[i++],convResults.title);
                    return;
                }
                if(convResults.intents[0]==null || convResults.intents[0]== undefined){
                    console.log("Context nulo e Intents nulo vindos do Watson Assistant. Nenhum retorno sera executado!");
                    return;
                }

            }
        }
        /* Fim do trecho de codigo que realiza a chamda ao W. Assistant e  trata a mensagem */

        /* callback error */
        if (err) {
            console.error("Falha ao chamar o Wantson Assistant. Motivo: "+err);
            return;
        }

    });
}

var timer;
function timeOut (sender,text_){
    function send(){
        text_ = "timeOut";
        var payload = {
            workspace_id: workspace_ID,
            input: {
                text:text_
            },
            context: contexid
        };
        callWatson(payload,sender);
    }
    timer = setTimeout(send,30000);
}
function stopTimeOut (){
    clearTimeout(timer);
}

var text__ = null;
function sendMessage(sender, text_,context_,intent) {

    var find = /user_name/g;
    var confirm = text_.match(find);
    console.log('match: ',confirm);

    if (confirm !== null){
        text__ = text_.replace(find, name);
        //console.log('user_first_name 2: ', name);
    }else {
        text__ = text_;
    }
    //----------------------------
    if (context_ != null){
        stopTimeOut();
        var messageData = {
            recipient: {id: sender},
            message:{
                text:text__,//text:text_
                quick_replies: context_
            }};

        /* Evitar if/else, utilizar mais comentarios e logar a aplicacao por inteira */
    } else {

        /*TODO Tornar esse codigo transparente para que funcione independente do tipo de dialogo */
        stopTimeOut();
        messageData = {
            recipient: {id: sender},
            message:{
                text: text__
            }};
    }

    /*TODO Tornar esse codigo transparente para que funcione independente do tipo de dialogo */
    if (intent !== 'timeOut' && intent !== 'Agradecimentos'){
        timeOut(sender,text__);
    }
    request({
        url: 'https://graph.facebook.com/v3.0/me/messages',//v2.6
        qs: { access_token: token },
        method: 'POST',
        json: messageData
    }, function (error, response, body) {
        if (error) {
            console.log('Error sending message: ', error);
        } else if (response.body.error) {
            console.log('Error: ', response.body.error);
        }
    });
}

var workspace_ID = "ab096c7d-f28c-41c2-b4cf-0d148af91d35";
var token = "EAAF1G3WBdVYBAJWTZAe71r2shYpEJ6DZCnM2utHipiF7RdsnZAIiB7DhMf8FrkleXyY25q2ugUkDqdD2JL4bDZBrevoKWbDQH91QjjhvZAgzuJmZCErHEHoJWh3tbN5ZCFGu4o4XYbJ4dKpj7xWToqVecKL6zZBiex5bnxQIHuXHDQZDZD";
var host = (process.env.VCAP_APP_HOST || 'localhost');
var port = (process.env.VCAP_APP_PORT || 3001);
app.listen(port, host);