var WEBHOOK_SECRET = '...';
 
// returns an express app instance
var webhook = require('telerivet-webhook')({
    webhookSecret: WEBHOOK_SECRET
});

var EVENT_INCOMING_MESSAGE = 'telerivet::incoming_message';
var EVENT_MESSAGE_STATUS = 'telerivet::send_status';
var EVENT_MESSAGE_SENT = 'telerivet::sent';
 
// parameters and event names are exactly the same as the documentation at https://telerivet.com/api/webhook
webhook.on(EVENT_INCOMING_MESSAGE, function(message) {
    console.log(message.id);
    console.log(message.type);
});
 
webhook.on(EVENT_MESSAGE_STATUS, function(message) {
    console.log(message.status);
});
 
webhook.on(EVENT_MESSAGE_SENT, function(message) {
    console.log(message.id);
    console.log(message.type);
});

// option 1 - run the app
webhook.listen(3000);
 
// option 2 - mount the app
var app = express();
app.use('/telerivet/webhook', webhook);
app.listen(3000);

var WEBHOOK_SECRET = '...';
var STATUS_URL = '...'; // public facing webhook url
 
// returns an express app instance
var webhook = require('telerivet-webhook')({
    webhookSecret: WEBHOOK_SECRET,
    autoReply: function(req, res) {
        // mock mongo query
        db.messages.find({}, function(err, messages) {
            res.json({
                messages: messages.map(function(message) {
                    return {
                        status_secret: WEBHOOK_SECRET,
                        status_url: STATUS_URL,
                        to_number: message.to,
                        content: message.content
                    };
                });
            });
        });
    }
});

var EVENT_MESSAGE_DELIVERED = 'telerivet::delivered';
var EVENT_INCOMING_MESSAGE = 'telerivet::incoming_message';
var WEBHOOK_SECRET = '...'; // as setup in the telerivet dashboard
var STATUS_URL = '...'; // public facing webhook url
 
// returns an express app instance
var webhook = require('telerivet-webhook')({
    // passed as express middleware
        // handles both incoming messages and status notifications
    webhookSecret: function(req, res, next) {
        var secret = req.body.secret || '';
        var event = req.body.event;
 
        // message status notification
        if (EVENT_INCOMING_MESSAGE !== event) {
            var split = secret.split(':');
            secret = split[0];
            // add the server identifier on the message for convenience
            req.body.__id = split[1];
        }
 
        // assert secret is correct
        if (WEBHOOK_SECRET === secret) {
            next();
        } else {
            // send Forbidden
            res.status(403).end();
        }
    },
    autoReply: function(req, res) {
        // mock
        db.messages.find({}, function(err, messages) {
            res.json({
                messages: messages.map(function(message) {
                    return {
                        // append the message id to the secret
                            // it is very important that we use the webhook secret as well as the message id here. if we only use the message id, an attacker simply needs to know a valid database identifier which may be weak (incremental - mysql, time based - mongo etc)
                        status_secret: WEBHOOK_SECRET + ':' + message._id,
                        status_url: STATUS_URL,
                        to_number: message.to,
                        content: message.content
                    };
                });
            });
        });
    }
});
 
// you can now get to the internal message id
webhook.on(EVENT_MESSAGE_DELIVERED, function(message) {
    console.log(message.__id); // internal id
    console.log(message.id); // telerivet id
});