recommendations with API

src/modules/property/property.controller.ts

@@ -75,6 +75,7 @@ export class PropertyController extends CommonServices {
   @Get('/listings')
   async getDashboardActiveUsers(@Query() query, @Res() res, @Req() req) {
     try {
+
       const page = Number(query.page);
       const resPerPage = query.resPerPage ? Number(query.resPerPage) : 20;
       const search = query.search || ''; // Default to empty search if not provided
@@ -82,11 +83,20 @@ export class PropertyController extends CommonServices {
 
       if (!query.sessionId) sessionId = uuidv4();
 
-      const listings = await this.propertyService.propertyLisitng(
-        page,
-        resPerPage,
-        search,
-      );
+      let listings;
+      if (!query.sessionId) {
+        listings = await this.propertyService.propertyLisitng(
+          page,
+          resPerPage,
+          search,
+        );
+      } else {
+        listings = await this.propertyService.propertyLisitngRecommendedSearch(
+          page,
+          resPerPage,
+          query.recommendations,
+        );
+      }
 
       this.sendResponse(
         this.messages.Success,

src/modules/property/property.service.ts

@@ -41,4 +41,50 @@ export class PropertyService extends sharedCrudService {
       per_page: resPerPage,
     };
   }
+
+  /**
+   * It will recieve array of IDs to get the recommended listing
+   * @param page
+   * @param resPerPage
+   * @param search
+   * @returns
+   */
+  async propertyLisitngRecommendedSearch(
+    page: number,
+    resPerPage: number,
+    recommendations: string[],
+  ): Promise<any> {
+    const query = [];
+
+    // Check if recommendations is a string and split it into an array
+    if (typeof recommendations === 'string') {
+      //@ts-ignore
+      recommendations = recommendations.split(',');
+    }
+
+    query.push({ id: { $exists: true } });
+
+    // Modify the query to handle an array of IDs
+    if (recommendations && recommendations.length > 0) {
+      query.push({ id: { $in: recommendations } });
+    }
+
+    const [listings, tLisitngsCount] = await Promise.all([
+      this.propertyRepository
+        .find({ $and: [...query] })
+        .sort({ createdAt: -1 })
+        .skip(resPerPage * (page - 1))
+        .limit(resPerPage)
+        .exec(),
+      this.propertyRepository.countDocuments({ $and: [...query] }).exec(),
+    ]);
+
+    return {
+      listings,
+      current_page: page,
+      pages: Math.ceil(tLisitngsCount / resPerPage),
+      total_listings: tLisitngsCount,
+      per_page: resPerPage,
+    };
+  }
 }