getuser utility function

1 files changed, 2 insertions, 24 deletions

diff --git a/lib/sockets.js b/lib/sockets.js
index f35ca5f5..ad7295b0 100644
--- a/lib/sockets.js
+++ b/lib/sockets.js
@@ -1,6 +1,6 @@
 const jwt = require("jsonwebtoken");
 const io = require("socket.io");
-const { Op } = require("sequelize");
+const { getUser } = require("./utils");
 
 /* eslint-disable-next-line */
 const pick = (O, ...K) => K.reduce((o, k) => ((o[k] = O[k]), o), {});
@@ -38,29 +38,7 @@ socket.sockets.on("connect", async socket => {
   if (app.get("rates")) socket.emit("rate", app.get("rates").ask);
   socket.on("getuser", async (data, callback) => {
     l.info("socket open", socket.request.user);
-    const user = await db.User.findOne({
-      include: [
-        {
-          model: db.Payment,
-          as: "payments",
-          order: [["id", "DESC"]],
-          where: {
-            [Op.or]: {
-              received: true,
-              amount: {
-                [Op.lt]: 0,
-              },
-            },
-          },
-          limit: 12
-        }
-      ],
-      where: {
-        username: socket.request.user
-      }
-    });
-
-    callback(user);
+    callback(await getUser(socket.request.user));
   });
 
   socket.on("disconnect", s => {