Review System

@IsDecimal()
@Max(10)
@Min(0)
readonly overall: number;

recommended Boolean?

async createAnimeReview(createAnimeReviewDto: CreateAnimeReviewDto) {
  const animeReview = await this.databaseService.animeReview.create({
    data: {
      overall: createAnimeReviewDto.overall,
      story: createAnimeReviewDto.story,
      characters: createAnimeReviewDto.characters,
      animation: createAnimeReviewDto.animation,
      sound: createAnimeReviewDto.sound,
      enjoyment: createAnimeReviewDto.enjoyment,
      summary: createAnimeReviewDto.summary,
      pros: createAnimeReviewDto.pros,
      cons: createAnimeReviewDto.cons,
      notes: createAnimeReviewDto.notes,
      recommended: createAnimeReviewDto.recommended,
      animeId: createAnimeReviewDto.animeId,
      userId: createAnimeReviewDto.userId,
    },
    include: {
      anime: true,
      user: {
        select: {
          id: true,
          name: true,
          username: true,
          profile: {
            select: {
              id: true,
              avatarUrl: true,
            },
          },
        },
      },
    },
  });

  await this.queueService.toFeedEventQueue({
    type: FeedEventType.NewReview,
    userId: createAnimeReviewDto.userId,
    metadata: { animeReview },
  });
}

NewReview

async getAnimeReviews(getAnimeReviewsDto: GetAnimeReviewsDto) {
  const animeReviews = await this.databaseService.offsetPagination<AnimeReviewFindManyArgs>({
    model: "animeReview",
    itemsPerPage: getAnimeReviewsDto.itemsPerPage,
    page: getAnimeReviewsDto.page,
    where: {
      animeId: getAnimeReviewsDto.animeId,
      userId: getAnimeReviewsDto.userId,
    },
    include: {
      anime: true,
      user: {
        select: {
          id: true,
          name: true,
          username: true,
          profile: {
            select: {
              id: true,
              avatarUrl: true,
            },
          },
        },
      },
    },
  });

  return animeReviews;
}

async getAnimeReviewById(animeReviewId: string) {
  const animeReview = await this.databaseService.animeReview.findUnique({
    where: { id: animeReviewId },
    include: {
      anime: true,
      user: {
        select: {
          id: true,
          name: true,
          username: true,
          profile: {
            select: {
              id: true,
              avatarUrl: true,
            },
          },
        },
      },
    },
  });

  if (!animeReview) {
    throw new AppException(ERROR_CODES.REVIEW_NOT_FOUND);
  }

  return animeReview;
}

async updateAnimeReview(updateAnimeReviewDto: UpdateAnimeReviewDto) {
  const animeReview = await this.databaseService.animeReview.findUnique({
    where: {
      id: updateAnimeReviewDto.animeReviewId,
    },
  });

  if (!animeReview || animeReview.userId !== updateAnimeReviewDto.userId) {
    throw new AppException(ERROR_CODES.REVIEW_NOT_FOUND);
  }

  await this.databaseService.animeReview.update({
    where: {
      id: animeReview.id,
    },
    data: {
      overall: updateAnimeReviewDto.overall,
      story: updateAnimeReviewDto.story,
      characters: updateAnimeReviewDto.characters,
      animation: updateAnimeReviewDto.animation,
      sound: updateAnimeReviewDto.sound,
      enjoyment: updateAnimeReviewDto.enjoyment,
      summary: updateAnimeReviewDto.summary,
      pros: updateAnimeReviewDto.pros,
      cons: updateAnimeReviewDto.cons,
      notes: updateAnimeReviewDto.notes,
      recommended: updateAnimeReviewDto.recommended,
    },
  });
}

async deleteAnimeReview(deleteAnimeReviewDto: DeleteAnimeReviewDto) {
  const animeReview = await this.databaseService.animeReview.findUnique({
    where: {
      id: deleteAnimeReviewDto.animeReviewId,
    },
  });

  if (!animeReview || animeReview.userId !== deleteAnimeReviewDto.userId) {
    throw new AppException(ERROR_CODES.REVIEW_NOT_FOUND);
  }

  await this.databaseService.animeReview.delete({
    where: { id: animeReview.id },
  });
}