Added logs to AML webhook (#2372)

* feat: added logs to AML webhook * feat: added log when starting aml webhook --------- Co-authored-by: Alon Peretz <[email protected]>
ballerine-io · May 16, 2024 · 5a5da47 · 5a5da47
1 parent 1aa075b
commit 5a5da47
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/services/workflows-service/src/webhooks/webhooks.service.ts b/services/workflows-service/src/webhooks/webhooks.service.ts
@@ -25,6 +25,8 @@ export class WebhooksService {
     endUserId: string;
     data: IndividualAmlWebhookInput['data'];
   }) {
+    this.logger.log('Started handling individual AML hit', { endUserId });
+
     const { projectId, ...rest } = await this.endUserRepository.findByIdUnscoped(endUserId, {
       select: {
         approvalState: true,
@@ -85,10 +87,12 @@ export class WebhooksService {
     });
 
     if (hits.length === 0) {
+      this.logger.log('No AML hits found', { endUserId });
+
       return;
     }
 
-    await this.workflowService.createOrUpdateWorkflowRuntime({
+    const workflow = await this.workflowService.createOrUpdateWorkflowRuntime({
       workflowDefinitionId,
       context: {
         aml: data,
@@ -105,5 +109,7 @@ export class WebhooksService {
       projectIds: [projectId],
       currentProjectId: projectId,
     });
+
+    this.logger.log(`Created workflow for AML hits`, { workflow });
   }
 }
diff --git a/services/workflows-service/src/workflow/workflow.service.ts b/services/workflows-service/src/workflow/workflow.service.ts
@@ -1352,6 +1352,11 @@ export class WorkflowService {
       const result = ConfigSchema.safeParse(config);
 
       if (!result.success) {
+        this.logger.error('Invalid workflow config', {
+          config,
+          error: result.error,
+        });
+
         throw ValidationError.fromZodError(result.error);
       }