const jwt = require("jsonwebtoken");
const io = require("socket.io");

/* eslint-disable-next-line */
const pick = (O, ...K) => K.reduce((o, k) => ((o[k] = O[k]), o), {});
sids = {};

socket = io(server, { origins: "*:*" });
emit = (username, msg, data) => {
  if (data.username !== undefined) data = pick(data, ...whitelist);

  if (!sids[username]) return;
  sids[username].map((sid, i) => {
    try {
      socket.to(sid).emit(msg, data);
    } catch (e) {
      sids[username].splice(i, 1);
    }
  });
};

socket.use((socket, next) => {
  try {
    let token = socket.handshake.query.token;
    let user = jwt.decode(token).username;
    socket.request.user = user;
    sids[user] ? sids[user].push(socket.id) : (sids[user] = [socket.id]);
    sids[socket.id] = user;
  } catch (e) {
    l.error("error creating socket", e);
  }
  next();
});

socket.sockets.on("connect", async socket => {
  socket.emit("connected");
  if (app.get("rates")) socket.emit("rate", app.get("rates").ask);
  socket.on("getuser", async (data, callback) => {
    let { user } = socket.request;
    l.info("socket open", user);
    callback(await getUser(user));
  });

  socket.on("disconnect", s => {
    let user = sids[socket.id];
    l.info("socket closed", user);
    sids[user].splice(sids[user].indexOf(socket.id), 1);
    delete sids[socket.id];
  });
});