YARA-1136

src/request-management/request-management.service.ts

@@ -10075,4 +10075,251 @@ export class RequestManagementService {
       );
     }
   }
+
+  // ── V6 call-center flow ────────────────────────────────────────────────
+
+  /**
+   * V6: Create a LINK blame file initiated by a call-center agent.
+   * Always LINK + CUSTOMER-filled (user fills the form after receiving the SMS).
+   * `skipInitialFormStep` is set so the user-side page skips the inquiry step
+   * (the agent already ran it via runCallCenterInquiryV6).
+   */
+  async createCallCenterInitiatedBlameV6(
+    agent: any,
+    dto: { type: "THIRD_PARTY" | "CAR_BODY" },
+  ): Promise<{ requestId: string; publicId: string }> {
+    if (agent?.role !== RoleEnum.CALL_CENTER) {
+      throw new ForbiddenException("Only call-center agents can use this endpoint.");
+    }
+    const agentId = new Types.ObjectId(agent.sub);
+    const type =
+      dto.type === "CAR_BODY"
+        ? BlameRequestType.CAR_BODY
+        : BlameRequestType.THIRD_PARTY;
+
+    const firstStep = await this.getWorkflowStep({ stepNumber: 1 });
+    if (!firstStep?.stepKey) {
+      throw new InternalServerErrorException(
+        "Workflow stepNumber=1 not configured in step manager",
+      );
+    }
+    const nextStepFromManager = firstStep.nextPossibleSteps?.[0];
+    const nextStep =
+      type === BlameRequestType.CAR_BODY
+        ? (WorkflowStep.CAR_BODY_ACCIDENT_TYPE as WorkflowStep)
+        : (nextStepFromManager as WorkflowStep);
+    if (!nextStep) {
+      throw new InternalServerErrorException(
+        "Workflow stepNumber=1 has no nextPossibleSteps configured",
+      );
+    }
+
+    const publicId = await this.publicIdService.generateRequestPublicId();
+
+    const created = await this.blameRequestDbService.create({
+      publicId,
+      requestNo: publicId,
+      type,
+      parties: [{ role: PartyRole.FIRST, person: {} }],
+      workflow: {
+        currentStep: firstStep.stepKey as WorkflowStep,
+        nextStep,
+        completedSteps: [firstStep.stepKey as WorkflowStep],
+        locked: false,
+      },
+      history: [],
+      callCenterInitiated: true,
+      initiatedByCallCenterId: agentId,
+      creationMethod: CreationMethod.LINK,
+      filledBy: FilledBy.CUSTOMER,
+      // User-side page should skip the inquiry/initial-form step
+      skipInitialFormStep: true,
+    });
+
+    const requestId = String((created as any)._id);
+    if (!Array.isArray((created as any).history)) (created as any).history = [];
+    (created as any).history.push({
+      type: "FILE_CREATED_BY_CALL_CENTER",
+      actor: {
+        actorId: agentId,
+        actorName: `${agent.firstName || ""} ${agent.lastName || ""}`.trim(),
+        actorType: RoleEnum.CALL_CENTER,
+      },
+      metadata: { creationMethod: CreationMethod.LINK, type: dto.type },
+    });
+    await (created as any).save();
+
+    return { requestId, publicId: (created as any).publicId };
+  }
+
+  /**
+   * V6: Run plate + personal inquiry for the guilty party on behalf of the caller.
+   * Stores the inquiry results on the blame's first party (same as V3 guilty-party path)
+   * but does NOT create a claim — the user will do that after filling the form via the link.
+   * Note: sheba is intentionally absent — the user provides their own IBAN later.
+   */
+  async runCallCenterInquiryV6(
+    agent: any,
+    requestId: string,
+    dto: Omit<RunInquiriesV3Dto, "sheba">,
+  ): Promise<{ blameRequestId: string; message: string }> {
+    if (agent?.role !== RoleEnum.CALL_CENTER) {
+      throw new ForbiddenException("Only call-center agents can use this endpoint.");
+    }
+    const req = await this.blameRequestDbService.findById(requestId);
+    if (!req) throw new NotFoundException("Blame request not found");
+    if (!req.callCenterInitiated || String(req.initiatedByCallCenterId) !== String(agent.sub)) {
+      throw new ForbiddenException("You can only access files that you have initiated.");
+    }
+
+    const firstIdx = this.getPartyIndex(req, PartyRole.FIRST);
+    if (firstIdx === -1) throw new BadRequestException("First party not found");
+    const firstParty = req.parties[firstIdx];
+
+    await this.runPartyInquiriesV3Internal(req, dto, PartyRole.FIRST, firstParty);
+    this.markPartyInquiriesCompleteOnBlame(req, PartyRole.FIRST, agent);
+    if (!Array.isArray((req as any).history)) (req as any).history = [];
+    (req as any).history.push({
+      type: "CALL_CENTER_INQUIRY_COMPLETED",
+      actor: {
+        actorId: new Types.ObjectId(agent.sub),
+        actorName: `${agent.firstName || ""} ${agent.lastName || ""}`.trim(),
+        actorType: RoleEnum.CALL_CENTER,
+      },
+      metadata: { partyRole: PartyRole.FIRST },
+    });
+    await (req as any).save();
+
+    return {
+      blameRequestId: requestId,
+      message: "Guilty-party inquiry complete. You can now send the blame link to the user.",
+    };
+  }
+
+  /**
+   * V6: Send the blame link to the guilty party's phone number.
+   * Registers/looks up the user by phone and stores them as the first party, then
+   * sends the SMS link so the user can fill in the rest of the form via the v2 flow.
+   */
+  async sendCallCenterLinkV6(
+    agent: any,
+    requestId: string,
+    dto: { phoneNumber: string },
+  ): Promise<{ sent: boolean; sentTo: { role: string; phoneNumber: string; smsSent: boolean; linkUrl: string }[] }> {
+    if (agent?.role !== RoleEnum.CALL_CENTER) {
+      throw new ForbiddenException("Only call-center agents can use this endpoint.");
+    }
+    const req = await this.blameRequestDbService.findById(requestId);
+    if (!req) throw new NotFoundException("Request not found");
+    if (!req.callCenterInitiated || String(req.initiatedByCallCenterId) !== String(agent.sub)) {
+      throw new ForbiddenException("You can only access files that you have initiated.");
+    }
+    if (!process.env.URL) {
+      throw new InternalServerErrorException("URL environment variable is not configured");
+    }
+
+    const phone = (dto?.phoneNumber || "").trim();
+    if (!phone) throw new BadRequestException("phoneNumber is required");
+
+    const firstIdx = this.getPartyIndex(req, PartyRole.FIRST);
+    if (firstIdx === -1) throw new BadRequestException("First party not found on request");
+    const userId = await this.getOrCreateUserByPhoneNumber(phone);
+    if (!req.parties[firstIdx].person) req.parties[firstIdx].person = {} as any;
+    req.parties[firstIdx].person.phoneNumber = normalizeIranMobile(phone) ?? phone;
+    req.parties[firstIdx].person.userId = userId;
+
+    const expertName = `${agent?.lastName || ""}`.trim() || "اپراتور";
+    const firstLink = this.smsOrchestrationService.buildBlamePartyLink(requestId, "FIRST");
+    const smsSent = await this.smsOrchestrationService.sendFieldExpertLink({
+      receptor: phone,
+      type: req.type,
+      expertLastName: expertName,
+      link: firstLink,
+    });
+
+    const sentTo = [{ role: PartyRole.FIRST, phoneNumber: phone, smsSent, linkUrl: firstLink }];
+
+    if (!Array.isArray((req as any).history)) (req as any).history = [];
+    (req as any).history.push({
+      type: "CALL_CENTER_LINK_SENT",
+      actor: {
+        actorId: new Types.ObjectId(agent.sub),
+        actorName: `${agent.firstName || ""} ${agent.lastName || ""}`.trim(),
+        actorType: RoleEnum.CALL_CENTER,
+      },
+      metadata: { sentTo },
+    });
+    await (req as any).save();
+
+    return { sent: smsSent, sentTo };
+  }
+
+  /**
+   * V6: Get a single blame file detail for the call-center agent who created it.
+   */
+  async getCallCenterBlameDetailV6(agent: any, requestId: string): Promise<any> {
+    if (agent?.role !== RoleEnum.CALL_CENTER) {
+      throw new ForbiddenException("Only call-center agents can use this endpoint.");
+    }
+    const req = await this.blameRequestDbService.findById(requestId);
+    if (!req) throw new NotFoundException("Blame request not found");
+    if (!req.callCenterInitiated || String(req.initiatedByCallCenterId) !== String(agent.sub)) {
+      throw new ForbiddenException("You can only access files that you have initiated.");
+    }
+    return {
+      _id: (req as any)._id,
+      publicId: (req as any).publicId,
+      requestNo: (req as any).requestNo,
+      type: (req as any).type,
+      status: (req as any).status,
+      blameStatus: (req as any).blameStatus,
+      workflow: (req as any).workflow,
+      skipInitialFormStep: (req as any).skipInitialFormStep,
+      parties: ((req as any).parties ?? []).map((p: any) => ({
+        role: p.role,
+        person: {
+          phoneNumber: p.person?.phoneNumber,
+          nationalCodeOfInsurer: p.person?.nationalCodeOfInsurer,
+          clientId: p.person?.clientId,
+        },
+        insurance: p.insurance
+          ? {
+              company: p.insurance.company,
+              policyNumber: p.insurance.policyNumber,
+              startDate: p.insurance.startDate,
+              endDate: p.insurance.endDate,
+            }
+          : undefined,
+        vehicle: p.vehicle
+          ? { plateId: p.vehicle.plateId, name: p.vehicle.name }
+          : undefined,
+      })),
+      createdAt: (req as any).createdAt,
+    };
+  }
+
+  /**
+   * V6: List blame files created by this call-center agent.
+   */
+  async getMyCallCenterFilesV6(agent: any): Promise<any[]> {
+    if (agent?.role !== RoleEnum.CALL_CENTER) {
+      throw new ForbiddenException("Only call-center agents can use this endpoint.");
+    }
+    const agentId = new Types.ObjectId(agent.sub);
+    const files = await this.blameRequestDbService.find({
+      callCenterInitiated: true,
+      initiatedByCallCenterId: agentId,
+    });
+    return (files || []).map((f: any) => ({
+      _id: f._id,
+      publicId: f.publicId,
+      requestNo: f.requestNo,
+      type: f.type,
+      status: f.status,
+      blameStatus: f.blameStatus,
+      workflow: f.workflow,
+      skipInitialFormStep: f.skipInitialFormStep,
+      createdAt: f.createdAt,
+    }));
+  }
 }