From d1cc66d1a02b75f90fbf0c05910777c76228259a Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Fri, 2 Sep 2022 15:06:43 -0700 Subject: es6 migration --- lib/sockets.js | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'lib/sockets.js') 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); } }); }); -- cgit v1.2.3