log binance error

1 files changed, 17 insertions, 11 deletions

diff --git a/binance.js b/binance.js
index 52d06ad9..ccb010e1 100644
--- a/binance.js
+++ b/binance.js
@@ -1,24 +1,30 @@
 const WebSocket = require("ws");
+const l = require("pino")();
+
 module.exports = (app, socket) => {
   const binance = new WebSocket(
     "wss://stream.binance.com:9443/ws/btcusdt@ticker"
   );
 
   binance.onmessage = async function(event) {
-    let msg = JSON.parse(event.data);
-    app.set("bid", msg.b);
-    app.set("ask", msg.a);
-    app.set("last", msg.l);
+    try {
+      let msg = JSON.parse(event.data);
+      app.set("bid", msg.b);
+      app.set("ask", msg.a);
+      app.set("last", msg.l);
 
-    let fx = app.get("fxrates");
-    if (!fx) return;
-    let rates = {};
+      let fx = app.get("fxrates");
+      if (!fx) return;
+      let rates = {};
 
-    Object.keys(fx).map(symbol => {
-      rates[symbol] = msg.a * fx[symbol];
-    });
+      Object.keys(fx).map(symbol => {
+        rates[symbol] = msg.a * fx[symbol];
+      });
 
-    app.set("rates", rates);
+      app.set("rates", rates);
+    } catch(e) {
+      l.error("binance socket error", e);
+    } 
   };
 
   return binance;