Add: update last_login column of user on login

UNICEFECAR · Apr 10, 2024 · 44c7f53 · 44c7f53
1 parent f4521d4
commit 44c7f53
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 1 deletion.
diff --git a/service/middlewares/auth.js b/service/middlewares/auth.js
@@ -40,7 +40,11 @@ import {
   tooManyLoginRequests,
 } from "#utils/errors";
 import { produceRaiseNotification } from "#utils/kafkaProducers";
-import { getFailedLoginAttempts, isJwtBlacklisted } from "#queries/auth";
+import {
+  getFailedLoginAttempts,
+  isJwtBlacklisted,
+  updateLastLoginQuery,
+} from "#queries/auth";
 
 const localStrategy = passportLocal.Strategy;
 const jwtStrategy = passportJWT.Strategy;
@@ -307,6 +311,13 @@ passport.use(
           return done(incorrectCredentials(language));
         }
 
+        await updateLastLoginQuery({
+          poolCountry: country,
+          userId: user.user_id,
+        }).catch((err) => {
+          console.log("Error updating last login", err);
+        });
+
         if (userType === "provider") {
           return done(null, user);
 

diff --git a/service/queries/auth.js b/service/queries/auth.js
@@ -42,3 +42,15 @@ export const getFailedLoginAttempts = async ({ poolCountry, userId }) => {
     [userId]
   );
 };
+
+export const updateLastLoginQuery = async ({ poolCountry, userId }) => {
+  return await getDBPool("piiDb", poolCountry).query(
+    `
+            UPDATE "user"
+            SET last_login = NOW()
+            WHERE user_id = $1
+            RETURNING *;
+        `,
+    [userId]
+  );
+};