🗑️ chore: remove repository from service
This commit is contained in:
@ -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);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -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);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -39,7 +39,7 @@ import { updateAllEpisodeThumbnailService } from "../services/http/updateAllEpis
|
|||||||
* }
|
* }
|
||||||
*/
|
*/
|
||||||
export const updateAllEpisodeThumbnailController = async (
|
export const updateAllEpisodeThumbnailController = async (
|
||||||
ctx: Context & { body: { service_reference_id: string } },
|
ctx: Context & { body: { service_reference_id?: string } },
|
||||||
) => {
|
) => {
|
||||||
try {
|
try {
|
||||||
const newEpisodeThumbnailsCount = await updateAllEpisodeThumbnailService(
|
const newEpisodeThumbnailsCount = await updateAllEpisodeThumbnailService(
|
||||||
|
|||||||
@ -1,35 +1,14 @@
|
|||||||
import { AppError } from "../../../../helpers/error/instances/app";
|
import { AppError } from "../../../../helpers/error/instances/app";
|
||||||
import { ErrorForwarder } from "../../../../helpers/error/instances/forwarder";
|
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 (
|
export const updateAllEpisodeThumbnailService = async (
|
||||||
serviceReferenceId: string,
|
serviceReferenceId?: string,
|
||||||
) => {
|
) => {
|
||||||
try {
|
try {
|
||||||
if (!serviceReferenceId)
|
if (!serviceReferenceId)
|
||||||
throw new AppError(400, "Service Reference ID is required.");
|
throw new AppError(400, "Service Reference ID is required.");
|
||||||
|
|
||||||
const episodesData = await getAllEpisodeWithThumbnailLinkRepository(
|
return serviceReferenceId;
|
||||||
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) {
|
} catch (error) {
|
||||||
ErrorForwarder(error);
|
ErrorForwarder(error);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user