Fixed registrar and field expert

src/expert-blame/expert-blame.service.ts

@@ -68,6 +68,7 @@ import { snapshotFromFieldExpert } from "src/helpers/expert-profile-snapshot";
 import { ExpertModel } from "src/users/entities/schema/expert.schema";
 import { SmsOrchestrationService } from "src/sms-orchestration/sms-orchestration.service";
 import { PartyRole } from "src/request-management/entities/schema/partyRole.enum";
+import { RoleEnum } from "src/Types&Enums/role.enum";
 import { ExpertFileActivityDbService } from "src/users/entities/db-service/expert-file-activity.db.service";
 import {
   ExpertFileActivityType,
@@ -243,7 +244,9 @@ export class ExpertBlameService {
    * Portfolio = file-activity (checked/handled), lock, decision, or expert-initiated file.
    */
   async getStatusReportBucketsV2(actor: any): Promise<Record<string, number>> {
-    requireActorClientKey(actor);
+    if (actor.role !== RoleEnum.FIELD_EXPERT) {
+      requireActorClientKey(actor);
+    }
     const expertId = String(actor.sub);
     const expertOid = new Types.ObjectId(expertId);
 
@@ -300,6 +303,9 @@ export class ExpertBlameService {
     query: ListQueryV2Dto = {},
   ): Promise<AllRequestDtoRsV2> {
     try {
+      if (actor.role === RoleEnum.FIELD_EXPERT) {
+        return this.getFieldExpertBlameListV2(actor, query);
+      }
       requireActorClientKey(actor);
       const expertId = actor.sub;
 
@@ -429,6 +435,90 @@ export class ExpertBlameService {
     }
   }
 
+  /**
+   * Blame review inbox for FIELD_EXPERT — expert-initiated DISAGREEMENT files only.
+   * IN_PERSON flows are AGREED and handled outside this panel; completed blames appear in expert-claim.
+   */
+  private async getFieldExpertBlameListV2(
+    actor: { sub: string },
+    query: ListQueryV2Dto = {},
+  ): Promise<AllRequestDtoRsV2> {
+    const expertId = actor.sub;
+    const expertOid = new Types.ObjectId(expertId);
+
+    const visibleCases = (await this.blameRequestDbService.find(
+      {
+        blameStatus: BlameStatus.DISAGREEMENT,
+        expertInitiated: true,
+        initiatedByFieldExpertId: expertOid,
+      },
+      { lean: true },
+    )) as Record<string, unknown>[];
+
+    const staleIds = new Set<string>();
+    for (const doc of visibleCases) {
+      const w = doc.workflow as Record<string, unknown> | undefined;
+      if (!w?.locked) continue;
+      if (!this.isBlameV2WorkflowLockCurrentlyEnforced(doc as any)) {
+        staleIds.add(String(doc._id));
+      }
+    }
+    await Promise.all(
+      [...staleIds].map((id) =>
+        this.expireBlameCaseWorkflowLockV2IfStale(id),
+      ),
+    );
+    for (const doc of visibleCases) {
+      if (!staleIds.has(String(doc._id))) continue;
+      const w = doc.workflow as Record<string, unknown>;
+      if (w) {
+        w.locked = false;
+        delete w.lockedAt;
+        delete w.expiredAt;
+        delete w.lockedBy;
+      }
+    }
+
+    const paged = applyListQueryV2(
+      visibleCases,
+      {
+        publicId: (doc) =>
+          String((doc as { publicId?: string }).publicId ?? ""),
+        createdAt: (doc) => (doc as { createdAt?: Date }).createdAt,
+        requestNo: (doc) =>
+          String(
+            (doc as { requestNo?: string }).requestNo ??
+              (doc as { publicId?: string }).publicId ??
+              "",
+          ),
+        status: (doc) => String((doc as { status?: string }).status ?? ""),
+        searchExtras: (doc) => {
+          const d = doc as {
+            _id?: unknown;
+            blameStatus?: string;
+            type?: string;
+          };
+          return [String(d._id ?? ""), d.blameStatus, d.type].filter(
+            Boolean,
+          ) as string[];
+        },
+      },
+      query,
+    );
+
+    const items: AllRequestDtoV2[] = paged.list.map((doc) =>
+      this.mapBlameRequestToListItemV2(doc),
+    );
+
+    return new AllRequestDtoRsV2({
+      data: items,
+      total: paged.total,
+      page: paged.page,
+      limit: paged.limit,
+      totalPages: paged.totalPages,
+    });
+  }
+
   private mapBlameRequestToListItemV2(
     doc: Record<string, unknown>,
   ): AllRequestDtoV2 {
@@ -1344,7 +1434,9 @@ export class ExpertBlameService {
     try {
       await this.expireBlameCaseWorkflowLockV2IfStale(requestId);
 
-      requireActorClientKey(actor);
+      if (actor.role !== RoleEnum.FIELD_EXPERT) {
+        requireActorClientKey(actor);
+      }
       const actorId = actor.sub;
       const request = await this.blameRequestDbService.findById(requestId);
 
@@ -1584,7 +1676,9 @@ export class ExpertBlameService {
   ): Promise<{ requestId: string; status: string }> {
     try {
       await this.expireBlameCaseWorkflowLockV2IfStale(requestId);
-      requireActorClientKey(actor);
+      if (actor.role !== RoleEnum.FIELD_EXPERT) {
+        requireActorClientKey(actor);
+      }
       const actorId = actor.sub;
       const request = await this.blameRequestDbService.findById(requestId);
 

src/expert-blame/expert-blame.v2.controller.ts

@@ -40,9 +40,12 @@ export class ExpertBlameV2Controller {
 
   @Get()
   @ApiOperation({
-    summary: "List blame cases for field expert (V2)",
+    summary: "List blame cases for expert review (V2)",
     description:
-      "Optional query: `search`, `sortBy` (publicId | createdAt | requestNo | status), `sortOrder`, `page`, `limit`. Without `page`/`limit`, returns the full filtered list.",
+      "Damage experts (`expert`): tenant-scoped **DISAGREEMENT** queue (available, locked, or decided by you). " +
+      "Field experts (`field_expert`): only **DISAGREEMENT** files they initiated that need expert review (e.g. LINK disputes). " +
+      "IN_PERSON expert-initiated blames are usually `AGREED` and are managed via expert-initiated / request-management APIs; after completion, use expert-claim. " +
+      "Optional query: `search`, `sortBy` (publicId | createdAt | requestNo | status), `sortOrder`, `page`, `limit`.",
   })
   async findAll(
     @CurrentUser() actor: any,