aboutsummaryrefslogtreecommitdiffstats
path: root/sockets.js
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2020-03-05 13:51:13 -0800
committerAdam Soltys <[email protected]>2020-03-05 13:51:13 -0800
commit5cb36445b47b7b2c888d802088726b6bec88651a (patch)
tree3f3921189646d7fb6d9d6a4dabe68781aa472574 /sockets.js
parentaf5e3116eb8bec64f40ebde74d1ec8c47ef971a2 (diff)
downloadcoinos-server-5cb36445b47b7b2c888d802088726b6bec88651a.tar.gz
coinos-server-5cb36445b47b7b2c888d802088726b6bec88651a.zip
pino logger
Diffstat (limited to 'sockets.js')
-rw-r--r--sockets.js8
1 files changed, 4 insertions, 4 deletions
diff --git a/sockets.js b/sockets.js
index 96315457..3360970d 100644
--- a/sockets.js
+++ b/sockets.js
@@ -5,7 +5,7 @@ const Sequelize = require("sequelize");
/* eslint-disable-next-line */
const pick = (O, ...K) => K.reduce((o, k) => ((o[k] = O[k]), o), {});
-const l = console.log;
+const l = require("pino")();;
module.exports = (app, db, server) => {
const socket = io(server, { origins: "*:*" });
@@ -32,7 +32,7 @@ module.exports = (app, db, server) => {
sids[user] ? sids[user].push(socket.id) : (sids[user] = [socket.id]);
sids[socket.id] = user;
} catch (e) {
- l(e);
+ l.error(e);
}
next();
});
@@ -41,7 +41,7 @@ module.exports = (app, db, server) => {
socket.emit("connected");
if (app.get("rates")) socket.emit("rate", app.get("rates").ask);
socket.on("getuser", async (data, callback) => {
- l("logging in", socket.request.user);
+ l.info(`logging in ${socket.request.user}`);
const user = await db.User.findOne({
include: [
{
@@ -64,7 +64,7 @@ module.exports = (app, db, server) => {
socket.on("disconnect", s => {
let user = sids[socket.id];
- l("logging out", user);
+ l.info("logging out", user);
sids[user].splice(sids[user].indexOf(socket.id), 1);
delete sids[socket.id];
});