improvement : location constraint in notification

Author: pranav514

dist/controllers/subscription.js

@@ -13,7 +13,8 @@ exports.CreateListingSubscription = exports.CreateSubscription = void 0;
 const subscription_1 = require("../services/subscription");
 const CreateSubscription = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const userId = req.userId;
-    const subscription = yield (0, subscription_1.CreateSubscriptions)(userId);
+    const location = req.body.location;
+    const subscription = yield (0, subscription_1.CreateSubscriptions)({ userId, location });
     if (subscription.status == 402) {
         return res.status(subscription.status).json({
             message: subscription.message

dist/interface/subscriptionInterface.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

dist/repositories/subscription.js

@@ -11,19 +11,23 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.CreateListingSubsripton = exports.FindListingSuscribers = exports.FindMany = exports.Create = exports.findUnique = void 0;
 const db_1 = require("../db");
-const findUnique = (userId) => __awaiter(void 0, void 0, void 0, function* () {
+const findUnique = ({ userId, location }) => __awaiter(void 0, void 0, void 0, function* () {
     const notification = yield db_1.prisma.subscription.findFirst({
         where: {
             userId,
+            location: {
+                hasEvery: location
+            }
         }
     });
     return notification;
 });
 exports.findUnique = findUnique;
-const Create = (userId) => __awaiter(void 0, void 0, void 0, function* () {
+const Create = ({ userId, location }) => __awaiter(void 0, void 0, void 0, function* () {
     const subscription = yield db_1.prisma.subscription.create({
         data: {
             userId,
+            location
         }
     });
     return subscription;

dist/services/subscription.js

@@ -11,15 +11,15 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.CreateSubscriptionLisiting = exports.CreateSubscriptions = void 0;
 const subscription_1 = require("../repositories/subscription");
-const CreateSubscriptions = (userId) => __awaiter(void 0, void 0, void 0, function* () {
-    const suscribed = yield (0, subscription_1.findUnique)(userId);
+const CreateSubscriptions = ({ userId, location }) => __awaiter(void 0, void 0, void 0, function* () {
+    const suscribed = yield (0, subscription_1.findUnique)({ userId, location });
     if (suscribed) {
         return {
             message: "You have already subscribed to this listing",
-            status: 402,
+            status: 409,
         };
     }
-    const subscription = yield (0, subscription_1.Create)(userId);
+    const subscription = yield (0, subscription_1.Create)({ userId, location });
     return {
         message: "Subscribed successfully",
         status: 200,

dist/tests/listing.test.js

@@ -41,6 +41,9 @@ vitest_1.vi.mock("../db", () => ({
         },
         subscription: {
             findMany: vitest_1.vi.fn(() => Promise.resolve([]))
+        },
+        listingNotifySubscription: {
+            findMany: vitest_1.vi.fn(() => Promise.resolve([]))
         }
     },
 }));

dist/utils/notificationListner.js

@@ -20,12 +20,14 @@ exports.notificationGenerator = notification_1.notificationEmitter.on("ListingCr
     console.log(subscribers);
     for (const subscriber of subscribers) {
         console.log(subscriber);
-        yield db_1.prisma.notification.create({
-            data: {
-                userId: subscriber.userId,
-                message: `New listing created: ${listing.title}`,
-            },
-        });
+        if (subscriber.location.find((location) => location === listing.location_city)) {
+            yield db_1.prisma.notification.create({
+                data: {
+                    userId: subscriber.userId,
+                    message: `New listing created: ${listing.title}`,
+                },
+            });
+        }
     }
 }));
 exports.specificlistingNotification = notification_1.notificationEmitter.on("ListingUpdated", (listing) => __awaiter(void 0, void 0, void 0, function* () {

prisma/migrations/20250211041736_subsrciption_location/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "Subscription" ADD COLUMN     "location" TEXT[];

prisma/schema.prisma

@@ -58,6 +58,7 @@ model Ping{
 model Subscription {
   id       String   @id @default(uuid())
   userId   String
+  location String[]
   user     User     @relation(fields: [userId], references: [id])
 }
 

src/controllers/subscription.ts

@@ -3,7 +3,8 @@ import { CreateSubscriptionLisiting, CreateSubscriptions } from "../services/sub
 
 export const CreateSubscription = async(req: Request , res : Response) : Promise<any> => {
     const userId = req.userId
-    const subscription = await CreateSubscriptions(userId);
+    const location = req.body.location
+    const subscription = await CreateSubscriptions({userId , location});
     if(subscription.status == 402){
         return res.status(subscription.status).json({
             message : subscription.message

src/interface/subscriptionInterface.ts

@@ -0,0 +1,4 @@
+export interface CreateSubscriptionInterface {
+    userId : string,
+    location : string[],
+}

src/repositories/subscription.ts

@@ -1,20 +1,25 @@
 import { prisma } from "../db";
 import { DeleteListingInterface } from "../interface/authInterface";
+import { CreateSubscriptionInterface } from "../interface/subscriptionInterface";
 
-export const findUnique = async(userId : string) => {
+
+export const findUnique = async({userId , location} : CreateSubscriptionInterface) => {
     const notification = await prisma.subscription.findFirst({
         where : {
             userId,
-
+            location: {
+                hasEvery: location
+            }
         }
     })
     return notification
 }
 
-export const Create = async (userId  : string) => {
+export const Create = async ({userId , location} : CreateSubscriptionInterface) => {
     const subscription = await prisma.subscription.create({
         data : {
             userId,
+            location
         }
     })
     return subscription

src/services/subscription.ts

@@ -1,14 +1,15 @@
+import { CreateSubscriptionInterface } from "../interface/subscriptionInterface"
 import { Create, CreateListingSubsripton, findUnique } from "../repositories/subscription"
 
-export const CreateSubscriptions = async (userId : string) => {
-    const suscribed  = await findUnique(userId )
+export const CreateSubscriptions = async ({userId , location} : CreateSubscriptionInterface) => {
+    const suscribed  = await findUnique({userId , location} )
     if(suscribed){
         return {
             message : "You have already subscribed to this listing",
-            status : 402,
+            status : 409,
         }
     }
-    const subscription = await Create(userId )
+    const subscription = await Create({userId , location})
     return {
         message : "Subscribed successfully",
         status : 200,

src/utils/notificationListner.ts

@@ -11,13 +11,15 @@ export const notificationGenerator = notificationEmitter.on(
     console.log(subscribers);
     for (const subscriber of subscribers) {
       console.log(subscriber);
-      
-      await prisma.notification.create({
+      if(subscriber.location.find((location : string) => location === listing.location_city)){
+              await prisma.notification.create({
         data: {
           userId: subscriber.userId,
           message: `New listing created: ${listing.title}`,
         },
       });
+      }
+
     }
   }
 );