feat(activities): step through the same desk list from a detail

Co-authored-by: Cursor <cursoragent@cursor.com>

apps/api/src/activities/activities.service.ts

@@ -265,6 +265,102 @@ export class ActivitiesService {
     facets?: ListFacets,
     stageScope?: StageScope,
   ): Promise<PaginatedResponse<ActivityDto>> {
+    const { where, ctx } = await this.listScope(
+      organizationId,
+      actor,
+      filter,
+      q,
+      entity,
+      range,
+      desk,
+      facets,
+      stageScope,
+    );
+    const take = Math.min(Math.max(limit, 1), 200);
+    const [rows, total] = await this.prisma.$transaction([
+      this.prisma.activity.findMany({
+        where,
+        include,
+        orderBy: [{ dueAt: 'asc' }, { createdAt: 'desc' }],
+        skip: (page - 1) * take,
+        take,
+      }),
+      this.prisma.activity.count({ where }),
+    ]);
+
+    return {
+      items: rows.map((row) => this.toDto(row, ctx)),
+      total,
+      page,
+      limit: take,
+    };
+  }
+
+  /**
+   * شناسه‌ها با همان فیلتر و ترتیب لیست (زمان شروع صعودی).
+   * برای ورق‌زدن جزئیات؛ سقف دارد تا یک زبانهٔ خیلی شلوغ کل پاسخ را بزرگ نکند.
+   */
+  async orderedIds(
+    organizationId: string,
+    actor: ActivityActor,
+    filter: ActivityFilter = 'today',
+    q?: string,
+    entity?: {
+      personId?: string;
+      companyId?: string;
+      dealId?: string;
+      leadId?: string;
+    },
+    range?: {
+      from?: string;
+      to?: string;
+    },
+    desk?: 'mine' | 'team',
+    facets?: ListFacets,
+    stageScope?: StageScope,
+  ): Promise<{ ids: string[]; total: number; truncated: boolean }> {
+    const cap = 2000;
+    const { where } = await this.listScope(
+      organizationId,
+      actor,
+      filter,
+      q,
+      entity,
+      range,
+      desk,
+      facets,
+      stageScope,
+    );
+    const [rows, total] = await this.prisma.$transaction([
+      this.prisma.activity.findMany({
+        where,
+        select: { id: true },
+        orderBy: [{ dueAt: 'asc' }, { createdAt: 'desc' }],
+        take: cap,
+      }),
+      this.prisma.activity.count({ where }),
+    ]);
+    return { ids: rows.map((row) => row.id), total, truncated: total > rows.length };
+  }
+
+  private async listScope(
+    organizationId: string,
+    actor: ActivityActor,
+    filter: ActivityFilter,
+    q: string | undefined,
+    entity:
+      | {
+          personId?: string;
+          companyId?: string;
+          dealId?: string;
+          leadId?: string;
+        }
+      | undefined,
+    range: { from?: string; to?: string } | undefined,
+    desk: 'mine' | 'team' | undefined,
+    facets: ListFacets | undefined,
+    stageScope: StageScope | undefined,
+  ): Promise<{ where: Prisma.ActivityWhereInput; ctx: DtoContext }> {
     const typeRows = await this.types.rows(organizationId);
     const where = this.buildWhere(
       organizationId,
@@ -291,27 +387,9 @@ export class ActivitiesService {
         await this.stages.whereForStage(organizationId, stageScope.stageId),
       );
     }
-    const ctx: DtoContext = {
-      stages: boardCtx,
-      types: this.types.systemOf(typeRows),
-    };
-    const take = Math.min(Math.max(limit, 1), 200);
-    const [rows, total] = await this.prisma.$transaction([
-      this.prisma.activity.findMany({
-        where,
-        include,
-        orderBy: [{ dueAt: 'asc' }, { createdAt: 'desc' }],
-        skip: (page - 1) * take,
-        take,
-      }),
-      this.prisma.activity.count({ where }),
-    ]);
-
     return {
-      items: rows.map((row) => this.toDto(row, ctx)),
-      total,
-      page,
-      limit: take,
+      where,
+      ctx: { stages: boardCtx, types: this.types.systemOf(typeRows) },
     };
   }