src/modules/episode/episode.model.ts

@@ -0,0 +1,3 @@
+import { prisma } from "../../utils/databases/prisma/connection";
+
+export const episodeModel = prisma.episode;

src/modules/episode/repositories/GET/getAllEpisodeWithThumbnailLink.repository.ts

@@ -0,0 +1,34 @@
+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);
+  }
+};

src/modules/episode/repositories/PUT/updateEpisode.repository.ts

@@ -0,0 +1,18 @@
+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);
+  }
+};

src/modules/internal/controllers/updateAllEpisodeThumbnail.controller.ts

@@ -0,0 +1,21 @@
+import { Context } from "elysia";
+import { mainErrorHandler } from "../../../helpers/error/handler";
+import { returnWriteResponse } from "../../../helpers/callback/httpResponse";
+import { updateAllEpisodeThumbnailService } from "../services/http/updateAllEpisodeThumbnail.service";
+
+export const updateAllEpisodeThumbnailController = async (
+  ctx: Context & { body: { service_reference_id: string } },
+) => {
+  try {
+    const newEpisodeThumbnailsCount = await updateAllEpisodeThumbnailService(
+      ctx.body.service_reference_id,
+    );
+    return returnWriteResponse(
+      ctx.set,
+      204,
+      `Updating ${newEpisodeThumbnailsCount} episode thumbnails successfully.`,
+    );
+  } catch (error) {
+    return mainErrorHandler(ctx.set, error);
+  }
+};

src/modules/internal/index.ts

@@ -3,9 +3,11 @@ import { bulkInsertEpisodeController } from "./controllers/bulkInsertEpisode.con
 import { bulkInsertMediaController } from "./controllers/bulkInsertMedia.controller";
 import { createVideoServiceInternalController } from "./controllers/createVideoService.controller";
 import { bulkInsertVideoController } from "./controllers/bulkInsertVideo.controller";
+import { updateAllEpisodeThumbnailController } from "./controllers/updateAllEpisodeThumbnail.controller";
 
 export const internalModule = new Elysia({ prefix: "/internal" })
   .post("/media/bulk-insert", bulkInsertMediaController)
   .post("/episode/bulk-insert", bulkInsertEpisodeController)
+  .post("/episode/update-thumbnails", updateAllEpisodeThumbnailController)
   .post("/video/bulk-insert", bulkInsertVideoController)
   .post("/video-service", createVideoServiceInternalController);

src/modules/internal/services/http/updateAllEpisodeThumbnail.service.ts

@@ -0,0 +1,36 @@
+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,
+) => {
+  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;
+  } catch (error) {
+    ErrorForwarder(error);
+  }
+};