es6 migration

1 files changed, 5 insertions, 4 deletions

diff --git a/lib/sockets.js b/lib/sockets.js
index dcb8a840..6ea369c0 100644
--- a/lib/sockets.js
+++ b/lib/sockets.js
@@ -1,3 +1,4 @@
+import { sockets } from "./store.js";
 import app from "../app.js";
 import jwt from "jsonwebtoken";
 import { v4 as uuidv4 } from "uuid";
@@ -70,7 +71,7 @@ app.register(async function(app) {
       try {
         ({ type, data } = JSON.parse(message));
       } catch (e) {
-        l.error("coudn't parse socket message");
+        err("coudn't parse socket message");
       }
 
       switch (type) {
@@ -137,7 +138,7 @@ app.register(async function(app) {
               JSON.stringify({ type: "version", data: config.clientVersion })
             );
           } catch (e) {
-            l.error("caught socket error", e.message);
+            err("caught socket error", e.message);
             if (e.message.includes("locked")) {
               ws.send(JSON.stringify({ type: "locked" }));
               ws.send(JSON.stringify({ type: "logout" }));
@@ -178,7 +179,7 @@ app.register(async function(app) {
           subscriptions.push({ invoice: data, ws });
           break;
         default:
-          l.warn("received socket message of unknown type", type, data);
+          warn("received socket message of unknown type", type, data);
       }
     });
 
@@ -192,7 +193,7 @@ app.register(async function(app) {
 
         if (all[id]) delete all[id];
       } catch (e) {
-        l.error("problem closing socket", e.message);
+        err("problem closing socket", e.message);
       }
     });
   });