app.js

var express = require('express');
var bodyParser = require('body-parser');
var request = require('request');

var app = new express();

app.set('port', (process.env.PORT || 5005));

// Process application/x-www-form-urlencoded
app.use(bodyParser.urlencoded({ extended: false }));

// Process application/json
app.use(bodyParser.json());

// FB settings
var PAGE_ACCESS_TOKEN = process.env.PAGE_ACCESS_TOKEN;
var VERIFY_TOKEN = process.env.VERIFY_TOKEN;

// Mongo 
var MONGO_CONNECTION_STRING = process.env.MONGO_CONNECTION_STRING;

var MongoClient = require('mongodb').MongoClient;
//API

var API_URL = 'https://go-bot-api.herokuapp.com/';
const emojiActivityMap = {
  hiking: '🚶🏾',
  biking: '🚴🏿',
  swimming: '🏊🏿'
}

app.get('/', function(req, res) {
    res.send('Go Bot');
});

app.get('/clear', function(req, res) {
    MongoClient.connect(MONGO_CONNECTION_STRING, function(err, db) {
        var col = db.collection('sessions');
        col.drop()
        db.close();
        res.send('clear');
    });
});

app.get('/api', function(req, res) {
    request.get(API_URL, function(error, response, body) {
        if (!error && response.statusCode == 200) {
            res.send(body);
        }
    });
});


/* WebHooks */
app.get('/webhook/', function(req, res) {
    if (req.query['hub.verify_token'] === VERIFY_TOKEN) {
        res.send(req.query['hub.challenge']);
    }
    res.send('Error, wrong validation token');
});

app.post('/webhook/', function(req, res) {
    messaging_events = req.body.entry[0].messaging
    for (i = 0; i < messaging_events.length; i++) {
        event = req.body.entry[0].messaging[i]
        sender = event.sender.id
        if (!event.message && !event.postback) {
            res.sendStatus(200);
            return;
        }
        console.log(JSON.stringify(messaging_events));

        MongoClient.connect(MONGO_CONNECTION_STRING, function(err, db) {
            var col = db.collection('sessions');
            if (event.message && event.message.text && event.message.text.toLowerCase() === 'start over') {
                col.deleteOne({ id: sender }, function(err, result) {
                    col.insertOne({ id: sender, step: 1 }, function(err, r) {
                        sendActivityButtonMessage(sender, "What do you want to do?");

                    });
                });
                return;
            }
            col.findOne({ id: sender }, function(err, doc) {

                if (doc) {
                    console.log(JSON.stringify(doc));

                    switch (doc.step) {
                        case 1:
                            col.updateOne({ id: sender }, { $set: { step: 2, activity: event.postback.payload } }, function(err, r) {
                                if (event.postback && event.postback.payload) {
                                    sendLocationMessage(sender, `Sounds fun 😀. ${emojiActivityMap[event.postback.payload]} Where are you?`);
                                }
                            });
                            break;
                        case 2:
                            //parse location
                            var myLocation = '';

                            if (event.message && event.message.attachments) {
                                myLocation = event.message.attachments[0].payload.coordinates.lat + ',' + event.message.attachments[0].payload.coordinates.long;
                            } else {
                                myLocation = encodeURIComponent(event.message.text);
                            }

                            col.updateOne({ id: sender }, { $set: { step: 3, location: myLocation } }, function(err, r) {
                                if (event.message && (event.message.text || event.message.attachments)) {
                                    sendTransitButtonMessage(sender);
                                }
                            });
                            break;
                        case 3:
                            col.updateOne({ id: sender }, { $set: { step: 4, transit: event.postback.payload } }, function(err, r) {
                                if (event.postback && event.postback.payload) {

                                    //get session obj
                                    doc.transit = event.postback.payload;
                                    sendParksMessage(sender, doc);

                                }
                            });
                            break;
                        case 4:
                            if (event.postback && event.postback.payload) {
                                col.updateOne({ id: sender }, { $set: { step: 4, transit: event.postback.payload } }, function(err, r) {

                                    //get session obj
                                    doc.transit = event.postback.payload;
                                    sendParksMessage(sender, doc);

                                });
                            }
                            break;
                        default:
                            sendActivityButtonMessage(sender, "What do you want to do?");
                    }
                } else {


                    col.insertOne({ id: sender, step: 1 }, function(err, r) {
                        if (event.message && event.message.text) {
                            sendActivityButtonMessage(sender, "What do you want to do?");
                        }
                    });


                }
                db.close();
            });

        });
    }
    res.sendStatus(200)
});

/* Helpers */
function sendTypingIndicator(sender) {
    request({
        url: 'https://graph.facebook.com/v2.6/me/messages',
        qs: { access_token: PAGE_ACCESS_TOKEN },
        method: 'POST',
        json: {
            recipient: { id: sender },
            "sender_action":"typing_on"
        }
    }, function(error, response, body) {
        if (error) {
            console.log('Error sending messages: ', error)
        } else if (response.body.error) {
            console.log('Error: ', response.body.error)
        }
    })
}

function sendTextMessage(sender, text) {
    messageData = {
        text: text
    }
    request({
        url: 'https://graph.facebook.com/v2.6/me/messages',
        qs: { access_token: PAGE_ACCESS_TOKEN },
        method: 'POST',
        json: {
            recipient: { id: sender },
            message: messageData,
        }
    }, function(error, response, body) {
        if (error) {
            console.log('Error sending messages: ', error)
        } else if (response.body.error) {
            console.log('Error: ', response.body.error)
        }
    })
    sendTypingIndicator(sender)
}

function sendLocationMessage(sender, text) {
    request({
        url: 'https://graph.facebook.com/v2.6/me/messages',
        qs: { access_token: PAGE_ACCESS_TOKEN },
        method: 'POST',
        json: {
            recipient: { id: sender },
            "message": {
                "text": text,
                "quick_replies": [{
                    "content_type": "location",
                }]
            },
        }
    }, function(error, response, body) {
        if (error) {
            console.log('Error sending messages: ', error)
        } else if (response.body.error) {
            console.log('Error: ', response.body.error)
        }
    })
    sendTypingIndicator(sender)
}

function sendActivityButtonMessage(sender, text) {
    var buttons = [{
        "type": "postback",
        "title": "Biking",
        "payload": "biking"
    }, {
        "type": "postback",
        "title": "Hiking",
        "payload": "hiking"
    }, {
        "type": "postback",
        "title": "Swimming",
        "payload": "swimming"
    }];

    sendButtonMessage(sender, text, buttons);
    sendTypingIndicator(sender)
}

function sendTransitButtonMessage(sender) {
    var buttons = [{
        "type": "postback",
        "title": "Car",
        "payload": "driving"
    }, {
        "type": "postback",
        "title": "Transit",
        "payload": "transit"
    }, {
        "type": "postback",
        "title": "Walk",
        "payload": "walking"
    }];

    sendButtonMessage(sender, "How are you getting there?", buttons);
    sendTypingIndicator(sender)
}

function sendParksMessage(sender, doc) {
    console.log('https://go-bot-api.herokuapp.com/recommendations?activity_name=' + doc.activity + '&start_location=' + doc.location + '&trans_mode=' + doc.transit);
    request('https://go-bot-api.herokuapp.com/recommendations?activity_name=' + doc.activity + '&start_location=' + doc.location + '&trans_mode=' + doc.transit, function(error, response, body) {
        if (!error && response.statusCode == 200) {
            var obj = JSON.parse(body);

            console.log(obj);

            //we have no data
            if (obj.recareas.length == 0) {
                MongoClient.connect(MONGO_CONNECTION_STRING, function(err, db) {
                    var col = db.collection('sessions');

                    col.deleteOne({ id: sender }, function(err, result) {
                        sendActivityButtonMessage(sender, "We couldn't find any parks that met your search criteria.  Let's try again.");
                    });
                });
            }
            var parks = [];
            for (var i = 0; i < obj.recareas.length; i++) {
                if (obj.recareas[i]) {
                    console.log(obj.recareas[i]);

                    var streetviewLocation = `https:\/\/s3.amazonaws.com/outerspatial-production/raibot/peeker.html?lat=${obj.recareas[i].latitude}&lng=${obj.recareas[i].longitude}`;
                    parks.push({ title: obj.recareas[i].name, image_url: obj.recareas[i].image, subtitle: "You're " + obj.recareas[i].travel_time + " away (" + obj.recareas[i].distance + "). The weather is " + obj.recareas[i].weather.summary.toLowerCase() + " " + Math.round(obj.recareas[i].weather.temperature) + " F.", buttons: [{ type: 'web_url', title: "Go!", url: 'https://www.google.com/maps/dir/' + doc.location + '/' + obj.recareas[i].latitude + ',' + obj.recareas[i].longitude }, { type: 'web_url', title: "Share", url: 'http://google.com' }, { type: "web_url", title: "Peek", url: streetviewLocation }] });
                }
            }

            messageData = {
                "attachment": {
                    "type": "template",
                    "payload": {
                        "template_type": "generic",
                        "elements": parks
                    }
                }
            }

            console.log(JSON.stringify(messageData));

            request({
                url: 'https://graph.facebook.com/v2.6/me/messages',
                qs: { access_token: PAGE_ACCESS_TOKEN },
                method: 'POST',
                json: {
                    recipient: { id: sender },
                    message: messageData,
                }
            }, function(error, response, body) {
                if (error) {
                    console.log('Error sending messages: ', error)
                } else if (response.body.error) {
                    console.log('Error: ', response.body.error)
                }
            })
            sendTypingIndicator(sender)
        }
    });
}

function sendButtonMessage(sender, text, buttons) {
    messageData = {
        "attachment": {
            "type": "template",
            "payload": {
                "template_type": "button",
                "text": text,
                "buttons": buttons
            }
        }
    }
    request({
        url: 'https://graph.facebook.com/v2.6/me/messages',
        qs: { access_token: PAGE_ACCESS_TOKEN },
        method: 'POST',
        json: {
            recipient: { id: sender },
            message: messageData,
        }
    }, function(error, response, body) {
        if (error) {
            console.log('Error sending messages: ', error)
        } else if (response.body.error) {
            console.log('Error: ', response.body.error)
        }
    })
    sendTypingIndicator(sender)
}


// Spin up the server
app.listen(app.get('port'), function() {
    console.log('running on port', app.get('port'))
});