n8n-workflow
Advanced tools
Comparing version 0.20.0 to 0.21.0
@@ -389,3 +389,3 @@ import { Workflow } from './Workflow'; | ||
webhookDescription: IWebhookDescription; | ||
workflow: Workflow; | ||
workflowId: string; | ||
workflowExecuteAdditionalData: IWorkflowExecuteAdditionalData; | ||
@@ -392,0 +392,0 @@ } |
@@ -237,6 +237,6 @@ "use strict"; | ||
if (propertyName.charAt(0) === '/') { | ||
value = nodeValuesRoot[propertyName.slice(1)]; | ||
value = lodash_1.get(nodeValuesRoot, propertyName.slice(1)); | ||
} | ||
else { | ||
value = nodeValues[propertyName]; | ||
value = lodash_1.get(nodeValues, propertyName); | ||
} | ||
@@ -251,6 +251,6 @@ if (value === undefined || !parameter.displayOptions.show[propertyName].includes(value)) { | ||
if (propertyName.charAt(0) === '/') { | ||
value = nodeValuesRoot[propertyName.slice(1)]; | ||
value = lodash_1.get(nodeValuesRoot, propertyName.slice(1)); | ||
} | ||
else { | ||
value = nodeValues[propertyName]; | ||
value = lodash_1.get(nodeValues, propertyName); | ||
} | ||
@@ -355,3 +355,3 @@ if (value !== undefined && parameter.displayOptions.hide[propertyName].includes(value)) { | ||
if (itterations > lastIndexReduction + nodePropertiesArray.length) { | ||
throw new Error('Could not resolve parameter depenencies!'); | ||
throw new Error('Could not resolve parameter depenencies. Max itterations got reached!'); | ||
} | ||
@@ -553,3 +553,3 @@ lastIndexLength = indexToResolve.length; | ||
webhookDescription, | ||
workflow, | ||
workflowId: workflow.id, | ||
workflowExecuteAdditionalData: additionalData, | ||
@@ -556,0 +556,0 @@ }); |
@@ -33,3 +33,2 @@ import { IConnections, IGetExecuteTriggerFunctions, INode, INodes, INodeExecuteFunctions, INodeExecutionData, INodeParameters, INodeType, INodeTypes, IPollFunctions, IRunExecutionData, ITaskDataConnections, ITriggerResponse, IWebhookData, IWebhookResponseData, IWorfklowIssues, IWorkflowExecuteAdditionalData, IWorkflowSettings, NodeParameterValue, WebhookSetupMethodNames, WorkflowExecuteMode } from './'; | ||
resolveSimpleParameterValue(parameterValue: NodeParameterValue, runExecutionData: IRunExecutionData | null, runIndex: number, itemIndex: number, activeNodeName: string, connectionInputData: INodeExecutionData[], returnObjectAsString?: boolean): NodeParameterValue | INodeParameters | NodeParameterValue[] | INodeParameters[]; | ||
runNodeHooks(hookName: string, webhookData: IWebhookData, nodeExecuteFunctions: INodeExecuteFunctions, mode: WorkflowExecuteMode): Promise<void>; | ||
runWebhookMethod(method: WebhookSetupMethodNames, webhookData: IWebhookData, nodeExecuteFunctions: INodeExecuteFunctions, mode: WorkflowExecuteMode, isTest?: boolean): Promise<boolean | undefined>; | ||
@@ -36,0 +35,0 @@ runTrigger(node: INode, getTriggerFunctions: IGetExecuteTriggerFunctions, additionalData: IWorkflowExecuteAdditionalData, mode: WorkflowExecuteMode): Promise<ITriggerResponse | undefined>; |
@@ -446,19 +446,2 @@ "use strict"; | ||
} | ||
async runNodeHooks(hookName, webhookData, nodeExecuteFunctions, mode) { | ||
const node = this.getNode(webhookData.node); | ||
const nodeType = this.nodeTypes.getByName(node.type); | ||
if (nodeType.description.hooks === undefined) { | ||
return; | ||
} | ||
if (nodeType.description.hooks[hookName] === undefined) { | ||
return; | ||
} | ||
if (nodeType.hooks === undefined && nodeType.description.hooks[hookName].length !== 0) { | ||
throw new Error('There are hooks defined to run but are not implemented.'); | ||
} | ||
for (const hookDescription of nodeType.description.hooks[hookName]) { | ||
const thisArgs = nodeExecuteFunctions.getExecuteHookFunctions(this, node, webhookData.workflowExecuteAdditionalData, mode); | ||
await nodeType.hooks[hookDescription.method].call(thisArgs); | ||
} | ||
} | ||
async runWebhookMethod(method, webhookData, nodeExecuteFunctions, mode, isTest) { | ||
@@ -465,0 +448,0 @@ const node = this.getNode(webhookData.node); |
{ | ||
"name": "n8n-workflow", | ||
"version": "0.20.0", | ||
"version": "0.21.0", | ||
"description": "Workflow base code of n8n", | ||
@@ -5,0 +5,0 @@ "license": "SEE LICENSE IN LICENSE.md", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
398590
6354