diff options
Diffstat (limited to 'lib/sockets.js')
| -rw-r--r-- | lib/sockets.js | 9 |
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); } }); }); |