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/helpers/http/jwt/decode/index.ts b/src/helpers/http/jwt/decode/index.ts index aaf5fe5..caed720 100644 --- a/src/helpers/http/jwt/decode/index.ts +++ b/src/helpers/http/jwt/decode/index.ts @@ -1,15 +1,14 @@ import jwt from "jsonwebtoken"; -import { JWTSessionPayload } from "../../../../modules/auth/auth.types"; +import { JWTAuthToken } from "./types"; import { AppError } from "../../../error/instances/app"; export const jwtDecode = (payload: string) => { - // return payload; if (!payload) throw new AppError(401, "Unauthorized"); const JWTKey = process.env.JWT_SECRET!; try { const decodedPayload = jwt.verify(payload, JWTKey); - return decodedPayload as JWTSessionPayload; + return decodedPayload as JWTAuthToken; } catch (error) { throw new AppError(401, "Invalid or expired token", error); } diff --git a/src/helpers/http/jwt/decode/types.ts b/src/helpers/http/jwt/decode/types.ts index 0320410..1b2950b 100644 --- a/src/helpers/http/jwt/decode/types.ts +++ b/src/helpers/http/jwt/decode/types.ts @@ -1,16 +1,7 @@ export interface JWTAuthToken { id: string; isAuthenticated: boolean; - userId: string; - deviceType: string; - deviceOs: string; - deviceIp: string; - isOnline: boolean; - lastOnline: Date; validUntil: Date; - deletedAt: null; - createdAt: Date; - updatedAt: Date; user: User; iat: number; exp: number; @@ -19,44 +10,21 @@ export interface JWTAuthToken { interface User { id: string; name: string; - username: string; email: string; + username: string; + avatar: string; birthDate: null; - gender: null; - phoneCC: null; - phoneNumber: null; bioProfile: null; - profilePicture: null; - commentPicture: null; - preferenceId: null; - verifiedAt: null; - disabledAt: null; - deletedAt: null; - createdAt: Date; - updatedAt: Date; - roles: Role[]; + preference: Preference; } -interface Role { +interface Preference { id: string; - name: string; - primaryColor: string; - secondaryColor: string; - pictureImage: string; - badgeImage: null; - isSuperadmin: boolean; - canEditMedia: boolean; - canManageMedia: boolean; - canEditEpisodes: boolean; - canManageEpisodes: boolean; - canEditComment: boolean; - canManageComment: boolean; - canEditUser: boolean; - canManageUser: boolean; - canEditSystem: boolean; - canManageSystem: boolean; - createdBy: string; - deletedAt: null; - createdAt: Date; - updatedAt: Date; + userId: string; + langPreference: null; + adultFiltering: string; + adultAlert: string; + videoQuality: string; + serviceDefaultId: null; + hideContries: any[]; } diff --git a/src/modules/auth/controllers/logout.controller.ts b/src/modules/auth/controllers/logout.controller.ts new file mode 100644 index 0000000..4d8f23f --- /dev/null +++ b/src/modules/auth/controllers/logout.controller.ts @@ -0,0 +1,19 @@ +import { Context } from "elysia"; +import { mainErrorHandler } from "../../../helpers/error/handler"; +import { logoutService } from "../services/http/logout.service"; +import { returnWriteResponse } from "../../../helpers/callback/httpResponse"; + +export const logoutController = async (ctx: Context) => { + try { + const jwtToken = ctx.cookie.auth_token?.value; + const serviceResponse = await logoutService(jwtToken); + return returnWriteResponse( + ctx.set, + 200, + "Logout successful", + serviceResponse, + ); + } catch (error) { + return mainErrorHandler(ctx.set, error); + } +}; diff --git a/src/modules/auth/index.ts b/src/modules/auth/index.ts index b6abb6d..bf0db41 100644 --- a/src/modules/auth/index.ts +++ b/src/modules/auth/index.ts @@ -6,6 +6,7 @@ import { googleCallbackController } from "./controllers/googleCallback.controlle import { getOauthProvidersController } from "./controllers/getOauthProviders.controller"; import { getCallbackProviderUrlController } from "./controllers/getCallbackProviderUrl.controller"; import { tokenValidationController } from "./controllers/tokenValidation.controller"; +import { logoutController } from "./controllers/logout.controller"; export const authModule = new Elysia({ prefix: "/auth" }) .post("/token/validate", tokenValidationController) @@ -14,4 +15,5 @@ export const authModule = new Elysia({ prefix: "/auth" }) .get("/github", githubRequestController) .get("/github/callback", githubCallbackController) .get("/google", googleRequestController) - .get("/google/callback", googleCallbackController); + .get("/google/callback", googleCallbackController) + .post("/logout", logoutController); diff --git a/src/modules/auth/services/http/logout.service.ts b/src/modules/auth/services/http/logout.service.ts new file mode 100644 index 0000000..40ade6a --- /dev/null +++ b/src/modules/auth/services/http/logout.service.ts @@ -0,0 +1,21 @@ +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); + + 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); + } +};