2867 - replace all new usages of getTaskDispatcherTask with getTask

Author: kresimir-coko

client/src/pages/platform/cluster-element-editor/hooks/useClusterElementsLayout.ts

@@ -14,8 +14,8 @@ import useDataPillPanelStore from '../../workflow-editor/stores/useDataPillPanel
 import useWorkflowDataStore from '../../workflow-editor/stores/useWorkflowDataStore';
 import useWorkflowEditorStore from '../../workflow-editor/stores/useWorkflowEditorStore';
 import useWorkflowNodeDetailsPanelStore from '../../workflow-editor/stores/useWorkflowNodeDetailsPanelStore';
+import {getTask} from '../../workflow-editor/utils/getTask';
 import {getLayoutedElements} from '../../workflow-editor/utils/layoutUtils';
-import {getTaskDispatcherTask} from '../../workflow-editor/utils/taskDispatcherConfig';
 import useClusterElementsDataStore from '../stores/useClusterElementsDataStore';
 import {isPlainObject} from '../utils/clusterElementsUtils';
 import createClusterElementsEdges from '../utils/createClusterElementsEdges';
@@ -112,9 +112,9 @@ const useClusterElementsLayout = () => {
             return undefined;
         }
 
-        return getTaskDispatcherTask({
-            taskDispatcherId: rootClusterElementNodeData.workflowNodeName,
+        return getTask({
             tasks: workflowDefinitionTasks,
+            workflowNodeName: rootClusterElementNodeData.workflowNodeName,
         });
     }, [workflowDefinitionTasks, rootClusterElementNodeData?.workflowNodeName]);
 

client/src/pages/platform/workflow-editor/components/WorkflowNodeDetailsPanel.tsx

@@ -447,9 +447,9 @@ const WorkflowNodeDetailsPanel = ({
             return undefined;
         }
 
-        const mainClusterRootTask = getTaskDispatcherTask({
-            taskDispatcherId: rootClusterElementNodeData.workflowNodeName,
+        const mainClusterRootTask = getTask({
             tasks: workflow.tasks || [],
+            workflowNodeName: rootClusterElementNodeData.workflowNodeName,
         });
 
         if (!mainClusterRootTask) {
@@ -1147,9 +1147,9 @@ const WorkflowNodeDetailsPanel = ({
         const workflowDefinitionTasks = JSON.parse(workflow.definition).tasks;
 
         const mainClusterRootTask = rootClusterElementNodeData?.workflowNodeName
-            ? getTaskDispatcherTask({
-                  taskDispatcherId: rootClusterElementNodeData.workflowNodeName,
+            ? getTask({
                   tasks: workflowDefinitionTasks,
+                  workflowNodeName: rootClusterElementNodeData.workflowNodeName,
               })
             : undefined;
 

client/src/pages/platform/workflow-editor/components/WorkflowNodesPopoverMenuOperationList.tsx

@@ -29,12 +29,12 @@ import useWorkflowNodeDetailsPanelStore from '../stores/useWorkflowNodeDetailsPa
 import calculateNodeInsertIndex from '../utils/calculateNodeInsertIndex';
 import getFormattedName from '../utils/getFormattedName';
 import getParametersWithDefaultValues from '../utils/getParametersWithDefaultValues';
+import {getTask} from '../utils/getTask';
 import getTaskDispatcherContext from '../utils/getTaskDispatcherContext';
 import handleComponentAddedSuccess from '../utils/handleComponentAddedSuccess';
 import handleTaskDispatcherSubtaskOperationClick from '../utils/handleTaskDispatcherSubtaskOperationClick';
 import processClusterElementsHierarchy from '../utils/processClusterElementsHierarchy';
 import saveWorkflowDefinition from '../utils/saveWorkflowDefinition';
-import {getTaskDispatcherTask} from '../utils/taskDispatcherConfig';
 
 interface WorkflowNodesPopoverMenuOperationListProps {
     clusterElementType?: string;
@@ -196,9 +196,9 @@ const WorkflowNodesPopoverMenuOperationList = ({
 
             const workflowDefinitionTasks = JSON.parse(workflow.definition).tasks;
 
-            const mainClusterRootTask = getTaskDispatcherTask({
-                taskDispatcherId: rootClusterElementNodeData.workflowNodeName,
+            const mainClusterRootTask = getTask({
                 tasks: workflowDefinitionTasks,
+                workflowNodeName: rootClusterElementNodeData.workflowNodeName,
             });
 
             if (!mainClusterRootTask) {

client/src/pages/platform/workflow-editor/utils/handleDeleteTask.ts

@@ -10,7 +10,8 @@ import {WorkflowDataType} from '../stores/useWorkflowDataStore';
 import useWorkflowNodeDetailsPanelStore from '../stores/useWorkflowNodeDetailsPanelStore';
 import findAndRemoveClusterElement from './findAndRemoveClusterElement';
 import getRecursivelyUpdatedTasks from './getRecursivelyUpdatedTasks';
-import {TASK_DISPATCHER_CONFIG, getTaskDispatcherTask} from './taskDispatcherConfig';
+import {getTask} from './getTask';
+import {TASK_DISPATCHER_CONFIG} from './taskDispatcherConfig';
 
 interface HandleDeleteTaskProps {
     rootClusterElementNodeData?: NodeDataType;
@@ -194,9 +195,9 @@ export default function handleDeleteTask({
             return parentForkJoinTask;
         }) as Array<WorkflowTaskType>;
     } else if (clusterElementsCanvasOpen && rootClusterElementNodeData) {
-        const mainRootClusterElementTask = getTaskDispatcherTask({
-            taskDispatcherId: rootClusterElementNodeData.name,
+        const mainRootClusterElementTask = getTask({
             tasks: workflowTasks,
+            workflowNodeName: rootClusterElementNodeData.name,
         });
 
         if (!mainRootClusterElementTask || !mainRootClusterElementTask.clusterElements) {

client/src/pages/platform/workflow-editor/utils/saveClusterElementFieldChange.ts

@@ -7,8 +7,8 @@ import useWorkflowEditorStore from '../stores/useWorkflowEditorStore';
 import useWorkflowNodeDetailsPanelStore from '../stores/useWorkflowNodeDetailsPanelStore';
 import {updateClusterRootElementField, updateNestedClusterElementField} from './clusterElementsFieldChangeUtils';
 import getParametersWithDefaultValues from './getParametersWithDefaultValues';
+import {getTask} from './getTask';
 import saveWorkflowDefinition from './saveWorkflowDefinition';
-import {getTaskDispatcherTask} from './taskDispatcherConfig';
 
 type FieldUpdateType = {
     field: 'operation' | 'label' | 'description';
@@ -49,9 +49,9 @@ export default function saveClusterElementFieldChange({
 
     const workflowDefinitionTasks = JSON.parse(workflow.definition).tasks;
 
-    const mainClusterRootTask = getTaskDispatcherTask({
-        taskDispatcherId: rootClusterElementNodeData.workflowNodeName,
+    const mainClusterRootTask = getTask({
         tasks: workflowDefinitionTasks,
+        workflowNodeName: rootClusterElementNodeData.workflowNodeName,
     });
 
     if (!mainClusterRootTask) {

client/src/pages/platform/workflow-editor/utils/saveWorkflowDefinition.ts

@@ -4,8 +4,8 @@ import {UseMutationResult} from '@tanstack/react-query';
 
 import useWorkflowDataStore from '../stores/useWorkflowDataStore';
 import getRecursivelyUpdatedTasks from './getRecursivelyUpdatedTasks';
+import {getTask} from './getTask';
 import insertTaskDispatcherSubtask from './insertTaskDispatcherSubtask';
-import {getTaskDispatcherTask} from './taskDispatcherConfig';
 
 const SPACE = 4;
 
@@ -187,9 +187,9 @@ export default async function saveWorkflowDefinition({
                     ...updatedWorkflowDefinitionTasks.slice(existingTaskIndex + 1),
                 ];
             } else {
-                const nestedTask = getTaskDispatcherTask({
-                    taskDispatcherId: existingWorkflowTask.name,
+                const nestedTask = getTask({
                     tasks: workflowDefinitionTasks,
+                    workflowNodeName: existingWorkflowTask.name,
                 });
 
                 if (!nestedTask) {