platformService.js

var requestModule = require('request');
var PasswordEncrypt = require('./lib/PasswordEncrypt');
var q = require('q');

var sharedSecret = process.env.SHARED_SECRET;
var encryptedPassword = PasswordEncrypt.encryptPassword(sharedSecret);
var platformUri = process.env.PLATFORM_BASE_URI;

console.log('Connecting to PLATFORM_BASE_URI : ' + platformUri);

var saveEvent = function (event) {
    var deferred = q.defer();
    var options = {
        url: platformUri + '/events/',
        auth: {
            user: "",
            password: encryptedPassword
        },
        json: {
            'payload': event
        }
    };
    requestModule.post(options, function (error, response) {
        if (!error && response.statusCode == 200) {
            deferred.resolve({status: "ok"});
        } else {
            deferred.reject(error);
        }
    });
    return deferred.promise;
};

var saveBatchEvents = function (batchEvents) {
    var deferred = q.defer();
    var options = {
        url: platformUri + '/events/batch',
        auth: {
            user: "",
            password: encryptedPassword
        },
        json: batchEvents
    };
    requestModule.post(options, function (error, response) {
        if (!error && response.statusCode == 200) {
            deferred.resolve({status: "ok"});
        } else {
            deferred.reject(error);
        }
    });
    return deferred.promise;
};

var aggregate = function (query) {
    var deferred = q.defer();
    var requestDetails = {
        url: platformUri + '/analytics/aggregate',
        auth: {
            user: "",
            password: encryptedPassword
        },
        qs: query,
        method: 'POST'
    };
    requestModule(requestDetails, function (error, response, body) {
        if (!error && response.statusCode == 200) {
            deferred.resolve(JSON.parse(body));
        } else {
            deferred.reject(error);
        }
    });
    return deferred.promise;
};

var filter = function (query) {
    var deferred = q.defer();
    var requestDetails = {
        url: platformUri + '/events/filter',
        auth: {
            user: "",
            password: encryptedPassword
        },
        qs: query,
        method: 'GET'
    };
    requestModule(requestDetails, function (error, response, body) {
        if (!error && response.statusCode == 200) {
            deferred.resolve(JSON.parse(body));
        } else {
            deferred.reject(error);
        }
    });
    return deferred.promise;
};


var getEventsCount = function () {
    var deferred = q.defer();

    var options = {
        url: platformUri + '/events/eventsCount',
        auth: {
            user: "",
            password: encryptedPassword
        },
        method: 'GET'
    };

    var getEventsCountFromPlatform = function (error, response, body) {
        if (!error && response.statusCode == 200) {
            var result = JSON.parse(body);
            deferred.resolve(result);
        } else {
            deferred.reject(error);
        }
    };
    requestModule(options, getEventsCountFromPlatform);
    return deferred.promise;
};

exports.saveEvent = saveEvent;
exports.saveBatchEvents = saveBatchEvents;
exports.aggregate = aggregate;
exports.filter = filter;
exports.getEventsCount = getEventsCount;