Merge pull request #10 from pranav514/layered_architecture

refactored [listings] code improvement

Author: pranav514

dist/routes/listingRoute.js

@@ -13,7 +13,6 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
 };
 Object.defineProperty(exports, "__esModule", { value: true });
 const express_1 = __importDefault(require("express"));
-const db_1 = require("../db");
 const authMiddleware_1 = require("../middleware/authMiddleware");
 const listing_1 = require("../repositories/listing");
 const lisiting_1 = require("../services/lisiting");
@@ -114,24 +113,16 @@ router.get("/getlisting/:id", authMiddleware_1.authMiddleware, (req, res) => __a
     }
 }));
 router.get("/userlisting", authMiddleware_1.authMiddleware, (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-    try {
-        const userId = req.userId;
-        console.log("userId", userId);
-        const listing = yield db_1.prisma.listing.findMany({
-            where: {
-                userId: userId,
-            },
-        });
-        console.log(listing);
-        return res.status(200).json({
-            message: `fetched the blog of the user ${userId}`,
-            listing,
-        });
-    }
-    catch (error) {
-        res.status(411).json({
-            message: "cannot fetched the blog",
+    const userId = req.userId;
+    const specificListing = yield (0, lisiting_1.GetUserSpecific)(userId);
+    if (specificListing.status === 411) {
+        return res.status(specificListing.status).json({
+            message: specificListing.message
         });
     }
+    return res.status(200).json({
+        message: specificListing.message,
+        listing: specificListing.listing
+    });
 }));
 exports.default = router;

dist/services/lisiting.js

@@ -9,7 +9,7 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
     });
 };
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.GetAll = exports.DeleteListing = exports.UpdateListings = exports.CreateListing = void 0;
+exports.GetUserSpecific = exports.GetAll = exports.DeleteListing = exports.UpdateListings = exports.CreateListing = void 0;
 const listing_1 = require("../repositories/listing");
 const CreateListing = ({ title, description, images, rent, prefered_gender, address, location_city, userId }) => __awaiter(void 0, void 0, void 0, function* () {
     try {
@@ -104,3 +104,22 @@ const GetAll = ({ skip, limit, page }) => __awaiter(void 0, void 0, void 0, func
     }
 });
 exports.GetAll = GetAll;
+const GetUserSpecific = (userId) => __awaiter(void 0, void 0, void 0, function* () {
+    try {
+        console.log("userId", userId);
+        const listing = yield (0, listing_1.findMany)(userId);
+        console.log(listing);
+        return {
+            message: `fetched the blog of the user ${userId}`,
+            status: 200,
+            listing
+        };
+    }
+    catch (error) {
+        return {
+            message: "cannot fetched the blog",
+            status: 411,
+        };
+    }
+});
+exports.GetUserSpecific = GetUserSpecific;

src/routes/listingRoute.ts

@@ -9,7 +9,7 @@ import {
   getAll,
   Update,
 } from "../repositories/listing";
-import { CreateListing, DeleteListing, GetAll, UpdateListings } from "../services/lisiting";
+import { CreateListing, DeleteListing, GetAll, GetUserSpecific, UpdateListings } from "../services/lisiting";
 const router = express.Router();
 
 router.post(
@@ -144,24 +144,20 @@ router.get(
 );
 
 router.get("/userlisting", authMiddleware, async (req, res): Promise<any> => {
-  try {
+  
     const userId = req.userId;
-    console.log("userId", userId);
-    const listing = await prisma.listing.findMany({
-      where: {
-        userId: userId,
-      },
-    });
-    console.log(listing);
+    const specificListing = await GetUserSpecific(userId);
+    if(specificListing.status === 411){
+      return res.status(specificListing.status).json({
+        message : specificListing.message
+      })
+    }
     return res.status(200).json({
-      message: `fetched the blog of the user ${userId}`,
-      listing,
-    });
-  } catch (error) {
-    res.status(411).json({
-      message: "cannot fetched the blog",
-    });
-  }
+      message : specificListing.message,
+      listing : specificListing.listing
+    })
+  
+  
 });
 
 export default router;

src/services/lisiting.ts

@@ -1,6 +1,6 @@
 import { any } from "vitest-mock-extended";
 import { CreateListing as CreateListingInterface, Pagination, UpdateListing } from "../interface/listingInterface";
-import { Count, Create, deleteListing, getAll, Update } from "../repositories/listing";
+import { Count, Create, deleteListing, findMany, getAll, Update } from "../repositories/listing";
 
 export const CreateListing = async ({title , description, images , rent , prefered_gender , address , location_city , userId} : CreateListingInterface) => {
     try {
@@ -105,4 +105,22 @@ export const GetAll = async({skip , limit , page} :any ) => {
             status : 411
         }
       }
+}
+
+export const GetUserSpecific = async(userId : string) => {
+    try {
+        console.log("userId", userId);
+        const listing = await findMany(userId);
+        console.log(listing);
+        return {
+            message :  `fetched the blog of the user ${userId}`,
+            status  :200,
+            listing
+        }
+      } catch (error) {
+        return {
+            message : "cannot fetched the blog",
+            status : 411,
+        }
+      }
 }