Skip to content

Commit acf352d

Browse files
authored
fix: fixed creation of initial steps for kyb (#2809)
1 parent c1976d7 commit acf352d

File tree

3 files changed

+12
-3
lines changed

3 files changed

+12
-3
lines changed

services/workflows-service/scripts/workflows/runtime/generate-initial-collection-flow-example.ts

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,8 @@ import { createWorkflow } from '@ballerine/workflow-core';
33
import { Prisma, PrismaClient, UiDefinition } from '@prisma/client';
44
import { env } from '../../../src/env';
55

6+
const EVENTS_BLACK_LIST = ['done', 'success', 'failed'];
7+
68
export const getStepsInOrder = async (uiDefinition: UiDefinition) => {
79
if (!uiDefinition?.uiSchema) return [];
810

@@ -23,7 +25,9 @@ export const getStepsInOrder = async (uiDefinition: UiDefinition) => {
2325

2426
while (!stateMachine.getSnapshot().done) {
2527
const snapshot = stateMachine.getSnapshot();
26-
stepsInOrder.push(snapshot.value);
28+
if (!EVENTS_BLACK_LIST.includes(snapshot.value)) {
29+
stepsInOrder.push(snapshot.value);
30+
}
2731

2832
// Check if NEXT event is available in current state
2933
if (snapshot.nextEvents.includes('NEXT')) {

services/workflows-service/src/collection-flow/helpers/get-steps-in-order.ts

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
import { createWorkflow } from '@ballerine/workflow-core';
22
import { Prisma, UiDefinition } from '@prisma/client';
33

4+
const EVENTS_BLACK_LIST = ['done', 'success', 'failed'];
5+
46
export const getStepsInOrder = async (uiDefinition: UiDefinition) => {
57
if (!uiDefinition?.uiSchema) return [];
68

@@ -21,7 +23,10 @@ export const getStepsInOrder = async (uiDefinition: UiDefinition) => {
2123

2224
while (!stateMachine.getSnapshot().done) {
2325
const snapshot = stateMachine.getSnapshot();
24-
stepsInOrder.push(snapshot.value);
26+
27+
if (!EVENTS_BLACK_LIST.includes(snapshot.value)) {
28+
stepsInOrder.push(snapshot.value);
29+
}
2530

2631
// Check if NEXT event is available in current state
2732
if (snapshot.nextEvents.includes('NEXT')) {

0 commit comments

Comments
 (0)