Class RelatedPersonAdminService

constructor

• new RelatedPersonAdminService(
      args: {
          aiPriseClient: AiPriseClient;
          aiPriseTimeoutMs?: number;
          db: B2bDatabase;
          eventPublisher: CustomerEventPublisher;
      },
  ): RelatedPersonAdminService

  Parameters

  • args: {
        aiPriseClient: AiPriseClient;
        aiPriseTimeoutMs?: number;
        db: B2bDatabase;
        eventPublisher: CustomerEventPublisher;
    }

    • aiPriseClient: AiPriseClient

    • OptionalaiPriseTimeoutMs?: number

      How long a collapse waits for one AiPrise call. Default 20 seconds: prod writes outlast 10, and the backfill's page goes stale 24 seconds after a heartbeat, so it cannot go higher.

    • db: B2bDatabase

    • eventPublisher: CustomerEventPublisher

  Returns RelatedPersonAdminService

Staticinstance

decideVerification

• decideVerification(
      __namedParameters: {
          decision: "APPROVED" | "DECLINED";
          id: string;
          note?: string;
          reasonCode?: string;
          verificationProfileId?: string;
      },
  ): Promise<
      | { error: ServiceError; ok: false }
      | { ok: true; value: { verificationProfileId: string } },
  >

  Push an operator's decision to AiPrise; the RESULT_UPDATE webhook is the only status writer. A caller that already read the live row passes verificationProfileId to skip the re-read.

  Parameters

  • __namedParameters: {
        decision: "APPROVED" | "DECLINED";
        id: string;
        note?: string;
        reasonCode?: string;
        verificationProfileId?: string;
    }

    • decision: "APPROVED" | "DECLINED"

    • id: string

    • Optionalnote?: string

      Kept beside the code as the MANUAL reason's detail; AiPrise never sees it.

    • OptionalreasonCode?: string

    • OptionalverificationProfileId?: string

  Returns Promise<
      | { error: ServiceError; ok: false }
      | { ok: true; value: { verificationProfileId: string } },
  >

findDuplicateProfileGroups

• findDuplicateProfileGroups(
      __namedParameters?: {
          after?: string;
          limit?: number;
          organizationIds?: string[];
      },
  ): Promise<
      | {
          ok: true;
          value: { hasNext: boolean; items: DuplicateProfileGroup[] };
      }
      | { error: ServiceError; ok: false },
  >

  Live rows on one organization sharing a name and date of birth: a person entered once per role before a control person could carry isBeneficialOwner. limit counts groups. A collapsed pair leaves one live row and drops out. after is a group's cursor from an earlier page.

  Parameters

  • __namedParameters: { after?: string; limit?: number; organizationIds?: string[] } = {}

  Returns Promise<
      | {
          ok: true;
          value: { hasNext: boolean; items: DuplicateProfileGroup[] };
      }
      | { error: ServiceError; ok: false },
  >

mergeProfileGroup

• mergeProfileGroup(
      __namedParameters: {
          dryRun?: boolean;
          group: DuplicateProfileGroup;
          heartbeat?: () => void;
      },
  ): Promise<
      | { ok: true; value: ProfileGroupMerge }
      | { error: ProfileGroupMergeError; ok: false },
  >

  Collapses a CONTROL row and a BENEFICIAL_OWNER row of one human onto the CONTROL row, flagged isBeneficialOwner. Reads AiPrise first with no lock held, then in one transaction locks both rows, re-checks them, widens the keeper and deletes the owner in AiPrise, and writes the rows. An AiPrise failure there rolls the rows back for a re-run. After the commit it publishes; an event that fails is returned in unfinished, not thrown. dryRun only reads.

  Parameters

  • __namedParameters: { dryRun?: boolean; group: DuplicateProfileGroup; heartbeat?: () => void }

    • OptionaldryRun?: boolean

    • group: DuplicateProfileGroup

    • Optionalheartbeat?: () => void

      Called before each AiPrise call and each write; a throw stops the merge.

  Returns Promise<
      | { ok: true; value: ProfileGroupMerge }
      | { error: ProfileGroupMergeError; ok: false },
  >

update

• update(
      __namedParameters: {
          id: string;
          routeFusionDocumentsUploadedAt?: string;
          routeFusionRepresentativeId?: string;
          status?:
              | "PENDING_VERIFICATION"
              | "ACTION_REQUIRED"
              | "APPROVED"
              | "REVIEW"
              | "BLOCKED";
          verificationReasons?: VerificationReasons
          | null;
          zenusPersonId?: string;
      },
  ): Promise<
      | { error: ServiceError; ok: false }
      | { ok: true; value: AdminRelatedPerson },
  >

  Writes the verification status and/or the RouteFusion and Zenus stamps on the live row id. A status change emits statusUpdated; an unchanged status or a stamp alone emits nothing. A soft-deleted person is NOT_FOUND.

  Parameters

  • __namedParameters: {
        id: string;
        routeFusionDocumentsUploadedAt?: string;
        routeFusionRepresentativeId?: string;
        status?:
            | "PENDING_VERIFICATION"
            | "ACTION_REQUIRED"
            | "APPROVED"
            | "REVIEW"
            | "BLOCKED";
        verificationReasons?: VerificationReasons
        | null;
        zenusPersonId?: string;
    }

    • id: string

    • OptionalrouteFusionDocumentsUploadedAt?: string

    • OptionalrouteFusionRepresentativeId?: string

    • Optionalstatus?: "PENDING_VERIFICATION" | "ACTION_REQUIRED" | "APPROVED" | "REVIEW" | "BLOCKED"

    • OptionalverificationReasons?: VerificationReasons | null

      Why the verification landed where it did; null clears it.

    • OptionalzenusPersonId?: string

  Returns Promise<
      | { error: ServiceError; ok: false }
      | { ok: true; value: AdminRelatedPerson },
  >