module.exports = function(config) { var knex = require('knex')(config); return { getEntity: function (message) { return new Promise(function(resolve, reject) { knex(message.tableName).where(message.where).select('*').then(function (data) { message.data = data[0]; resolve(message); }); }); } } }