Skip to content

Commit

Permalink
fix(editor): improve expression and parameters performance (#3874)
Browse files Browse the repository at this point in the history
* fix expr perf issue

* refactor a bit
  • Loading branch information
mutdmour committed Aug 12, 2022
1 parent 762b422 commit 3608d13
Show file tree
Hide file tree
Showing 10 changed files with 36 additions and 23 deletions.
2 changes: 1 addition & 1 deletion packages/editor-ui/src/components/CodeEdit.vue
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ export default mixins(
let runIndex = 0;
const executedWorkflow: IExecutionResponse | null = this.$store.getters.getWorkflowExecution;
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();
const activeNode: INodeUi | null = this.$store.getters.activeNode;
const parentNode = workflow.getParentNodes(activeNode!.name, inputName, 1);
const nodeConnection = workflow.getNodeConnectionIndexes(activeNode!.name, parentNode[0]) || {
Expand Down
2 changes: 1 addition & 1 deletion packages/editor-ui/src/components/ExpressionInput.vue
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ export default mixins(
};
},
workflow (): Workflow {
return this.getWorkflow();
return this.getCurrentWorkflow();
},
},
watch: {
Expand Down
2 changes: 1 addition & 1 deletion packages/editor-ui/src/components/Node.vue
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,7 @@ export default mixins(
}
},
setSubtitle() {
const nodeSubtitle = this.getNodeSubtitle(this.data, this.nodeType, this.getWorkflow()) || '';
const nodeSubtitle = this.getNodeSubtitle(this.data, this.nodeType, this.getCurrentWorkflow()) || '';
this.nodeSubtitle = nodeSubtitle.includes(CUSTOM_API_CALL_KEY)
? ''
Expand Down
4 changes: 2 additions & 2 deletions packages/editor-ui/src/components/NodeDetailsView.vue
Original file line number Diff line number Diff line change
Expand Up @@ -224,7 +224,7 @@ export default mixins(
);
},
workflow(): Workflow {
return this.getWorkflow();
return this.getCurrentWorkflow();
},
parentNodes(): string[] {
if (this.activeNode) {
Expand Down Expand Up @@ -344,7 +344,7 @@ export default mixins(
this.$store.commit('ui/setNDVSessionId');
this.$externalHooks().run('dataDisplay.nodeTypeChanged', {
nodeSubtitle: this.getNodeSubtitle(node, this.activeNodeType, this.getWorkflow()),
nodeSubtitle: this.getNodeSubtitle(node, this.activeNodeType, this.getCurrentWorkflow()),
});
setTimeout(() => {
Expand Down
2 changes: 1 addition & 1 deletion packages/editor-ui/src/components/ParameterInput.vue
Original file line number Diff line number Diff line change
Expand Up @@ -685,7 +685,7 @@ export default mixins(
return shortPath.join('.');
},
workflow (): Workflow {
return this.getWorkflow();
return this.getCurrentWorkflow();
},
},
methods: {
Expand Down
2 changes: 1 addition & 1 deletion packages/editor-ui/src/components/VariableSelector.vue
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ export default mixins(
return this.getFilterResults(this.variableFilter.toLowerCase(), 0);
},
workflow (): Workflow {
return this.getWorkflow();
return this.getCurrentWorkflow();
},
},
methods: {
Expand Down
3 changes: 1 addition & 2 deletions packages/editor-ui/src/components/mixins/pushConnection.ts
Original file line number Diff line number Diff line change
Expand Up @@ -221,8 +221,7 @@ export const pushConnection = mixins(

const runDataExecutedErrorMessage = this.$getExecutionError(runDataExecuted.data.resultData.error);

// @ts-ignore
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();
if (runDataExecuted.waitTill !== undefined) {
const {
activeExecutionId,
Expand Down
28 changes: 21 additions & 7 deletions packages/editor-ui/src/components/mixins/workflowHelpers.ts
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,9 @@ import { isEqual } from 'lodash';
import mixins from 'vue-typed-mixins';
import { v4 as uuid } from 'uuid';

let cachedWorkflowKey: string | null = '';
let cachedWorkflow: Workflow | null = null;

export const workflowHelpers = mixins(
externalHooks,
nodeHelpers,
Expand Down Expand Up @@ -317,11 +320,20 @@ export const workflowHelpers = mixins(
return nodeTypes;
},

// Returns a workflow instance.
getWorkflow (nodes?: INodeUi[], connections?: IConnections, copyData?: boolean): Workflow {
nodes = nodes || this.getNodes();
connections = connections || (this.$store.getters.allConnections as IConnections);
getCurrentWorkflow(copyData?: boolean): Workflow {
const nodes = this.getNodes();
const connections = (this.$store.getters.allConnections as IConnections);
const cacheKey = JSON.stringify({nodes, connections});
if (cachedWorkflow && cacheKey === cachedWorkflowKey) {
return cachedWorkflow;
}
cachedWorkflowKey = cacheKey;

return this.getWorkflow(nodes, connections, copyData);
},

// Returns a workflow instance.
getWorkflow (nodes: INodeUi[], connections: IConnections, copyData?: boolean): Workflow {
const nodeTypes = this.getNodeTypes();
let workflowId = this.$store.getters.workflowId;
if (workflowId === PLACEHOLDER_EMPTY_WORKFLOW_ID) {
Expand All @@ -330,7 +342,7 @@ export const workflowHelpers = mixins(

const workflowName = this.$store.getters.workflowName;

return new Workflow({
cachedWorkflow = new Workflow({
id: workflowId,
name: workflowName,
nodes: copyData ? JSON.parse(JSON.stringify(nodes)) : nodes,
Expand All @@ -340,6 +352,8 @@ export const workflowHelpers = mixins(
settings: this.$store.getters.workflowSettings,
pinData: this.$store.getters.pinData,
});

return cachedWorkflow;
},

// Returns the currently loaded workflow as JSON.
Expand Down Expand Up @@ -503,7 +517,7 @@ export const workflowHelpers = mixins(
const itemIndex = 0;
const inputName = 'main';
const activeNode = this.$store.getters.activeNode;
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();
const parentNode = workflow.getParentNodes(activeNode.name, inputName, 1);
const executionData = this.$store.getters.getWorkflowExecution as IExecutionResponse | null;

Expand Down Expand Up @@ -584,7 +598,7 @@ export const workflowHelpers = mixins(
const returnData = this.resolveParameter(parameters) as IDataObject;

if (typeof returnData['__xxxxxxx__'] === 'object') {
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();
return workflow.expression.convertObjectValueToString(returnData['__xxxxxxx__'] as object);
}
return returnData['__xxxxxxx__'];
Expand Down
2 changes: 1 addition & 1 deletion packages/editor-ui/src/components/mixins/workflowRun.ts
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ export const workflowRun = mixins(
return response;
},
async runWorkflow (nodeName?: string, source?: string): Promise<IExecutionPushResponse | undefined> {
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();

if (this.$store.getters.isActionActive('workflowRunning') === true) {
return;
Expand Down
12 changes: 6 additions & 6 deletions packages/editor-ui/src/views/NodeView.vue
Original file line number Diff line number Diff line change
Expand Up @@ -927,7 +927,7 @@ export default mixins(
return;
}

const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();

if (!workflow.connectionsByDestinationNode.hasOwnProperty(lastSelectedNode.name)) {
return;
Expand All @@ -949,7 +949,7 @@ export default mixins(
return;
}

const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();

if (!workflow.connectionsByDestinationNode.hasOwnProperty(lastSelectedNode.name)) {
return;
Expand Down Expand Up @@ -1036,7 +1036,7 @@ export default mixins(
this.deselectAllNodes();

// Get all upstream nodes and select them
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();
for (const nodeName of workflow.getParentNodes(lastSelectedNode.name)) {
this.nodeSelectedByName(nodeName);
}
Expand All @@ -1053,7 +1053,7 @@ export default mixins(
this.deselectAllNodes();

// Get all downstream nodes and select them
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();
for (const nodeName of workflow.getChildNodes(lastSelectedNode.name)) {
this.nodeSelectedByName(nodeName);
}
Expand All @@ -1064,7 +1064,7 @@ export default mixins(

pushDownstreamNodes (sourceNodeName: string, margin: number) {
const sourceNode = this.$store.getters.nodesByName[sourceNodeName];
const workflow = this.getWorkflow();
const workflow = this.getCurrentWorkflow();
const childNodes = workflow.getChildNodes(sourceNodeName);
for (const nodeName of childNodes) {
const node = this.$store.getters.nodesByName[nodeName] as INodeUi;
Expand Down Expand Up @@ -2586,7 +2586,7 @@ export default mixins(
});

// Rename the node and update the connections
const workflow = this.getWorkflow(undefined, undefined, true);
const workflow = this.getCurrentWorkflow(true);
workflow.renameNode(currentName, newName);

// Update also last selected node and exeuction data
Expand Down

0 comments on commit 3608d13

Please sign in to comment.