new events

package-lock.json

@@ -26,7 +26,8 @@
         "passport-jwt": "^4.0.1",
         "passport-local": "^1.0.0",
         "reflect-metadata": "^0.2.0",
-        "rxjs": "^7.8.1"
+        "rxjs": "^7.8.1",
+        "uuid": "^10.0.0"
       },
       "devDependencies": {
         "@nestjs/cli": "^10.0.0",
@@ -9630,6 +9631,19 @@
         "node": ">= 0.4.0"
       }
     },
+    "node_modules/uuid": {
+      "version": "10.0.0",
+      "resolved": "https://registry.npmjs.org/uuid/-/uuid-10.0.0.tgz",
+      "integrity": "sha512-8XkAphELsDnEGrDxUOHB3RGvXz6TeuYSGEZBOjtTtPm2lwhGBjLgOzLHB63IUWfBpNucQjND6d3AOudO+H3RWQ==",
+      "funding": [
+        "https://github.com/sponsors/broofa",
+        "https://github.com/sponsors/ctavan"
+      ],
+      "license": "MIT",
+      "bin": {
+        "uuid": "dist/bin/uuid"
+      }
+    },
     "node_modules/v8-compile-cache-lib": {
       "version": "3.0.1",
       "resolved": "https://registry.npmjs.org/v8-compile-cache-lib/-/v8-compile-cache-lib-3.0.1.tgz",

package.json

@@ -37,7 +37,8 @@
     "passport-jwt": "^4.0.1",
     "passport-local": "^1.0.0",
     "reflect-metadata": "^0.2.0",
-    "rxjs": "^7.8.1"
+    "rxjs": "^7.8.1",
+    "uuid": "^10.0.0"
   },
   "devDependencies": {
     "@nestjs/cli": "^10.0.0",

src/modules/activity/activity.controller.ts

@@ -26,14 +26,14 @@ export class ActivityController extends CommonServices {
   }
 
   @Post('create')
-  @UseGuards(JwtAuthGuard)
+  // @UseGuards(JwtAuthGuard)
   async createActivity(@Body() body: any, @Res() res: Response, @Req() req) {
     try {
-      const payload = {
-        ...body,
-        userId: req.user.userId,
-      };
-      const activity = await this.activityService.sharedCreate(payload);
+      // const payload = {
+      //   ...body,
+      //   userId: req.user.userId,
+      // };
+      const activity = await this.activityService.sharedCreate(body);
 
       // update views
       if (body.action == 'view')

src/modules/activity/activity.schema.ts

@@ -4,26 +4,30 @@ import { IUserDocument } from '../user/user.schema';
 import { IPropertyDocument } from '../property/property.schema';
 
 export interface IUserActivityDocument extends Document {
-  userId: IUserDocument;
+  // userId: IUserDocument;
   propertyId: IPropertyDocument;
   action: string; // E.g., 'click', 'view', 'time_spent'
+  sessionId: string; // E.g., 'click', 'view', 'time_spent'
   timestamp: Date;
   duration?: number; // Store time spent in seconds for 'time_spent' action
+  searchQuery?: string;
 }
 
 const UserActivitySchema = new mongoose.Schema<IUserActivityDocument>(
   {
-    userId: {
-      type: mongoose.Schema.Types.ObjectId,
-      ref: 'User',
-      required: true,
-    },
+    // userId: {
+    //   type: mongoose.Schema.Types.ObjectId,
+    //   ref: 'User',
+    //   required: true,
+    // },
     propertyId: {
       type: mongoose.Schema.Types.ObjectId,
       ref: 'propertie',
-      required: true,
+      // required: true,
     },
     action: { type: String, required: true }, // 'click', 'view', 'time_spent'
+    sessionId: { type: String, required: true },
+    searchQuery: { type: String },
     timestamp: { type: Date, default: Date.now },
     duration: { type: Number }, // Only applicable for 'time_spent'
   },

src/modules/database/database.provider.ts

@@ -9,4 +9,4 @@ export const databaseProviders = [
         'mongodb+srv://rehmanwahlah248:l73aCc2uUPWuiaod@cluster0.16fl8yq.mongodb.net/property-listing?retryWrites=true&w=majority',
       ),
   },
-];
+];

src/modules/property/property.controller.ts

@@ -12,6 +12,7 @@ import {
 import { Response } from 'express';
 import { CommonServices } from '../shared/common.service';
 import { PropertyService } from './property.service';
+import { v4 as uuidv4 } from 'uuid';
 
 @Controller('property')
 export class PropertyController extends CommonServices {
@@ -77,8 +78,9 @@ export class PropertyController extends CommonServices {
       const page = Number(query.page);
       const resPerPage = query.resPerPage ? Number(query.resPerPage) : 20;
       const search = query.search || ''; // Default to empty search if not provided
+      let sessionId = null;
 
-      console.log(`search =>`, query);
+      if (!query.sessionId) sessionId = uuidv4();
 
       const listings = await this.propertyService.propertyLisitng(
         page,
@@ -86,7 +88,12 @@ export class PropertyController extends CommonServices {
         search,
       );
 
-      this.sendResponse(this.messages.Success, listings, HttpStatus.OK, res);
+      this.sendResponse(
+        this.messages.Success,
+        { listings, sessionId: sessionId },
+        HttpStatus.OK,
+        res,
+      );
     } catch (error) {
       console.error('error', error);
       this.sendResponse(