Implement cleaning methods (CRON tasks)

[vchess.git] / server / models / User.js

diff --git a/server/models/User.js b/server/models/User.js
index 7a0f70a..ee4b056 100644 (file)
--- a/server/models/User.js
+++ b/server/models/User.js
@@ -1,7 +1,7 @@
 var db = require("../utils/database");
-var maild = require("../utils/mailer.js");
 var genToken = require("../utils/tokenGenerator");
 var params = require("../config/parameters");
+var sendEmail = require('../utils/mailer');
 
 /*
  * Structure:
@@ -12,6 +12,7 @@ var params = require("../config/parameters");
  *   loginTime: datetime (validity)
  *   sessionToken: token in cookies for authentication
  *   notify: boolean (send email notifications for corr games)
+ *   created: datetime
  */
 
 const UserModel =
@@ -40,8 +41,8 @@ const UserModel =
                db.serialize(function() {
                        const insertQuery =
                                "INSERT INTO Users " +
-                               "(name, email, notify) VALUES " +
-                               "('" + name + "', '" + email + "', " + notify + ")";
+                               "(name, email, notify, created) VALUES " +
+                               "('" + name + "', '" + email + "', " + notify + "," + Date.now() + ")";
                        db.run(insertQuery, err => {
                                if (!!err)
                                        return callback(err);
@@ -63,14 +64,14 @@ const UserModel =
                });
        },
 
-  getByName: function(names, cb) {
-               db.serialize(function() {
-                       const query =
-                               "SELECT id " +
+  getByIds: function(ids, cb) {
+    db.serialize(function() {
+      const query =
+        "SELECT id, name " +
         "FROM Users " +
-                               "WHERE name IN ('" + names.join("','") + "')";
-                       db.all(query, cb);
-               });
+        "WHERE id IN (" + ids + ")";
+      db.all(query, cb);
+    });
   },
 
        /////////
@@ -128,11 +129,40 @@ const UserModel =
   /////////////////
   // NOTIFICATIONS
 
-  tryNotify: function(oppId, gid, vname, message)
+  tryNotify: function(oppId, message)
+  {
+               UserModel.getOne("id", oppId, (err,opp) => {
+      if (!err || !opp.notify)
+        return; //error is ignored here (TODO: should be logged)
+      const subject = "vchess.club - notification";
+      const body = "Hello " + opp.name + "!\n" + message;
+      sendEmail(params.mail.noreply, opp.email, subject, body, err => {
+        res.json(err || {});
+      });
+    });
+  },
+
+  ////////////
+  // CLEANING
+
+  cleanUsersDb: function()
   {
-    // TODO: send email to oppId (request...) with title
-    // "vchess.club - vname" and content "message"
-  }
+    const tsNow = Date.now();
+    // 86400000 = 24 hours in milliseconds
+    const day = 86400000;
+    db.serialize(function() {
+      const query =
+        "SELECT id, sessionToken, created " +
+        "FROM Users";
+      db.all(query, (err, users) => {
+        users.forEach(u => {
+          // Remove unlogged users for >1 day
+          if (!u.sessionToken && tsNow - u.created > day)
+            db.run("DELETE FROM Users WHERE id = " + u.id);
+        });
+      });
+    });
+  },
 }
 
 module.exports = UserModel;