Skip API and create test data in the DB directly (since the API is async)

lib/featureDb.js

@@ -6,20 +6,11 @@ var NotFoundError   = require('./error/NotFoundError');
 var FEATURE_COLUMNS = ['name', 'description', 'enabled', 'strategy_name', 'parameters'];
 
 eventStore.on(eventType.featureCreated, function (event) {
-    knex('features')
+    return createFeature(event.data);
-        .insert(eventToRow(event))
-        .catch(function (err) {
-            logger.error('Could not insert feature, error was: ', err);
-        });
 });
 
 eventStore.on(eventType.featureUpdated, function (event) {
-    knex('features')
+    return updateFeature(event.data);
-        .where({name: event.data.name})
-        .update(eventToRow(event))
-        .catch(function (err) {
-            logger.error('Could not update feature, error was: ', err);
-        });
 });
 
 function getFeatures() {
@@ -52,18 +43,37 @@ function rowToFeature(row) {
     };
 }
 
-function eventToRow(event) {
+function eventDataToRow(data) {
     return {
-        name: event.data.name,
+        name: data.name,
-        description: event.data.description,
+        description: data.description,
-        enabled: event.data.enabled ? 1 : 0,
+        enabled: data.enabled ? 1 : 0,
-        strategy_name: event.data.strategy, // jshint ignore: line
+        strategy_name: data.strategy, // jshint ignore: line
-        parameters: event.data.parameters
+        parameters: data.parameters
     };
 }
 
+function createFeature(data) {
+    return knex('features')
+        .insert(eventDataToRow(data))
+        .catch(function (err) {
+            logger.error('Could not insert feature, error was: ', err);
+        });
+}
+
+function updateFeature(data) {
+    return knex('features')
+        .where({name: data.name})
+        .update(eventDataToRow(data))
+        .catch(function (err) {
+            logger.error('Could not update feature, error was: ', err);
+        });
+}
+
 module.exports = {
     getFeatures: getFeatures,
-    getFeature: getFeature
+    getFeature: getFeature,
+    _createFeature: createFeature, // visible for testing
+    _updateFeature: updateFeature  // visible for testing
 };
 

lib/strategyDb.js

@@ -5,11 +5,7 @@ var knex            = require('./dbPool');
 var STRATEGY_COLUMNS = ['name', 'description', 'parameters_template'];
 
 eventStore.on(eventType.strategyCreated, function (event) {
-    knex('strategies')
+    return createStrategy(event.data);
-        .insert(eventToRow(event))
-        .catch(function (err) {
-            logger.error('Could not insert strategy, error was: ', err);
-        });
 });
 
 eventStore.on(eventType.strategyDeleted, function (event) {
@@ -45,21 +41,29 @@ function rowToStrategy(row) {
     return {
         name: row.name,
         description: row.description,
-        enabled: row.enabled > 0,
         parametersTemplate: row.parameters_template // jshint ignore: line
     };
 }
 
-function eventToRow(event) {
+function eventDataToRow(data) {
     return {
-        name: event.data.name,
+        name: data.name,
-        description: event.data.description,
+        description: data.description,
-        parameters_template: event.data.parametersTemplate // jshint ignore: line
+        parameters_template: data.parametersTemplate // jshint ignore: line
     };
 }
 
+function createStrategy(data) {
+    knex('strategies')
+        .insert(eventDataToRow(data))
+        .catch(function (err) {
+            logger.error('Could not insert strategy, error was: ', err);
+        });
+}
+
 module.exports = {
     getStrategies: getStrategies,
-    getStrategy: getStrategy
+    getStrategy: getStrategy,
+    _createStrategy: createStrategy // visible for testing
 };
 

test/featureApiSpec.js

@@ -5,11 +5,9 @@ var stringify  = function (o) { return JSON.stringify(o, null, ' '); };
 
 describe('The features api', function () {
     beforeEach(function (done) {
-        var d = function (err) { console.log('done', err); done.bind(null, err)(); };
-
         specHelper.db.resetAndSetup()
-            .then(d.bind(null, null))
+            .then(done.bind(null, null))
-            .catch(d);
+            .catch(done);
     });
 
     it('returns three feature toggles', function (done) {

test/specHelper.js

@@ -1,9 +1,11 @@
 process.env.NODE_ENV = 'test';
 
-var Promise = require('bluebird');
+var Promise    = require('bluebird');
-var request = require('supertest');
+var request    = require('supertest');
-var app     = require('../app');
+var app        = require('../app');
-var knex    = require('../lib/dbPool');
+var knex       = require('../lib/dbPool');
+var featureDb  = require('../lib/featureDb');
+var strategyDb = require('../lib/strategyDb');
 
 Promise.promisifyAll(request);
 request = request(app);
@@ -21,13 +23,7 @@ function createStrategies() {
                 emails: "String"
             }
         }
-    ], function (strategy) {
+    ], function (strategy) { return strategyDb._createStrategy(strategy); });
-        return request
-            .post('/strategies').send(strategy)
-            .set('Content-Type', 'application/json')
-            .expect(201)
-            .endAsync();
-    });
 }
 
 function createFeatures() {
@@ -56,13 +52,7 @@ function createFeatures() {
                 "foo": "rab"
             }
         }
-    ], function (feature) {
+    ], function (feature) { return featureDb._createFeature(feature);  });
-        return request
-            .post('/features').send(feature)
-            .set('Content-Type', 'application/json')
-            .expect(201)
-            .endAsync();
-    });
 }
 
 function destroyStrategies() {