unleash/lib/featureDb.js

var eventStore = require('./eventStore'),
    eventType = require('./eventType'),
    logger = require('./logger'),
    Promise = require('bluebird'),
    dbPool = require('./dbPool');

eventStore.on(eventType.featureCreated, function (event) {
        var sql = 'INSERT INTO features(name, description, enabled, strategy_name, parameters) ' +
                   'VALUES ($1, $2, $3, $4, $5)';
        var params = [
            event.data.name,
            event.data.description,
            event.data.enabled ? 1 : 0,
            event.data.strategy,
            event.data.parameters
        ];

        dbPool.query(sql, params, function(err) {
            if(err) {
                logger.error('Could not insert feature, error was: ', err);
            }
        });
    }
);

eventStore.on(eventType.featureUpdated, function (event) {
        var feature = event.data;

        var sql = 'UPDATE features SET enabled = $1, strategy_name = $2, ' +
                  'description = $3, parameters = $4 WHERE name = $5';

        var params = [
            feature.enabled ? 1 : 0,
            feature.strategy,
            feature.description,
            feature.paramaters,
            feature.name
        ];

       dbPool.query(sql, params, function(err) {
           if(err) {
               logger.error('Could not update feature, error was: ', err);
           }
       });

    }
);

function getFeatures() {
    var sql = 'SELECT name, description, enabled, strategy_name as strategy, parameters ' +
                 'FROM features ORDER BY created_at DESC';
    return new Promise(function (resolve, reject) {
        dbPool.query(sql, function(err, res) {
            if(err) {reject(err);}
            resolve(res.rows.map(mapToToggle));
        });
    });
}

function getFeature(name) {
    var sql = 'SELECT name, description, enabled, strategy_name as strategy, parameters ' +
                 'FROM features WHERE name=$1';

    return new Promise(function (resolve, reject) {
        dbPool.query(sql, [name], function(err, res) {
            if(err) {reject(err);}

            if(res.rows.length === 1) {
                resolve(mapToToggle(res.rows[0]));
            } else {
                reject();
            }
        });
    });
}

function mapToToggle(row) {
    return {
        name: row.name,
        description: row.description,
        enabled: row.enabled > 0,
        strategy: row.strategy,
        parameters: row.parameters
    };
}

module.exports = {
    getFeatures: getFeatures,
    getFeature: getFeature
};