const WebSocket = require("ws"); module.exports = () => { binance = new WebSocket("wss://stream.binance.com:9443/ws/btcusdt@ticker"); binance.onmessage = async function (event) { try { let msg = JSON.parse(event.data); let fx = app.get("fx"); if (!fx) return; let rates = {}; Object.keys(fx).map((symbol) => { rates[symbol] = msg.c * fx[symbol]; }); app.set("ask", msg.a); app.set("bid", msg.b); app.set("last", msg.c); app.set("rates", rates); } catch (e) { l.error("binance message error", e.message); } }; binance.onerror = async function (error) { console.log("binance socket error", error); } return binance; };
coinos server — legacy coinos.io backend (Lightning, on-chain, Liquid)coinos
aboutsummaryrefslogblamecommitdiffstats
path: root/lib/invoices.js.map
blob: e48d08fc2483424255d6ce3b5329130c2cdd50c2 (plain) (tree) 
fe62cadd ^

1