From 1038ad068f023ca9def91c719031f2140548f11e Mon Sep 17 00:00:00 2001 From: Rafi Arrafif Date: Sat, 21 Feb 2026 19:53:17 +0700 Subject: [PATCH] =?UTF-8?q?=F0=9F=97=91=EF=B8=8F=20chore:=20remove=20repos?= =?UTF-8?q?itory=20from=20service?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...tAllEpisodeWithThumbnailLink.repository.ts | 34 ------------------- .../PUT/updateEpisode.repository.ts | 18 ---------- .../updateAllEpisodeThumbnail.controller.ts | 2 +- .../http/updateAllEpisodeThumbnail.service.ts | 25 ++------------ 4 files changed, 3 insertions(+), 76 deletions(-) delete mode 100644 src/modules/episode/repositories/GET/getAllEpisodeWithThumbnailLink.repository.ts delete mode 100644 src/modules/episode/repositories/PUT/updateEpisode.repository.ts diff --git a/src/modules/episode/repositories/GET/getAllEpisodeWithThumbnailLink.repository.ts b/src/modules/episode/repositories/GET/getAllEpisodeWithThumbnailLink.repository.ts deleted file mode 100644 index a4502e3..0000000 --- a/src/modules/episode/repositories/GET/getAllEpisodeWithThumbnailLink.repository.ts +++ /dev/null @@ -1,34 +0,0 @@ -import { AppError } from "../../../../helpers/error/instances/app"; -import { episodeModel } from "../../episode.model"; - -export const getAllEpisodeWithThumbnailLinkRepository = async ( - serviceReferenceId: string, -) => { - try { - return await episodeModel.findMany({ - where: { - deletedAt: null, - }, - select: { - id: true, - episode: true, - videos: { - where: { - deletedAt: null, - serviceId: serviceReferenceId, - }, - select: { - code: true, - service: { - select: { - endpointThumbnail: true, - }, - }, - }, - }, - }, - }); - } catch (error) { - throw new AppError(500, "Failed to get all episode thumbnails", error); - } -}; diff --git a/src/modules/episode/repositories/PUT/updateEpisode.repository.ts b/src/modules/episode/repositories/PUT/updateEpisode.repository.ts deleted file mode 100644 index 92b09ec..0000000 --- a/src/modules/episode/repositories/PUT/updateEpisode.repository.ts +++ /dev/null @@ -1,18 +0,0 @@ -import { Prisma } from "@prisma/client"; -import { AppError } from "../../../../helpers/error/instances/app"; -import { episodeModel } from "../../episode.model"; - -export const updateEpisodeRepository = async ( - payload: Prisma.EpisodeUncheckedUpdateInput, -) => { - try { - return await episodeModel.update({ - where: { - id: payload.id as string, - }, - data: payload, - }); - } catch (error) { - throw new AppError(500, "Failed to edit episode", error); - } -}; diff --git a/src/modules/internal/controllers/updateAllEpisodeThumbnail.controller.ts b/src/modules/internal/controllers/updateAllEpisodeThumbnail.controller.ts index 5a89369..c83279e 100644 --- a/src/modules/internal/controllers/updateAllEpisodeThumbnail.controller.ts +++ b/src/modules/internal/controllers/updateAllEpisodeThumbnail.controller.ts @@ -39,7 +39,7 @@ import { updateAllEpisodeThumbnailService } from "../services/http/updateAllEpis * } */ export const updateAllEpisodeThumbnailController = async ( - ctx: Context & { body: { service_reference_id: string } }, + ctx: Context & { body: { service_reference_id?: string } }, ) => { try { const newEpisodeThumbnailsCount = await updateAllEpisodeThumbnailService( diff --git a/src/modules/internal/services/http/updateAllEpisodeThumbnail.service.ts b/src/modules/internal/services/http/updateAllEpisodeThumbnail.service.ts index 7a3067a..1370003 100644 --- a/src/modules/internal/services/http/updateAllEpisodeThumbnail.service.ts +++ b/src/modules/internal/services/http/updateAllEpisodeThumbnail.service.ts @@ -1,35 +1,14 @@ import { AppError } from "../../../../helpers/error/instances/app"; import { ErrorForwarder } from "../../../../helpers/error/instances/forwarder"; -import { updateEpisodeRepository } from "../../../episode/repositories/PUT/updateEpisode.repository"; -import { getAllEpisodeWithThumbnailLinkRepository } from "../../../episode/repositories/GET/getAllEpisodeWithThumbnailLink.repository"; export const updateAllEpisodeThumbnailService = async ( - serviceReferenceId: string, + serviceReferenceId?: string, ) => { try { if (!serviceReferenceId) throw new AppError(400, "Service Reference ID is required."); - const episodesData = await getAllEpisodeWithThumbnailLinkRepository( - serviceReferenceId, - ); - - let updatedThumbnailsCount = 0; - for (const episode of episodesData) { - if (episode.videos.length === 0) continue; - await updateEpisodeRepository({ - id: episode.id, - pictureThumbnail: - episode.videos[0].service.endpointThumbnail?.replace( - ":code:", - episode.videos[0].code, - ) || null, - }); - - updatedThumbnailsCount++; - } - - return updatedThumbnailsCount; + return serviceReferenceId; } catch (error) { ErrorForwarder(error); }