Extract beer post, beer image, and beer like controller logic

src/controllers/beerImages/index.ts

@@ -0,0 +1,34 @@
+import ServerError from '@/config/util/ServerError';
+import addBeerImageToDB from '@/services/BeerImage/addBeerImageToDB';
+import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema';
+import { NextApiResponse } from 'next';
+import { z } from 'zod';
+import { UploadBeerPostImagesRequest } from './types';
+
+// eslint-disable-next-line import/prefer-default-export
+export const processBeerImageData = async (
+  req: UploadBeerPostImagesRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  const { files, user, body } = req;
+
+  if (!files || !files.length) {
+    throw new ServerError('No images uploaded', 400);
+  }
+
+  const beerImages = await addBeerImageToDB({
+    alt: body.alt,
+    caption: body.caption,
+    beerPostId: req.query.id,
+    userId: user!.id,
+    files,
+  });
+
+  res.status(200).json({
+    success: true,
+    message: `Successfully uploaded ${beerImages.length} image${
+      beerImages.length > 1 ? 's' : ''
+    }`,
+    statusCode: 200,
+  });
+};

src/controllers/beerImages/types/index.ts

@@ -0,0 +1,9 @@
+import { UserExtendedNextApiRequest } from '@/config/auth/types';
+import ImageMetadataValidationSchema from '@/services/schema/ImageSchema/ImageMetadataValidationSchema';
+import { z } from 'zod';
+
+export interface UploadBeerPostImagesRequest extends UserExtendedNextApiRequest {
+  files?: Express.Multer.File[];
+  query: { id: string };
+  body: z.infer<typeof ImageMetadataValidationSchema>;
+}

src/controllers/beerPostLikes/index.ts

@@ -0,0 +1,77 @@
+import { UserExtendedNextApiRequest } from "@/config/auth/types";
+import ServerError from "@/config/util/ServerError";
+import getBeerPostById from "@/services/BeerPost/getBeerPostById";
+import createBeerPostLike from "@/services/BeerPostLike/createBeerPostLike";
+import findBeerPostLikeById from "@/services/BeerPostLike/findBeerPostLikeById";
+import getBeerPostLikeCount from "@/services/BeerPostLike/getBeerPostLikeCount";
+import removeBeerPostLikeById from "@/services/BeerPostLike/removeBeerPostLikeById";
+import APIResponseValidationSchema from "@/validation/APIResponseValidationSchema";
+import { NextApiResponse, NextApiRequest } from "next";
+import { z } from "zod";
+
+export const sendLikeRequest = async (
+  req: UserExtendedNextApiRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  const user = req.user!;
+  const id = req.query.id as string;
+
+  const beer = await getBeerPostById(id);
+  if (!beer) {
+    throw new ServerError('Could not find a beer post with that id', 404);
+  }
+
+  const alreadyLiked = await findBeerPostLikeById({
+    beerPostId: beer.id,
+    likedById: user.id,
+  });
+
+  const jsonResponse = {
+    success: true as const,
+    message: '',
+    statusCode: 200 as const,
+  };
+
+  if (alreadyLiked) {
+    await removeBeerPostLikeById({ beerLikeId: alreadyLiked.id });
+    jsonResponse.message = 'Successfully unliked beer post';
+  } else {
+    await createBeerPostLike({ id, user });
+    jsonResponse.message = 'Successfully liked beer post';
+  }
+
+  res.status(200).json(jsonResponse);
+};
+
+export const getLikeCount = async (
+  req: NextApiRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  const id = req.query.id as string;
+
+  const likeCount = await getBeerPostLikeCount({ beerPostId: id });
+
+  res.status(200).json({
+    success: true,
+    message: 'Successfully retrieved like count.',
+    statusCode: 200,
+    payload: { likeCount },
+  });
+};
+
+export const checkIfLiked = async (
+  req: UserExtendedNextApiRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  const user = req.user!;
+  const beerPostId = req.query.id as string;
+
+  const alreadyLiked = await findBeerPostLikeById({ beerPostId, likedById: user.id });
+
+  res.status(200).json({
+    success: true,
+    message: alreadyLiked ? 'Beer post is liked.' : 'Beer post is not liked.',
+    statusCode: 200,
+    payload: { isLiked: !!alreadyLiked },
+  });
+};

src/controllers/beerPosts/index.ts

@@ -0,0 +1,143 @@
+import ServerError from '@/config/util/ServerError';
+import deleteBeerPostById from '@/services/BeerPost/deleteBeerPostById';
+import editBeerPostById from '@/services/BeerPost/editBeerPostById';
+import getBeerPostById from '@/services/BeerPost/getBeerPostById';
+import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema';
+import { NextApiResponse } from 'next';
+import { NextHandler } from 'next-connect';
+import { z } from 'zod';
+import getBeerRecommendations from '@/services/BeerPost/getBeerRecommendations';
+import getAllBeerPosts from '@/services/BeerPost/getAllBeerPosts';
+import DBClient from '@/prisma/DBClient';
+import createNewBeerPost from '@/services/BeerPost/createNewBeerPost';
+import {
+  BeerPostRequest,
+  CreateBeerPostRequest,
+  EditBeerPostRequest,
+  GetAllBeerPostsRequest,
+  GetBeerRecommendationsRequest,
+} from './types';
+
+export const checkIfBeerPostOwner = async <BeerPostRequestType extends BeerPostRequest>(
+  req: BeerPostRequestType,
+  res: NextApiResponse,
+  next: NextHandler,
+) => {
+  const { user, query } = req;
+  const { id } = query;
+
+  const beerPost = await getBeerPostById(id);
+
+  if (!beerPost) {
+    throw new ServerError('Beer post not found', 404);
+  }
+
+  if (beerPost.postedBy.id !== user!.id) {
+    throw new ServerError('You cannot edit that beer post.', 403);
+  }
+
+  return next();
+};
+
+export const editBeerPost = async (
+  req: EditBeerPostRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  await editBeerPostById({ id: req.query.id, data: req.body });
+
+  res.status(200).json({
+    message: 'Beer post updated successfully',
+    success: true,
+    statusCode: 200,
+  });
+};
+
+export const deleteBeerPost = async (req: BeerPostRequest, res: NextApiResponse) => {
+  const { id } = req.query;
+
+  const deleted = await deleteBeerPostById({ beerPostId: id });
+  if (!deleted) {
+    throw new ServerError('Beer post not found', 404);
+  }
+
+  res.status(200).json({
+    message: 'Beer post deleted successfully',
+    success: true,
+    statusCode: 200,
+  });
+};
+
+export const getBeerPostRecommendations = async (
+  req: GetBeerRecommendationsRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  const { id } = req.query;
+
+  const beerPost = await getBeerPostById(id);
+
+  if (!beerPost) {
+    throw new ServerError('Beer post not found', 404);
+  }
+
+  const pageNum = parseInt(req.query.page_num as string, 10);
+  const pageSize = parseInt(req.query.page_size as string, 10);
+
+  const { count, beerRecommendations } = await getBeerRecommendations({
+    beerPost,
+    pageNum,
+    pageSize,
+  });
+
+  res.setHeader('X-Total-Count', count);
+  res.status(200).json({
+    success: true,
+    message: 'Recommendations fetched successfully',
+    statusCode: 200,
+    payload: beerRecommendations,
+  });
+};
+
+export const getBeerPosts = async (
+  req: GetAllBeerPostsRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  const pageNum = parseInt(req.query.page_num, 10);
+  const pageSize = parseInt(req.query.page_size, 10);
+
+  const beerPosts = await getAllBeerPosts({ pageNum, pageSize });
+
+  const beerPostCount = await DBClient.instance.beerPost.count();
+
+  res.setHeader('X-Total-Count', beerPostCount);
+
+  res.status(200).json({
+    message: 'Beer posts retrieved successfully',
+    statusCode: 200,
+    payload: beerPosts,
+    success: true,
+  });
+};
+
+export const createBeerPost = async (
+  req: CreateBeerPostRequest,
+  res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
+) => {
+  const { name, description, styleId: typeId, abv, ibu, breweryId } = req.body;
+
+  const newBeerPost = await createNewBeerPost({
+    name,
+    description,
+    abv,
+    ibu,
+    styleId: typeId,
+    breweryId,
+    userId: req.user!.id,
+  });
+
+  res.status(201).json({
+    message: 'Beer post created successfully',
+    statusCode: 201,
+    payload: newBeerPost,
+    success: true,
+  });
+};

src/controllers/beerPosts/types/index.ts

@@ -0,0 +1,25 @@
+import { UserExtendedNextApiRequest } from '@/config/auth/types';
+import CreateBeerPostValidationSchema from '@/services/BeerPost/schema/CreateBeerPostValidationSchema';
+import EditBeerPostValidationSchema from '@/services/BeerPost/schema/EditBeerPostValidationSchema';
+import { NextApiRequest } from 'next';
+import { z } from 'zod';
+
+export interface BeerPostRequest extends UserExtendedNextApiRequest {
+  query: { id: string };
+}
+
+export interface EditBeerPostRequest extends BeerPostRequest {
+  body: z.infer<typeof EditBeerPostValidationSchema>;
+}
+
+export interface GetAllBeerPostsRequest extends NextApiRequest {
+  query: { page_num: string; page_size: string };
+}
+
+export interface GetBeerRecommendationsRequest extends BeerPostRequest {
+  query: { id: string; page_num: string; page_size: string };
+}
+
+export interface CreateBeerPostRequest extends UserExtendedNextApiRequest {
+  body: z.infer<typeof CreateBeerPostValidationSchema>;
+}