diff --git a/index.js b/index.js index ba85262..2b28718 100644 --- a/index.js +++ b/index.js @@ -13,16 +13,20 @@ const client = new WebSocketClient(config.urlHO); client.on('open', function open() { console.log('conection to socket ho is open'); - client.send(JSON.stringify({ gln: config.gln, action: 'gnl'})); + client.send(JSON.stringify({ gln: config.gln, action: 'gln'})); client.on('message', function incoming(message) { - message = message.data.toString('utf8'); + message = JSON.parse(message.toString('utf8')); + + switch (message.action) { + case 'getEntity': - switch (message) { - case message.action == 'getEntity': data.getEntity(message.tableName, message.where || {}).then(function(data) { - client.send(data); + + message.data = data[0]; + + client.send(JSON.stringify(message)); }); break; default: