diff --git a/lib/ws.js b/lib/ws.js index f8b401c..c38c031 100644 --- a/lib/ws.js +++ b/lib/ws.js @@ -30,7 +30,14 @@ export function init(cfg, db) { db.subscribe( message.subject, message.filter - ).then(r => ws.send(r)); + ).then(r => ws.send( + JSON.stringify({ + subject: message.subject, + field: message.field, + filter: message.filter, + value: r.map(v => v[message.field]), + }) + )); break; default: throw 'invalid action "' + message.action + '"';