SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Update activity-walker.ts

Browse source
This commit is contained in:
Sipke Schoorstra 2022-06-09 13:18:29 +02:00
parent 3cf878fcd9
commit 0cb72acdff
1 changed files with 4 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/designer/elsa-workflows-designer/src/components/activities/flowchart/activity-walker.ts
View file

@ -18,13 +18,10 @@ export interface ActivityPort {
}
export function walkActivities(root: Activity, descriptors: Array<ActivityDescriptor>): ActivityNode {
// Create a copy of the root to avoid transposing its outbound properties.
const rootCopy = {...root};
const collectedActivities = new Set<Activity>([rootCopy]);
const collectedActivities = new Set<Activity>([root]);
const graph: ActivityNode = {activity: root, parents: [], children: []};
const collectedNodes = new Set<ActivityNode>([graph]);
walkRecursive(graph, rootCopy, collectedActivities, collectedNodes, descriptors);
walkRecursive(graph, root, collectedActivities, collectedNodes, descriptors);
return graph;
}
@ -68,6 +65,7 @@ function getPorts(node: ActivityNode, activity: Activity, descriptors: Array<Act
const transposeHandler = transposeHandlerRegistry.get(activity.typeName);
const portProvider = portProviderRegistry.get(activity.typeName);
const activityDescriptor = descriptors.find(x => x.activityType == activity.typeName);
const untransposedConnections = transposeHandler.untranspose({activity, activityDescriptor});
const activityCopy: Activity = {...activity};
const untransposedConnections = transposeHandler.untranspose({activity: activityCopy, activityDescriptor});
return untransposedConnections.map(x => ({activity: x.target, port: x.sourcePort}));
}