avances

Eric Fernandez
1 parent b98e2730ff
Showing 2 changed files with 10 additions and 5 deletions Show diff stats
data/index.js
index.js
@@ -3,9 +3,16 @@ module.exports = function(config) {
   var knex = require('knex')(config);
  
   return {
-    getEntity: function (table, where) {
+    getEntity: function (message) {
  
-      return knex(table).where(where).select('*');
+      return new Promise(function(resolve, reject) {
+
+        knex(message.tableName).where(message.where).select('*').then(function (data) {
+
+          message.data = data[0];
+          resolve(message);
+        });
+      });
     }
   }
 }
@@ -22,9 +22,7 @@ client.on(&#39;open&#39;, function open() {
     switch (message.action) {
       case 'getEntity':
  
-        data.getEntity(message.tableName, message.where || {}).then(function(data) {
-
-          message.data = data[0];
+        data.getEntity(message).then(function(message) {
  
           client.send(JSON.stringify(message));
         });
...	...	@@ -3,9 +3,16 @@ module.exports = function(config) {
3	3	var knex = require('knex')(config);
4	4
5	5	return {
6		- getEntity: function (table, where) {
	6	+ getEntity: function (message) {
7	7
8		- return knex(table).where(where).select('*');
	8	+ return new Promise(function(resolve, reject) {
	9	+
	10	+ knex(message.tableName).where(message.where).select('*').then(function (data) {
	11	+
	12	+ message.data = data[0];
	13	+ resolve(message);
	14	+ });
	15	+ });
9	16	}
10	17	}
11	18	}
...	...	@@ -22,9 +22,7 @@ client.on('open', function open() {
22	22	switch (message.action) {
23	23	case 'getEntity':
24	24
25		- data.getEntity(message.tableName, message.where \|\| {}).then(function(data) {
26		-
27		- message.data = data[0];
	25	+ data.getEntity(message).then(function(message) {
28	26
29	27	client.send(JSON.stringify(message));
30	28	});