WIP - Directors individual sanctions

apps/backoffice-v2/CHANGELOG.md

@@ -1,5 +1,14 @@
 # @ballerine/backoffice-v2
 
+## 0.7.96
+
+### Patch Changes
+
+- Updated dependencies
+  - @ballerine/[email protected]
+  - @ballerine/[email protected]
+  - @ballerine/[email protected]
+
 ## 0.7.95
 
 ### Patch Changes

apps/backoffice-v2/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@ballerine/backoffice-v2",
-  "version": "0.7.95",
+  "version": "0.7.96",
   "description": "Ballerine - Backoffice",
   "homepage": "https://github.com/ballerine-io/ballerine",
   "type": "module",
@@ -53,9 +53,9 @@
   },
   "dependencies": {
     "@ballerine/blocks": "0.2.34",
-    "@ballerine/common": "0.9.68",
-    "@ballerine/workflow-browser-sdk": "0.6.87",
-    "@ballerine/workflow-node-sdk": "0.6.87",
+    "@ballerine/common": "0.9.69",
+    "@ballerine/workflow-browser-sdk": "0.6.88",
+    "@ballerine/workflow-node-sdk": "0.6.88",
     "@ballerine/react-pdf-toolkit": "^1.2.67",
     "@ballerine/ui": "^0.5.67",
     "@botpress/webchat": "^2.1.10",

apps/backoffice-v2/src/domains/entities/hooks/mutations/useApproveTaskByIdMutation/useApproveTaskByIdMutation.tsx

@@ -13,10 +13,12 @@ export const useApproveTaskByIdMutation = (workflowId: string) => {
 
   return useMutation({
     mutationFn: ({
+      directorId,
       documentId,
       contextUpdateMethod = 'base',
       comment,
     }: {
+      directorId?: string;
       documentId: string;
       contextUpdateMethod?: 'base' | 'director';
       comment?: string;
@@ -25,6 +27,7 @@ export const useApproveTaskByIdMutation = (workflowId: string) => {
         workflowId,
         documentId,
         body: {
+          directorId,
           decision: Action.APPROVE,
           comment,
         },

apps/backoffice-v2/src/domains/entities/hooks/mutations/useRemoveDecisionTaskByIdMutation/useRemoveDecisionTaskByIdMutation.tsx

@@ -13,15 +13,18 @@ export const useRemoveDecisionTaskByIdMutation = (workflowId: string) => {
   return useMutation({
     mutationFn: ({
       documentId,
+      directorId,
       contextUpdateMethod,
     }: {
       documentId: string;
+      directorId?: string;
       contextUpdateMethod: 'base' | 'director';
     }) =>
       updateWorkflowDecision({
         workflowId,
         documentId,
         body: {
+          directorId,
           decision: null,
           reason: null,
         },

apps/backoffice-v2/src/domains/entities/hooks/mutations/useRevisionTaskByIdMutation/useRevisionTaskByIdMutation.tsx

@@ -15,18 +15,21 @@ export const useRevisionTaskByIdMutation = () => {
       workflowId,
       documentId,
       reason,
+      directorId,
       contextUpdateMethod,
     }: {
       workflowId: string;
       documentId: string;
       reason?: string;
+      directorId?: string;
       contextUpdateMethod?: 'base' | 'director';
     }) =>
       updateWorkflowDecision({
         workflowId,
         documentId,
         contextUpdateMethod,
         body: {
+          directorId,
           decision: Action.REVISION,
           reason,
         },

apps/backoffice-v2/src/domains/individuals/fetchers.ts

@@ -0,0 +1,24 @@
+import { handleZodError } from '@/common/utils/handle-zod-error/handle-zod-error';
+
+import { Method } from '@/common/enums';
+
+import { z } from 'zod';
+
+import { HitSchema } from '@/lib/blocks/components/AmlBlock/utils/aml-adapter';
+
+import { apiClient } from '@/common/api-client/api-client';
+
+export const EndUserSchema = z.object({
+  amlHits: z.array(HitSchema.extend({ vendor: z.string().optional() })).optional(),
+});
+
+export const getEndUserById = async ({ id }: { id: string }) => {
+  const [endUser, error] = await apiClient({
+    endpoint: `end-users/${id}`,
+    method: Method.GET,
+    schema: EndUserSchema,
+    timeout: 30_000,
+  });
+
+  return handleZodError(error, endUser);
+};

apps/backoffice-v2/src/domains/individuals/queries/useEndUserByIdQuery/useEndUserByIdQuery.tsx

@@ -0,0 +1,12 @@
+import { useIsAuthenticated } from '@/domains/auth/context/AuthProvider/hooks/useIsAuthenticated/useIsAuthenticated';
+import { useQuery } from '@tanstack/react-query';
+import { endUsersQueryKeys } from '../../query-keys';
+
+export const useEndUserByIdQuery = ({ id }: { id: string }) => {
+  const isAuthenticated = useIsAuthenticated();
+
+  return useQuery({
+    ...endUsersQueryKeys.byId({ id }),
+    enabled: !!id && isAuthenticated,
+  });
+};

apps/backoffice-v2/src/domains/individuals/query-keys.ts

@@ -0,0 +1,9 @@
+import { createQueryKeys } from '@lukemorales/query-key-factory';
+import { getEndUserById } from './fetchers';
+
+export const endUsersQueryKeys = createQueryKeys('end-users', {
+  byId: ({ id }: { id: string }) => ({
+    queryKey: ['end-users', id],
+    queryFn: () => getEndUserById({ id }),
+  }),
+});

apps/backoffice-v2/src/domains/workflows/fetchers.ts

@@ -300,6 +300,7 @@ export const updateWorkflowDecision = async ({
   documentId: string;
   body: {
     decision: string | null;
+    directorId?: string;
     reason?: string;
     comment?: string;
   };

apps/backoffice-v2/src/lib/blocks/components/DirectorBlock/DirectorBlock.tsx

@@ -0,0 +1,50 @@
+import { BlocksComponent } from '@ballerine/blocks';
+import { cells } from '../../create-blocks-typed/create-blocks-typed';
+import { useEndUserByIdQuery } from '@/domains/individuals/queries/useEndUserByIdQuery/useEndUserByIdQuery';
+import { useDirectorBlock } from './hooks/useDirectorBlock/useDirectorBlock';
+
+export const DirectorBlock = ({
+  workflowId,
+  onReuploadNeeded,
+  onRemoveDecision,
+  onApprove,
+  director,
+  tags,
+  revisionReasons,
+  isEditable,
+  isApproveDisabled,
+  documentSchemas,
+  isLoadingDocuments,
+  workflow,
+}: Omit<Parameters<typeof useDirectorBlock>[0], 'director'> & {
+  director: Omit<Parameters<typeof useDirectorBlock>[0]['director'], 'aml'>;
+}) => {
+  const { data: endUser } = useEndUserByIdQuery({ id: director.id });
+  const directorWithAml = {
+    ...director,
+    aml: {
+      vendor: endUser?.amlHits?.find(({ vendor }) => !!vendor)?.vendor,
+      hits: endUser?.amlHits,
+    },
+  };
+  const directorBlock = useDirectorBlock({
+    workflowId,
+    onReuploadNeeded,
+    onRemoveDecision,
+    onApprove,
+    director: directorWithAml,
+    tags,
+    revisionReasons,
+    isEditable,
+    isApproveDisabled,
+    documentSchemas,
+    isLoadingDocuments,
+    workflow,
+  });
+
+  return (
+    <BlocksComponent blocks={directorBlock} cells={cells}>
+      {(Cell, cell) => <Cell {...cell} />}
+    </BlocksComponent>
+  );
+};

apps/backoffice-v2/src/lib/blocks/components/DirectorBlock/hooks/useDirectorBlock/create-directors-blocks.tsx

@@ -0,0 +1,58 @@
+import { createBlocksTyped } from '@/lib/blocks/create-blocks-typed/create-blocks-typed';
+import { ComponentProps } from 'react';
+import { DirectorBlock } from '../../DirectorBlock';
+import { getDocumentsByCountry } from '@ballerine/common';
+import { extractCountryCodeFromDocuments } from '@/pages/Entity/hooks/useEntityLogic/utils';
+
+export const createDirectorsBlocks = ({
+  workflowId,
+  onReuploadNeeded,
+  onRemoveDecision,
+  onApprove,
+  directors,
+  tags,
+  revisionReasons,
+  isEditable,
+  isApproveDisabled,
+  isLoadingDocuments,
+  workflow,
+}: Omit<ComponentProps<typeof DirectorBlock>, 'director' | 'documentSchemas'> & {
+  directors: Array<ComponentProps<typeof DirectorBlock>['director']>;
+}) => {
+  const directorsBlocks = createBlocksTyped().addBlock();
+
+  if (!directors?.length) {
+    return [];
+  }
+
+  directors?.forEach(director => {
+    const issuerCountryCode = extractCountryCodeFromDocuments(director.documents);
+    const documentSchemas = issuerCountryCode ? getDocumentsByCountry(issuerCountryCode) : [];
+
+    if (!Array.isArray(documentSchemas) || !documentSchemas.length) {
+      console.warn(`No document schema found for issuer country code of "${issuerCountryCode}".`);
+    }
+
+    directorsBlocks.addCell({
+      type: 'node',
+      value: (
+        <DirectorBlock
+          workflowId={workflowId}
+          onReuploadNeeded={onReuploadNeeded}
+          onRemoveDecision={onRemoveDecision}
+          onApprove={onApprove}
+          director={director}
+          tags={tags}
+          revisionReasons={revisionReasons}
+          isEditable={isEditable}
+          isApproveDisabled={isApproveDisabled}
+          documentSchemas={documentSchemas}
+          isLoadingDocuments={isLoadingDocuments}
+          workflow={workflow}
+        />
+      ),
+    });
+  });
+
+  return directorsBlocks.build();
+};

apps/backoffice-v2/src/lib/blocks/components/DirectorBlock/hooks/useDirectorBlock/helpers.ts

@@ -0,0 +1,51 @@
+import { createDirectorsBlocks } from './create-directors-blocks';
+
+export const directorDocumentsAdapter = ({ documents, storageFiles }) => {
+  return documents?.map(
+    (document, documentIndex) =>
+      ({
+        id: document?.id,
+        category: document?.category,
+        type: document?.type,
+        issuer: {
+          country: document?.issuer?.country,
+        },
+        decision: {
+          status: document?.decision?.status,
+        },
+        version: document?.version,
+        properties: document?.properties,
+        propertiesSchema: document?.propertiesSchema,
+        pages: document?.pages?.map(
+          (page, pageIndex) =>
+            ({
+              type: page?.type,
+              imageUrl: storageFiles?.[documentIndex]?.[pageIndex],
+              metadata: {
+                side: page?.metadata?.side,
+              },
+            } satisfies Parameters<
+              typeof createDirectorsBlocks
+            >[0]['directors'][number]['documents'][number]['pages'][number]),
+        ),
+      } satisfies Parameters<
+        typeof createDirectorsBlocks
+      >[0]['directors'][number]['documents'][number]),
+  );
+};
+
+export const directorAdapter =
+  storageFiles =>
+  ({ ballerineEntityId, firstName, lastName, additionalInfo }) => {
+    const documents = directorDocumentsAdapter({
+      documents: additionalInfo?.documents,
+      storageFiles,
+    });
+
+    return {
+      id: ballerineEntityId,
+      firstName,
+      lastName,
+      documents,
+    } satisfies Parameters<typeof createDirectorsBlocks>[0]['directors'][number];
+  };

apps/backoffice-v2/src/lib/blocks/components/DirectorBlock/hooks/useDirectorBlock/index.ts

@@ -0,0 +1 @@
+export * from './useDirectorBlock';