refactor: update comments services

This commit is contained in:
Aaron William Po
2023-12-11 18:17:41 -05:00
parent 8b0d182cb3
commit 80404802dc
22 changed files with 406 additions and 413 deletions

View File

@@ -1,13 +1,19 @@
import ServerError from '@/config/util/ServerError';
import DBClient from '@/prisma/DBClient';
import editBeerCommentById from '@/services/comments/beer-comment/editBeerCommentById';
import findBeerCommentById from '@/services/comments/beer-comment/findBeerCommentById';
import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema';
import { NextApiResponse } from 'next'; import { NextApiResponse } from 'next';
import { NextHandler } from 'next-connect'; import { NextHandler } from 'next-connect';
import { z } from 'zod'; import { z } from 'zod';
import createNewBeerComment from '@/services/comments/beer-comment/createNewBeerComment';
import getAllBeerComments from '@/services/comments/beer-comment/getAllBeerComments'; import ServerError from '@/config/util/ServerError';
import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema';
import {
getBeerPostCommentByIdService,
editBeerPostCommentByIdService,
createBeerPostCommentService,
getAllBeerCommentsService,
deleteBeerCommentByIdService,
getBeerPostCommentCountService,
} from '@/services/comments/beer-comment';
import { import {
CommentRequest, CommentRequest,
EditAndCreateCommentRequest, EditAndCreateCommentRequest,
@@ -21,7 +27,7 @@ export const checkIfBeerCommentOwner = async <T extends CommentRequest>(
) => { ) => {
const { id } = req.query; const { id } = req.query;
const user = req.user!; const user = req.user!;
const comment = await findBeerCommentById({ beerCommentId: id }); const comment = await getBeerPostCommentByIdService({ beerPostCommentId: id });
if (!comment) { if (!comment) {
throw new ServerError('Comment not found', 404); throw new ServerError('Comment not found', 404);
@@ -40,17 +46,12 @@ export const editBeerPostComment = async (
) => { ) => {
const { id } = req.query; const { id } = req.query;
const updated = await editBeerCommentById({ await editBeerPostCommentByIdService({ body: req.body, beerPostCommentId: id });
content: req.body.content,
rating: req.body.rating,
id,
});
res.status(200).json({ res.status(200).json({
success: true, success: true,
message: 'Comment updated successfully', message: 'Comment updated successfully',
statusCode: 200, statusCode: 200,
payload: updated,
}); });
}; };
@@ -60,9 +61,7 @@ export const deleteBeerPostComment = async (
) => { ) => {
const { id } = req.query; const { id } = req.query;
await DBClient.instance.beerComment.delete({ await deleteBeerCommentByIdService({ beerPostCommentId: id });
where: { id },
});
res.status(200).json({ res.status(200).json({
success: true, success: true,
@@ -75,15 +74,12 @@ export const createBeerPostComment = async (
req: EditAndCreateCommentRequest, req: EditAndCreateCommentRequest,
res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>, res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
) => { ) => {
const { content, rating } = req.body;
const beerPostId = req.query.id; const beerPostId = req.query.id;
const newBeerComment = await createNewBeerComment({ const newBeerComment = await createBeerPostCommentService({
content, body: req.body,
rating,
beerPostId,
userId: req.user!.id, userId: req.user!.id,
beerPostId,
}); });
res.status(201).json({ res.status(201).json({
@@ -102,13 +98,13 @@ export const getAllBeerPostComments = async (
// eslint-disable-next-line @typescript-eslint/naming-convention // eslint-disable-next-line @typescript-eslint/naming-convention
const { page_size, page_num } = req.query; const { page_size, page_num } = req.query;
const comments = await getAllBeerComments({ const comments = await getAllBeerCommentsService({
beerPostId, beerPostId,
pageNum: parseInt(page_num, 10), pageNum: parseInt(page_num, 10),
pageSize: parseInt(page_size, 10), pageSize: parseInt(page_size, 10),
}); });
const count = await DBClient.instance.beerComment.count({ where: { beerPostId } }); const count = await getBeerPostCommentCountService({ beerPostId });
res.setHeader('X-Total-Count', count); res.setHeader('X-Total-Count', count);

View File

@@ -1,14 +1,18 @@
import ServerError from '@/config/util/ServerError'; import ServerError from '@/config/util/ServerError';
import DBClient from '@/prisma/DBClient'; import DBClient from '@/prisma/DBClient';
import updateBeerStyleCommentById from '@/services/comments/beer-style-comment/updateBeerStyleCommentById';
import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema'; import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema';
import { NextApiResponse } from 'next'; import { NextApiResponse } from 'next';
import { NextHandler } from 'next-connect'; import { NextHandler } from 'next-connect';
import { z } from 'zod'; import { z } from 'zod';
import CommentQueryResult from '@/services/schema/CommentSchema/CommentQueryResult'; import {
import createNewBeerStyleComment from '@/services/comments/beer-style-comment/createNewBeerStyleComment'; updateBeerStyleCommentById,
import getAllBeerStyleComments from '@/services/comments/beer-style-comment/getAllBeerStyleComments'; createNewBeerStyleComment,
getAllBeerStyleComments,
findBeerStyleCommentById,
deleteBeerStyleCommentById,
} from '@/services/comments/beer-style-comment';
import { import {
CommentRequest, CommentRequest,
@@ -25,15 +29,14 @@ export const checkIfBeerStyleCommentOwner = async <
) => { ) => {
const { id } = req.query; const { id } = req.query;
const user = req.user!; const user = req.user!;
const beerStyleComment = await DBClient.instance.beerStyleComment.findFirst({
where: { id }, const beerStyleComment = await findBeerStyleCommentById({ beerStyleCommentId: id });
});
if (!beerStyleComment) { if (!beerStyleComment) {
throw new ServerError('Beer style comment not found.', 404); throw new ServerError('Beer style comment not found.', 404);
} }
if (beerStyleComment.postedById !== user.id) { if (beerStyleComment.postedBy.id !== user.id) {
throw new ServerError( throw new ServerError(
'You are not authorized to modify this beer style comment.', 'You are not authorized to modify this beer style comment.',
403, 403,
@@ -47,8 +50,8 @@ export const editBeerStyleComment = async (
req: EditAndCreateCommentRequest, req: EditAndCreateCommentRequest,
res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>, res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
) => { ) => {
const updated = await updateBeerStyleCommentById({ await updateBeerStyleCommentById({
id: req.query.id, beerStyleCommentId: req.query.id,
body: req.body, body: req.body,
}); });
@@ -56,7 +59,6 @@ export const editBeerStyleComment = async (
success: true, success: true,
message: 'Comment updated successfully', message: 'Comment updated successfully',
statusCode: 200, statusCode: 200,
payload: updated,
}); });
}; };
@@ -66,7 +68,7 @@ export const deleteBeerStyleComment = async (
) => { ) => {
const { id } = req.query; const { id } = req.query;
await DBClient.instance.beerStyleComment.delete({ where: { id } }); await deleteBeerStyleCommentById({ beerStyleCommentId: id });
res.status(200).json({ res.status(200).json({
success: true, success: true,
@@ -79,15 +81,11 @@ export const createComment = async (
req: EditAndCreateCommentRequest, req: EditAndCreateCommentRequest,
res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>, res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
) => { ) => {
const { content, rating } = req.body; const newBeerStyleComment = await createNewBeerStyleComment({
body: req.body,
const newBeerStyleComment: z.infer<typeof CommentQueryResult> = beerStyleId: req.query.id,
await createNewBeerStyleComment({ userId: req.user!.id,
content, });
rating,
beerStyleId: req.query.id,
userId: req.user!.id,
});
res.status(201).json({ res.status(201).json({
message: 'Beer comment created successfully', message: 'Beer comment created successfully',

View File

@@ -1,13 +1,18 @@
import ServerError from '@/config/util/ServerError'; import ServerError from '@/config/util/ServerError';
import DBClient from '@/prisma/DBClient';
import getBreweryCommentById from '@/services/comments/brewery-comment/getBreweryCommentById';
import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema'; import APIResponseValidationSchema from '@/validation/APIResponseValidationSchema';
import { NextApiResponse } from 'next'; import { NextApiResponse } from 'next';
import { NextHandler } from 'next-connect'; import { NextHandler } from 'next-connect';
import { z } from 'zod'; import { z } from 'zod';
import CommentQueryResult from '@/services/schema/CommentSchema/CommentQueryResult';
import createNewBreweryComment from '@/services/comments/brewery-comment/createNewBreweryComment'; import {
import getAllBreweryComments from '@/services/comments/brewery-comment/getAllBreweryComments'; getBreweryCommentById,
createNewBreweryComment,
getAllBreweryComments,
deleteBreweryCommentByIdService,
updateBreweryCommentById,
getBreweryCommentCount,
} from '@/services/comments/brewery-comment';
import { import {
CommentRequest, CommentRequest,
EditAndCreateCommentRequest, EditAndCreateCommentRequest,
@@ -23,13 +28,13 @@ export const checkIfBreweryCommentOwner = async <
) => { ) => {
const { id } = req.query; const { id } = req.query;
const user = req.user!; const user = req.user!;
const comment = await getBreweryCommentById(id); const comment = await getBreweryCommentById({ breweryCommentId: id });
if (!comment) { if (!comment) {
throw new ServerError('Comment not found', 404); throw new ServerError('Comment not found', 404);
} }
if (comment.postedById !== user.id) { if (comment.postedBy.id !== user.id) {
throw new ServerError('You are not authorized to modify this comment', 403); throw new ServerError('You are not authorized to modify this comment', 403);
} }
@@ -42,13 +47,9 @@ export const editBreweryPostComment = async (
) => { ) => {
const { id } = req.query; const { id } = req.query;
const updated = await DBClient.instance.breweryComment.update({ const updated = updateBreweryCommentById({
where: { id }, breweryCommentId: id,
data: { body: req.body,
content: req.body.content,
rating: req.body.rating,
updatedAt: new Date(),
},
}); });
return res.status(200).json({ return res.status(200).json({
@@ -65,7 +66,7 @@ export const deleteBreweryPostComment = async (
) => { ) => {
const { id } = req.query; const { id } = req.query;
await DBClient.instance.breweryComment.delete({ where: { id } }); await deleteBreweryCommentByIdService({ breweryCommentId: id });
res.status(200).json({ res.status(200).json({
success: true, success: true,
@@ -78,19 +79,15 @@ export const createComment = async (
req: EditAndCreateCommentRequest, req: EditAndCreateCommentRequest,
res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>, res: NextApiResponse<z.infer<typeof APIResponseValidationSchema>>,
) => { ) => {
const { content, rating } = req.body;
const breweryPostId = req.query.id; const breweryPostId = req.query.id;
const user = req.user!; const user = req.user!;
const newBreweryComment: z.infer<typeof CommentQueryResult> = const newBreweryComment = await createNewBreweryComment({
await createNewBreweryComment({ body: req.body,
content, breweryPostId,
rating, userId: user.id,
breweryPostId, });
userId: user.id,
});
res.status(201).json({ res.status(201).json({
message: 'Beer comment created successfully', message: 'Beer comment created successfully',
@@ -114,9 +111,7 @@ export const getAll = async (
pageSize: parseInt(page_size, 10), pageSize: parseInt(page_size, 10),
}); });
const count = await DBClient.instance.breweryComment.count({ const count = await getBreweryCommentCount({ breweryPostId });
where: { breweryPostId },
});
res.setHeader('X-Total-Count', count); res.setHeader('X-Total-Count', count);

View File

@@ -10,7 +10,8 @@ import updateUserAvatarById, {
} from '@/services/users/account/UpdateUserAvatarByIdParams'; } from '@/services/users/account/UpdateUserAvatarByIdParams';
import { UserExtendedNextApiRequest } from '@/config/auth/types'; import { UserExtendedNextApiRequest } from '@/config/auth/types';
import updateUserProfileById from '@/services/users/auth/updateUserProfileById'; import updateUserProfileById from '@/services/users/auth/updateUserProfileById';
import getUsersFollowingUser from '@/services/users/follows/getUsersFollowingUser';
import getUsersFollowedByUser from '@/services/users/follows/getUsersFollowedByUser';
import { import {
UserRouteRequest, UserRouteRequest,
GetUserFollowInfoRequest, GetUserFollowInfoRequest,
@@ -18,8 +19,6 @@ import {
UpdateAvatarRequest, UpdateAvatarRequest,
UpdateProfileRequest, UpdateProfileRequest,
} from './types'; } from './types';
import getUsersFollowingUser from '@/services/users/follows/getUsersFollowingUser';
import getUsersFollowedByUser from '@/services/users/follows/getUsersFollowedByUser';
export const followUser = async ( export const followUser = async (
req: UserRouteRequest, req: UserRouteRequest,

View File

@@ -1,37 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CreateCommentValidationSchema from '../../schema/CommentSchema/CreateCommentValidationSchema';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
const CreateNewBeerCommentServiceSchema = CreateCommentValidationSchema.extend({
userId: z.string().cuid(),
beerPostId: z.string().cuid(),
});
type CreateNewBeerCommentArgs = z.infer<typeof CreateNewBeerCommentServiceSchema>;
const createNewBeerComment = async ({
content,
rating,
beerPostId,
userId,
}: CreateNewBeerCommentArgs): Promise<z.infer<typeof CommentQueryResult>> => {
return DBClient.instance.beerComment.create({
data: {
content,
rating,
beerPost: { connect: { id: beerPostId } },
postedBy: { connect: { id: userId } },
},
select: {
id: true,
content: true,
rating: true,
postedBy: { select: { id: true, username: true, userAvatar: true } },
createdAt: true,
updatedAt: true,
},
});
};
export default createNewBeerComment;

View File

@@ -1,32 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
interface EditBeerCommentByIdArgs {
id: string;
content: string;
rating: number;
}
const editBeerCommentById = async ({
id,
content,
rating,
}: EditBeerCommentByIdArgs): Promise<z.infer<typeof CommentQueryResult>> => {
return DBClient.instance.beerComment.update({
where: { id },
data: { content, rating, updatedAt: new Date() },
select: {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
},
});
};
export default editBeerCommentById;

View File

@@ -1,27 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
interface FindBeerCommentArgs {
beerCommentId: string;
}
const findBeerCommentById = async ({
beerCommentId,
}: FindBeerCommentArgs): Promise<z.infer<typeof CommentQueryResult> | null> => {
return DBClient.instance.beerComment.findUnique({
where: { id: beerCommentId },
select: {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
},
});
};
export default findBeerCommentById;

View File

@@ -1,34 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
interface GetAllBeerCommentsArgs {
beerPostId: string;
pageNum: number;
pageSize: number;
}
const getAllBeerComments = async ({
beerPostId,
pageNum,
pageSize,
}: GetAllBeerCommentsArgs): Promise<z.infer<typeof CommentQueryResult>[]> => {
return DBClient.instance.beerComment.findMany({
skip: (pageNum - 1) * pageSize,
take: pageSize,
where: { beerPostId },
orderBy: { createdAt: 'desc' },
select: {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
},
});
};
export default getAllBeerComments;

View File

@@ -1,13 +0,0 @@
import DBClient from '@/prisma/DBClient';
interface GetBeerCommentCountArgs {
beerPostId: string;
}
const getBeerCommentCount = async ({
beerPostId,
}: GetBeerCommentCountArgs): Promise<number> => {
return DBClient.instance.beerComment.count({ where: { beerPostId } });
};
export default getBeerCommentCount;

View File

@@ -0,0 +1,87 @@
import DBClient from '@/prisma/DBClient';
import {
CreateBeerPostComment,
EditBeerPostCommentById,
FindOrDeleteBeerPostCommentById,
GetAllBeerPostComments,
GetBeerPostCommentCount,
} from './types';
const beerPostCommentSelect = {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
} as const;
export const createBeerPostCommentService: CreateBeerPostComment = ({
body,
beerPostId,
userId,
}) => {
const { content, rating } = body;
return DBClient.instance.beerComment.create({
data: {
content,
rating,
beerPost: { connect: { id: beerPostId } },
postedBy: { connect: { id: userId } },
},
select: beerPostCommentSelect,
});
};
export const editBeerPostCommentByIdService: EditBeerPostCommentById = ({
beerPostCommentId,
body,
}) => {
const { content, rating } = body;
return DBClient.instance.beerComment.update({
where: { id: beerPostCommentId },
data: { content, rating, updatedAt: new Date() },
select: beerPostCommentSelect,
});
};
export const getBeerPostCommentByIdService: FindOrDeleteBeerPostCommentById = ({
beerPostCommentId,
}) => {
return DBClient.instance.beerComment.findUnique({
where: { id: beerPostCommentId },
select: beerPostCommentSelect,
});
};
export const deleteBeerCommentByIdService: FindOrDeleteBeerPostCommentById = ({
beerPostCommentId,
}) => {
return DBClient.instance.beerComment.delete({
where: { id: beerPostCommentId },
select: beerPostCommentSelect,
});
};
export const getAllBeerCommentsService: GetAllBeerPostComments = ({
beerPostId,
pageNum,
pageSize,
}) => {
return DBClient.instance.beerComment.findMany({
skip: (pageNum - 1) * pageSize,
take: pageSize,
where: { beerPostId },
orderBy: { createdAt: 'desc' },
select: beerPostCommentSelect,
});
};
export const getBeerPostCommentCountService: GetBeerPostCommentCount = ({
beerPostId,
}) => {
return DBClient.instance.beerComment.count({ where: { beerPostId } });
};

View File

@@ -0,0 +1,28 @@
import CommentQueryResult from '@/services/schema/CommentSchema/CommentQueryResult';
import CreateCommentValidationSchema from '@/services/schema/CommentSchema/CreateCommentValidationSchema';
import { z } from 'zod';
type BeerPostComment = z.infer<typeof CommentQueryResult>;
export type CreateBeerPostComment = (args: {
body: z.infer<typeof CreateCommentValidationSchema>;
userId: string;
beerPostId: string;
}) => Promise<BeerPostComment>;
export type EditBeerPostCommentById = (args: {
body: z.infer<typeof CreateCommentValidationSchema>;
beerPostCommentId: string;
}) => Promise<BeerPostComment>;
export type FindOrDeleteBeerPostCommentById = (args: {
beerPostCommentId: string;
}) => Promise<BeerPostComment | null>;
export type GetBeerPostCommentCount = (args: { beerPostId: string }) => Promise<number>;
export type GetAllBeerPostComments = (args: {
beerPostId: string;
pageNum: number;
pageSize: number;
}) => Promise<BeerPostComment[]>;

View File

@@ -1,39 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CreateCommentValidationSchema from '../../schema/CommentSchema/CreateCommentValidationSchema';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
const CreateNewBeerStyleCommentServiceSchema = CreateCommentValidationSchema.extend({
userId: z.string().cuid(),
beerStyleId: z.string().cuid(),
});
type CreateNewBeerCommentArgs = z.infer<typeof CreateNewBeerStyleCommentServiceSchema>;
const createNewBeerStyleComment = async ({
content,
rating,
userId,
beerStyleId,
}: CreateNewBeerCommentArgs): Promise<z.infer<typeof CommentQueryResult>> => {
return DBClient.instance.beerStyleComment.create({
data: {
content,
rating,
beerStyle: { connect: { id: beerStyleId } },
postedBy: { connect: { id: userId } },
},
select: {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
},
});
};
export default createNewBeerStyleComment;

View File

@@ -1,34 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
interface GetAllBeerStyleCommentArgs {
beerStyleId: string;
pageNum: number;
pageSize: number;
}
const getAllBeerStyleComments = async ({
beerStyleId,
pageNum,
pageSize,
}: GetAllBeerStyleCommentArgs): Promise<z.infer<typeof CommentQueryResult>[]> => {
return DBClient.instance.beerStyleComment.findMany({
skip: (pageNum - 1) * pageSize,
take: pageSize,
where: { beerStyleId },
orderBy: { createdAt: 'desc' },
select: {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
},
});
};
export default getAllBeerStyleComments;

View File

@@ -1,15 +0,0 @@
import DBClient from '@/prisma/DBClient';
interface GetBeerStyleCommentCountArgs {
beerStyleId: string;
}
const getBeerCommentCount = async ({
beerStyleId,
}: GetBeerStyleCommentCountArgs): Promise<number> => {
return DBClient.instance.beerStyleComment.count({
where: { beerStyleId },
});
};
export default getBeerCommentCount;

View File

@@ -0,0 +1,85 @@
import DBClient from '@/prisma/DBClient';
import {
CreateNewBeerStyleComment,
GetAllBeerStyleComments,
GetBeerStyleCommentCount,
UpdateBeerStyleCommentById,
FindOrDeleteBeerStyleCommentById,
} from './types';
const beerStyleCommentSelect = {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
} as const;
export const createNewBeerStyleComment: CreateNewBeerStyleComment = ({
body,
userId,
beerStyleId,
}) => {
const { content, rating } = body;
return DBClient.instance.beerStyleComment.create({
data: {
content,
rating,
beerStyle: { connect: { id: beerStyleId } },
postedBy: { connect: { id: userId } },
},
select: beerStyleCommentSelect,
});
};
export const getAllBeerStyleComments: GetAllBeerStyleComments = ({
beerStyleId,
pageNum,
pageSize,
}) => {
return DBClient.instance.beerStyleComment.findMany({
skip: (pageNum - 1) * pageSize,
take: pageSize,
where: { beerStyleId },
orderBy: { createdAt: 'desc' },
select: beerStyleCommentSelect,
});
};
export const getBeerStyleCommentCount: GetBeerStyleCommentCount = ({ beerStyleId }) => {
return DBClient.instance.beerStyleComment.count({ where: { beerStyleId } });
};
export const updateBeerStyleCommentById: UpdateBeerStyleCommentById = ({
body,
beerStyleCommentId,
}) => {
const { content, rating } = body;
return DBClient.instance.beerStyleComment.update({
where: { id: beerStyleCommentId },
data: { content, rating, updatedAt: new Date() },
select: beerStyleCommentSelect,
});
};
export const findBeerStyleCommentById: FindOrDeleteBeerStyleCommentById = ({
beerStyleCommentId,
}) => {
return DBClient.instance.beerStyleComment.findUnique({
where: { id: beerStyleCommentId },
select: beerStyleCommentSelect,
});
};
export const deleteBeerStyleCommentById: FindOrDeleteBeerStyleCommentById = ({
beerStyleCommentId,
}) => {
return DBClient.instance.beerStyleComment.delete({
where: { id: beerStyleCommentId },
select: beerStyleCommentSelect,
});
};

View File

@@ -0,0 +1,28 @@
import CommentQueryResult from '@/services/schema/CommentSchema/CommentQueryResult';
import CreateCommentValidationSchema from '@/services/schema/CommentSchema/CreateCommentValidationSchema';
import { z } from 'zod';
type BeerStyleComment = z.infer<typeof CommentQueryResult>;
export type FindOrDeleteBeerStyleCommentById = (args: {
beerStyleCommentId: string;
}) => Promise<BeerStyleComment | null>;
export type UpdateBeerStyleCommentById = (args: {
body: z.infer<typeof CreateCommentValidationSchema>;
beerStyleCommentId: string;
}) => Promise<BeerStyleComment>;
export type GetBeerStyleCommentCount = (args: { beerStyleId: string }) => Promise<number>;
export type GetAllBeerStyleComments = (args: {
beerStyleId: string;
pageNum: number;
pageSize: number;
}) => Promise<BeerStyleComment[]>;
export type CreateNewBeerStyleComment = (args: {
body: z.infer<typeof CreateCommentValidationSchema>;
userId: string;
beerStyleId: string;
}) => Promise<BeerStyleComment>;

View File

@@ -1,23 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CreateCommentValidationSchema from '../../schema/CommentSchema/CreateCommentValidationSchema';
interface UpdateBeerStyleCommentByIdParams {
body: z.infer<typeof CreateCommentValidationSchema>;
id: string;
}
const updateBeerStyleCommentById = ({ body, id }: UpdateBeerStyleCommentByIdParams) => {
const { content, rating } = body;
return DBClient.instance.beerStyleComment.update({
where: { id },
data: {
content,
rating,
updatedAt: new Date(),
},
});
};
export default updateBeerStyleCommentById;

View File

@@ -1,39 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CreateCommentValidationSchema from '../../schema/CommentSchema/CreateCommentValidationSchema';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
const CreateNewBreweryCommentServiceSchema = CreateCommentValidationSchema.extend({
userId: z.string().cuid(),
breweryPostId: z.string().cuid(),
});
const createNewBreweryComment = async ({
content,
rating,
breweryPostId,
userId,
}: z.infer<typeof CreateNewBreweryCommentServiceSchema>): Promise<
z.infer<typeof CommentQueryResult>
> => {
return DBClient.instance.breweryComment.create({
data: {
content,
rating,
breweryPost: { connect: { id: breweryPostId } },
postedBy: { connect: { id: userId } },
},
select: {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
},
});
};
export default createNewBreweryComment;

View File

@@ -1,35 +0,0 @@
import DBClient from '@/prisma/DBClient';
import { z } from 'zod';
import CommentQueryResult from '../../schema/CommentSchema/CommentQueryResult';
const getAllBreweryComments = async ({
id,
pageNum,
pageSize,
}: {
id: string;
pageNum: number;
pageSize: number;
}) => {
const skip = (pageNum - 1) * pageSize;
const breweryComments: z.infer<typeof CommentQueryResult>[] =
await DBClient.instance.breweryComment.findMany({
skip,
take: pageSize,
where: { breweryPostId: id },
select: {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
},
orderBy: { createdAt: 'desc' },
});
return breweryComments;
};
export default getAllBreweryComments;

View File

@@ -1,9 +0,0 @@
import DBClient from '@/prisma/DBClient';
const getBreweryCommentById = async (id: string) => {
return DBClient.instance.breweryComment.findUnique({
where: { id },
});
};
export default getBreweryCommentById;

View File

@@ -0,0 +1,85 @@
import DBClient from '@/prisma/DBClient';
import {
CreateNewBreweryComment,
FindDeleteBreweryCommentById,
GetAllBreweryComments,
GetBreweryCommentCount,
UpdateBreweryCommentById,
} from './types';
const breweryCommentSelect = {
id: true,
content: true,
rating: true,
createdAt: true,
updatedAt: true,
postedBy: {
select: { id: true, username: true, createdAt: true, userAvatar: true },
},
} as const;
export const updateBreweryCommentById: UpdateBreweryCommentById = ({
breweryCommentId,
body,
}) => {
const { content, rating } = body;
return DBClient.instance.breweryComment.update({
where: { id: breweryCommentId },
data: { content, rating },
select: breweryCommentSelect,
});
};
export const createNewBreweryComment: CreateNewBreweryComment = ({
body,
breweryPostId,
userId,
}) => {
const { content, rating } = body;
return DBClient.instance.breweryComment.create({
data: {
content,
rating,
breweryPost: { connect: { id: breweryPostId } },
postedBy: { connect: { id: userId } },
},
select: breweryCommentSelect,
});
};
export const getAllBreweryComments: GetAllBreweryComments = ({
id,
pageNum,
pageSize,
}) => {
return DBClient.instance.breweryComment.findMany({
skip: (pageNum - 1) * pageSize,
take: pageSize,
where: { breweryPostId: id },
select: breweryCommentSelect,
orderBy: { createdAt: 'desc' },
});
};
export const getBreweryCommentById: FindDeleteBreweryCommentById = ({
breweryCommentId,
}) => {
return DBClient.instance.breweryComment.findUnique({
where: { id: breweryCommentId },
select: breweryCommentSelect,
});
};
export const deleteBreweryCommentByIdService: FindDeleteBreweryCommentById = ({
breweryCommentId,
}) => {
return DBClient.instance.breweryComment.delete({
where: { id: breweryCommentId },
select: breweryCommentSelect,
});
};
export const getBreweryCommentCount: GetBreweryCommentCount = ({ breweryPostId }) => {
return DBClient.instance.breweryComment.count({ where: { breweryPostId } });
};

View File

@@ -0,0 +1,29 @@
import CommentQueryResult from '@/services/schema/CommentSchema/CommentQueryResult';
import CreateCommentValidationSchema from '@/services/schema/CommentSchema/CreateCommentValidationSchema';
import { z } from 'zod';
type BreweryComment = z.infer<typeof CommentQueryResult>;
export type UpdateBreweryCommentById = (args: {
breweryCommentId: string;
body: z.infer<typeof CreateCommentValidationSchema>;
}) => Promise<BreweryComment>;
export type CreateNewBreweryComment = (args: {
body: z.infer<typeof CreateCommentValidationSchema>;
breweryPostId: string;
userId: string;
}) => Promise<BreweryComment>;
export type GetAllBreweryComments = (args: {
id: string;
pageNum: number;
pageSize: number;
}) => Promise<BreweryComment[]>;
export type FindDeleteBreweryCommentById = (args: {
breweryCommentId: string;
}) => Promise<BreweryComment | null>;
export type GetBreweryCommentCount = (args: { breweryPostId: string }) => Promise<number>;