feat: added end user creation skip for created entities in kyb

ballerine-io · Feb 11, 2025 · 1cb204d · 1cb204d
1 parent badfb02
commit 1cb204d
Showing 1 changed file with 18 additions and 2 deletions.
diff --git a/services/workflows-service/src/collection-flow/controllers/collection-flow.controller.ts b/services/workflows-service/src/collection-flow/controllers/collection-flow.controller.ts
@@ -155,7 +155,15 @@ export class CollectionFlowController {
 
       const directors = await Promise.all(
         workflowRuntimeData.context.entity.data.additionalInfo.directors?.map(
-          async (director: { firstName: string; lastName: string; email: string }) => {
+          async (director: { id?: string; firstName: string; lastName: string; email: string }) => {
+            // If ID is present then entity been created in KYB
+            if (director.id) {
+              return {
+                ballerineEntityId: director.id,
+                ...director,
+              };
+            }
+
             const { id } = await this.endUserService.create({
               data: {
                 firstName: director.firstName,
@@ -175,7 +183,15 @@ export class CollectionFlowController {
 
       const ubos = await Promise.all(
         workflowRuntimeData.context.entity.data.additionalInfo.ubos?.map(
-          async (ubo: { firstName: string; lastName: string; email: string }) => {
+          async (ubo: { id?: string; firstName: string; lastName: string; email: string }) => {
+            // If ID is present then entity been created in KYB
+            if (ubo.id) {
+              return {
+                ballerineEntityId: ubo.id,
+                ...ubo,
+              };
+            }
+
             const { id } = await this.endUserService.create({
               data: {
                 firstName: ubo.firstName,