+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +22/22 | +100% | +0/0 | +100% | +0/0 | +100% | +22/22 | +
| src/controllers | +
+
+ |
+ 85.71% | +318/371 | +73.28% | +96/131 | +85.33% | +64/75 | +85.18% | +276/324 | +
| src/lib | +
+
+ |
+ 50% | +19/38 | +50% | +6/12 | +37.5% | +3/8 | +50% | +17/34 | +
| src/lib/errors | +
+
+ |
+ 62.5% | +5/8 | +100% | +0/0 | +50% | +1/2 | +62.5% | +5/8 | +
| src/middlewares | +
+
+ |
+ 84.37% | +27/32 | +87.5% | +7/8 | +75% | +3/4 | +82.14% | +23/28 | +
| src/routers | +
+
+ |
+ 100% | +74/74 | +100% | +0/0 | +100% | +0/0 | +100% | +74/74 | +
| src/socket | +
+
+ |
+ 31.25% | +5/16 | +0% | +0/2 | +0% | +0/5 | +21.42% | +3/14 | +
| src/structs | +
+
+ |
+ 100% | +29/29 | +100% | +0/0 | +100% | +3/3 | +100% | +28/28 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| src | +
+
+ |
+ 100% | +22/22 | +100% | +0/0 | +100% | +0/0 | +100% | +22/22 | +
| src/controllers | +
+
+ |
+ 85.71% | +318/371 | +73.28% | +96/131 | +85.33% | +64/75 | +85.18% | +276/324 | +
| src/lib | +
+
+ |
+ 50% | +19/38 | +50% | +6/12 | +37.5% | +3/8 | +50% | +17/34 | +
| src/lib/errors | +
+
+ |
+ 62.5% | +5/8 | +100% | +0/0 | +50% | +1/2 | +62.5% | +5/8 | +
| src/middlewares | +
+
+ |
+ 84.37% | +27/32 | +87.5% | +7/8 | +75% | +3/4 | +82.14% | +23/28 | +
| src/routers | +
+
+ |
+ 100% | +74/74 | +100% | +0/0 | +100% | +0/0 | +100% | +74/74 | +
| src/socket | +
+
+ |
+ 31.25% | +5/16 | +0% | +0/2 | +0% | +0/5 | +21.42% | +3/14 | +
| src/structs | +
+
+ |
+ 100% | +29/29 | +100% | +0/0 | +100% | +3/3 | +100% | +28/28 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 | 2x +2x +2x +2x +2x +2x + + + + +2x + + +3x +3x + +1x + + + + + + + + +1x + + + +3x +3x + +2x +2x + +1x + + + +2x +2x +2x + +2x + +2x +1x + + + +1x + + + + +1x + + +2x +2x + +2x + +2x +1x + + + +1x + +1x + + +4x +4x + +4x + + + +4x +4x + + + + + + +4x + + + +2x +2x +2x + +1x +1x + +1x + + + + + + + +1x + + + +2x +1x +1x + +1x +1x + +1x + + + + + + +1x +1x +1x + +1x + | import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient';
+import { withAsync } from '../lib/withAsync';
+import NotFoundError from '../lib/errors/NotFoundError';
+import { IdParamsStruct } from '../structs/commonStructs';
+import {
+ CreateArticleBodyStruct,
+ UpdateArticleBodyStruct,
+ GetArticleListParamsStruct,
+} from '../structs/articlesStructs';
+import { CreateCommentBodyStruct, GetCommentListParamsStruct } from '../structs/commentsStruct';
+import type { Request, Response } from 'express';
+
+export const createArticle = withAsync(async (req: Request, res: Response) => {
+ const { title, content, image } = create(req.body, CreateArticleBodyStruct);
+
+ const article = await prisma.article.create({
+ data: {
+ title,
+ content,
+ image,
+ userId: req.user.id
+ }
+ });
+
+ res.status(201).send(article);
+});
+
+
+export const getArticle = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const article = await prisma.article.findUnique({ where: { id } });
+ if (!article) throw new NotFoundError('article', id.toString());
+
+ res.send(article);
+});
+
+
+export const updateArticle = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+ const { title, content, image } = create(req.body, UpdateArticleBodyStruct);
+
+ const existingArticle = await prisma.article.findUnique({ where: { id } });
+
+ if (!existingArticle) throw new NotFoundError('article', id.toString());
+ Iif (existingArticle.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 게시글을 수정할 권한이 없습니다.' });
+ }
+
+ const updatedArticle = await prisma.article.update({
+ where: { id },
+ data: { title, content, image },
+ });
+
+ res.send(updatedArticle);
+});
+
+export const deleteArticle = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const existingArticle = await prisma.article.findUnique({ where: { id } });
+
+ if (!existingArticle) throw new NotFoundError('article', id.toString());
+ Iif (existingArticle.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 게시글을 삭제할 권한이 없습니다.' });
+ }
+
+ await prisma.article.delete({ where: { id } });
+
+ res.status(204).send();
+});
+
+export const getArticleList = withAsync(async (req: Request, res: Response) => {
+ const { page, pageSize, orderBy, keyword } = create(req.query, GetArticleListParamsStruct);
+
+ const where = {
+ title: keyword ? { contains: keyword } : undefined,
+ };
+
+ const totalCount = await prisma.article.count({ where });
+ const articles = await prisma.article.findMany({
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: orderBy === 'recent' ? { createdAt: 'desc' } : { id: 'asc' },
+ where,
+ });
+
+ res.send({ list: articles, totalCount });
+});
+
+
+export const createComment = withAsync(async (req: Request, res: Response) => {
+ const { id: articleId } = create(req.params, IdParamsStruct);
+ const { content } = create(req.body, CreateCommentBodyStruct);
+
+ const existingArticle = await prisma.article.findUnique({ where: { id: articleId } });
+ Iif (!existingArticle) throw new NotFoundError('article', articleId.toString());
+
+ const comment = await prisma.comment.create({
+ data: {
+ articleId,
+ content,
+ userId: req.user.id,
+ },
+ });
+
+ res.status(201).send(comment);
+});
+
+
+export const getCommentList = withAsync(async (req: Request, res: Response) => {
+ const { id: articleId } = create(req.params, IdParamsStruct);
+ const { cursor, limit } = create(req.query, GetCommentListParamsStruct);
+
+ const article = await prisma.article.findUnique({ where: { id: articleId } });
+ Iif (!article) throw new NotFoundError('article', articleId.toString());
+
+ const commentsWithCursor = await prisma.comment.findMany({
+ cursor: cursor ? { id: cursor } : undefined,
+ take: limit + 1,
+ where: { articleId },
+ orderBy: { createdAt: 'desc' },
+ });
+
+ const hasNextPage = commentsWithCursor.length > limit;
+ const comments = commentsWithCursor.slice(0, limit);
+ const nextCursor = hasNextPage ? commentsWithCursor[limit].id : null;
+
+ res.send({ list: comments, nextCursor });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 | 3x +3x +3x + +3x + +3x + + +3x +2x +2x + +2x +2x + +2x + + + +3x +2x + +2x +2x +1x + + +1x +1x + + + +1x +1x + + + +3x +3x + +3x +3x +1x + + +2x +2x +1x + + +1x + +1x + + + + +1x +1x + + + + + + + +3x +3x + +3x +1x + + +2x + +2x + +1x + +1x + + + +1x + +1x + + + + +1x + + + + | import { PrismaClient, User } from '@prisma/client';
+import bcrypt from 'bcrypt';
+import jwt from 'jsonwebtoken';
+import type { Request, Response } from 'express';
+import { withAsync } from '../lib/withAsync';
+
+const prisma = new PrismaClient();
+
+
+const generateTokens = (user: User) => {
+ const accessSecret = process.env.JWT_SECRET || 'access_secret';
+ const refreshSecret = process.env.REFRESH_SECRET || 'refresh_secret';
+
+ const accessToken = jwt.sign({ id: user.id }, accessSecret, { expiresIn: '15m' });
+ const refreshToken = jwt.sign({ id: user.id }, refreshSecret, { expiresIn: '7d' });
+
+ return { accessToken, refreshToken };
+};
+
+
+export const signUp = withAsync(async (req: Request, res: Response) => {
+ const { email, nickname, password } = req.body;
+
+ const existingUser = await prisma.user.findUnique({ where: { email } });
+ if (existingUser) {
+ return res.status(400).json({ message: '이미 사용 중인 이메일입니다.' });
+ }
+
+ const hashedPassword = await bcrypt.hash(password, 10);
+ const user = await prisma.user.create({
+ data: { email, nickname, password: hashedPassword },
+ });
+
+ const { password: _, refreshToken: __, ...userWithoutPassword } = user;
+ res.status(201).json(userWithoutPassword);
+});
+
+
+export const signIn = withAsync(async (req: Request, res: Response) => {
+ const { email, password } = req.body;
+
+ const user = await prisma.user.findUnique({ where: { email } });
+ if (!user) {
+ return res.status(401).json({ message: '이메일 또는 비밀번호가 일치하지 않습니다.' });
+ }
+
+ const isPasswordValid = await bcrypt.compare(password, user.password);
+ if (!isPasswordValid) {
+ return res.status(401).json({ message: '이메일 또는 비밀번호가 일치하지 않습니다.' });
+ }
+
+ const { accessToken, refreshToken } = generateTokens(user);
+
+ await prisma.user.update({
+ where: { id: user.id },
+ data: { refreshToken },
+ });
+
+ const { password: _, refreshToken: __, ...userWithoutPassword } = user;
+ res.status(200).json({
+ accessToken,
+ refreshToken,
+ user: userWithoutPassword,
+ });
+});
+
+
+export const refresh = withAsync(async (req: Request, res: Response) => {
+ const { refreshToken } = req.body;
+
+ if (!refreshToken) {
+ return res.status(401).json({ message: '리프레시 토큰이 없습니다.' });
+ }
+
+ const refreshSecret = process.env.REFRESH_SECRET || 'refresh_secret';
+
+ const decoded = jwt.verify(refreshToken, refreshSecret) as { id: number };
+
+ const user = await prisma.user.findUnique({ where: { id: decoded.id } });
+
+ Iif (!user || user.refreshToken !== refreshToken) {
+ return res.status(403).json({ message: '유효하지 않은 리프레시 토큰입니다.' });
+ }
+
+ const tokens = generateTokens(user);
+
+ await prisma.user.update({
+ where: { id: user.id },
+ data: { refreshToken: tokens.refreshToken },
+ });
+
+ res.json({
+ accessToken: tokens.accessToken,
+ refreshToken: tokens.refreshToken,
+ });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 | 2x +2x +2x +2x +2x +2x + + + +2x +2x +2x + +1x +1x + + + +1x + + + + + + + +1x + + + + + + + + + + +1x + + + +2x +1x +1x + +1x +1x + + + +1x + + + + + + +1x +1x +1x + +1x + + + + + +2x + + + + + + + + + + + + + + + + + + + + + +2x + + + + + + + + + + + + + + + | import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient'; // 통일된 이름 사용
+import { withAsync } from '../lib/withAsync';
+import { UpdateCommentBodyStruct, CreateCommentBodyStruct, GetCommentListParamsStruct } from '../structs/commentsStruct';
+import NotFoundError from '../lib/errors/NotFoundError';
+import { IdParamsStruct } from '../structs/commonStructs';
+import type { Request, Response } from 'express';
+
+
+export const createComment = withAsync(async (req: Request, res: Response) => {
+ const { id: productId } = create(req.params, IdParamsStruct);
+ const { content } = create(req.body, CreateCommentBodyStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id: productId } });
+ Iif (!existingProduct) {
+ throw new NotFoundError('product', productId.toString());
+ }
+
+ const comment = await prisma.comment.create({
+ data: {
+ productId,
+ content,
+ userId: req.user.id
+ }
+ });
+
+ Iif (existingProduct.userId && existingProduct.userId !== req.user.id) {
+ await prisma.notification.create({
+ data: {
+ type: 'COMMENT',
+ userId: existingProduct.userId,
+ message: `[${existingProduct.name}] 상품에 새로운 댓글이 달렸습니다: ${content.substring(0, 15)}...`,
+ productId: productId,
+ },
+ });
+ }
+
+ res.status(201).send(comment);
+});
+
+
+export const getCommentList = withAsync(async (req: Request, res: Response) => {
+ const { id: productId } = create(req.params, IdParamsStruct);
+ const { cursor, limit } = create(req.query, GetCommentListParamsStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id: productId } });
+ Iif (!existingProduct) {
+ throw new NotFoundError('product', productId.toString());
+ }
+
+ const commentsWithCursor = await prisma.comment.findMany({
+ cursor: cursor ? { id: cursor } : undefined,
+ take: limit + 1,
+ where: { productId },
+ orderBy: { createdAt: 'desc' },
+ });
+
+ const hasNextPage = commentsWithCursor.length > limit;
+ const comments = commentsWithCursor.slice(0, limit);
+ const nextCursor = hasNextPage ? commentsWithCursor[limit].id : null;
+
+ res.send({
+ list: comments,
+ nextCursor,
+ });
+});
+
+export const updateComment = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+ const { content } = create(req.body, UpdateCommentBodyStruct);
+
+ const existingComment = await prisma.comment.findUnique({ where: { id } });
+ if (!existingComment) {
+ throw new NotFoundError('comment', id.toString());
+ }
+
+ if (existingComment.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 댓글을 수정할 권한이 없습니다.' });
+ }
+
+ const updatedComment = await prisma.comment.update({
+ where: { id },
+ data: { content },
+ });
+
+ res.send(updatedComment);
+});
+
+
+export const deleteComment = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const existingComment = await prisma.comment.findUnique({ where: { id } });
+ if (!existingComment) {
+ throw new NotFoundError('comment', id.toString());
+ }
+
+ if (existingComment.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 댓글을 삭제할 권한이 없습니다.' });
+ }
+
+ await prisma.comment.delete({ where: { id } });
+
+ res.status(204).send();
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 | 3x + +3x +3x + +3x + + + +3x +15x +9x + + +6x + + + +6x +6x + + + + + + + + + + | import { StructError } from 'superstruct';
+import type { Request, Response, NextFunction } from 'express'; // ✅ Express 타입 임포트
+import BadRequestError from '../lib/errors/BadRequestError';
+import NotFoundError from '../lib/errors/NotFoundError';
+
+export function defaultNotFoundHandler(req: Request, res: Response, _next: NextFunction) {
+ return res.status(404).send({ message: 'Not found' });
+}
+
+export function globalErrorHandler(err: any, req: Request, res: Response, _next: NextFunction) {
+ if (err instanceof StructError || err instanceof BadRequestError) {
+ return res.status(400).send({ message: err.message });
+ }
+
+ Iif (err instanceof SyntaxError && (err as any).status === 400 && 'body' in err) {
+ return res.status(400).send({ message: 'Invalid JSON' });
+ }
+
+ Eif (err instanceof NotFoundError) {
+ return res.status(404).send({ message: err.message });
+ }
+
+ if (err.code) {
+ console.error('DB/Code Error:', err);
+ return res.status(500).send({ message: 'Failed to process data' });
+ }
+
+ console.error('Unexpected Error:', err);
+ return res.status(500).send({ message: 'Internal server error' });
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 | 2x +2x +2x +2x +2x + + + + + + +2x + + + + + + + + + + + + + + + + + + + + + + + + + + + +2x + + + + + + + + + | import multer, { FileFilterCallback } from 'multer';
+import path from 'path';
+import { v4 as uuidv4 } from 'uuid';
+import { PUBLIC_PATH, STATIC_PATH } from '../lib/constants';
+import BadRequestError from '../lib/errors/BadRequestError';
+import type { Request, Response } from 'express';
+
+type DestinationCallback = (error: Error | null, destination: string) => void;
+type FileNameCallback = (error: Error | null, filename: string) => void;
+
+
+export const upload = multer({
+ storage: multer.diskStorage({
+ destination(req: Request, file: Express.Multer.File, cb: DestinationCallback) {
+ cb(null, PUBLIC_PATH);
+ },
+ filename(req: Request, file: Express.Multer.File, cb: FileNameCallback) {
+ const ext = path.extname(file.originalname);
+ const filename = `${uuidv4()}${ext}`;
+ cb(null, filename);
+ },
+ }),
+
+ limits: {
+ fileSize: 5 * 1024 * 1024, // 5MB 제한
+ },
+
+ fileFilter: (req: Request, file: Express.Multer.File, cb: FileFilterCallback) => {
+ const ALLOWED_MIME_TYPES = ['image/png', 'image/jpeg', 'image/jpg'];
+
+ if (!ALLOWED_MIME_TYPES.includes(file.mimetype)) {
+ const err = new BadRequestError('Only png, jpeg, and jpg are allowed');
+ return cb(err as any, false);
+ }
+ cb(null, true);
+ },
+});
+
+
+export async function uploadImage(req: Request, res: Response) {
+ if (!req.file) {
+ throw new BadRequestError('파일이 업로드되지 않았습니다.');
+ }
+
+ const host = req.get('host');
+ const url = `http://${host}/${STATIC_PATH}/${req.file.filename}`;
+
+ return res.send({ url });
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| articlesController.ts | +
+
+ |
+ 94.11% | +64/68 | +72.72% | +16/22 | +100% | +14/14 | +96.42% | +54/56 | +
| authController.ts | +
+
+ |
+ 97.95% | +48/49 | +77.77% | +14/18 | +100% | +7/7 | +97.72% | +43/44 | +
| commentsController.ts | +
+
+ |
+ 56% | +28/50 | +35% | +7/20 | +50% | +4/8 | +56.52% | +26/46 | +
| errorController.ts | +
+
+ |
+ 58.82% | +10/17 | +53.84% | +7/13 | +50% | +1/2 | +58.82% | +10/17 | +
| imagesController.ts | +
+
+ |
+ 33.33% | +7/21 | +0% | +0/4 | +0% | +0/4 | +33.33% | +7/21 | +
| likeController.ts | +
+
+ |
+ 100% | +35/35 | +83.33% | +10/12 | +100% | +6/6 | +100% | +32/32 | +
| productsController.ts | +
+
+ |
+ 100% | +57/57 | +100% | +20/20 | +100% | +12/12 | +100% | +49/49 | +
| userController.ts | +
+
+ |
+ 93.24% | +69/74 | +100% | +22/22 | +90.9% | +20/22 | +93.22% | +55/59 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 | 3x + +3x + +3x + + +3x +3x +3x + +3x + + + + + + + + +2x +1x + + +1x + + +1x + + + + + +1x + + + + + + +3x +2x +2x + +2x + + + + + + + + +2x +1x +1x + +1x + + + + + +1x + + + + +4x +4x +4x + +4x + + + + + + +4x +1x + + +3x +3x +3x + + + + + + + +3x + + +3x + | import { PrismaClient } from '@prisma/client';
+import type { Request, Response } from 'express';
+import { withAsync } from '../lib/withAsync';
+
+const prisma = new PrismaClient();
+
+
+export const toggleProductLike = withAsync(async (req: Request, res: Response) => {
+ const { id: productId } = req.params;
+ const userId = req.user.id;
+
+ const existingLike = await prisma.productLike.findUnique({
+ where: {
+ userId_productId: {
+ userId: userId,
+ productId: Number(productId),
+ },
+ },
+ });
+
+ if (existingLike) {
+ await prisma.productLike.delete({
+ where: { id: existingLike.id },
+ });
+ res.json({ isLiked: false });
+ } else {
+ // 좋아요 생성
+ await prisma.productLike.create({
+ data: {
+ userId: userId,
+ productId: Number(productId),
+ },
+ });
+ res.json({ isLiked: true });
+ }
+});
+
+/**
+ * 💡 게시글 좋아요 토글
+ */
+export const toggleArticleLike = withAsync(async (req: Request, res: Response) => {
+ const { id: articleId } = req.params;
+ const userId = req.user.id;
+
+ const existingLike = await prisma.articleLike.findUnique({
+ where: {
+ userId_articleId: {
+ userId: userId,
+ articleId: Number(articleId),
+ },
+ },
+ });
+
+ if (existingLike) {
+ await prisma.articleLike.delete({ where: { id: existingLike.id } });
+ res.json({ isLiked: false });
+ } else {
+ await prisma.articleLike.create({
+ data: {
+ userId,
+ articleId: Number(articleId)
+ },
+ });
+ res.json({ isLiked: true });
+ }
+});
+
+
+export const getProductDetail = withAsync(async (req: Request, res: Response) => {
+ const { id } = req.params;
+ const userId = req.user?.id;
+
+ const product = await prisma.product.findUnique({
+ where: { id: Number(id) },
+ include: {
+ _count: { select: { productLikes: true } }
+ }
+ });
+
+ if (!product) {
+ return res.status(404).json({ message: '상품을 찾을 수 없습니다.' });
+ }
+
+ let isLiked = false;
+ Eif (userId) {
+ const like = await prisma.productLike.findUnique({
+ where: {
+ userId_productId: {
+ userId,
+ productId: Number(id)
+ }
+ }
+ });
+ isLiked = !!like;
+ }
+
+ res.json({ ...product, isLiked });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 | 3x +3x +3x +3x +3x +3x + + + + +3x + + + +5x +5x + +3x + + + + + + + + + + +2x + + + +5x +5x + +4x +4x + +2x + + + +6x +6x +6x + +6x +6x + +4x +1x + + +3x + +3x + + + + +3x +2x + + + + +2x +1x + +1x +2x + + + + + + + +1x +1x +2x + + + + + + + + + +3x + + + +8x +8x + +8x + + + + + +8x +8x + + + + + + +8x + + +5x +5x + +5x +5x + +3x +1x + + +2x + +2x + + | import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient';
+import { withAsync } from '../lib/withAsync';
+import NotFoundError from '../lib/errors/NotFoundError';
+import { IdParamsStruct } from '../structs/commonStructs';
+import {
+ CreateProductBodyStruct,
+ GetProductListParamsStruct,
+ UpdateProductBodyStruct,
+} from '../structs/productsStruct';
+import { emitNotification } from '../socket/socket';
+import type { Request, Response } from 'express';
+
+
+export const createProduct = withAsync(async (req: Request, res: Response) => {
+ const { name, description, price, tags, images } = create(req.body, CreateProductBodyStruct);
+
+ const product = await prisma.product.create({
+ data: {
+ name,
+ description,
+ price,
+ tags,
+ images,
+ userId: req.user.id
+ },
+ });
+
+ res.status(201).send(product);
+});
+
+
+export const getProduct = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const product = await prisma.product.findUnique({ where: { id } });
+ if (!product) throw new NotFoundError('product', id.toString());
+
+ res.send(product);
+});
+
+
+export const updateProduct = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+ const { name, description, price, tags, images } = create(req.body, UpdateProductBodyStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id } });
+ if (!existingProduct) throw new NotFoundError('product', id.toString());
+
+ if (existingProduct.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 상품을 수정할 권한이 없습니다.' });
+ }
+
+ const isPriceChanged = price !== undefined && existingProduct.price !== price;
+
+ const updatedProduct = await prisma.product.update({
+ where: { id },
+ data: { name, description, price, tags, images },
+ });
+
+ if (isPriceChanged) {
+ const likes = await prisma.productLike.findMany({
+ where: { productId: id },
+ select: { userId: true },
+ });
+
+ if (likes.length > 0) {
+ const message = `관심 상품 [${updatedProduct.name}]의 가격이 ${existingProduct.price}원에서 ${price}원으로 변경되었습니다!`;
+
+ await prisma.notification.createMany({
+ data: likes.map((like) => ({
+ type: 'PRICE_CHANGE',
+ userId: like.userId,
+ message: message,
+ productId: id,
+ })),
+ });
+
+ const io = req.app.get('io');
+ likes.forEach((like) => {
+ emitNotification(io, like.userId, {
+ type: 'PRICE_CHANGE',
+ message: message,
+ productId: id,
+ createdAt: new Date(),
+ });
+ });
+ }
+ }
+
+ res.send(updatedProduct);
+});
+
+
+export const getProductList = withAsync(async (req: Request, res: Response) => {
+ const { page, pageSize, orderBy, keyword } = create(req.query, GetProductListParamsStruct);
+
+ const where = keyword
+ ? {
+ OR: [{ name: { contains: keyword } }, { description: { contains: keyword } }],
+ }
+ : undefined;
+
+ const totalCount = await prisma.product.count({ where });
+ const products = await prisma.product.findMany({
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: orderBy === 'recent' ? { id: 'desc' } : { id: 'asc' },
+ where,
+ });
+
+ res.send({ list: products, totalCount });
+});
+
+export const deleteProduct = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id } });
+ if (!existingProduct) throw new NotFoundError('product', id.toString());
+
+ if (existingProduct.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 상품을 삭제할 권한이 없습니다.' });
+ }
+
+ await prisma.product.delete({ where: { id } });
+
+ res.status(204).send();
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 | 1x +1x +1x +1x +1x + + +1x +1x +1x + + +2x +2x + +2x + + + + +2x +2x + + +3x +3x + +2x +2x +1x + + +1x +1x + + + + +1x + + + +2x +2x +2x + +2x + + + + + + + + + +2x + + + +4x +4x +4x +4x + +4x +2x + + + + + + + + + + +2x + + +2x +1x + + + + + + + + + + +1x + + +1x + + + +1x +1x +1x + +1x + + + + + + + + + +1x + + + +1x +1x + + + + +1x + + + +2x +2x + + + +2x + + + +2x +2x + +2x + + + + + + + +2x +1x + + +1x + + + +1x + + + + + + + + + + + | import bcrypt from 'bcrypt';
+import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient';
+import { withAsync } from '../lib/withAsync';
+import { UpdateUserStruct, ChangePasswordStruct } from '../structs/userStructs';
+import type { Request, Response } from 'express';
+
+export const getMe = withAsync(async (req: Request, res: Response) => {
+ const { password, ...userWithoutPassword } = req.user;
+ res.json(userWithoutPassword);
+});
+
+export const updateMe = withAsync(async (req: Request, res: Response) => {
+ const { nickname, image } = create(req.body, UpdateUserStruct);
+
+ const updatedUser = await prisma.user.update({
+ where: { id: req.user.id },
+ data: { nickname, image },
+ });
+
+ const { password, ...userWithoutPassword } = updatedUser;
+ res.json(userWithoutPassword);
+});
+
+export const changePassword = withAsync(async (req: Request, res: Response) => {
+ const { currentPassword, newPassword } = create(req.body, ChangePasswordStruct);
+
+ const isMatch = await bcrypt.compare(currentPassword, req.user.password);
+ if (!isMatch) {
+ return res.status(401).json({ message: '현재 비밀번호가 일치하지 않습니다.' });
+ }
+
+ const hashedNewPassword = await bcrypt.hash(newPassword, 10);
+ await prisma.user.update({
+ where: { id: req.user.id },
+ data: { password: hashedNewPassword },
+ });
+
+ res.status(200).json({ message: '비밀번호가 성공적으로 변경되었습니다.' });
+});
+
+// ── 내 상품 목록 조회 ────────────────────────────────────────────
+export const getMyProducts = withAsync(async (req: Request, res: Response) => {
+ const page = Number(req.query.page) || 1;
+ const pageSize = Number(req.query.pageSize) || 10;
+
+ const [products, totalCount] = await Promise.all([
+ prisma.product.findMany({
+ where: { userId: req.user.id },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { createdAt: 'desc' },
+ }),
+ prisma.product.count({ where: { userId: req.user.id } }),
+ ]);
+
+ res.json({ list: products, totalCount });
+});
+
+// ── 내가 좋아요한 상품/게시글 목록 조회 ─────────────────────────
+export const getMyLikedItems = withAsync(async (req: Request, res: Response) => {
+ const page = Number(req.query.page) || 1;
+ const pageSize = Number(req.query.pageSize) || 10;
+ const type = req.query.type as string | undefined; // 'product' | 'article'
+
+ if (!type || type === 'product') {
+ const [likes, totalCount] = await Promise.all([
+ prisma.productLike.findMany({
+ where: { userId: req.user.id },
+ include: { product: true },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { id: 'desc' },
+ }),
+ prisma.productLike.count({ where: { userId: req.user.id } }),
+ ]);
+
+ return res.json({ list: likes.map((l) => l.product), totalCount });
+ }
+
+ if (type === 'article') {
+ const [likes, totalCount] = await Promise.all([
+ prisma.articleLike.findMany({
+ where: { userId: req.user.id },
+ include: { article: true },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { id: 'desc' },
+ }),
+ prisma.articleLike.count({ where: { userId: req.user.id } }),
+ ]);
+
+ return res.json({ list: likes.map((l) => l.article), totalCount });
+ }
+
+ res.status(400).json({ message: 'type은 product 또는 article 이어야 합니다.' });
+});
+
+// ── 내 알림 목록 조회 ────────────────────────────────────────────
+export const getMyNotifications = withAsync(async (req: Request, res: Response) => {
+ const page = Number(req.query.page) || 1;
+ const pageSize = Number(req.query.pageSize) || 20;
+
+ const [notifications, totalCount] = await Promise.all([
+ prisma.notification.findMany({
+ where: { userId: req.user.id },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { createdAt: 'desc' },
+ }),
+ prisma.notification.count({ where: { userId: req.user.id } }),
+ ]);
+
+ res.json({ list: notifications, totalCount });
+});
+
+// ── 모든 알림 읽음 처리 ──────────────────────────────────────────
+export const readAllNotifications = withAsync(async (req: Request, res: Response) => {
+ await prisma.notification.updateMany({
+ where: { userId: req.user.id, isRead: false },
+ data: { isRead: true },
+ });
+
+ res.status(200).json({ message: '모든 알림을 읽음 처리했습니다.' });
+});
+
+// ── 읽지 않은 알림 개수 조회 ─────────────────────────────────────
+export const getUnreadNotificationCount = withAsync(async (req: Request, res: Response) => {
+ const count = await prisma.notification.count({
+ where: { userId: req.user.id, isRead: false },
+ });
+
+ res.json({ count });
+});
+
+// ── 단일 알림 읽음 처리 ──────────────────────────────────────────
+export const readNotification = withAsync(async (req: Request, res: Response) => {
+ const { id } = req.params;
+
+ const result = await prisma.notification.updateMany({
+ where: {
+ id: Number(id),
+ userId: req.user.id,
+ },
+ data: { isRead: true },
+ });
+
+ if (result.count === 0) {
+ return res.status(404).json({ message: '알림을 찾을 수 없거나 권한이 없습니다.' });
+ }
+
+ res.status(200).json({ message: '알림을 읽음 처리했습니다.' });
+});
+
+// ── 30일 이상 된 알림 삭제 (스케줄러용) ─────────────────────────
+export const deleteOldNotifications = withAsync(async (req: Request, res: Response) => {
+ const thirtyDaysAgo = new Date();
+ thirtyDaysAgo.setDate(thirtyDaysAgo.getDate() - 30);
+
+ const deleted = await prisma.notification.deleteMany({
+ where: {
+ createdAt: { lt: thirtyDaysAgo },
+ },
+ });
+
+ res.status(200).json({ message: `${deleted.count}개의 오래된 알림을 삭제했습니다.` });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| server.ts | +
+
+ |
+ 100% | +22/22 | +100% | +0/0 | +100% | +0/0 | +100% | +22/22 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 2x +2x + +2x + + + +2x +2x +2x +2x | import dotenv from 'dotenv'; +dotenv.config(); + +Iif (!process.env.DATABASE_URL) { + throw new Error(' DATABASE_URL is missing in .env file'); +} + +export const DATABASE_URL: string = process.env.DATABASE_URL; +export const PORT: number = Number(process.env.PORT) || 3000; +export const PUBLIC_PATH: string = './public'; +export const STATIC_PATH: string = '/public'; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 | + + + + + + + + +3x | class BadRequestError extends Error {
+ constructor(message: string) {
+ super(message);
+ this.name = 'BadRequestError';
+
+ Object.setPrototypeOf(this, BadRequestError.prototype);
+ }
+}
+
+export default BadRequestError; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | + +9x + +9x + +9x + + + +4x | class NotFoundError extends Error {
+ constructor(modelName: string, id: string | number) {
+ super(`${modelName} with id ${id} not found`);
+
+ this.name = 'NotFoundError';
+
+ Object.setPrototypeOf(this, NotFoundError.prototype);
+ }
+}
+
+export default NotFoundError; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| BadRequestError.ts | +
+
+ |
+ 25% | +1/4 | +100% | +0/0 | +0% | +0/1 | +25% | +1/4 | +
| NotFoundError.ts | +
+
+ |
+ 100% | +4/4 | +100% | +0/0 | +100% | +1/1 | +100% | +4/4 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| constants.ts | +
+
+ |
+ 87.5% | +7/8 | +50% | +2/4 | +100% | +0/0 | +87.5% | +7/8 | +
| prismaClient.ts | +
+
+ |
+ 100% | +5/5 | +66.66% | +4/6 | +100% | +0/0 | +100% | +5/5 | +
| socket.ts | +
+
+ |
+ 0% | +0/18 | +0% | +0/2 | +0% | +0/5 | +0% | +0/16 | +
| withAsync.ts | +
+
+ |
+ 100% | +7/7 | +100% | +0/0 | +100% | +3/3 | +100% | +5/5 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 | 3x + + +3x + + + + +3x + + +3x +3x + | import { PrismaClient } from '@prisma/client';
+
+
+const globalForPrisma = globalThis as unknown as {
+ prisma: PrismaClient | undefined;
+};
+
+
+export const prismaClient: PrismaClient =
+ globalForPrisma.prisma ?? new PrismaClient();
+
+Eif (process.env.NODE_ENV !== 'production') {
+ globalForPrisma.prisma = prismaClient;
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 | + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { Server } from 'socket.io'; +import type { Socket } from 'socket.io'; +import type { Server as HttpServer } from 'http'; + +let io: Server | null = null; + +export const initSocket = (server: HttpServer): Server => { + io = new Server(server, { + cors: { + origin: "*", + methods: ["GET", "POST"] + } + }); + + io.on('connection', (socket: Socket) => { + console.log(` User connected: ${socket.id}`); + + socket.on('join', (userId: string | number) => { + socket.join(`user_${userId}`); + console.log(` User ${userId} joined their private room.`); + }); + + socket.on('disconnect', () => { + console.log(' User disconnected'); + }); + }); + + return io; +}; + +export const getIO = (): Server => { + if (!io) { + throw new Error("⚠️ Socket.io not initialized! Call initSocket first."); + } + return io; +}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | + +6x +144x +144x +144x + +21x + + + | import { Request, Response, NextFunction, RequestHandler } from 'express';
+
+export const withAsync = (fn: Function): RequestHandler => {
+ return async (req: Request, res: Response, next: NextFunction) => {
+ try {
+ await fn(req, res, next);
+ } catch (error) {
+ next(error);
+ }
+ };
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 | 3x +3x + + +3x + + + + + + + +50x +50x +50x + +50x +10x + + +40x + +40x + +40x + + + +40x +2x + + +38x +38x + + + + | import jwt from 'jsonwebtoken';
+import { PrismaClient } from '@prisma/client';
+import type { Request, Response, NextFunction } from 'express';
+
+const prisma = new PrismaClient();
+
+
+interface JwtPayload {
+ id: number;
+}
+
+
+export const authenticate = async (req: Request, res: Response, next: NextFunction) => {
+ try {
+ const authHeader = req.headers.authorization;
+
+ if (!authHeader || !authHeader.startsWith('Bearer ')) {
+ return res.status(401).json({ message: '로그인이 필요한 서비스입니다.' });
+ }
+
+ const token = authHeader.split(' ')[1];
+
+ const decoded = jwt.verify(token, process.env.JWT_SECRET || 'secret') as unknown as JwtPayload;
+
+ const user = await prisma.user.findUnique({
+ where: { id: decoded.id },
+ });
+
+ if (!user) {
+ return res.status(401).json({ message: '유효하지 않은 사용자입니다.' });
+ }
+
+ req.user = user;
+ next();
+ } catch (error) {
+ return res.status(401).json({ message: '인증에 실패했습니다. 다시 로그인해 주세요.' });
+ }
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| authMiddleware.ts | +
+
+ |
+ 94.44% | +17/18 | +87.5% | +7/8 | +100% | +2/2 | +93.75% | +15/16 | +
| validate.ts | +
+
+ |
+ 71.42% | +10/14 | +100% | +0/0 | +50% | +1/2 | +66.66% | +8/12 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 | 3x +3x + + + +3x +4x + +4x +2x + +2x + + + + + + + +3x + + + + + + + + + + | import { assert } from 'superstruct';
+import { SignUpStruct, SignInStruct } from '../structs/authStructs';
+import type { Request, Response, NextFunction } from 'express';
+
+
+export const validateSignUp = (req: Request, res: Response, next: NextFunction) => {
+ try {
+ // req.body가 SignUpStruct 구조와 일치하는지 확인
+ assert(req.body, SignUpStruct);
+ next();
+ } catch (error: any) {
+ res.status(400).json({
+ message: '입력 데이터 형식이 올바르지 않습니다.',
+ details: error.message
+ });
+ }
+};
+
+
+export const validateSignIn = (req: Request, res: Response, next: NextFunction) => {
+ try {
+ assert(req.body, SignInStruct);
+ next();
+ } catch (error: any) {
+ res.status(400).json({
+ message: '로그인 정보 형식이 올바르지 않습니다.',
+ details: error.message
+ });
+ }
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 | 2x +2x +2x + + + + + + + + +2x +2x + +2x + +2x +2x + +2x + +2x +2x +2x +2x +2x +2x + +2x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import {
+ createArticle,
+ getArticleList,
+ getArticle,
+ updateArticle,
+ deleteArticle,
+ createComment,
+ getCommentList,
+} from '../controllers/articlesController';
+import { toggleArticleLike } from '../controllers/likeController';
+import { authenticate } from '../middlewares/authMiddleware';
+
+const articlesRouter: Router = express.Router();
+
+articlesRouter.get('/', withAsync(getArticleList));
+articlesRouter.get('/:id', withAsync(getArticle));
+
+articlesRouter.use(authenticate);
+
+articlesRouter.post('/', withAsync(createArticle));
+articlesRouter.patch('/:id', withAsync(updateArticle));
+articlesRouter.delete('/:id', withAsync(deleteArticle));
+articlesRouter.post('/:id/comments', withAsync(createComment));
+articlesRouter.get('/:id/comments', withAsync(getCommentList));
+articlesRouter.post('/:id/like', withAsync(toggleArticleLike));
+
+export default articlesRouter; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 | 3x +3x +3x +3x + +3x + +3x +3x +3x + +3x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import * as authController from '../controllers/authController';
+import { validateSignUp } from '../middlewares/validate';
+
+const router: Router = express.Router();
+
+router.post('/signup', validateSignUp, withAsync(authController.signUp));
+router.post('/signin', withAsync(authController.signIn));
+router.post('/refresh', withAsync(authController.refresh));
+
+export default router; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 | 2x +2x +2x +2x + +2x + +2x +2x +2x + +2x + | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import { updateComment, deleteComment } from '../controllers/commentsController';
+import { authenticate } from '../middlewares/authMiddleware';
+
+const commentsRouter: Router = express.Router();
+
+commentsRouter.use(authenticate);
+commentsRouter.patch('/:id', withAsync(updateComment));
+commentsRouter.delete('/:id', withAsync(deleteComment));
+
+export default commentsRouter;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 | 2x +2x +2x + +2x + + +2x + + + + + +2x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import { upload, uploadImage } from '../controllers/imagesController';
+
+const imagesRouter: Router = express.Router();
+
+
+imagesRouter.post(
+ '/upload',
+ upload.single('image'),
+ withAsync(uploadImage)
+);
+
+export default imagesRouter; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| articlesRouter.ts | +
+
+ |
+ 100% | +16/16 | +100% | +0/0 | +100% | +0/0 | +100% | +16/16 | +
| authRoutes.ts | +
+
+ |
+ 100% | +9/9 | +100% | +0/0 | +100% | +0/0 | +100% | +9/9 | +
| commentsRouter.ts | +
+
+ |
+ 100% | +9/9 | +100% | +0/0 | +100% | +0/0 | +100% | +9/9 | +
| imagesRouter.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +0/0 | +100% | +6/6 | +
| productsRouter.ts | +
+
+ |
+ 100% | +17/17 | +100% | +0/0 | +100% | +0/0 | +100% | +17/17 | +
| userRoutes.ts | +
+
+ |
+ 100% | +17/17 | +100% | +0/0 | +100% | +0/0 | +100% | +17/17 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 | 2x +2x +2x + + + + + + +2x +2x +2x + +2x + +2x +2x + + +2x + + +2x +2x +2x + + +2x +2x + + +2x + +2x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import {
+ createProduct,
+ getProduct,
+ updateProduct,
+ deleteProduct,
+ getProductList,
+} from '../controllers/productsController';
+import { createComment, getCommentList } from '../controllers/commentsController';
+import { toggleProductLike } from '../controllers/likeController';
+import { authenticate } from '../middlewares/authMiddleware';
+
+const productsRouter: Router = express.Router();
+
+productsRouter.get('/', withAsync(getProductList));
+productsRouter.get('/:id', withAsync(getProduct));
+
+
+productsRouter.use(authenticate);
+
+// 상품(Product) 관련
+productsRouter.post('/', withAsync(createProduct));
+productsRouter.patch('/:id', withAsync(updateProduct));
+productsRouter.delete('/:id', withAsync(deleteProduct));
+
+// 댓글(Comment) 관련
+productsRouter.post('/:id/comments', withAsync(createComment));
+productsRouter.get('/:id/comments', withAsync(getCommentList));
+
+// 좋아요(Like) 관련
+productsRouter.post('/:id/like', withAsync(toggleProductLike));
+
+export default productsRouter; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 | 1x +1x +1x +1x +1x + + +1x + + +1x +1x +1x + + +1x +1x + + +1x +1x +1x +1x + + +1x + +1x | import express, { Router } from 'express';
+import * as userController from '../controllers/userController';
+import { authenticate } from '../middlewares/authMiddleware';
+import { withAsync } from '../lib/withAsync';
+const router: Router = express.Router();
+
+
+router.use(authenticate);
+
+
+router.get('/me', withAsync(userController.getMe));
+router.patch('/me', withAsync(userController.updateMe));
+router.patch('/me/password', withAsync(userController.changePassword));
+
+
+router.get('/me/products', withAsync(userController.getMyProducts));
+router.get('/me/likes', withAsync(userController.getMyLikedItems));
+
+
+router.get('/me/notifications', withAsync(userController.getMyNotifications));
+router.patch('/me/notifications', withAsync(userController.readAllNotifications));
+router.get('/me/notifications/unread-count', withAsync(userController.getUnreadNotificationCount));
+router.patch('/me/notifications/:id', withAsync(userController.readNotification));
+
+
+router.delete('/notifications/cleanup', withAsync(userController.deleteOldNotifications));
+
+export default router; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 | 2x +2x +2x +2x +2x +2x +2x +2x +2x +2x + +2x + + +2x +2x +2x + + +2x + + +2x +2x +2x +2x + + +2x +2x + +2x | import express, { Application } from 'express';
+import cors from 'cors';
+import path from 'path';
+import { PUBLIC_PATH, STATIC_PATH } from './lib/constants';
+import articlesRouter from './routers/articlesRouter';
+import productsRouter from './routers/productsRouter';
+import commentsRouter from './routers/commentsRouter';
+import imagesRouter from './routers/imagesRouter';
+import authRouter from './routers/authRoutes';
+import { defaultNotFoundHandler, globalErrorHandler } from './controllers/errorController';
+
+const server: Application = express();
+
+// 💡 기본 설정
+server.use(cors());
+server.use(express.json());
+server.use('/auth', authRouter);
+
+// 💡 정적 파일 설정
+server.use(STATIC_PATH, express.static(path.resolve(process.cwd(), PUBLIC_PATH)));
+
+// 💡 라우터 연결
+server.use('/articles', articlesRouter);
+server.use('/products', productsRouter);
+server.use('/comments', commentsRouter);
+server.use('/images', imagesRouter);
+
+// 💡 에러 핸들러
+server.use(defaultNotFoundHandler);
+server.use(globalErrorHandler);
+
+export default server; // 👈 main.ts에서 가져다 쓸 수 있게 내보냅니다. |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| socket.ts | +
+
+ |
+ 31.25% | +5/16 | +0% | +0/2 | +0% | +0/5 | +21.42% | +3/14 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 | 2x + + +2x + + + + + + + + + + + + + + + + + + + + + + + +2x + + + + | import { Server, Socket } from 'socket.io';
+import type { Server as HttpServer } from 'http';
+
+export const setupSocket = (server: HttpServer): Server => {
+ const io = new Server(server, {
+ cors: {
+ origin: "*",
+ methods: ["GET", "POST"]
+ }
+ });
+
+ io.on('connection', (socket: Socket) => {
+ console.log('소켓 연결됨:', socket.id);
+
+ socket.on('join', (userId: string | number) => {
+ socket.join(`user_${userId}`);
+ console.log(`유저 ${userId}가 알림 방(user_${userId})에 입장했습니다.`);
+ });
+
+ socket.on('disconnect', () => {
+ console.log('소켓 연결 해제');
+ });
+ });
+
+ return io;
+};
+
+export const emitNotification = (io: Server | undefined, userId: string | number, notificationData: any): void => {
+ if (io) {
+ io.to(`user_${userId}`).emit('NEW_NOTIFICATION', notificationData);
+ }
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 | 2x +2x + +2x + +2x +4x + + + + +2x + + + + | import { coerce, nonempty, nullable, object, partial, string, type Infer } from 'superstruct';
+import { PageParamsStruct } from './commonStructs';
+
+export const GetArticleListParamsStruct = PageParamsStruct;
+
+export const CreateArticleBodyStruct = object({
+ title: coerce(nonempty(string()), string(), (value) => value.trim()),
+ content: nonempty(string()),
+ image: nullable(string()),
+});
+
+export const UpdateArticleBodyStruct = partial(CreateArticleBodyStruct);
+
+export type CreateArticleBody = Infer<typeof CreateArticleBodyStruct>;
+export type UpdateArticleBody = Infer<typeof UpdateArticleBodyStruct>;
+export type GetArticleListParams = Infer<typeof GetArticleListParamsStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 | 3x + +3x + + + + + +3x + + + + + + | import { object, string, size, type Infer } from 'superstruct';
+
+export const SignUpStruct = object({
+ email: string(),
+ nickname: string(),
+ password: size(string(), 8, 20),
+});
+
+export const SignInStruct = object({
+ email: string(),
+ password: string(),
+});
+
+export type SignUpBody = Infer<typeof SignUpStruct>;
+export type SignInBody = Infer<typeof SignInStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 | 2x +2x + +2x + + + +2x +2x + + + + | import { nonempty, object, partial, string, type Infer } from 'superstruct';
+import { CursorParamsStruct } from './commonStructs';
+
+export const CreateCommentBodyStruct = object({
+ content: nonempty(string()),
+});
+
+export const GetCommentListParamsStruct = CursorParamsStruct;
+export const UpdateCommentBodyStruct = partial(CreateCommentBodyStruct);
+
+export type CreateCommentBody = Infer<typeof CreateCommentBodyStruct>;
+export type GetCommentListParams = Infer<typeof GetCommentListParamsStruct>;
+export type UpdateCommentBody = Infer<typeof UpdateCommentBodyStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 | 3x + +41x + +3x + + + +3x + + + + + + +3x + + + + + + + + + + | import { coerce, integer, object, string, defaulted, optional, enums, nonempty, type Infer } from 'superstruct';
+
+const integerString = coerce(integer(), string(), (value) => parseInt(value, 10));
+
+export const IdParamsStruct = object({
+ id: integerString,
+});
+
+export const PageParamsStruct = object({
+ page: defaulted(integerString, 1),
+ pageSize: defaulted(integerString, 10),
+ orderBy: optional(enums(['recent'])),
+ keyword: optional(nonempty(string())),
+});
+
+export const CursorParamsStruct = object({
+ cursor: defaulted(integerString, 0),
+ limit: defaulted(integerString, 10),
+ orderBy: optional(enums(['recent'])),
+ keyword: optional(nonempty(string())),
+});
+
+
+export type IdParams = Infer<typeof IdParamsStruct>;
+export type PageParams = Infer<typeof PageParamsStruct>;
+export type CursorParams = Infer<typeof CursorParamsStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| articlesStructs.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +1/1 | +100% | +6/6 | +
| authStructs.ts | +
+
+ |
+ 100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +
| commentsStruct.ts | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +0/0 | +100% | +5/5 | +
| commonStructs.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +1/1 | +100% | +5/5 | +
| productsStruct.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +1/1 | +100% | +6/6 | +
| userStructs.ts | +
+
+ |
+ 100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 3x +3x + +3x +11x + + + + + + +3x + +3x + + + + + | import { coerce, partial, object, string, min, nonempty, array, integer, type Infer } from 'superstruct';
+import { PageParamsStruct } from './commonStructs';
+
+export const CreateProductBodyStruct = object({
+ name: coerce(nonempty(string()), string(), (value) => value.trim()),
+ description: nonempty(string()),
+ price: min(integer(), 0),
+ tags: array(nonempty(string())),
+ images: array(nonempty(string())),
+});
+
+export const GetProductListParamsStruct = PageParamsStruct;
+
+export const UpdateProductBodyStruct = partial(CreateProductBodyStruct);
+
+export type CreateProductBody = Infer<typeof CreateProductBodyStruct>;
+export type UpdateProductBody = Infer<typeof UpdateProductBodyStruct>;
+export type GetProductListParams = Infer<typeof GetProductListParamsStruct>;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 | 1x + +1x + + + + +1x + + + + + + | import { object, string, size, optional, type Infer } from 'superstruct';
+
+export const UpdateUserStruct = object({
+ nickname: optional(string()),
+ image: optional(string()),
+});
+
+export const ChangePasswordStruct = object({
+ currentPassword: string(),
+ newPassword: size(string(), 8, 20),
+});
+
+export type UpdateUserBody = Infer<typeof UpdateUserStruct>;
+export type ChangePasswordBody = Infer<typeof ChangePasswordStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 | 2x +2x +2x +2x +2x +2x + + + + +2x + + +3x +3x + +1x + + + + + + + + +1x + + + +3x +3x + +2x +2x + +1x + + + +2x +2x +2x + +2x + +2x +1x + + + +1x + + + + +1x + + +2x +2x + +2x + +2x +1x + + + +1x + +1x + + +4x +4x + +4x + + + +4x +4x + + + + + + +4x + + + +2x +2x +2x + +1x +1x + +1x + + + + + + + +1x + + + +2x +1x +1x + +1x +1x + +1x + + + + + + +1x +1x +1x + +1x + | import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient';
+import { withAsync } from '../lib/withAsync';
+import NotFoundError from '../lib/errors/NotFoundError';
+import { IdParamsStruct } from '../structs/commonStructs';
+import {
+ CreateArticleBodyStruct,
+ UpdateArticleBodyStruct,
+ GetArticleListParamsStruct,
+} from '../structs/articlesStructs';
+import { CreateCommentBodyStruct, GetCommentListParamsStruct } from '../structs/commentsStruct';
+import type { Request, Response } from 'express';
+
+export const createArticle = withAsync(async (req: Request, res: Response) => {
+ const { title, content, image } = create(req.body, CreateArticleBodyStruct);
+
+ const article = await prisma.article.create({
+ data: {
+ title,
+ content,
+ image,
+ userId: req.user.id
+ }
+ });
+
+ res.status(201).send(article);
+});
+
+
+export const getArticle = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const article = await prisma.article.findUnique({ where: { id } });
+ if (!article) throw new NotFoundError('article', id.toString());
+
+ res.send(article);
+});
+
+
+export const updateArticle = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+ const { title, content, image } = create(req.body, UpdateArticleBodyStruct);
+
+ const existingArticle = await prisma.article.findUnique({ where: { id } });
+
+ if (!existingArticle) throw new NotFoundError('article', id.toString());
+ Iif (existingArticle.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 게시글을 수정할 권한이 없습니다.' });
+ }
+
+ const updatedArticle = await prisma.article.update({
+ where: { id },
+ data: { title, content, image },
+ });
+
+ res.send(updatedArticle);
+});
+
+export const deleteArticle = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const existingArticle = await prisma.article.findUnique({ where: { id } });
+
+ if (!existingArticle) throw new NotFoundError('article', id.toString());
+ Iif (existingArticle.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 게시글을 삭제할 권한이 없습니다.' });
+ }
+
+ await prisma.article.delete({ where: { id } });
+
+ res.status(204).send();
+});
+
+export const getArticleList = withAsync(async (req: Request, res: Response) => {
+ const { page, pageSize, orderBy, keyword } = create(req.query, GetArticleListParamsStruct);
+
+ const where = {
+ title: keyword ? { contains: keyword } : undefined,
+ };
+
+ const totalCount = await prisma.article.count({ where });
+ const articles = await prisma.article.findMany({
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: orderBy === 'recent' ? { createdAt: 'desc' } : { id: 'asc' },
+ where,
+ });
+
+ res.send({ list: articles, totalCount });
+});
+
+
+export const createComment = withAsync(async (req: Request, res: Response) => {
+ const { id: articleId } = create(req.params, IdParamsStruct);
+ const { content } = create(req.body, CreateCommentBodyStruct);
+
+ const existingArticle = await prisma.article.findUnique({ where: { id: articleId } });
+ Iif (!existingArticle) throw new NotFoundError('article', articleId.toString());
+
+ const comment = await prisma.comment.create({
+ data: {
+ articleId,
+ content,
+ userId: req.user.id,
+ },
+ });
+
+ res.status(201).send(comment);
+});
+
+
+export const getCommentList = withAsync(async (req: Request, res: Response) => {
+ const { id: articleId } = create(req.params, IdParamsStruct);
+ const { cursor, limit } = create(req.query, GetCommentListParamsStruct);
+
+ const article = await prisma.article.findUnique({ where: { id: articleId } });
+ Iif (!article) throw new NotFoundError('article', articleId.toString());
+
+ const commentsWithCursor = await prisma.comment.findMany({
+ cursor: cursor ? { id: cursor } : undefined,
+ take: limit + 1,
+ where: { articleId },
+ orderBy: { createdAt: 'desc' },
+ });
+
+ const hasNextPage = commentsWithCursor.length > limit;
+ const comments = commentsWithCursor.slice(0, limit);
+ const nextCursor = hasNextPage ? commentsWithCursor[limit].id : null;
+
+ res.send({ list: comments, nextCursor });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 | 3x +3x +3x + +3x + +3x + + +3x +2x +2x + +2x +2x + +2x + + + +3x +2x + +2x +2x +1x + + +1x +1x + + + +1x +1x + + + +3x +3x + +3x +3x +1x + + +2x +2x +1x + + +1x + +1x + + + + +1x +1x + + + + + + + +3x +3x + +3x +1x + + +2x + +2x + +1x + +1x + + + +1x + +1x + + + + +1x + + + + | import { PrismaClient, User } from '@prisma/client';
+import bcrypt from 'bcrypt';
+import jwt from 'jsonwebtoken';
+import type { Request, Response } from 'express';
+import { withAsync } from '../lib/withAsync';
+
+const prisma = new PrismaClient();
+
+
+const generateTokens = (user: User) => {
+ const accessSecret = process.env.JWT_SECRET || 'access_secret';
+ const refreshSecret = process.env.REFRESH_SECRET || 'refresh_secret';
+
+ const accessToken = jwt.sign({ id: user.id }, accessSecret, { expiresIn: '15m' });
+ const refreshToken = jwt.sign({ id: user.id }, refreshSecret, { expiresIn: '7d' });
+
+ return { accessToken, refreshToken };
+};
+
+
+export const signUp = withAsync(async (req: Request, res: Response) => {
+ const { email, nickname, password } = req.body;
+
+ const existingUser = await prisma.user.findUnique({ where: { email } });
+ if (existingUser) {
+ return res.status(400).json({ message: '이미 사용 중인 이메일입니다.' });
+ }
+
+ const hashedPassword = await bcrypt.hash(password, 10);
+ const user = await prisma.user.create({
+ data: { email, nickname, password: hashedPassword },
+ });
+
+ const { password: _, refreshToken: __, ...userWithoutPassword } = user;
+ res.status(201).json(userWithoutPassword);
+});
+
+
+export const signIn = withAsync(async (req: Request, res: Response) => {
+ const { email, password } = req.body;
+
+ const user = await prisma.user.findUnique({ where: { email } });
+ if (!user) {
+ return res.status(401).json({ message: '이메일 또는 비밀번호가 일치하지 않습니다.' });
+ }
+
+ const isPasswordValid = await bcrypt.compare(password, user.password);
+ if (!isPasswordValid) {
+ return res.status(401).json({ message: '이메일 또는 비밀번호가 일치하지 않습니다.' });
+ }
+
+ const { accessToken, refreshToken } = generateTokens(user);
+
+ await prisma.user.update({
+ where: { id: user.id },
+ data: { refreshToken },
+ });
+
+ const { password: _, refreshToken: __, ...userWithoutPassword } = user;
+ res.status(200).json({
+ accessToken,
+ refreshToken,
+ user: userWithoutPassword,
+ });
+});
+
+
+export const refresh = withAsync(async (req: Request, res: Response) => {
+ const { refreshToken } = req.body;
+
+ if (!refreshToken) {
+ return res.status(401).json({ message: '리프레시 토큰이 없습니다.' });
+ }
+
+ const refreshSecret = process.env.REFRESH_SECRET || 'refresh_secret';
+
+ const decoded = jwt.verify(refreshToken, refreshSecret) as { id: number };
+
+ const user = await prisma.user.findUnique({ where: { id: decoded.id } });
+
+ Iif (!user || user.refreshToken !== refreshToken) {
+ return res.status(403).json({ message: '유효하지 않은 리프레시 토큰입니다.' });
+ }
+
+ const tokens = generateTokens(user);
+
+ await prisma.user.update({
+ where: { id: user.id },
+ data: { refreshToken: tokens.refreshToken },
+ });
+
+ res.json({
+ accessToken: tokens.accessToken,
+ refreshToken: tokens.refreshToken,
+ });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 | 2x +2x +2x +2x +2x +2x + + + +2x +2x +2x + +1x +1x + + + +1x + + + + + + + +1x + + + + + + + + + + +1x + + + +2x +1x +1x + +1x +1x + + + +1x + + + + + + +1x +1x +1x + +1x + + + + + +2x + + + + + + + + + + + + + + + + + + + + + +2x + + + + + + + + + + + + + + + | import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient'; // 통일된 이름 사용
+import { withAsync } from '../lib/withAsync';
+import { UpdateCommentBodyStruct, CreateCommentBodyStruct, GetCommentListParamsStruct } from '../structs/commentsStruct';
+import NotFoundError from '../lib/errors/NotFoundError';
+import { IdParamsStruct } from '../structs/commonStructs';
+import type { Request, Response } from 'express';
+
+
+export const createComment = withAsync(async (req: Request, res: Response) => {
+ const { id: productId } = create(req.params, IdParamsStruct);
+ const { content } = create(req.body, CreateCommentBodyStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id: productId } });
+ Iif (!existingProduct) {
+ throw new NotFoundError('product', productId.toString());
+ }
+
+ const comment = await prisma.comment.create({
+ data: {
+ productId,
+ content,
+ userId: req.user.id
+ }
+ });
+
+ Iif (existingProduct.userId && existingProduct.userId !== req.user.id) {
+ await prisma.notification.create({
+ data: {
+ type: 'COMMENT',
+ userId: existingProduct.userId,
+ message: `[${existingProduct.name}] 상품에 새로운 댓글이 달렸습니다: ${content.substring(0, 15)}...`,
+ productId: productId,
+ },
+ });
+ }
+
+ res.status(201).send(comment);
+});
+
+
+export const getCommentList = withAsync(async (req: Request, res: Response) => {
+ const { id: productId } = create(req.params, IdParamsStruct);
+ const { cursor, limit } = create(req.query, GetCommentListParamsStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id: productId } });
+ Iif (!existingProduct) {
+ throw new NotFoundError('product', productId.toString());
+ }
+
+ const commentsWithCursor = await prisma.comment.findMany({
+ cursor: cursor ? { id: cursor } : undefined,
+ take: limit + 1,
+ where: { productId },
+ orderBy: { createdAt: 'desc' },
+ });
+
+ const hasNextPage = commentsWithCursor.length > limit;
+ const comments = commentsWithCursor.slice(0, limit);
+ const nextCursor = hasNextPage ? commentsWithCursor[limit].id : null;
+
+ res.send({
+ list: comments,
+ nextCursor,
+ });
+});
+
+export const updateComment = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+ const { content } = create(req.body, UpdateCommentBodyStruct);
+
+ const existingComment = await prisma.comment.findUnique({ where: { id } });
+ if (!existingComment) {
+ throw new NotFoundError('comment', id.toString());
+ }
+
+ if (existingComment.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 댓글을 수정할 권한이 없습니다.' });
+ }
+
+ const updatedComment = await prisma.comment.update({
+ where: { id },
+ data: { content },
+ });
+
+ res.send(updatedComment);
+});
+
+
+export const deleteComment = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const existingComment = await prisma.comment.findUnique({ where: { id } });
+ if (!existingComment) {
+ throw new NotFoundError('comment', id.toString());
+ }
+
+ if (existingComment.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 댓글을 삭제할 권한이 없습니다.' });
+ }
+
+ await prisma.comment.delete({ where: { id } });
+
+ res.status(204).send();
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 | 3x + +3x +3x + +3x + + + +3x +15x +9x + + +6x + + + +6x +6x + + + + + + + + + + | import { StructError } from 'superstruct';
+import type { Request, Response, NextFunction } from 'express'; // ✅ Express 타입 임포트
+import BadRequestError from '../lib/errors/BadRequestError';
+import NotFoundError from '../lib/errors/NotFoundError';
+
+export function defaultNotFoundHandler(req: Request, res: Response, _next: NextFunction) {
+ return res.status(404).send({ message: 'Not found' });
+}
+
+export function globalErrorHandler(err: any, req: Request, res: Response, _next: NextFunction) {
+ if (err instanceof StructError || err instanceof BadRequestError) {
+ return res.status(400).send({ message: err.message });
+ }
+
+ Iif (err instanceof SyntaxError && (err as any).status === 400 && 'body' in err) {
+ return res.status(400).send({ message: 'Invalid JSON' });
+ }
+
+ Eif (err instanceof NotFoundError) {
+ return res.status(404).send({ message: err.message });
+ }
+
+ if (err.code) {
+ console.error('DB/Code Error:', err);
+ return res.status(500).send({ message: 'Failed to process data' });
+ }
+
+ console.error('Unexpected Error:', err);
+ return res.status(500).send({ message: 'Internal server error' });
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 | 2x +2x +2x +2x +2x + + + + + + +2x + + + + + + + + + + + + + + + + + + + + + + + + + + + +2x + + + + + + + + + | import multer, { FileFilterCallback } from 'multer';
+import path from 'path';
+import { v4 as uuidv4 } from 'uuid';
+import { PUBLIC_PATH, STATIC_PATH } from '../lib/constants';
+import BadRequestError from '../lib/errors/BadRequestError';
+import type { Request, Response } from 'express';
+
+type DestinationCallback = (error: Error | null, destination: string) => void;
+type FileNameCallback = (error: Error | null, filename: string) => void;
+
+
+export const upload = multer({
+ storage: multer.diskStorage({
+ destination(req: Request, file: Express.Multer.File, cb: DestinationCallback) {
+ cb(null, PUBLIC_PATH);
+ },
+ filename(req: Request, file: Express.Multer.File, cb: FileNameCallback) {
+ const ext = path.extname(file.originalname);
+ const filename = `${uuidv4()}${ext}`;
+ cb(null, filename);
+ },
+ }),
+
+ limits: {
+ fileSize: 5 * 1024 * 1024, // 5MB 제한
+ },
+
+ fileFilter: (req: Request, file: Express.Multer.File, cb: FileFilterCallback) => {
+ const ALLOWED_MIME_TYPES = ['image/png', 'image/jpeg', 'image/jpg'];
+
+ if (!ALLOWED_MIME_TYPES.includes(file.mimetype)) {
+ const err = new BadRequestError('Only png, jpeg, and jpg are allowed');
+ return cb(err as any, false);
+ }
+ cb(null, true);
+ },
+});
+
+
+export async function uploadImage(req: Request, res: Response) {
+ if (!req.file) {
+ throw new BadRequestError('파일이 업로드되지 않았습니다.');
+ }
+
+ const host = req.get('host');
+ const url = `http://${host}/${STATIC_PATH}/${req.file.filename}`;
+
+ return res.send({ url });
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| articlesController.ts | +
+
+ |
+ 94.11% | +64/68 | +72.72% | +16/22 | +100% | +14/14 | +96.42% | +54/56 | +
| authController.ts | +
+
+ |
+ 97.95% | +48/49 | +77.77% | +14/18 | +100% | +7/7 | +97.72% | +43/44 | +
| commentsController.ts | +
+
+ |
+ 56% | +28/50 | +35% | +7/20 | +50% | +4/8 | +56.52% | +26/46 | +
| errorController.ts | +
+
+ |
+ 58.82% | +10/17 | +53.84% | +7/13 | +50% | +1/2 | +58.82% | +10/17 | +
| imagesController.ts | +
+
+ |
+ 33.33% | +7/21 | +0% | +0/4 | +0% | +0/4 | +33.33% | +7/21 | +
| likeController.ts | +
+
+ |
+ 100% | +35/35 | +83.33% | +10/12 | +100% | +6/6 | +100% | +32/32 | +
| productsController.ts | +
+
+ |
+ 100% | +57/57 | +100% | +20/20 | +100% | +12/12 | +100% | +49/49 | +
| userController.ts | +
+
+ |
+ 93.24% | +69/74 | +100% | +22/22 | +90.9% | +20/22 | +93.22% | +55/59 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 | 3x + +3x + +3x + + +3x +3x +3x + +3x + + + + + + + + +2x +1x + + +1x + + +1x + + + + + +1x + + + + + + +3x +2x +2x + +2x + + + + + + + + +2x +1x +1x + +1x + + + + + +1x + + + + +4x +4x +4x + +4x + + + + + + +4x +1x + + +3x +3x +3x + + + + + + + +3x + + +3x + | import { PrismaClient } from '@prisma/client';
+import type { Request, Response } from 'express';
+import { withAsync } from '../lib/withAsync';
+
+const prisma = new PrismaClient();
+
+
+export const toggleProductLike = withAsync(async (req: Request, res: Response) => {
+ const { id: productId } = req.params;
+ const userId = req.user.id;
+
+ const existingLike = await prisma.productLike.findUnique({
+ where: {
+ userId_productId: {
+ userId: userId,
+ productId: Number(productId),
+ },
+ },
+ });
+
+ if (existingLike) {
+ await prisma.productLike.delete({
+ where: { id: existingLike.id },
+ });
+ res.json({ isLiked: false });
+ } else {
+ // 좋아요 생성
+ await prisma.productLike.create({
+ data: {
+ userId: userId,
+ productId: Number(productId),
+ },
+ });
+ res.json({ isLiked: true });
+ }
+});
+
+/**
+ * 💡 게시글 좋아요 토글
+ */
+export const toggleArticleLike = withAsync(async (req: Request, res: Response) => {
+ const { id: articleId } = req.params;
+ const userId = req.user.id;
+
+ const existingLike = await prisma.articleLike.findUnique({
+ where: {
+ userId_articleId: {
+ userId: userId,
+ articleId: Number(articleId),
+ },
+ },
+ });
+
+ if (existingLike) {
+ await prisma.articleLike.delete({ where: { id: existingLike.id } });
+ res.json({ isLiked: false });
+ } else {
+ await prisma.articleLike.create({
+ data: {
+ userId,
+ articleId: Number(articleId)
+ },
+ });
+ res.json({ isLiked: true });
+ }
+});
+
+
+export const getProductDetail = withAsync(async (req: Request, res: Response) => {
+ const { id } = req.params;
+ const userId = req.user?.id;
+
+ const product = await prisma.product.findUnique({
+ where: { id: Number(id) },
+ include: {
+ _count: { select: { productLikes: true } }
+ }
+ });
+
+ if (!product) {
+ return res.status(404).json({ message: '상품을 찾을 수 없습니다.' });
+ }
+
+ let isLiked = false;
+ Eif (userId) {
+ const like = await prisma.productLike.findUnique({
+ where: {
+ userId_productId: {
+ userId,
+ productId: Number(id)
+ }
+ }
+ });
+ isLiked = !!like;
+ }
+
+ res.json({ ...product, isLiked });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 | 3x +3x +3x +3x +3x +3x + + + + +3x + + + +5x +5x + +3x + + + + + + + + + + +2x + + + +5x +5x + +4x +4x + +2x + + + +6x +6x +6x + +6x +6x + +4x +1x + + +3x + +3x + + + + +3x +2x + + + + +2x +1x + +1x +2x + + + + + + + +1x +1x +2x + + + + + + + + + +3x + + + +8x +8x + +8x + + + + + +8x +8x + + + + + + +8x + + +5x +5x + +5x +5x + +3x +1x + + +2x + +2x + + | import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient';
+import { withAsync } from '../lib/withAsync';
+import NotFoundError from '../lib/errors/NotFoundError';
+import { IdParamsStruct } from '../structs/commonStructs';
+import {
+ CreateProductBodyStruct,
+ GetProductListParamsStruct,
+ UpdateProductBodyStruct,
+} from '../structs/productsStruct';
+import { emitNotification } from '../socket/socket';
+import type { Request, Response } from 'express';
+
+
+export const createProduct = withAsync(async (req: Request, res: Response) => {
+ const { name, description, price, tags, images } = create(req.body, CreateProductBodyStruct);
+
+ const product = await prisma.product.create({
+ data: {
+ name,
+ description,
+ price,
+ tags,
+ images,
+ userId: req.user.id
+ },
+ });
+
+ res.status(201).send(product);
+});
+
+
+export const getProduct = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const product = await prisma.product.findUnique({ where: { id } });
+ if (!product) throw new NotFoundError('product', id.toString());
+
+ res.send(product);
+});
+
+
+export const updateProduct = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+ const { name, description, price, tags, images } = create(req.body, UpdateProductBodyStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id } });
+ if (!existingProduct) throw new NotFoundError('product', id.toString());
+
+ if (existingProduct.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 상품을 수정할 권한이 없습니다.' });
+ }
+
+ const isPriceChanged = price !== undefined && existingProduct.price !== price;
+
+ const updatedProduct = await prisma.product.update({
+ where: { id },
+ data: { name, description, price, tags, images },
+ });
+
+ if (isPriceChanged) {
+ const likes = await prisma.productLike.findMany({
+ where: { productId: id },
+ select: { userId: true },
+ });
+
+ if (likes.length > 0) {
+ const message = `관심 상품 [${updatedProduct.name}]의 가격이 ${existingProduct.price}원에서 ${price}원으로 변경되었습니다!`;
+
+ await prisma.notification.createMany({
+ data: likes.map((like) => ({
+ type: 'PRICE_CHANGE',
+ userId: like.userId,
+ message: message,
+ productId: id,
+ })),
+ });
+
+ const io = req.app.get('io');
+ likes.forEach((like) => {
+ emitNotification(io, like.userId, {
+ type: 'PRICE_CHANGE',
+ message: message,
+ productId: id,
+ createdAt: new Date(),
+ });
+ });
+ }
+ }
+
+ res.send(updatedProduct);
+});
+
+
+export const getProductList = withAsync(async (req: Request, res: Response) => {
+ const { page, pageSize, orderBy, keyword } = create(req.query, GetProductListParamsStruct);
+
+ const where = keyword
+ ? {
+ OR: [{ name: { contains: keyword } }, { description: { contains: keyword } }],
+ }
+ : undefined;
+
+ const totalCount = await prisma.product.count({ where });
+ const products = await prisma.product.findMany({
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: orderBy === 'recent' ? { id: 'desc' } : { id: 'asc' },
+ where,
+ });
+
+ res.send({ list: products, totalCount });
+});
+
+export const deleteProduct = withAsync(async (req: Request, res: Response) => {
+ const { id } = create(req.params, IdParamsStruct);
+
+ const existingProduct = await prisma.product.findUnique({ where: { id } });
+ if (!existingProduct) throw new NotFoundError('product', id.toString());
+
+ if (existingProduct.userId !== req.user.id) {
+ return res.status(403).json({ message: '해당 상품을 삭제할 권한이 없습니다.' });
+ }
+
+ await prisma.product.delete({ where: { id } });
+
+ res.status(204).send();
+});
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 | 1x +1x +1x +1x +1x + + +1x +1x +1x + + +2x +2x + +2x + + + + +2x +2x + + +3x +3x + +2x +2x +1x + + +1x +1x + + + + +1x + + + +2x +2x +2x + +2x + + + + + + + + + +2x + + + +4x +4x +4x +4x + +4x +2x + + + + + + + + + + +2x + + +2x +1x + + + + + + + + + + +1x + + +1x + + + +1x +1x +1x + +1x + + + + + + + + + +1x + + + +1x +1x + + + + +1x + + + +2x +2x + + + +2x + + + +2x +2x + +2x + + + + + + + +2x +1x + + +1x + + + +1x + + + + + + + + + + + | import bcrypt from 'bcrypt';
+import { create } from 'superstruct';
+import { prismaClient as prisma } from '../lib/prismaClient';
+import { withAsync } from '../lib/withAsync';
+import { UpdateUserStruct, ChangePasswordStruct } from '../structs/userStructs';
+import type { Request, Response } from 'express';
+
+export const getMe = withAsync(async (req: Request, res: Response) => {
+ const { password, ...userWithoutPassword } = req.user;
+ res.json(userWithoutPassword);
+});
+
+export const updateMe = withAsync(async (req: Request, res: Response) => {
+ const { nickname, image } = create(req.body, UpdateUserStruct);
+
+ const updatedUser = await prisma.user.update({
+ where: { id: req.user.id },
+ data: { nickname, image },
+ });
+
+ const { password, ...userWithoutPassword } = updatedUser;
+ res.json(userWithoutPassword);
+});
+
+export const changePassword = withAsync(async (req: Request, res: Response) => {
+ const { currentPassword, newPassword } = create(req.body, ChangePasswordStruct);
+
+ const isMatch = await bcrypt.compare(currentPassword, req.user.password);
+ if (!isMatch) {
+ return res.status(401).json({ message: '현재 비밀번호가 일치하지 않습니다.' });
+ }
+
+ const hashedNewPassword = await bcrypt.hash(newPassword, 10);
+ await prisma.user.update({
+ where: { id: req.user.id },
+ data: { password: hashedNewPassword },
+ });
+
+ res.status(200).json({ message: '비밀번호가 성공적으로 변경되었습니다.' });
+});
+
+// ── 내 상품 목록 조회 ────────────────────────────────────────────
+export const getMyProducts = withAsync(async (req: Request, res: Response) => {
+ const page = Number(req.query.page) || 1;
+ const pageSize = Number(req.query.pageSize) || 10;
+
+ const [products, totalCount] = await Promise.all([
+ prisma.product.findMany({
+ where: { userId: req.user.id },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { createdAt: 'desc' },
+ }),
+ prisma.product.count({ where: { userId: req.user.id } }),
+ ]);
+
+ res.json({ list: products, totalCount });
+});
+
+// ── 내가 좋아요한 상품/게시글 목록 조회 ─────────────────────────
+export const getMyLikedItems = withAsync(async (req: Request, res: Response) => {
+ const page = Number(req.query.page) || 1;
+ const pageSize = Number(req.query.pageSize) || 10;
+ const type = req.query.type as string | undefined; // 'product' | 'article'
+
+ if (!type || type === 'product') {
+ const [likes, totalCount] = await Promise.all([
+ prisma.productLike.findMany({
+ where: { userId: req.user.id },
+ include: { product: true },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { id: 'desc' },
+ }),
+ prisma.productLike.count({ where: { userId: req.user.id } }),
+ ]);
+
+ return res.json({ list: likes.map((l) => l.product), totalCount });
+ }
+
+ if (type === 'article') {
+ const [likes, totalCount] = await Promise.all([
+ prisma.articleLike.findMany({
+ where: { userId: req.user.id },
+ include: { article: true },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { id: 'desc' },
+ }),
+ prisma.articleLike.count({ where: { userId: req.user.id } }),
+ ]);
+
+ return res.json({ list: likes.map((l) => l.article), totalCount });
+ }
+
+ res.status(400).json({ message: 'type은 product 또는 article 이어야 합니다.' });
+});
+
+// ── 내 알림 목록 조회 ────────────────────────────────────────────
+export const getMyNotifications = withAsync(async (req: Request, res: Response) => {
+ const page = Number(req.query.page) || 1;
+ const pageSize = Number(req.query.pageSize) || 20;
+
+ const [notifications, totalCount] = await Promise.all([
+ prisma.notification.findMany({
+ where: { userId: req.user.id },
+ skip: (page - 1) * pageSize,
+ take: pageSize,
+ orderBy: { createdAt: 'desc' },
+ }),
+ prisma.notification.count({ where: { userId: req.user.id } }),
+ ]);
+
+ res.json({ list: notifications, totalCount });
+});
+
+// ── 모든 알림 읽음 처리 ──────────────────────────────────────────
+export const readAllNotifications = withAsync(async (req: Request, res: Response) => {
+ await prisma.notification.updateMany({
+ where: { userId: req.user.id, isRead: false },
+ data: { isRead: true },
+ });
+
+ res.status(200).json({ message: '모든 알림을 읽음 처리했습니다.' });
+});
+
+// ── 읽지 않은 알림 개수 조회 ─────────────────────────────────────
+export const getUnreadNotificationCount = withAsync(async (req: Request, res: Response) => {
+ const count = await prisma.notification.count({
+ where: { userId: req.user.id, isRead: false },
+ });
+
+ res.json({ count });
+});
+
+// ── 단일 알림 읽음 처리 ──────────────────────────────────────────
+export const readNotification = withAsync(async (req: Request, res: Response) => {
+ const { id } = req.params;
+
+ const result = await prisma.notification.updateMany({
+ where: {
+ id: Number(id),
+ userId: req.user.id,
+ },
+ data: { isRead: true },
+ });
+
+ if (result.count === 0) {
+ return res.status(404).json({ message: '알림을 찾을 수 없거나 권한이 없습니다.' });
+ }
+
+ res.status(200).json({ message: '알림을 읽음 처리했습니다.' });
+});
+
+// ── 30일 이상 된 알림 삭제 (스케줄러용) ─────────────────────────
+export const deleteOldNotifications = withAsync(async (req: Request, res: Response) => {
+ const thirtyDaysAgo = new Date();
+ thirtyDaysAgo.setDate(thirtyDaysAgo.getDate() - 30);
+
+ const deleted = await prisma.notification.deleteMany({
+ where: {
+ createdAt: { lt: thirtyDaysAgo },
+ },
+ });
+
+ res.status(200).json({ message: `${deleted.count}개의 오래된 알림을 삭제했습니다.` });
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| server.ts | +
+
+ |
+ 100% | +22/22 | +100% | +0/0 | +100% | +0/0 | +100% | +22/22 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | 2x +2x + +2x + + + +2x +2x +2x +2x | import dotenv from 'dotenv'; +dotenv.config(); + +Iif (!process.env.DATABASE_URL) { + throw new Error(' DATABASE_URL is missing in .env file'); +} + +export const DATABASE_URL: string = process.env.DATABASE_URL; +export const PORT: number = Number(process.env.PORT) || 3000; +export const PUBLIC_PATH: string = './public'; +export const STATIC_PATH: string = '/public'; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 | + + + + + + + + +3x | class BadRequestError extends Error {
+ constructor(message: string) {
+ super(message);
+ this.name = 'BadRequestError';
+
+ Object.setPrototypeOf(this, BadRequestError.prototype);
+ }
+}
+
+export default BadRequestError; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | + +9x + +9x + +9x + + + +4x | class NotFoundError extends Error {
+ constructor(modelName: string, id: string | number) {
+ super(`${modelName} with id ${id} not found`);
+
+ this.name = 'NotFoundError';
+
+ Object.setPrototypeOf(this, NotFoundError.prototype);
+ }
+}
+
+export default NotFoundError; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| BadRequestError.ts | +
+
+ |
+ 25% | +1/4 | +100% | +0/0 | +0% | +0/1 | +25% | +1/4 | +
| NotFoundError.ts | +
+
+ |
+ 100% | +4/4 | +100% | +0/0 | +100% | +1/1 | +100% | +4/4 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| constants.ts | +
+
+ |
+ 87.5% | +7/8 | +50% | +2/4 | +100% | +0/0 | +87.5% | +7/8 | +
| prismaClient.ts | +
+
+ |
+ 100% | +5/5 | +66.66% | +4/6 | +100% | +0/0 | +100% | +5/5 | +
| socket.ts | +
+
+ |
+ 0% | +0/18 | +0% | +0/2 | +0% | +0/5 | +0% | +0/16 | +
| withAsync.ts | +
+
+ |
+ 100% | +7/7 | +100% | +0/0 | +100% | +3/3 | +100% | +5/5 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 | 3x + + +3x + + + + +3x + + +3x +3x + | import { PrismaClient } from '@prisma/client';
+
+
+const globalForPrisma = globalThis as unknown as {
+ prisma: PrismaClient | undefined;
+};
+
+
+export const prismaClient: PrismaClient =
+ globalForPrisma.prisma ?? new PrismaClient();
+
+Eif (process.env.NODE_ENV !== 'production') {
+ globalForPrisma.prisma = prismaClient;
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 | + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import { Server } from 'socket.io'; +import type { Socket } from 'socket.io'; +import type { Server as HttpServer } from 'http'; + +let io: Server | null = null; + +export const initSocket = (server: HttpServer): Server => { + io = new Server(server, { + cors: { + origin: "*", + methods: ["GET", "POST"] + } + }); + + io.on('connection', (socket: Socket) => { + console.log(` User connected: ${socket.id}`); + + socket.on('join', (userId: string | number) => { + socket.join(`user_${userId}`); + console.log(` User ${userId} joined their private room.`); + }); + + socket.on('disconnect', () => { + console.log(' User disconnected'); + }); + }); + + return io; +}; + +export const getIO = (): Server => { + if (!io) { + throw new Error("⚠️ Socket.io not initialized! Call initSocket first."); + } + return io; +}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 | + +6x +144x +144x +144x + +21x + + + | import { Request, Response, NextFunction, RequestHandler } from 'express';
+
+export const withAsync = (fn: Function): RequestHandler => {
+ return async (req: Request, res: Response, next: NextFunction) => {
+ try {
+ await fn(req, res, next);
+ } catch (error) {
+ next(error);
+ }
+ };
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 | 3x +3x + + +3x + + + + + + + +50x +50x +50x + +50x +10x + + +40x + +40x + +40x + + + +40x +2x + + +38x +38x + + + + | import jwt from 'jsonwebtoken';
+import { PrismaClient } from '@prisma/client';
+import type { Request, Response, NextFunction } from 'express';
+
+const prisma = new PrismaClient();
+
+
+interface JwtPayload {
+ id: number;
+}
+
+
+export const authenticate = async (req: Request, res: Response, next: NextFunction) => {
+ try {
+ const authHeader = req.headers.authorization;
+
+ if (!authHeader || !authHeader.startsWith('Bearer ')) {
+ return res.status(401).json({ message: '로그인이 필요한 서비스입니다.' });
+ }
+
+ const token = authHeader.split(' ')[1];
+
+ const decoded = jwt.verify(token, process.env.JWT_SECRET || 'secret') as unknown as JwtPayload;
+
+ const user = await prisma.user.findUnique({
+ where: { id: decoded.id },
+ });
+
+ if (!user) {
+ return res.status(401).json({ message: '유효하지 않은 사용자입니다.' });
+ }
+
+ req.user = user;
+ next();
+ } catch (error) {
+ return res.status(401).json({ message: '인증에 실패했습니다. 다시 로그인해 주세요.' });
+ }
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| authMiddleware.ts | +
+
+ |
+ 94.44% | +17/18 | +87.5% | +7/8 | +100% | +2/2 | +93.75% | +15/16 | +
| validate.ts | +
+
+ |
+ 71.42% | +10/14 | +100% | +0/0 | +50% | +1/2 | +66.66% | +8/12 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 | 3x +3x + + + +3x +4x + +4x +2x + +2x + + + + + + + +3x + + + + + + + + + + | import { assert } from 'superstruct';
+import { SignUpStruct, SignInStruct } from '../structs/authStructs';
+import type { Request, Response, NextFunction } from 'express';
+
+
+export const validateSignUp = (req: Request, res: Response, next: NextFunction) => {
+ try {
+ // req.body가 SignUpStruct 구조와 일치하는지 확인
+ assert(req.body, SignUpStruct);
+ next();
+ } catch (error: any) {
+ res.status(400).json({
+ message: '입력 데이터 형식이 올바르지 않습니다.',
+ details: error.message
+ });
+ }
+};
+
+
+export const validateSignIn = (req: Request, res: Response, next: NextFunction) => {
+ try {
+ assert(req.body, SignInStruct);
+ next();
+ } catch (error: any) {
+ res.status(400).json({
+ message: '로그인 정보 형식이 올바르지 않습니다.',
+ details: error.message
+ });
+ }
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 | 2x +2x +2x + + + + + + + + +2x +2x + +2x + +2x +2x + +2x + +2x +2x +2x +2x +2x +2x + +2x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import {
+ createArticle,
+ getArticleList,
+ getArticle,
+ updateArticle,
+ deleteArticle,
+ createComment,
+ getCommentList,
+} from '../controllers/articlesController';
+import { toggleArticleLike } from '../controllers/likeController';
+import { authenticate } from '../middlewares/authMiddleware';
+
+const articlesRouter: Router = express.Router();
+
+articlesRouter.get('/', withAsync(getArticleList));
+articlesRouter.get('/:id', withAsync(getArticle));
+
+articlesRouter.use(authenticate);
+
+articlesRouter.post('/', withAsync(createArticle));
+articlesRouter.patch('/:id', withAsync(updateArticle));
+articlesRouter.delete('/:id', withAsync(deleteArticle));
+articlesRouter.post('/:id/comments', withAsync(createComment));
+articlesRouter.get('/:id/comments', withAsync(getCommentList));
+articlesRouter.post('/:id/like', withAsync(toggleArticleLike));
+
+export default articlesRouter; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 | 3x +3x +3x +3x + +3x + +3x +3x +3x + +3x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import * as authController from '../controllers/authController';
+import { validateSignUp } from '../middlewares/validate';
+
+const router: Router = express.Router();
+
+router.post('/signup', validateSignUp, withAsync(authController.signUp));
+router.post('/signin', withAsync(authController.signIn));
+router.post('/refresh', withAsync(authController.refresh));
+
+export default router; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 | 2x +2x +2x +2x + +2x + +2x +2x +2x + +2x + | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import { updateComment, deleteComment } from '../controllers/commentsController';
+import { authenticate } from '../middlewares/authMiddleware';
+
+const commentsRouter: Router = express.Router();
+
+commentsRouter.use(authenticate);
+commentsRouter.patch('/:id', withAsync(updateComment));
+commentsRouter.delete('/:id', withAsync(deleteComment));
+
+export default commentsRouter;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 | 2x +2x +2x + +2x + + +2x + + + + + +2x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import { upload, uploadImage } from '../controllers/imagesController';
+
+const imagesRouter: Router = express.Router();
+
+
+imagesRouter.post(
+ '/upload',
+ upload.single('image'),
+ withAsync(uploadImage)
+);
+
+export default imagesRouter; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| articlesRouter.ts | +
+
+ |
+ 100% | +16/16 | +100% | +0/0 | +100% | +0/0 | +100% | +16/16 | +
| authRoutes.ts | +
+
+ |
+ 100% | +9/9 | +100% | +0/0 | +100% | +0/0 | +100% | +9/9 | +
| commentsRouter.ts | +
+
+ |
+ 100% | +9/9 | +100% | +0/0 | +100% | +0/0 | +100% | +9/9 | +
| imagesRouter.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +0/0 | +100% | +6/6 | +
| productsRouter.ts | +
+
+ |
+ 100% | +17/17 | +100% | +0/0 | +100% | +0/0 | +100% | +17/17 | +
| userRoutes.ts | +
+
+ |
+ 100% | +17/17 | +100% | +0/0 | +100% | +0/0 | +100% | +17/17 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 | 2x +2x +2x + + + + + + +2x +2x +2x + +2x + +2x +2x + + +2x + + +2x +2x +2x + + +2x +2x + + +2x + +2x | import express, { Router } from 'express';
+import { withAsync } from '../lib/withAsync';
+import {
+ createProduct,
+ getProduct,
+ updateProduct,
+ deleteProduct,
+ getProductList,
+} from '../controllers/productsController';
+import { createComment, getCommentList } from '../controllers/commentsController';
+import { toggleProductLike } from '../controllers/likeController';
+import { authenticate } from '../middlewares/authMiddleware';
+
+const productsRouter: Router = express.Router();
+
+productsRouter.get('/', withAsync(getProductList));
+productsRouter.get('/:id', withAsync(getProduct));
+
+
+productsRouter.use(authenticate);
+
+// 상품(Product) 관련
+productsRouter.post('/', withAsync(createProduct));
+productsRouter.patch('/:id', withAsync(updateProduct));
+productsRouter.delete('/:id', withAsync(deleteProduct));
+
+// 댓글(Comment) 관련
+productsRouter.post('/:id/comments', withAsync(createComment));
+productsRouter.get('/:id/comments', withAsync(getCommentList));
+
+// 좋아요(Like) 관련
+productsRouter.post('/:id/like', withAsync(toggleProductLike));
+
+export default productsRouter; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 | 1x +1x +1x +1x +1x + + +1x + + +1x +1x +1x + + +1x +1x + + +1x +1x +1x +1x + + +1x + +1x | import express, { Router } from 'express';
+import * as userController from '../controllers/userController';
+import { authenticate } from '../middlewares/authMiddleware';
+import { withAsync } from '../lib/withAsync';
+const router: Router = express.Router();
+
+
+router.use(authenticate);
+
+
+router.get('/me', withAsync(userController.getMe));
+router.patch('/me', withAsync(userController.updateMe));
+router.patch('/me/password', withAsync(userController.changePassword));
+
+
+router.get('/me/products', withAsync(userController.getMyProducts));
+router.get('/me/likes', withAsync(userController.getMyLikedItems));
+
+
+router.get('/me/notifications', withAsync(userController.getMyNotifications));
+router.patch('/me/notifications', withAsync(userController.readAllNotifications));
+router.get('/me/notifications/unread-count', withAsync(userController.getUnreadNotificationCount));
+router.patch('/me/notifications/:id', withAsync(userController.readNotification));
+
+
+router.delete('/notifications/cleanup', withAsync(userController.deleteOldNotifications));
+
+export default router; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 | 2x +2x +2x +2x +2x +2x +2x +2x +2x +2x + +2x + + +2x +2x +2x + + +2x + + +2x +2x +2x +2x + + +2x +2x + +2x | import express, { Application } from 'express';
+import cors from 'cors';
+import path from 'path';
+import { PUBLIC_PATH, STATIC_PATH } from './lib/constants';
+import articlesRouter from './routers/articlesRouter';
+import productsRouter from './routers/productsRouter';
+import commentsRouter from './routers/commentsRouter';
+import imagesRouter from './routers/imagesRouter';
+import authRouter from './routers/authRoutes';
+import { defaultNotFoundHandler, globalErrorHandler } from './controllers/errorController';
+
+const server: Application = express();
+
+// 💡 기본 설정
+server.use(cors());
+server.use(express.json());
+server.use('/auth', authRouter);
+
+// 💡 정적 파일 설정
+server.use(STATIC_PATH, express.static(path.resolve(process.cwd(), PUBLIC_PATH)));
+
+// 💡 라우터 연결
+server.use('/articles', articlesRouter);
+server.use('/products', productsRouter);
+server.use('/comments', commentsRouter);
+server.use('/images', imagesRouter);
+
+// 💡 에러 핸들러
+server.use(defaultNotFoundHandler);
+server.use(globalErrorHandler);
+
+export default server; // 👈 main.ts에서 가져다 쓸 수 있게 내보냅니다. |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| socket.ts | +
+
+ |
+ 31.25% | +5/16 | +0% | +0/2 | +0% | +0/5 | +21.42% | +3/14 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 | 2x + + +2x + + + + + + + + + + + + + + + + + + + + + + + +2x + + + + | import { Server, Socket } from 'socket.io';
+import type { Server as HttpServer } from 'http';
+
+export const setupSocket = (server: HttpServer): Server => {
+ const io = new Server(server, {
+ cors: {
+ origin: "*",
+ methods: ["GET", "POST"]
+ }
+ });
+
+ io.on('connection', (socket: Socket) => {
+ console.log('소켓 연결됨:', socket.id);
+
+ socket.on('join', (userId: string | number) => {
+ socket.join(`user_${userId}`);
+ console.log(`유저 ${userId}가 알림 방(user_${userId})에 입장했습니다.`);
+ });
+
+ socket.on('disconnect', () => {
+ console.log('소켓 연결 해제');
+ });
+ });
+
+ return io;
+};
+
+export const emitNotification = (io: Server | undefined, userId: string | number, notificationData: any): void => {
+ if (io) {
+ io.to(`user_${userId}`).emit('NEW_NOTIFICATION', notificationData);
+ }
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 | 2x +2x + +2x + +2x +4x + + + + +2x + + + + | import { coerce, nonempty, nullable, object, partial, string, type Infer } from 'superstruct';
+import { PageParamsStruct } from './commonStructs';
+
+export const GetArticleListParamsStruct = PageParamsStruct;
+
+export const CreateArticleBodyStruct = object({
+ title: coerce(nonempty(string()), string(), (value) => value.trim()),
+ content: nonempty(string()),
+ image: nullable(string()),
+});
+
+export const UpdateArticleBodyStruct = partial(CreateArticleBodyStruct);
+
+export type CreateArticleBody = Infer<typeof CreateArticleBodyStruct>;
+export type UpdateArticleBody = Infer<typeof UpdateArticleBodyStruct>;
+export type GetArticleListParams = Infer<typeof GetArticleListParamsStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 | 3x + +3x + + + + + +3x + + + + + + | import { object, string, size, type Infer } from 'superstruct';
+
+export const SignUpStruct = object({
+ email: string(),
+ nickname: string(),
+ password: size(string(), 8, 20),
+});
+
+export const SignInStruct = object({
+ email: string(),
+ password: string(),
+});
+
+export type SignUpBody = Infer<typeof SignUpStruct>;
+export type SignInBody = Infer<typeof SignInStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 | 2x +2x + +2x + + + +2x +2x + + + + | import { nonempty, object, partial, string, type Infer } from 'superstruct';
+import { CursorParamsStruct } from './commonStructs';
+
+export const CreateCommentBodyStruct = object({
+ content: nonempty(string()),
+});
+
+export const GetCommentListParamsStruct = CursorParamsStruct;
+export const UpdateCommentBodyStruct = partial(CreateCommentBodyStruct);
+
+export type CreateCommentBody = Infer<typeof CreateCommentBodyStruct>;
+export type GetCommentListParams = Infer<typeof GetCommentListParamsStruct>;
+export type UpdateCommentBody = Infer<typeof UpdateCommentBodyStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 | 3x + +41x + +3x + + + +3x + + + + + + +3x + + + + + + + + + + | import { coerce, integer, object, string, defaulted, optional, enums, nonempty, type Infer } from 'superstruct';
+
+const integerString = coerce(integer(), string(), (value) => parseInt(value, 10));
+
+export const IdParamsStruct = object({
+ id: integerString,
+});
+
+export const PageParamsStruct = object({
+ page: defaulted(integerString, 1),
+ pageSize: defaulted(integerString, 10),
+ orderBy: optional(enums(['recent'])),
+ keyword: optional(nonempty(string())),
+});
+
+export const CursorParamsStruct = object({
+ cursor: defaulted(integerString, 0),
+ limit: defaulted(integerString, 10),
+ orderBy: optional(enums(['recent'])),
+ keyword: optional(nonempty(string())),
+});
+
+
+export type IdParams = Infer<typeof IdParamsStruct>;
+export type PageParams = Infer<typeof PageParamsStruct>;
+export type CursorParams = Infer<typeof CursorParamsStruct>; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| articlesStructs.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +1/1 | +100% | +6/6 | +
| authStructs.ts | +
+
+ |
+ 100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +
| commentsStruct.ts | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +0/0 | +100% | +5/5 | +
| commonStructs.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +1/1 | +100% | +5/5 | +
| productsStruct.ts | +
+
+ |
+ 100% | +6/6 | +100% | +0/0 | +100% | +1/1 | +100% | +6/6 | +
| userStructs.ts | +
+
+ |
+ 100% | +3/3 | +100% | +0/0 | +100% | +0/0 | +100% | +3/3 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 | 3x +3x + +3x +11x + + + + + + +3x + +3x + + + + + | import { coerce, partial, object, string, min, nonempty, array, integer, type Infer } from 'superstruct';
+import { PageParamsStruct } from './commonStructs';
+
+export const CreateProductBodyStruct = object({
+ name: coerce(nonempty(string()), string(), (value) => value.trim()),
+ description: nonempty(string()),
+ price: min(integer(), 0),
+ tags: array(nonempty(string())),
+ images: array(nonempty(string())),
+});
+
+export const GetProductListParamsStruct = PageParamsStruct;
+
+export const UpdateProductBodyStruct = partial(CreateProductBodyStruct);
+
+export type CreateProductBody = Infer<typeof CreateProductBodyStruct>;
+export type UpdateProductBody = Infer<typeof UpdateProductBodyStruct>;
+export type GetProductListParams = Infer<typeof GetProductListParamsStruct>;
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 | 1x + +1x + + + + +1x + + + + + + | import { object, string, size, optional, type Infer } from 'superstruct';
+
+export const UpdateUserStruct = object({
+ nickname: optional(string()),
+ image: optional(string()),
+});
+
+export const ChangePasswordStruct = object({
+ currentPassword: string(),
+ newPassword: size(string(), 8, 20),
+});
+
+export type UpdateUserBody = Infer<typeof UpdateUserStruct>;
+export type ChangePasswordBody = Infer<typeof ChangePasswordStruct>; |