release: 2.39.0

.github/workflows/staging.yml

@@ -2,7 +2,7 @@ name: Staging
 on:
   push:
     branches:
-      - release/2.37.0
+      - release/2.39.0
 
 jobs:
   build:

package.json

@@ -1,6 +1,6 @@
 {
   "name": "project-sparrow-api",
-  "version": "2.37.0",
+  "version": "2.39.0",
   "description": "Backend APIs for Project Sparrow.",
   "author": "techdome",
   "license": "",

src/main.ts

@@ -74,7 +74,13 @@ const { PORT } = process.env;
   SwaggerModule.setup(SWAGGER_API_ROOT, app, document);
 
   // Enable Cross-Origin Resource Sharing (CORS)
-  app.enableCors();
+  if (process.env.APP_ENV === "DEV") {
+    app.enableCors({
+      origin: "*",
+    });
+  } else {
+    app.enableCors();
+  }
 
   // Register additional Fastify plugins
   app.register(headers);

src/modules/common/enum/database.collection.enum.ts

@@ -23,4 +23,5 @@ export enum Collections {
   PROMOCODES = "promocodes",
   SUPERADMINS = "superadmins",
   NOTIFICATIONS = "notifications",
+  USER_METRICS = "user_metrics",
 }

src/modules/common/models/user-metrics.model.ts

@@ -0,0 +1,105 @@
+import {
+  IsDate,
+  IsNotEmpty,
+  IsNumber,
+  IsOptional,
+  IsString,
+} from "class-validator";
+
+/**
+ * UserMetrics model for precomputed weekly digest metrics.
+ * Designed for efficient upserts and bulk reads without aggregation.
+ */
+export class UserMetrics {
+  /**
+   * The user ID this metric belongs to. Indexed for fast lookups.
+   */
+  @IsString()
+  @IsNotEmpty()
+  userId: string;
+
+  /**
+   * The start of the week (Monday 00:00:00 UTC) this metric covers.
+   * Combined with userId for compound index.
+   */
+  @IsDate()
+  @IsNotEmpty()
+  weekStart: Date;
+
+  /**
+   * Total number of executions (updates/activities) by the user this week.
+   */
+  @IsNumber()
+  @IsOptional()
+  totalExecutions?: number;
+
+  /**
+   * Number of APIs created by the user this week.
+   */
+  @IsNumber()
+  @IsOptional()
+  apisCreated?: number;
+
+  /**
+   * Number of collections the user has access to.
+   */
+  @IsNumber()
+  @IsOptional()
+  collectionsCount?: number;
+
+  /**
+   * Number of active workspaces the user participated in this week.
+   */
+  @IsNumber()
+  @IsOptional()
+  activeWorkspaces?: number;
+
+  /**
+   * Number of new workspaces created by the user this week.
+   */
+  @IsNumber()
+  @IsOptional()
+  newWorkspaces?: number;
+
+  /**
+   * Number of testflows executed by the user this week.
+   */
+  @IsNumber()
+  @IsOptional()
+  testflowsExecuted?: number;
+
+  /**
+   * Timestamp when this metric was last updated.
+   */
+  @IsDate()
+  @IsOptional()
+  updatedAt?: Date;
+}
+
+/**
+ * Payload for incrementing metrics. All fields are optional
+ * since we use $inc for partial updates.
+ */
+export interface IncrementMetricsPayload {
+  totalExecutions?: number;
+  apisCreated?: number;
+  collectionsCount?: number;
+  activeWorkspaces?: number;
+  newWorkspaces?: number;
+  testflowsExecuted?: number;
+}
+
+/**
+ * Metrics data returned from the repository.
+ */
+export interface UserMetricsData {
+  userId: string;
+  weekStart: Date;
+  totalExecutions: number;
+  apisCreated: number;
+  collectionsCount: number;
+  activeWorkspaces: number;
+  newWorkspaces: number;
+  testflowsExecuted: number;
+  updatedAt: Date;
+}

src/modules/identity/repositories/userInvites.repository.ts

@@ -101,7 +101,6 @@ export class UserInvitesRepository {
       .aggregate([
         {
           $match: {
-            createdAt: { $gte: start, $lte: end },
             email: { $in: emails },
           },
         },

src/modules/notifications/repositories/notification.repository.ts

@@ -119,4 +119,86 @@ export class NotificationRepository {
       "data.inviteStatus": "pending",
     });
   }
+
+  /**
+   * Fetch pending workspace invite notifications for a list of users within a time range.
+   * Returns a Map keyed by userId (string) with an array of formatted messages.
+   */
+  async getPendingInvitesForUsers(
+    userIds: string[],
+    start: Date,
+    end: Date,
+  ): Promise<Map<string, string[]>> {
+    if (!userIds || userIds.length === 0) return new Map();
+
+    const objectIds = userIds.map((id) => new ObjectId(id));
+
+    const pipeline = [
+      {
+        $match: {
+          recipientId: { $in: objectIds },
+          type: "WORKSPACE_INVITE",
+          "data.inviteStatus": "pending",
+          createdAt: { $gte: start, $lte: end },
+          isArchived: false,
+        },
+      },
+      { $sort: { createdAt: -1 } },
+      {
+        $group: {
+          _id: "$recipientId",
+          invites: {
+            $push: {
+              inviterName: "$data.inviterName",
+              workspaceNames: "$data.workspaceNames",
+              role: "$data.role",
+              teamName: "$data.teamName",
+            },
+          },
+        },
+      },
+      // Keep only the latest 5 invites per recipient for compactness
+      {
+        $project: {
+          invites: { $slice: ["$invites", 5] },
+        },
+      },
+    ];
+
+    const results = await this.db
+      .collection(Collections.NOTIFICATIONS)
+      .aggregate(pipeline)
+      .toArray();
+
+    const map = new Map<string, string[]>();
+
+    for (const row of results) {
+      const key = row._id.toString();
+      const messages: string[] = [];
+      for (const inv of row.invites || []) {
+        const inviter = inv?.inviterName || "Someone";
+
+        if (inv?.role === "admin") {
+          const teamName = inv?.teamName || "team";
+          messages.push(`${inviter} invited you as admin to ${teamName}`);
+        } else {
+          const workspaceNames = Array.isArray(inv?.workspaceNames)
+            ? inv.workspaceNames
+            : inv?.workspaceNames
+              ? [inv.workspaceNames]
+              : [];
+
+          const workspaceText =
+            workspaceNames.length > 0
+              ? workspaceNames.join(", ")
+              : "a workspace";
+
+          messages.push(`${inviter} invited you to ${workspaceText}`);
+        }
+      }
+      map.set(key, messages);
+    }
+
+    return map;
+  }
 }