Add cron jon to delete inactive users + Update

Author: mmdzov

.gitignore

@@ -1,6 +1,8 @@
 # db
 *.sqlite
 
+users.json
+
 # Logs
 logs
 *.log

app.js

@@ -3,14 +3,16 @@ const { Ws, Api } = require("./config");
 const DBSqlite3 = require("./db/DBSqlite3");
 const def = require("./def");
 const express = require("express");
+const nodeCron = require("node-cron");
+const { DBAdapter } = require("./db/Adapter");
 require("dotenv").config();
 
 const app = express();
+const api = new Api();
+const DBType = new DBSqlite3();
 
 def();
 
-const api = new Api();
-
 (async () => {
   await api.create();
 
@@ -22,13 +24,19 @@ const api = new Api();
     false,
   );
 
-  const ws = new Ws({ url, accessToken: api.accessToken, DB: new DBSqlite3() });
+  const ws = new Ws({ url, accessToken: api.accessToken, DB: DBType });
 
   ws.logs();
 })();
 
 const PORT = process.env.PORT;
 
+nodeCron.schedule(`*/${process.env.CHECK_INACTIVE_USERS_DURATION} * * * *`, () => {
+  const db = new DBAdapter(DBType);
+
+  db.deleteInactiveUsers();
+});
+
 app.listen(PORT, () => {
   console.log(`Server running on port ${PORT}`);
 });

config.js

@@ -3,7 +3,7 @@ const { User, Server, IPGuard, File } = require("./utils");
 const { default: axios } = require("axios");
 const { DBAdapter } = require("./db/Adapter");
 const { join } = require("path");
-const sqlite3 = require("sqlite3");
+const sqlite3 = require("sqlite3").verbose();
 const DBSqlite3 = require("./db/DBSqlite3");
 
 class Ws {

db/Adapter.js

@@ -69,6 +69,15 @@ class DBAdapter {
   addIp(email, ip) {
     return this.database.addIp(email, ip);
   }
+
+  /**
+   * @description delete inactive users from database record
+   * @returns {void}
+   */  
+  deleteInactiveUsers() {
+    return this.database.deleteInactiveUsers()
+
+  }
 }
 
 module.exports = { DBAdapter };

db/DBSqlite3.js

@@ -1,6 +1,6 @@
 const { join } = require("path");
 const { DBInterface } = require("../interface");
-const sqlite3 = require("sqlite3");
+const sqlite3 = require("sqlite3").verbose();
 const { File } = require("../utils");
 
 function connect() {
@@ -138,6 +138,49 @@ class DBSqlite3 extends DBInterface {
       });
     });
   }
+
+  deleteInactiveUsers() {
+    const currentTime = new Date().getTime();
+    const fiveMinutesAgo = new Date(
+      currentTime - process.env.CHECK_INACTIVE_USERS_DURATION * 60 * 1000,
+    );
+
+    db.serialize(function () {
+      db.all(
+        `SELECT * FROM users WHERE json_extract(ips, '$[0].date') <= ?`,
+        fiveMinutesAgo.toISOString(),
+        function (err, rows) {
+          if (err) {
+            console.error(err);
+            return;
+          }
+
+          rows.forEach(function (row) {
+            const email = row.email;
+            const ips = JSON.parse(row.ips);
+
+            const updatedIds = ips.filter(function (id) {
+              const idDate = new Date(id.date);
+              return idDate > fiveMinutesAgo;
+            });
+
+            db.run(
+              `UPDATE users SET ips = ? WHERE email = ?`,
+              JSON.stringify(updatedIds),
+              email,
+              function (err) {
+                if (err) {
+                  console.error(err);
+                  return;
+                }
+                console.log(`Record with email ${email} updated.`);
+              },
+            );
+          });
+        },
+      );
+    });
+  }
 }
 
 module.exports = DBSqlite3;

ecosystem.config.js

@@ -20,7 +20,6 @@ module.exports = {
         NODE_ENV: "development",
         PORT: 4000,
         watch: true,
-        watch_delay: 3000,
         ignore_watch: [
           "./node_modules",
           "./package.json",

interface.js

@@ -22,6 +22,10 @@ class DBInterface {
   addIp(email, ip) {
     throw new Error("This method must be implemented in the class");
   }
+
+  deleteInactiveUsers() {
+    throw new Error("This method must be implemented in the class");
+  }
 }
 
 class LuIPInterface {

package-lock.json

@@ -23,6 +23,7 @@
     "body-parser": "^1.20.2",
     "dotenv": "^16.3.1",
     "express": "^4.18.2",
+    "node-cron": "^3.0.2",
     "node-html-parser": "^6.1.5",
     "pm2": "^5.3.0",
     "sqlite3": "^5.1.6",