[이제창] sprint8

.gitignore

@@ -0,0 +1,6 @@
+node_modules
+# Keep environment variables out of version control
+.env
+node_modules
+uploads
+/generated/prisma

.prettierrc.json

@@ -0,0 +1,7 @@
+{
+  "semi": true,
+  "trailingComma": "all",
+  "singleQuote": true,
+  "printWidth": 100,
+  "tabWidth": 2
+}

README.md

@@ -1 +1 @@
-스프린트 미션2
+스프린트 미션5

dist/ArticleService.js

@@ -0,0 +1,27 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+class ArticleService {
+    constructor(articleRepository) {
+        this.articleRepository = articleRepository;
+    }
+    async createArticle(data) {
+        const { userId, ...rest } = data;
+        return this.articleRepository.createArticle({
+            ...rest,
+            user: { connect: { id: userId } },
+        });
+    }
+    async getArticleById(id) {
+        return this.articleRepository.findArticleById(id);
+    }
+    async getArticles(options) {
+        return this.articleRepository.findArticles(options);
+    }
+    async updateArticle(id, data) {
+        return this.articleRepository.updateArticle(id, data);
+    }
+    async deleteArticle(id) {
+        return this.articleRepository.deleteArticle(id);
+    }
+}
+exports.default = ArticleService;

dist/CommentService.js

@@ -0,0 +1,39 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+class CommentService {
+    constructor(commentRepository, articleRepository, notificationService) {
+        this.commentRepository = commentRepository;
+        this.articleRepository = articleRepository;
+        this.notificationService = notificationService;
+    }
+    async createComment(data) {
+        const { userId, productId, articleId, ...rest } = data;
+        const createdComment = await this.commentRepository.createComment({
+            ...rest,
+            user: { connect: { id: userId } },
+            ...(productId && { product: { connect: { id: productId } } }),
+            ...(articleId && { article: { connect: { id: articleId } } }),
+        });
+        if (articleId) {
+            const article = await this.articleRepository.findArticleById(articleId);
+            if (article && article.userId !== userId) {
+                const message = `'${article.title}' 게시글에 새로운 댓글이 달렸습니다.`;
+                await this.notificationService.create(article.userId, 'NEW_COMMENT', message, articleId);
+            }
+        }
+        return createdComment;
+    }
+    async getCommentById(id) {
+        return this.commentRepository.findCommentById(id);
+    }
+    async getComments(options) {
+        return this.commentRepository.findComments(options);
+    }
+    async updateComment(id, data) {
+        return this.commentRepository.updateComment(id, data);
+    }
+    async deleteComment(id) {
+        return this.commentRepository.deleteComment(id);
+    }
+}
+exports.default = CommentService;

dist/LikeService.js

@@ -0,0 +1,29 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+class LikeService {
+    constructor(likeRepository) {
+        this.likeRepository = likeRepository;
+    }
+    async createLike(data) {
+        const { userId, productId, articleId, ...rest } = data;
+        return this.likeRepository.createLike({
+            ...rest,
+            user: { connect: { id: userId } },
+            ...(productId && { product: { connect: { id: productId } } }),
+            ...(articleId && { article: { connect: { id: articleId } } }),
+        });
+    }
+    async deleteLike(id) {
+        return this.likeRepository.deleteLike(id);
+    }
+    async findLikeByUserIdAndProductId(userId, productId) {
+        return this.likeRepository.findLikeByUserIdAndProductId(userId, productId);
+    }
+    async findLikeByUserIdAndArticleId(userId, articleId) {
+        return this.likeRepository.findLikeByUserIdAndArticleId(userId, articleId);
+    }
+    async findLikes(options) {
+        return this.likeRepository.findLikes(options);
+    }
+}
+exports.default = LikeService;

dist/ProductService.js

@@ -0,0 +1,53 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+class ProductService {
+    constructor(productRepository, likeRepository, notificationService) {
+        this.productRepository = productRepository;
+        this.likeRepository = likeRepository;
+        this.notificationService = notificationService;
+    }
+    async createProduct(data) {
+        const { userId, ...rest } = data;
+        return this.productRepository.createProduct({
+            ...rest,
+            user: { connect: { id: userId } },
+        });
+    }
+    async getProductById(id) {
+        return this.productRepository.findProductById(id);
+    }
+    async getProducts(options) {
+        return this.productRepository.findProducts(options);
+    }
+    async updateProduct(id, data, userId) {
+        const originalProduct = await this.productRepository.findProductById(id);
+        if (!originalProduct) {
+            throw new Error('Product not found');
+        }
+        if (originalProduct.userId !== userId) {
+            throw new Error('You do not have permission to update this product.');
+        }
+        const { description, ...restOfData } = data;
+        const updateData = { ...restOfData };
+        if (description) {
+            updateData.content = description;
+        }
+        const updatedProduct = await this.productRepository.updateProduct(id, updateData);
+        if (data.price && originalProduct.price !== updatedProduct.price) {
+            const likes = await this.likeRepository.findLikes({ where: { productId: id } });
+            for (const like of likes) {
+                // Skip notification for the user who updated the product
+                if (like.userId === userId) {
+                    continue;
+                }
+                const message = `'${originalProduct.name}' 상품의 가격이 ${originalProduct.price}원에서 ${updatedProduct.price}원으로 변경되었습니다.`;
+                await this.notificationService.create(like.userId, 'PRICE_CHANGE', message, id);
+            }
+        }
+        return updatedProduct;
+    }
+    async deleteProduct(id) {
+        return this.productRepository.deleteProduct(id);
+    }
+}
+exports.default = ProductService;