mirror of
https://github.com/n8n-io/n8n.git
synced 2025-03-05 20:50:17 -08:00
fix(core): Make expression resolution improvements (#4829)
⚡ Make expression resolution improvements
This commit is contained in:
parent
1e4ca1f0d0
commit
0bd13c7173
|
@ -254,6 +254,7 @@ export class Expression {
|
||||||
// Execute the expression
|
// Execute the expression
|
||||||
const returnValue = this.renderExpression(parameterValue, data);
|
const returnValue = this.renderExpression(parameterValue, data);
|
||||||
if (typeof returnValue === 'function') {
|
if (typeof returnValue === 'function') {
|
||||||
|
if (returnValue.name === '$') throw new Error('invalid syntax');
|
||||||
throw new Error('Expression resolved to a function. Please add "()"');
|
throw new Error('Expression resolved to a function. Please add "()"');
|
||||||
} else if (typeof returnValue === 'string') {
|
} else if (typeof returnValue === 'string') {
|
||||||
return returnValue;
|
return returnValue;
|
||||||
|
@ -278,12 +279,8 @@ export class Expression {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (
|
if (error instanceof Error && error.name === 'SyntaxError') {
|
||||||
error instanceof Error &&
|
throw new Error('invalid syntax');
|
||||||
typeof error.message === 'string' &&
|
|
||||||
error.name === 'SyntaxError'
|
|
||||||
) {
|
|
||||||
throw new Error(error.message);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -126,6 +126,10 @@ export class WorkflowDataProxy {
|
||||||
const that = this;
|
const that = this;
|
||||||
const node = this.workflow.nodes[nodeName];
|
const node = this.workflow.nodes[nodeName];
|
||||||
|
|
||||||
|
if (!that.runExecutionData?.executionData && that.connectionInputData.length > 1) {
|
||||||
|
return {}; // incoming connection has pinned data, so stub context object
|
||||||
|
}
|
||||||
|
|
||||||
if (!that.runExecutionData?.executionData) {
|
if (!that.runExecutionData?.executionData) {
|
||||||
throw new ExpressionError(
|
throw new ExpressionError(
|
||||||
`The workflow hasn't been executed yet, so you can't reference any context data`,
|
`The workflow hasn't been executed yet, so you can't reference any context data`,
|
||||||
|
@ -332,7 +336,7 @@ export class WorkflowDataProxy {
|
||||||
);
|
);
|
||||||
|
|
||||||
if (nodeConnection === undefined) {
|
if (nodeConnection === undefined) {
|
||||||
throw new ExpressionError(`connect ${that.activeNodeName} to ${nodeName}`, {
|
throw new ExpressionError(`connect "${that.activeNodeName}" to "${nodeName}"`, {
|
||||||
runIndex: that.runIndex,
|
runIndex: that.runIndex,
|
||||||
itemIndex: that.itemIndex,
|
itemIndex: that.itemIndex,
|
||||||
});
|
});
|
||||||
|
@ -569,7 +573,39 @@ export class WorkflowDataProxy {
|
||||||
{},
|
{},
|
||||||
{
|
{
|
||||||
get(target, name, receiver) {
|
get(target, name, receiver) {
|
||||||
return that.nodeDataGetter(name.toString());
|
const nodeName = name.toString();
|
||||||
|
|
||||||
|
if (that.workflow.getNode(nodeName) === null) {
|
||||||
|
throw new ExpressionError(`"${nodeName}" node doesn't exist`, {
|
||||||
|
runIndex: that.runIndex,
|
||||||
|
itemIndex: that.itemIndex,
|
||||||
|
failExecution: true,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (
|
||||||
|
nodeName !== that.activeNodeName &&
|
||||||
|
!that.runExecutionData?.resultData.runData?.hasOwnProperty(nodeName)
|
||||||
|
) {
|
||||||
|
throw new ExpressionError(`no data, execute "${nodeName}" node first`, {
|
||||||
|
runIndex: that.runIndex,
|
||||||
|
itemIndex: that.itemIndex,
|
||||||
|
failExecution: true,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (
|
||||||
|
nodeName !== that.activeNodeName &&
|
||||||
|
!that.workflow.getNodeConnectionIndexes(that.activeNodeName, nodeName, 'main')
|
||||||
|
) {
|
||||||
|
throw new ExpressionError(`connect "${that.activeNodeName}" to "${nodeName}"`, {
|
||||||
|
runIndex: that.runIndex,
|
||||||
|
itemIndex: that.itemIndex,
|
||||||
|
failExecution: true,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
return that.nodeDataGetter(nodeName);
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
|
|
|
@ -1057,6 +1057,11 @@ describe('Workflow', () => {
|
||||||
description:
|
description:
|
||||||
'return resolved value when referencing another property with expression when a node has spaces (long "$node["{NODE}"].parameter" syntax)',
|
'return resolved value when referencing another property with expression when a node has spaces (long "$node["{NODE}"].parameter" syntax)',
|
||||||
input: {
|
input: {
|
||||||
|
'Node 4 with spaces': {
|
||||||
|
parameters: {
|
||||||
|
value1: '',
|
||||||
|
},
|
||||||
|
},
|
||||||
Node1: {
|
Node1: {
|
||||||
parameters: {
|
parameters: {
|
||||||
value1: 'valueNode1',
|
value1: 'valueNode1',
|
||||||
|
@ -1190,6 +1195,17 @@ describe('Workflow', () => {
|
||||||
],
|
],
|
||||||
],
|
],
|
||||||
},
|
},
|
||||||
|
'Node 4 with spaces': {
|
||||||
|
main: [
|
||||||
|
[
|
||||||
|
{
|
||||||
|
node: 'Node2',
|
||||||
|
type: 'main',
|
||||||
|
index: 0,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
],
|
||||||
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
const workflow = new Workflow({ nodes, connections, active: false, nodeTypes });
|
const workflow = new Workflow({ nodes, connections, active: false, nodeTypes });
|
||||||
|
@ -1219,6 +1235,8 @@ describe('Workflow', () => {
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
],
|
],
|
||||||
|
Node2: [],
|
||||||
|
'Node 4 with spaces': [],
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
Loading…
Reference in a new issue