diff options
Diffstat (limited to 'lib/sockets.js')
| -rw-r--r-- | lib/sockets.js | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/sockets.js b/lib/sockets.js index 117a8d67..9e683e0c 100644 --- a/lib/sockets.js +++ b/lib/sockets.js @@ -11,10 +11,11 @@ const subscriptions = []; emit = (username, type, data) => { if (data.username !== undefined) data = pick(data, ...whitelist); + l.info("msg", data); if (type === "payment" && data.amount > 0) { for (let i = subscriptions.length - 1; i >= 0; i--) { let s = subscriptions[i]; - if (s.invoice.amount === data.amount) { + if (s.invoice.amount === data.amount || s.invoice.address === data.address || s.invoice.unconfidential === data.address) { s.ws.send(JSON.stringify({ type, data })); subscriptions.splice(i, 1); } @@ -134,6 +135,7 @@ wss.on("connection", function (ws, req) { } break; case "subscribe": + l.info("subscribe", data.amount); subscriptions.push({ invoice: data, ws }); break; default: |