diff --git a/src/helpers/http/jwt/decode/example.json b/src/helpers/http/jwt/decode/example.json new file mode 100644 index 0000000..e69de29 diff --git a/src/modules/auth/services/http/logout.service.ts b/src/modules/auth/services/http/logout.service.ts index 0662960..40ade6a 100644 --- a/src/modules/auth/services/http/logout.service.ts +++ b/src/modules/auth/services/http/logout.service.ts @@ -1,13 +1,20 @@ import { AppError } from "../../../../helpers/error/instances/app"; import { ErrorForwarder } from "../../../../helpers/error/instances/forwarder"; import { jwtDecode } from "../../../../helpers/http/jwt/decode"; +import { redis } from "../../../../utils/databases/redis/connection"; +import { deleteUserSessionRepository } from "../../../userSession/repositories/deleteUserSession.repository"; export const logoutService = async (jwtToken?: any) => { try { if (!jwtToken) throw new AppError(403, "No auth token provided"); const jwtPayload = jwtDecode(jwtToken); - return jwtPayload; + + await redis.del( + `${process.env.APP_NAME}:users:${jwtPayload.user.id}:sessions:${jwtPayload.id}`, + ); + + return deleteUserSessionRepository(jwtPayload.id); } catch (error) { ErrorForwarder(error); } diff --git a/src/modules/userSession/repositories/deleteUserSession.repository.ts b/src/modules/userSession/repositories/deleteUserSession.repository.ts new file mode 100644 index 0000000..def23ad --- /dev/null +++ b/src/modules/userSession/repositories/deleteUserSession.repository.ts @@ -0,0 +1,18 @@ +import { AppError } from "../../../helpers/error/instances/app"; +import { prisma } from "../../../utils/databases/prisma/connection"; + +export const deleteUserSessionRepository = async (sessionId: string) => { + try { + return await prisma.userSession.update({ + where: { + id: sessionId, + }, + data: { + isAuthenticated: false, + deletedAt: new Date(), + }, + }); + } catch (error) { + throw new AppError(500, "Failed to delete user session", error); + } +};