diff --git a/src/modules/episode/controllers/getEpisodeDetails.controller.ts b/src/modules/episode/controllers/getEpisodeDetails.controller.ts new file mode 100644 index 0000000..a1f83f1 --- /dev/null +++ b/src/modules/episode/controllers/getEpisodeDetails.controller.ts @@ -0,0 +1,25 @@ +import { Context } from "elysia"; +import { mainErrorHandler } from "../../../helpers/error/handler"; +import { returnReadResponse } from "../../../helpers/callback/httpResponse"; +import { getEpisodeDetailsService } from "../services/http/getEpisodeDetails.service"; + +export interface GetEpisodeDetailsParams { + mediaSlug?: string; + episode?: string; +} + +export const getEpisodeDetailsController = async ( + ctx: Context & { params: GetEpisodeDetailsParams }, +) => { + try { + const result = await getEpisodeDetailsService(ctx.params); + return returnReadResponse( + ctx.set, + 200, + "Episode details fetched successfully.", + result, + ); + } catch (error) { + return mainErrorHandler(ctx.set, error); + } +}; diff --git a/src/modules/episode/index.ts b/src/modules/episode/index.ts index 1c8b22d..f70af3a 100644 --- a/src/modules/episode/index.ts +++ b/src/modules/episode/index.ts @@ -1,7 +1,7 @@ import Elysia from "elysia"; import { getAllEpisodeFromSpecificMediaController } from "./controllers/getAllEpisodeFromSpecificMedia.controller"; +import { getEpisodeDetailsController } from "./controllers/getEpisodeDetails.controller"; -export const episodeModule = new Elysia({ prefix: "/episodes/:mediaSlug" }).get( - "/", - getAllEpisodeFromSpecificMediaController, -); +export const episodeModule = new Elysia({ prefix: "/episodes/:mediaSlug" }) + .get("/", getAllEpisodeFromSpecificMediaController) + .get("/:episode", getEpisodeDetailsController); diff --git a/src/modules/episode/repositories/GET/getEpisodeDetails.repository.ts b/src/modules/episode/repositories/GET/getEpisodeDetails.repository.ts new file mode 100644 index 0000000..216f35d --- /dev/null +++ b/src/modules/episode/repositories/GET/getEpisodeDetails.repository.ts @@ -0,0 +1,63 @@ +import { AppError } from "../../../../helpers/error/instances/app"; +import { episodeModel } from "../../episode.model"; + +export const getEpisodeDetailsRepository = async (payload: { + mediaId: string; + episode: number; +}) => { + try { + return await episodeModel.findUnique({ + where: { + mediaId_episode: { + mediaId: payload.mediaId, + episode: payload.episode, + }, + deletedAt: null, + }, + select: { + episode: true, + name: true, + score: true, + pictureThumbnail: true, + viewed: true, + likes: true, + updatedAt: true, + uploader: { + select: { + name: true, + username: true, + }, + }, + videos: { + where: { + pendingUpload: false, + deletedAt: null, + }, + select: { + code: true, + service: { + select: { + endpointThumbnail: true, + endpointVideo: true, + endpointDownload: true, + }, + }, + }, + }, + media: { + select: { + slug: true, + title: true, + _count: { + select: { + episodes: true, + }, + }, + }, + }, + }, + }); + } catch (error) { + throw new AppError(500, "Failed to fetch episode details.", error); + } +}; diff --git a/src/modules/episode/services/http/getEpisodeDetails.service.ts b/src/modules/episode/services/http/getEpisodeDetails.service.ts new file mode 100644 index 0000000..fa7d1b3 --- /dev/null +++ b/src/modules/episode/services/http/getEpisodeDetails.service.ts @@ -0,0 +1,27 @@ +import { AppError } from "../../../../helpers/error/instances/app"; +import { ErrorForwarder } from "../../../../helpers/error/instances/forwarder"; +import { getMediaIdFromSlugRepository } from "../../../media/repositories/GET/getMediaIdFromSlug.repository"; +import { GetEpisodeDetailsParams } from "../../controllers/getEpisodeDetails.controller"; +import { getEpisodeDetailsRepository } from "../../repositories/GET/getEpisodeDetails.repository"; + +export const getEpisodeDetailsService = async ( + params: GetEpisodeDetailsParams, +) => { + try { + if (!params.mediaSlug || !params.episode) + throw new AppError(400, "Media slug and episode are required."); + + const mediaId = await getMediaIdFromSlugRepository(params.mediaSlug); + if (!mediaId?.id) throw new AppError(404, "Media not found."); + + const result = await getEpisodeDetailsRepository({ + mediaId: mediaId.id, + episode: Number(params.episode), + }); + if (!result) throw new AppError(404, "Episode not found."); + + return result; + } catch (error) { + ErrorForwarder(error); + } +}; diff --git a/src/modules/media/repositories/GET/getMediaIdFromSlug.repository.ts b/src/modules/media/repositories/GET/getMediaIdFromSlug.repository.ts new file mode 100644 index 0000000..b29064e --- /dev/null +++ b/src/modules/media/repositories/GET/getMediaIdFromSlug.repository.ts @@ -0,0 +1,15 @@ +import { AppError } from "../../../../helpers/error/instances/app"; +import { mediaModel } from "../../model"; + +export const getMediaIdFromSlugRepository = async (slug: string) => { + try { + return await mediaModel.findUnique({ + where: { slug }, + select: { + id: true, + }, + }); + } catch (error) { + throw new AppError(500, "Failed to fetch media ID from slug.", error); + } +};