diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts index 899fe57a74..887017ccaf 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts @@ -114,7 +114,7 @@ export async function conversationalAgentExecute( } catch (error) { throwIfToolSchema(this, error); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: itemIndex } }); continue; } diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts index 072039259f..12e1dbda4e 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts @@ -116,7 +116,7 @@ export async function openAiFunctionsAgentExecute( returnData.push({ json: response }); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: itemIndex } }); continue; } diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts index 4c77a6a0aa..a4ae1a0f1c 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts @@ -93,7 +93,7 @@ export async function planAndExecuteAgentExecute( returnData.push({ json: response }); } catch (error) { throwIfToolSchema(this, error); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: itemIndex } }); continue; } diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts index 1fdaafc290..11a5acb040 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts @@ -114,7 +114,7 @@ export async function reActAgentAgentExecute( returnData.push({ json: response }); } catch (error) { throwIfToolSchema(this, error); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: itemIndex } }); continue; } diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts index bd8868ad32..4b31491120 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts @@ -142,7 +142,7 @@ export async function sqlAgentAgentExecute( returnData.push({ json: response }); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i } }); continue; } diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts index fc760cb928..295b0a5d1d 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts @@ -225,7 +225,7 @@ export async function toolsAgentExecute(this: IExecuteFunctions): Promise executeData, - continueOnFail: (error?: Error) => { - const shouldContinue = continueOnFail(node); - if (error && shouldContinue && !(error instanceof ApplicationError)) { - error.message = OBFUSCATED_ERROR_MESSAGE; - } - return shouldContinue; + continueOnFail: () => { + return continueOnFail(node); }, evaluateExpression: (expression: string, itemIndex: number) => { return workflow.expression.resolveSimpleParameterValue( diff --git a/packages/core/src/WorkflowExecute.ts b/packages/core/src/WorkflowExecute.ts index 3e563e04b8..a7c282e434 100644 --- a/packages/core/src/WorkflowExecute.ts +++ b/packages/core/src/WorkflowExecute.ts @@ -1333,8 +1333,6 @@ export class WorkflowExecute { } else { // Report any unhandled and non-wrapped errors to Sentry toReport = error; - // Set obfuscate to true so that the error would be obfuscated in th UI - error.obfuscate = true; } if (toReport) { ErrorReporterProxy.error(toReport, { diff --git a/packages/editor-ui/src/components/Error/NodeErrorView.vue b/packages/editor-ui/src/components/Error/NodeErrorView.vue index 7ca1b7d2d9..d1bcb87bee 100644 --- a/packages/editor-ui/src/components/Error/NodeErrorView.vue +++ b/packages/editor-ui/src/components/Error/NodeErrorView.vue @@ -226,10 +226,6 @@ function addItemIndexSuffix(message: string): string { } function getErrorMessage(): string { - if ('obfuscate' in props.error && props.error.obfuscate === true) { - return i18n.baseText('nodeErrorView.showMessage.obfuscate'); - } - let message = ''; const isSubNodeError = diff --git a/packages/editor-ui/src/plugins/i18n/locales/en.json b/packages/editor-ui/src/plugins/i18n/locales/en.json index 89d317d64e..3fd9714b8e 100644 --- a/packages/editor-ui/src/plugins/i18n/locales/en.json +++ b/packages/editor-ui/src/plugins/i18n/locales/en.json @@ -1135,7 +1135,6 @@ "nodeErrorView.itemIndex": "Item Index", "nodeErrorView.runIndex": "Run Index", "nodeErrorView.showMessage.title": "Copied to clipboard", - "nodeErrorView.showMessage.obfuscate": "Internal error", "nodeErrorView.stack": "Stack", "nodeErrorView.theErrorCauseIsTooLargeToBeDisplayed": "The error cause is too large to be displayed", "nodeErrorView.time": "Time", diff --git a/packages/nodes-base/nodes/ActionNetwork/ActionNetwork.node.ts b/packages/nodes-base/nodes/ActionNetwork/ActionNetwork.node.ts index 20a9cbce0e..068cf0b902 100644 --- a/packages/nodes-base/nodes/ActionNetwork/ActionNetwork.node.ts +++ b/packages/nodes-base/nodes/ActionNetwork/ActionNetwork.node.ts @@ -487,7 +487,7 @@ export class ActionNetwork implements INodeType { ? returnData.push(...(response as IDataObject[])) : returnData.push(response as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/ActiveCampaign/ActiveCampaign.node.ts b/packages/nodes-base/nodes/ActiveCampaign/ActiveCampaign.node.ts index 33ebbd9261..ca7ea31c3d 100644 --- a/packages/nodes-base/nodes/ActiveCampaign/ActiveCampaign.node.ts +++ b/packages/nodes-base/nodes/ActiveCampaign/ActiveCampaign.node.ts @@ -1189,7 +1189,7 @@ export class ActiveCampaign implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Affinity/Affinity.node.ts b/packages/nodes-base/nodes/Affinity/Affinity.node.ts index d526f4f5b2..d70d908704 100644 --- a/packages/nodes-base/nodes/Affinity/Affinity.node.ts +++ b/packages/nodes-base/nodes/Affinity/Affinity.node.ts @@ -420,7 +420,7 @@ export class Affinity implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/AiTransform/AiTransform.node.ts b/packages/nodes-base/nodes/AiTransform/AiTransform.node.ts index 9d21d82888..573c34ad62 100644 --- a/packages/nodes-base/nodes/AiTransform/AiTransform.node.ts +++ b/packages/nodes-base/nodes/AiTransform/AiTransform.node.ts @@ -133,7 +133,7 @@ export class AiTransform implements INodeType { try { items = (await sandbox.runCodeAllItems()) as INodeExecutionData[]; } catch (error) { - if (!this.continueOnFail(error)) { + if (!this.continueOnFail()) { set(error, 'node', node); throw error; } diff --git a/packages/nodes-base/nodes/Airtable/v1/AirtableV1.node.ts b/packages/nodes-base/nodes/Airtable/v1/AirtableV1.node.ts index b143394e92..84ddd66e06 100644 --- a/packages/nodes-base/nodes/Airtable/v1/AirtableV1.node.ts +++ b/packages/nodes-base/nodes/Airtable/v1/AirtableV1.node.ts @@ -653,7 +653,7 @@ export class AirtableV1 implements INodeType { rows.length = 0; } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } @@ -696,7 +696,7 @@ export class AirtableV1 implements INodeType { rows.length = 0; } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } @@ -757,7 +757,7 @@ export class AirtableV1 implements INodeType { }), ]; } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); } else { throw error; @@ -792,7 +792,7 @@ export class AirtableV1 implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } @@ -880,7 +880,7 @@ export class AirtableV1 implements INodeType { rows.length = 0; } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Airtable/v2/actions/base/getSchema.operation.ts b/packages/nodes-base/nodes/Airtable/v2/actions/base/getSchema.operation.ts index fae52ba66e..aa791f7b64 100644 --- a/packages/nodes-base/nodes/Airtable/v2/actions/base/getSchema.operation.ts +++ b/packages/nodes-base/nodes/Airtable/v2/actions/base/getSchema.operation.ts @@ -48,7 +48,7 @@ export async function execute( returnData.push(...executionData); } catch (error) { error = processAirtableError(error as NodeApiError, undefined, i); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Airtable/v2/actions/record/create.operation.ts b/packages/nodes-base/nodes/Airtable/v2/actions/record/create.operation.ts index 3686e33bff..758c3b7a2f 100644 --- a/packages/nodes-base/nodes/Airtable/v2/actions/record/create.operation.ts +++ b/packages/nodes-base/nodes/Airtable/v2/actions/record/create.operation.ts @@ -87,7 +87,7 @@ export async function execute( returnData.push(...executionData); } catch (error) { error = processAirtableError(error as NodeApiError, undefined, i); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { message: error.message, error } }); continue; } diff --git a/packages/nodes-base/nodes/Airtable/v2/actions/record/deleteRecord.operation.ts b/packages/nodes-base/nodes/Airtable/v2/actions/record/deleteRecord.operation.ts index 100590fc5a..cbbf12ba3c 100644 --- a/packages/nodes-base/nodes/Airtable/v2/actions/record/deleteRecord.operation.ts +++ b/packages/nodes-base/nodes/Airtable/v2/actions/record/deleteRecord.operation.ts @@ -55,7 +55,7 @@ export async function execute( returnData.push(...executionData); } catch (error) { error = processAirtableError(error as NodeApiError, id, i); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Airtable/v2/actions/record/get.operation.ts b/packages/nodes-base/nodes/Airtable/v2/actions/record/get.operation.ts index 4dcfaeda4e..73a9933076 100644 --- a/packages/nodes-base/nodes/Airtable/v2/actions/record/get.operation.ts +++ b/packages/nodes-base/nodes/Airtable/v2/actions/record/get.operation.ts @@ -91,7 +91,7 @@ export async function execute( returnData.push(...executionData); } catch (error) { error = processAirtableError(error as NodeApiError, id, i); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Airtable/v2/actions/record/search.operation.ts b/packages/nodes-base/nodes/Airtable/v2/actions/record/search.operation.ts index beb11dc921..4d3fc8e9df 100644 --- a/packages/nodes-base/nodes/Airtable/v2/actions/record/search.operation.ts +++ b/packages/nodes-base/nodes/Airtable/v2/actions/record/search.operation.ts @@ -227,7 +227,7 @@ export async function execute( returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { message: error.message, error }, pairedItem: { item: i } }); continue; } else { diff --git a/packages/nodes-base/nodes/Airtable/v2/actions/record/update.operation.ts b/packages/nodes-base/nodes/Airtable/v2/actions/record/update.operation.ts index cc9d785cfc..d2c4172dd5 100644 --- a/packages/nodes-base/nodes/Airtable/v2/actions/record/update.operation.ts +++ b/packages/nodes-base/nodes/Airtable/v2/actions/record/update.operation.ts @@ -138,7 +138,7 @@ export async function execute( returnData.push(...executionData); } catch (error) { error = processAirtableError(error as NodeApiError, recordId, i); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { message: error.message, error } }); continue; } diff --git a/packages/nodes-base/nodes/Airtable/v2/actions/record/upsert.operation.ts b/packages/nodes-base/nodes/Airtable/v2/actions/record/upsert.operation.ts index 27f9314cbc..e6266480ce 100644 --- a/packages/nodes-base/nodes/Airtable/v2/actions/record/upsert.operation.ts +++ b/packages/nodes-base/nodes/Airtable/v2/actions/record/upsert.operation.ts @@ -148,7 +148,7 @@ export async function execute( returnData.push(...executionData); } catch (error) { error = processAirtableError(error as NodeApiError, undefined, i); - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { message: error.message, error } }); continue; } diff --git a/packages/nodes-base/nodes/Amqp/Amqp.node.ts b/packages/nodes-base/nodes/Amqp/Amqp.node.ts index 47f1833a38..ce711d9695 100644 --- a/packages/nodes-base/nodes/Amqp/Amqp.node.ts +++ b/packages/nodes-base/nodes/Amqp/Amqp.node.ts @@ -261,7 +261,7 @@ export class Amqp implements INodeType { return [responseData]; } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { return [[{ json: { error: error.message }, pairedItems: { item: 0 } }]]; } else { throw error; diff --git a/packages/nodes-base/nodes/ApiTemplateIo/ApiTemplateIo.node.ts b/packages/nodes-base/nodes/ApiTemplateIo/ApiTemplateIo.node.ts index 0ffbc8d7c1..28f1a52c6a 100644 --- a/packages/nodes-base/nodes/ApiTemplateIo/ApiTemplateIo.node.ts +++ b/packages/nodes-base/nodes/ApiTemplateIo/ApiTemplateIo.node.ts @@ -385,7 +385,7 @@ export class ApiTemplateIo implements INodeType { returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } @@ -471,7 +471,7 @@ export class ApiTemplateIo implements INodeType { } returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } @@ -561,7 +561,7 @@ export class ApiTemplateIo implements INodeType { } returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Asana/Asana.node.ts b/packages/nodes-base/nodes/Asana/Asana.node.ts index dc980a96e0..550c386273 100644 --- a/packages/nodes-base/nodes/Asana/Asana.node.ts +++ b/packages/nodes-base/nodes/Asana/Asana.node.ts @@ -2467,7 +2467,7 @@ export class Asana implements INodeType { ), ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Autopilot/Autopilot.node.ts b/packages/nodes-base/nodes/Autopilot/Autopilot.node.ts index 876dfdbc34..069e2dd03f 100644 --- a/packages/nodes-base/nodes/Autopilot/Autopilot.node.ts +++ b/packages/nodes-base/nodes/Autopilot/Autopilot.node.ts @@ -306,7 +306,7 @@ export class Autopilot implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const exectionErrorWithMetaData = this.helpers.constructExecutionMetaData( [{ json: { error: error.message } }], { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Aws/AwsLambda.node.ts b/packages/nodes-base/nodes/Aws/AwsLambda.node.ts index ddd95c4a22..1dc35d651b 100644 --- a/packages/nodes-base/nodes/Aws/AwsLambda.node.ts +++ b/packages/nodes-base/nodes/Aws/AwsLambda.node.ts @@ -204,7 +204,7 @@ export class AwsLambda implements INodeType { returnData.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: (error as JsonObject).message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Aws/AwsSns.node.ts b/packages/nodes-base/nodes/Aws/AwsSns.node.ts index fe898d4276..858f93774a 100644 --- a/packages/nodes-base/nodes/Aws/AwsSns.node.ts +++ b/packages/nodes-base/nodes/Aws/AwsSns.node.ts @@ -318,7 +318,7 @@ export class AwsSns implements INodeType { } as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Aws/CertificateManager/AwsCertificateManager.node.ts b/packages/nodes-base/nodes/Aws/CertificateManager/AwsCertificateManager.node.ts index 5cdb0cfa76..25abdb7669 100644 --- a/packages/nodes-base/nodes/Aws/CertificateManager/AwsCertificateManager.node.ts +++ b/packages/nodes-base/nodes/Aws/CertificateManager/AwsCertificateManager.node.ts @@ -223,7 +223,7 @@ export class AwsCertificateManager implements INodeType { returnData.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Aws/Comprehend/AwsComprehend.node.ts b/packages/nodes-base/nodes/Aws/Comprehend/AwsComprehend.node.ts index 3d995fd01f..8a416bcd50 100644 --- a/packages/nodes-base/nodes/Aws/Comprehend/AwsComprehend.node.ts +++ b/packages/nodes-base/nodes/Aws/Comprehend/AwsComprehend.node.ts @@ -277,7 +277,7 @@ export class AwsComprehend implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Aws/DynamoDB/AwsDynamoDB.node.ts b/packages/nodes-base/nodes/Aws/DynamoDB/AwsDynamoDB.node.ts index efc7130007..cecc3aca46 100644 --- a/packages/nodes-base/nodes/Aws/DynamoDB/AwsDynamoDB.node.ts +++ b/packages/nodes-base/nodes/Aws/DynamoDB/AwsDynamoDB.node.ts @@ -399,7 +399,7 @@ export class AwsDynamoDB implements INodeType { returnData.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Aws/ELB/AwsElb.node.ts b/packages/nodes-base/nodes/Aws/ELB/AwsElb.node.ts index 470b5b3546..fbc781fb6f 100644 --- a/packages/nodes-base/nodes/Aws/ELB/AwsElb.node.ts +++ b/packages/nodes-base/nodes/Aws/ELB/AwsElb.node.ts @@ -451,7 +451,7 @@ export class AwsElb implements INodeType { ), ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: (error as JsonObject).toString() }); continue; } diff --git a/packages/nodes-base/nodes/Aws/Rekognition/AwsRekognition.node.ts b/packages/nodes-base/nodes/Aws/Rekognition/AwsRekognition.node.ts index 0f9be63d17..a1e24ea4b9 100644 --- a/packages/nodes-base/nodes/Aws/Rekognition/AwsRekognition.node.ts +++ b/packages/nodes-base/nodes/Aws/Rekognition/AwsRekognition.node.ts @@ -455,7 +455,7 @@ export class AwsRekognition implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Aws/S3/V1/AwsS3V1.node.ts b/packages/nodes-base/nodes/Aws/S3/V1/AwsS3V1.node.ts index 82de951fef..8456f4a8cf 100644 --- a/packages/nodes-base/nodes/Aws/S3/V1/AwsS3V1.node.ts +++ b/packages/nodes-base/nodes/Aws/S3/V1/AwsS3V1.node.ts @@ -893,7 +893,7 @@ export class AwsS3V1 implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Aws/S3/V2/AwsS3V2.node.ts b/packages/nodes-base/nodes/Aws/S3/V2/AwsS3V2.node.ts index 7892374659..fe97fa0761 100644 --- a/packages/nodes-base/nodes/Aws/S3/V2/AwsS3V2.node.ts +++ b/packages/nodes-base/nodes/Aws/S3/V2/AwsS3V2.node.ts @@ -1057,7 +1057,7 @@ export class AwsS3V2 implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Aws/SES/AwsSes.node.ts b/packages/nodes-base/nodes/Aws/SES/AwsSes.node.ts index 5cf0bd4dc8..4589f8a212 100644 --- a/packages/nodes-base/nodes/Aws/SES/AwsSes.node.ts +++ b/packages/nodes-base/nodes/Aws/SES/AwsSes.node.ts @@ -1285,7 +1285,7 @@ export class AwsSes implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Aws/SQS/AwsSqs.node.ts b/packages/nodes-base/nodes/Aws/SQS/AwsSqs.node.ts index 5b4654a08b..474a928bb2 100644 --- a/packages/nodes-base/nodes/Aws/SQS/AwsSqs.node.ts +++ b/packages/nodes-base/nodes/Aws/SQS/AwsSqs.node.ts @@ -378,7 +378,7 @@ export class AwsSqs implements INodeType { const result = responseData.SendMessageResponse.SendMessageResult; returnData.push(result as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.description }); continue; } diff --git a/packages/nodes-base/nodes/Aws/Textract/AwsTextract.node.ts b/packages/nodes-base/nodes/Aws/Textract/AwsTextract.node.ts index a5173d0d14..6d032b3d89 100644 --- a/packages/nodes-base/nodes/Aws/Textract/AwsTextract.node.ts +++ b/packages/nodes-base/nodes/Aws/Textract/AwsTextract.node.ts @@ -144,7 +144,7 @@ export class AwsTextract implements INodeType { returnData.push(responseData as unknown as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Aws/Transcribe/AwsTranscribe.node.ts b/packages/nodes-base/nodes/Aws/Transcribe/AwsTranscribe.node.ts index d44f1ca0c7..013279db5d 100644 --- a/packages/nodes-base/nodes/Aws/Transcribe/AwsTranscribe.node.ts +++ b/packages/nodes-base/nodes/Aws/Transcribe/AwsTranscribe.node.ts @@ -540,7 +540,7 @@ export class AwsTranscribe implements INodeType { returnData.push(responseData as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/BambooHr/v1/actions/router.ts b/packages/nodes-base/nodes/BambooHr/v1/actions/router.ts index 4d3f434a2a..9e8cb85a9e 100644 --- a/packages/nodes-base/nodes/BambooHr/v1/actions/router.ts +++ b/packages/nodes-base/nodes/BambooHr/v1/actions/router.ts @@ -39,7 +39,7 @@ export async function router(this: IExecuteFunctions): Promise { x.json.error = error.reason || 'LDAP connection error occurred'; @@ -418,7 +418,7 @@ export class Ldap implements INodeType { ); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnItems.push({ json: items[itemIndex].json, error, pairedItem: itemIndex }); } else { await client.unbind(); diff --git a/packages/nodes-base/nodes/Lemlist/Lemlist.node.ts b/packages/nodes-base/nodes/Lemlist/Lemlist.node.ts index 63c21d7c88..9e55d83759 100644 --- a/packages/nodes-base/nodes/Lemlist/Lemlist.node.ts +++ b/packages/nodes-base/nodes/Lemlist/Lemlist.node.ts @@ -289,7 +289,7 @@ export class Lemlist implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Line/Line.node.ts b/packages/nodes-base/nodes/Line/Line.node.ts index 7cdc4b03de..349e598722 100644 --- a/packages/nodes-base/nodes/Line/Line.node.ts +++ b/packages/nodes-base/nodes/Line/Line.node.ts @@ -129,7 +129,7 @@ export class Line implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Linear/Linear.node.ts b/packages/nodes-base/nodes/Linear/Linear.node.ts index 0657cf7d05..7ea6f2aca5 100644 --- a/packages/nodes-base/nodes/Linear/Linear.node.ts +++ b/packages/nodes-base/nodes/Linear/Linear.node.ts @@ -299,7 +299,7 @@ export class Linear implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/LinkedIn/LinkedIn.node.ts b/packages/nodes-base/nodes/LinkedIn/LinkedIn.node.ts index b3be6c4eaa..9732176da9 100644 --- a/packages/nodes-base/nodes/LinkedIn/LinkedIn.node.ts +++ b/packages/nodes-base/nodes/LinkedIn/LinkedIn.node.ts @@ -282,7 +282,7 @@ export class LinkedIn implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/LoneScale/LoneScale.node.ts b/packages/nodes-base/nodes/LoneScale/LoneScale.node.ts index 521a5f9876..46efa2af38 100644 --- a/packages/nodes-base/nodes/LoneScale/LoneScale.node.ts +++ b/packages/nodes-base/nodes/LoneScale/LoneScale.node.ts @@ -466,7 +466,7 @@ export class LoneScale implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Magento/Magento2.node.ts b/packages/nodes-base/nodes/Magento/Magento2.node.ts index 835fb81441..0d7196eb75 100644 --- a/packages/nodes-base/nodes/Magento/Magento2.node.ts +++ b/packages/nodes-base/nodes/Magento/Magento2.node.ts @@ -800,7 +800,7 @@ export class Magento2 implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Mailcheck/Mailcheck.node.ts b/packages/nodes-base/nodes/Mailcheck/Mailcheck.node.ts index 5a9a30aca4..2c5562dbc4 100644 --- a/packages/nodes-base/nodes/Mailcheck/Mailcheck.node.ts +++ b/packages/nodes-base/nodes/Mailcheck/Mailcheck.node.ts @@ -98,7 +98,7 @@ export class Mailcheck implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Mailchimp/Mailchimp.node.ts b/packages/nodes-base/nodes/Mailchimp/Mailchimp.node.ts index 8b452a1eee..c2e63b6f93 100644 --- a/packages/nodes-base/nodes/Mailchimp/Mailchimp.node.ts +++ b/packages/nodes-base/nodes/Mailchimp/Mailchimp.node.ts @@ -2190,7 +2190,7 @@ export class Mailchimp implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/MailerLite/MailerLite.node.ts b/packages/nodes-base/nodes/MailerLite/MailerLite.node.ts index 266aebcd27..6fe7c621b1 100644 --- a/packages/nodes-base/nodes/MailerLite/MailerLite.node.ts +++ b/packages/nodes-base/nodes/MailerLite/MailerLite.node.ts @@ -182,7 +182,7 @@ export class MailerLite implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Mailgun/Mailgun.node.ts b/packages/nodes-base/nodes/Mailgun/Mailgun.node.ts index a36b235d45..324118a46e 100644 --- a/packages/nodes-base/nodes/Mailgun/Mailgun.node.ts +++ b/packages/nodes-base/nodes/Mailgun/Mailgun.node.ts @@ -194,7 +194,7 @@ export class Mailgun implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: itemIndex } }, diff --git a/packages/nodes-base/nodes/Mailjet/Mailjet.node.ts b/packages/nodes-base/nodes/Mailjet/Mailjet.node.ts index a1d282deac..0b02a4590c 100644 --- a/packages/nodes-base/nodes/Mailjet/Mailjet.node.ts +++ b/packages/nodes-base/nodes/Mailjet/Mailjet.node.ts @@ -310,7 +310,7 @@ export class Mailjet implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Mandrill/Mandrill.node.ts b/packages/nodes-base/nodes/Mandrill/Mandrill.node.ts index 7371d7acfa..b673d3eba6 100644 --- a/packages/nodes-base/nodes/Mandrill/Mandrill.node.ts +++ b/packages/nodes-base/nodes/Mandrill/Mandrill.node.ts @@ -891,7 +891,7 @@ export class Mandrill implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Markdown/Markdown.node.ts b/packages/nodes-base/nodes/Markdown/Markdown.node.ts index dc38ee2567..bcd270797d 100644 --- a/packages/nodes-base/nodes/Markdown/Markdown.node.ts +++ b/packages/nodes-base/nodes/Markdown/Markdown.node.ts @@ -608,7 +608,7 @@ export class Markdown implements INodeType { returnData.push(newItem); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: (error as JsonObject).message }); continue; } diff --git a/packages/nodes-base/nodes/Marketstack/Marketstack.node.ts b/packages/nodes-base/nodes/Marketstack/Marketstack.node.ts index 2d7aba98e2..62617ee6fa 100644 --- a/packages/nodes-base/nodes/Marketstack/Marketstack.node.ts +++ b/packages/nodes-base/nodes/Marketstack/Marketstack.node.ts @@ -161,7 +161,7 @@ export class Marketstack implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Matrix/Matrix.node.ts b/packages/nodes-base/nodes/Matrix/Matrix.node.ts index eb24fb3c31..141a6c5181 100644 --- a/packages/nodes-base/nodes/Matrix/Matrix.node.ts +++ b/packages/nodes-base/nodes/Matrix/Matrix.node.ts @@ -151,7 +151,7 @@ export class Matrix implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Mattermost/v1/actions/router.ts b/packages/nodes-base/nodes/Mattermost/v1/actions/router.ts index 17ce9945fa..bd1af59af2 100644 --- a/packages/nodes-base/nodes/Mattermost/v1/actions/router.ts +++ b/packages/nodes-base/nodes/Mattermost/v1/actions/router.ts @@ -42,7 +42,7 @@ export async function router(this: IExecuteFunctions): Promise result[0]) as unknown as IDataObject[], ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnItems = this.helpers.returnJsonArray({ error: error.message }); } else { await connection.end(); diff --git a/packages/nodes-base/nodes/MySql/v2/helpers/utils.ts b/packages/nodes-base/nodes/MySql/v2/helpers/utils.ts index daff2a131e..1e15ce71bb 100644 --- a/packages/nodes-base/nodes/MySql/v2/helpers/utils.ts +++ b/packages/nodes-base/nodes/MySql/v2/helpers/utils.ts @@ -264,7 +264,7 @@ export function configureQueryRunner( } catch (err) { const error = parseMySqlError.call(this, err, 0, formatedQueries); - if (!this.continueOnFail(err)) throw error; + if (!this.continueOnFail()) throw error; returnData.push({ json: { message: error.message, error: { ...error } } }); } } else { @@ -302,7 +302,7 @@ export function configureQueryRunner( } catch (err) { const error = parseMySqlError.call(this, err, index, [formatedQuery]); - if (!this.continueOnFail(err)) { + if (!this.continueOnFail()) { connection.release(); throw error; } @@ -352,7 +352,7 @@ export function configureQueryRunner( connection.release(); } - if (!this.continueOnFail(err)) throw error; + if (!this.continueOnFail()) throw error; returnData.push(prepareErrorItem(queries[index], error as Error, index)); // Return here because we already rolled back the transaction diff --git a/packages/nodes-base/nodes/Nasa/Nasa.node.ts b/packages/nodes-base/nodes/Nasa/Nasa.node.ts index b192c21451..b291680c59 100644 --- a/packages/nodes-base/nodes/Nasa/Nasa.node.ts +++ b/packages/nodes-base/nodes/Nasa/Nasa.node.ts @@ -1110,7 +1110,7 @@ export class Nasa implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { if (resource === 'earthImagery' && operation === 'get') { items[i].json = { error: error.message }; } else if (resource === 'astronomyPictureOfTheDay' && operation === 'get' && download) { diff --git a/packages/nodes-base/nodes/Netlify/Netlify.node.ts b/packages/nodes-base/nodes/Netlify/Netlify.node.ts index 11cd3c1fed..c2f6f93320 100644 --- a/packages/nodes-base/nodes/Netlify/Netlify.node.ts +++ b/packages/nodes-base/nodes/Netlify/Netlify.node.ts @@ -195,7 +195,7 @@ export class Netlify implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Netscaler/ADC/NetscalerAdc.node.ts b/packages/nodes-base/nodes/Netscaler/ADC/NetscalerAdc.node.ts index 5dd09f9808..2f7fff154d 100644 --- a/packages/nodes-base/nodes/Netscaler/ADC/NetscalerAdc.node.ts +++ b/packages/nodes-base/nodes/Netscaler/ADC/NetscalerAdc.node.ts @@ -240,7 +240,7 @@ export class NetscalerAdc implements INodeType { }), ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: (error as JsonObject).toString() }); continue; } diff --git a/packages/nodes-base/nodes/NextCloud/NextCloud.node.ts b/packages/nodes-base/nodes/NextCloud/NextCloud.node.ts index e889bf572c..9a710c2a9c 100644 --- a/packages/nodes-base/nodes/NextCloud/NextCloud.node.ts +++ b/packages/nodes-base/nodes/NextCloud/NextCloud.node.ts @@ -1099,7 +1099,7 @@ export class NextCloud implements INodeType { qs, ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { if (resource === 'file' && operation === 'download') { items[i].json = { error: error.message }; } else { @@ -1288,7 +1288,7 @@ export class NextCloud implements INodeType { returnData.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { if (resource === 'file' && operation === 'download') { items[i].json = { error: error.message }; } else { diff --git a/packages/nodes-base/nodes/NocoDB/NocoDB.node.ts b/packages/nodes-base/nodes/NocoDB/NocoDB.node.ts index 00b46ebd02..390c3e2791 100644 --- a/packages/nodes-base/nodes/NocoDB/NocoDB.node.ts +++ b/packages/nodes-base/nodes/NocoDB/NocoDB.node.ts @@ -405,7 +405,7 @@ export class NocoDB implements INodeType { returnData.push(...body); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.toString() }); } throw new NodeApiError(this.getNode(), error as JsonObject); @@ -468,7 +468,7 @@ export class NocoDB implements INodeType { returnData.push(...responseData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.toString() }); } throw new NodeApiError(this.getNode(), error as JsonObject); @@ -541,7 +541,7 @@ export class NocoDB implements INodeType { return [data]; } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.toString() } }); } else { throw error; @@ -617,7 +617,7 @@ export class NocoDB implements INodeType { newItems.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.toString() }), { itemData: { item: i } }, @@ -759,7 +759,7 @@ export class NocoDB implements INodeType { returnData.push(...body); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.toString() }); } throw new NodeApiError(this.getNode(), error as JsonObject); diff --git a/packages/nodes-base/nodes/Notion/v2/NotionV2.node.ts b/packages/nodes-base/nodes/Notion/v2/NotionV2.node.ts index c69bb8ee7b..6c5205f9d0 100644 --- a/packages/nodes-base/nodes/Notion/v2/NotionV2.node.ts +++ b/packages/nodes-base/nodes/Notion/v2/NotionV2.node.ts @@ -86,7 +86,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -161,7 +161,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -193,7 +193,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -236,7 +236,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -299,7 +299,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -386,7 +386,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -416,7 +416,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -511,7 +511,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -563,7 +563,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -589,7 +589,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -618,7 +618,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -652,7 +652,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -704,7 +704,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, @@ -766,7 +766,7 @@ export class NotionV2 implements INodeType { ); returnData = returnData.concat(executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: { item: i }, diff --git a/packages/nodes-base/nodes/Odoo/Odoo.node.ts b/packages/nodes-base/nodes/Odoo/Odoo.node.ts index 0df41f47bc..58472d9340 100644 --- a/packages/nodes-base/nodes/Odoo/Odoo.node.ts +++ b/packages/nodes-base/nodes/Odoo/Odoo.node.ts @@ -751,7 +751,7 @@ export class Odoo implements INodeType { returnData.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/OneSimpleApi/OneSimpleApi.node.ts b/packages/nodes-base/nodes/OneSimpleApi/OneSimpleApi.node.ts index be8e294ce6..e04dbaaedd 100644 --- a/packages/nodes-base/nodes/OneSimpleApi/OneSimpleApi.node.ts +++ b/packages/nodes-base/nodes/OneSimpleApi/OneSimpleApi.node.ts @@ -865,7 +865,7 @@ export class OneSimpleApi implements INodeType { returnData.push(responseData as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Onfleet/Onfleet.ts b/packages/nodes-base/nodes/Onfleet/Onfleet.ts index 1c49d8908c..b5c17186c5 100644 --- a/packages/nodes-base/nodes/Onfleet/Onfleet.ts +++ b/packages/nodes-base/nodes/Onfleet/Onfleet.ts @@ -879,7 +879,7 @@ export class Onfleet { } } catch (error) { //@ts-ignore - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -923,7 +923,7 @@ export class Onfleet { responseData.push(await onfleetApiRequest.call(this, 'GET', path)); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -965,7 +965,7 @@ export class Onfleet { responseData.push(await onfleetApiRequest.call(this, 'GET', path)); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -1022,7 +1022,7 @@ export class Onfleet { responseData.push(await onfleetApiRequest.call(this, 'GET', path)); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -1085,7 +1085,7 @@ export class Onfleet { responseData.push({ success: true }); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -1140,7 +1140,7 @@ export class Onfleet { responseData.push(await onfleetApiRequest.call(this, 'PUT', path, hubData)); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -1259,7 +1259,7 @@ export class Onfleet { responseData.push(await onfleetApiRequest.call(this, 'POST', path, workerSchedule)); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -1308,7 +1308,7 @@ export class Onfleet { responseData.push({ success: true }); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -1366,7 +1366,7 @@ export class Onfleet { responseData.push(await onfleetApiRequest.call(this, 'PUT', path, { tasks, ...options })); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } @@ -1462,7 +1462,7 @@ export class Onfleet { responseData.push(await onfleetApiRequest.call(this, 'POST', path, teamAutoDispatch)); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { responseData.push({ error: (error as IDataObject).toString() }); continue; } diff --git a/packages/nodes-base/nodes/OpenThesaurus/OpenThesaurus.node.ts b/packages/nodes-base/nodes/OpenThesaurus/OpenThesaurus.node.ts index b85e296296..0e2481f625 100644 --- a/packages/nodes-base/nodes/OpenThesaurus/OpenThesaurus.node.ts +++ b/packages/nodes-base/nodes/OpenThesaurus/OpenThesaurus.node.ts @@ -173,7 +173,7 @@ export class OpenThesaurus implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/OpenWeatherMap/OpenWeatherMap.node.ts b/packages/nodes-base/nodes/OpenWeatherMap/OpenWeatherMap.node.ts index 9cb874c68e..c5766b5df8 100644 --- a/packages/nodes-base/nodes/OpenWeatherMap/OpenWeatherMap.node.ts +++ b/packages/nodes-base/nodes/OpenWeatherMap/OpenWeatherMap.node.ts @@ -278,7 +278,7 @@ export class OpenWeatherMap implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Paddle/Paddle.node.ts b/packages/nodes-base/nodes/Paddle/Paddle.node.ts index d472b428e3..cb9ce4b76a 100644 --- a/packages/nodes-base/nodes/Paddle/Paddle.node.ts +++ b/packages/nodes-base/nodes/Paddle/Paddle.node.ts @@ -520,7 +520,7 @@ export class Paddle implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/PagerDuty/PagerDuty.node.ts b/packages/nodes-base/nodes/PagerDuty/PagerDuty.node.ts index d55a9db026..4a1cfbbe67 100644 --- a/packages/nodes-base/nodes/PagerDuty/PagerDuty.node.ts +++ b/packages/nodes-base/nodes/PagerDuty/PagerDuty.node.ts @@ -460,7 +460,7 @@ export class PagerDuty implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/PayPal/PayPal.node.ts b/packages/nodes-base/nodes/PayPal/PayPal.node.ts index bbd46890b5..c046226a3e 100644 --- a/packages/nodes-base/nodes/PayPal/PayPal.node.ts +++ b/packages/nodes-base/nodes/PayPal/PayPal.node.ts @@ -242,7 +242,7 @@ export class PayPal implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Phantombuster/Phantombuster.node.ts b/packages/nodes-base/nodes/Phantombuster/Phantombuster.node.ts index 0bb38ba27a..33a323830d 100644 --- a/packages/nodes-base/nodes/Phantombuster/Phantombuster.node.ts +++ b/packages/nodes-base/nodes/Phantombuster/Phantombuster.node.ts @@ -253,7 +253,7 @@ export class Phantombuster implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Pipedrive/Pipedrive.node.ts b/packages/nodes-base/nodes/Pipedrive/Pipedrive.node.ts index 15cb8358b9..7fb02e9fae 100644 --- a/packages/nodes-base/nodes/Pipedrive/Pipedrive.node.ts +++ b/packages/nodes-base/nodes/Pipedrive/Pipedrive.node.ts @@ -4962,7 +4962,7 @@ export class Pipedrive implements INodeType { returnData.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { if (resource === 'file' && operation === 'download') { items[i].json = { error: error.message }; } else { diff --git a/packages/nodes-base/nodes/PostHog/PostHog.node.ts b/packages/nodes-base/nodes/PostHog/PostHog.node.ts index 7b9a1b737d..603bddcc02 100644 --- a/packages/nodes-base/nodes/PostHog/PostHog.node.ts +++ b/packages/nodes-base/nodes/PostHog/PostHog.node.ts @@ -122,7 +122,7 @@ export class PostHog implements INodeType { returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } @@ -174,7 +174,7 @@ export class PostHog implements INodeType { returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); } else { throw error; @@ -218,7 +218,7 @@ export class PostHog implements INodeType { returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } @@ -274,7 +274,7 @@ export class PostHog implements INodeType { returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/ProfitWell/ProfitWell.node.ts b/packages/nodes-base/nodes/ProfitWell/ProfitWell.node.ts index 727d32ac5b..8298e68340 100644 --- a/packages/nodes-base/nodes/ProfitWell/ProfitWell.node.ts +++ b/packages/nodes-base/nodes/ProfitWell/ProfitWell.node.ts @@ -139,7 +139,7 @@ export class ProfitWell implements INodeType { returnData.push(responseData as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Pushbullet/Pushbullet.node.ts b/packages/nodes-base/nodes/Pushbullet/Pushbullet.node.ts index c1a9209dac..6af7b5f236 100644 --- a/packages/nodes-base/nodes/Pushbullet/Pushbullet.node.ts +++ b/packages/nodes-base/nodes/Pushbullet/Pushbullet.node.ts @@ -493,7 +493,7 @@ export class Pushbullet implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Pushover/Pushover.node.ts b/packages/nodes-base/nodes/Pushover/Pushover.node.ts index b1262175de..2ac87ecb8a 100644 --- a/packages/nodes-base/nodes/Pushover/Pushover.node.ts +++ b/packages/nodes-base/nodes/Pushover/Pushover.node.ts @@ -359,7 +359,7 @@ export class Pushover implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/QuickBooks/QuickBooks.node.ts b/packages/nodes-base/nodes/QuickBooks/QuickBooks.node.ts index 8e81df8aa7..17e1e01e9d 100644 --- a/packages/nodes-base/nodes/QuickBooks/QuickBooks.node.ts +++ b/packages/nodes-base/nodes/QuickBooks/QuickBooks.node.ts @@ -1119,7 +1119,7 @@ export class QuickBooks implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const download = this.getNodeParameter('download', 0, false); if ( ['invoice', 'estimate', 'payment'].includes(resource) && diff --git a/packages/nodes-base/nodes/Raindrop/Raindrop.node.ts b/packages/nodes-base/nodes/Raindrop/Raindrop.node.ts index 2a4661b35b..9a14e77854 100644 --- a/packages/nodes-base/nodes/Raindrop/Raindrop.node.ts +++ b/packages/nodes-base/nodes/Raindrop/Raindrop.node.ts @@ -417,7 +417,7 @@ export class Raindrop implements INodeType { ? returnData.push(...(responseData as IDataObject[])) : returnData.push(responseData as IDataObject); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/ReadBinaryFile/ReadBinaryFile.node.ts b/packages/nodes-base/nodes/ReadBinaryFile/ReadBinaryFile.node.ts index a41dadbe7a..dedc00d37c 100644 --- a/packages/nodes-base/nodes/ReadBinaryFile/ReadBinaryFile.node.ts +++ b/packages/nodes-base/nodes/ReadBinaryFile/ReadBinaryFile.node.ts @@ -75,7 +75,7 @@ export class ReadBinaryFile implements INodeType { newItem.binary![dataPropertyName] = await this.helpers.prepareBinaryData(stream, filePath); returnData.push(newItem); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: (error as Error).message, diff --git a/packages/nodes-base/nodes/ReadPdf/ReadPDF.node.ts b/packages/nodes-base/nodes/ReadPdf/ReadPDF.node.ts index 7eed004d57..c7a1485cb1 100644 --- a/packages/nodes-base/nodes/ReadPdf/ReadPDF.node.ts +++ b/packages/nodes-base/nodes/ReadPdf/ReadPDF.node.ts @@ -85,7 +85,7 @@ export class ReadPDF implements INodeType { json, }); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message, diff --git a/packages/nodes-base/nodes/Reddit/Reddit.node.ts b/packages/nodes-base/nodes/Reddit/Reddit.node.ts index 38d35b1326..d04e6406aa 100644 --- a/packages/nodes-base/nodes/Reddit/Reddit.node.ts +++ b/packages/nodes-base/nodes/Reddit/Reddit.node.ts @@ -428,7 +428,7 @@ export class Reddit implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/RespondToWebhook/RespondToWebhook.node.ts b/packages/nodes-base/nodes/RespondToWebhook/RespondToWebhook.node.ts index ea378f97e2..68bd19e3f1 100644 --- a/packages/nodes-base/nodes/RespondToWebhook/RespondToWebhook.node.ts +++ b/packages/nodes-base/nodes/RespondToWebhook/RespondToWebhook.node.ts @@ -433,7 +433,7 @@ export class RespondToWebhook implements INodeType { this.sendResponse(response); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const itemData = generatePairedItemData(items.length); const returnData = this.helpers.constructExecutionMetaData( [{ json: { error: error.message } }], diff --git a/packages/nodes-base/nodes/Rocketchat/Rocketchat.node.ts b/packages/nodes-base/nodes/Rocketchat/Rocketchat.node.ts index de8ddb4924..274aae41ab 100644 --- a/packages/nodes-base/nodes/Rocketchat/Rocketchat.node.ts +++ b/packages/nodes-base/nodes/Rocketchat/Rocketchat.node.ts @@ -484,7 +484,7 @@ export class Rocketchat implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/RssFeedRead/RssFeedRead.node.ts b/packages/nodes-base/nodes/RssFeedRead/RssFeedRead.node.ts index 4b63a43d74..de9f602b81 100644 --- a/packages/nodes-base/nodes/RssFeedRead/RssFeedRead.node.ts +++ b/packages/nodes-base/nodes/RssFeedRead/RssFeedRead.node.ts @@ -137,7 +137,7 @@ export class RssFeedRead implements INodeType { returnData.push(...executionData); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message }, pairedItem: fallbackPairedItems || [{ item: i }], diff --git a/packages/nodes-base/nodes/S3/S3.node.ts b/packages/nodes-base/nodes/S3/S3.node.ts index 777788d52d..bfb581447c 100644 --- a/packages/nodes-base/nodes/S3/S3.node.ts +++ b/packages/nodes-base/nodes/S3/S3.node.ts @@ -890,7 +890,7 @@ export class S3 implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { if (resource === 'file' && operation === 'download') { items[i].json = { error: error.message }; } else { diff --git a/packages/nodes-base/nodes/Salesforce/Salesforce.node.ts b/packages/nodes-base/nodes/Salesforce/Salesforce.node.ts index 73fc54fce1..df0fd29515 100644 --- a/packages/nodes-base/nodes/Salesforce/Salesforce.node.ts +++ b/packages/nodes-base/nodes/Salesforce/Salesforce.node.ts @@ -3084,7 +3084,7 @@ export class Salesforce implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/SeaTable/SeaTable.node.ts b/packages/nodes-base/nodes/SeaTable/SeaTable.node.ts index 9010e0d3c9..0b62dae691 100644 --- a/packages/nodes-base/nodes/SeaTable/SeaTable.node.ts +++ b/packages/nodes-base/nodes/SeaTable/SeaTable.node.ts @@ -234,7 +234,7 @@ export class SeaTable implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -266,7 +266,7 @@ export class SeaTable implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -329,7 +329,7 @@ export class SeaTable implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -364,7 +364,7 @@ export class SeaTable implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -431,7 +431,7 @@ export class SeaTable implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Segment/Segment.node.ts b/packages/nodes-base/nodes/Segment/Segment.node.ts index d54612d114..bfef2985a5 100644 --- a/packages/nodes-base/nodes/Segment/Segment.node.ts +++ b/packages/nodes-base/nodes/Segment/Segment.node.ts @@ -617,7 +617,7 @@ export class Segment implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/SendGrid/SendGrid.node.ts b/packages/nodes-base/nodes/SendGrid/SendGrid.node.ts index eedd6f7e6a..c803521206 100644 --- a/packages/nodes-base/nodes/SendGrid/SendGrid.node.ts +++ b/packages/nodes-base/nodes/SendGrid/SendGrid.node.ts @@ -173,7 +173,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -214,7 +214,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -306,7 +306,7 @@ export class SendGrid implements INodeType { ); returnData.push(responseData as INodeExecutionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message } }); } else { throw error; @@ -335,7 +335,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -372,7 +372,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -403,7 +403,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -433,7 +433,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -464,7 +464,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -494,7 +494,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -642,7 +642,7 @@ export class SendGrid implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/SentryIo/SentryIo.node.ts b/packages/nodes-base/nodes/SentryIo/SentryIo.node.ts index bd76abd86c..ad83f771b6 100644 --- a/packages/nodes-base/nodes/SentryIo/SentryIo.node.ts +++ b/packages/nodes-base/nodes/SentryIo/SentryIo.node.ts @@ -733,7 +733,7 @@ export class SentryIo implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/ServiceNow/ServiceNow.node.ts b/packages/nodes-base/nodes/ServiceNow/ServiceNow.node.ts index 0e866e1357..50d78a31f5 100644 --- a/packages/nodes-base/nodes/ServiceNow/ServiceNow.node.ts +++ b/packages/nodes-base/nodes/ServiceNow/ServiceNow.node.ts @@ -1138,7 +1138,7 @@ export class ServiceNow implements INodeType { }); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Set/v2/manual.mode.ts b/packages/nodes-base/nodes/Set/v2/manual.mode.ts index 724a303336..282730bbf0 100644 --- a/packages/nodes-base/nodes/Set/v2/manual.mode.ts +++ b/packages/nodes-base/nodes/Set/v2/manual.mode.ts @@ -249,7 +249,7 @@ export async function execute( ); return composeReturnItem.call(this, i, item, newData, options, node.typeVersion); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { return { json: { error: (error as Error).message, pairedItem: { item: i } } }; } throw new NodeOperationError(this.getNode(), error as Error, { diff --git a/packages/nodes-base/nodes/Set/v2/raw.mode.ts b/packages/nodes-base/nodes/Set/v2/raw.mode.ts index 86aa11c750..b24a5e2dd5 100644 --- a/packages/nodes-base/nodes/Set/v2/raw.mode.ts +++ b/packages/nodes-base/nodes/Set/v2/raw.mode.ts @@ -56,7 +56,7 @@ export async function execute( return composeReturnItem.call(this, i, item, newData, options, node.typeVersion); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { return { json: { error: (error as Error).message }, pairedItem: { item: i } }; } throw new NodeOperationError(node, error as Error, { diff --git a/packages/nodes-base/nodes/Shopify/Shopify.node.ts b/packages/nodes-base/nodes/Shopify/Shopify.node.ts index 0c3f49078f..f2c70184e6 100644 --- a/packages/nodes-base/nodes/Shopify/Shopify.node.ts +++ b/packages/nodes-base/nodes/Shopify/Shopify.node.ts @@ -466,7 +466,7 @@ export class Shopify implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Signl4/Signl4.node.ts b/packages/nodes-base/nodes/Signl4/Signl4.node.ts index b86170ea6f..6aa599b120 100644 --- a/packages/nodes-base/nodes/Signl4/Signl4.node.ts +++ b/packages/nodes-base/nodes/Signl4/Signl4.node.ts @@ -342,7 +342,7 @@ export class Signl4 implements INodeType { returnData.push(responseData as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Slack/V1/SlackV1.node.ts b/packages/nodes-base/nodes/Slack/V1/SlackV1.node.ts index 70cd852469..585bde58e4 100644 --- a/packages/nodes-base/nodes/Slack/V1/SlackV1.node.ts +++ b/packages/nodes-base/nodes/Slack/V1/SlackV1.node.ts @@ -1372,7 +1372,7 @@ export class SlackV1 implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: (error as JsonObject).message } }); continue; } diff --git a/packages/nodes-base/nodes/Slack/V2/SlackV2.node.ts b/packages/nodes-base/nodes/Slack/V2/SlackV2.node.ts index 19a5efc286..14d62c6971 100644 --- a/packages/nodes-base/nodes/Slack/V2/SlackV2.node.ts +++ b/packages/nodes-base/nodes/Slack/V2/SlackV2.node.ts @@ -1359,7 +1359,7 @@ export class SlackV2 implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: (error as JsonObject).message } }); continue; } diff --git a/packages/nodes-base/nodes/Sms77/Sms77.node.ts b/packages/nodes-base/nodes/Sms77/Sms77.node.ts index 1fd9a9a12e..a59f1ea217 100644 --- a/packages/nodes-base/nodes/Sms77/Sms77.node.ts +++ b/packages/nodes-base/nodes/Sms77/Sms77.node.ts @@ -298,7 +298,7 @@ export class Sms77 implements INodeType { returnData.push(responseData as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Spontit/Spontit.node.ts b/packages/nodes-base/nodes/Spontit/Spontit.node.ts index c91fb3eced..9e20cd87cd 100644 --- a/packages/nodes-base/nodes/Spontit/Spontit.node.ts +++ b/packages/nodes-base/nodes/Spontit/Spontit.node.ts @@ -103,7 +103,7 @@ export class Spontit implements INodeType { returnData.push(responseData as IDataObject); } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ error: error.message }); continue; } diff --git a/packages/nodes-base/nodes/Spotify/Spotify.node.ts b/packages/nodes-base/nodes/Spotify/Spotify.node.ts index 5a7db76a6c..b951831c3b 100644 --- a/packages/nodes-base/nodes/Spotify/Spotify.node.ts +++ b/packages/nodes-base/nodes/Spotify/Spotify.node.ts @@ -1314,7 +1314,7 @@ export class Spotify implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/SpreadsheetFile/v1/SpreadsheetFileV1.node.ts b/packages/nodes-base/nodes/SpreadsheetFile/v1/SpreadsheetFileV1.node.ts index b954aa1691..99c7cc80bb 100644 --- a/packages/nodes-base/nodes/SpreadsheetFile/v1/SpreadsheetFileV1.node.ts +++ b/packages/nodes-base/nodes/SpreadsheetFile/v1/SpreadsheetFileV1.node.ts @@ -155,7 +155,7 @@ export class SpreadsheetFileV1 implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { newItems.push({ json: { error: error.message, @@ -242,7 +242,7 @@ export class SpreadsheetFileV1 implements INodeType { newItems.push(newItem); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { newItems.push({ json: { error: error.message, diff --git a/packages/nodes-base/nodes/SpreadsheetFile/v2/fromFile.operation.ts b/packages/nodes-base/nodes/SpreadsheetFile/v2/fromFile.operation.ts index de0e41ba61..719faeb478 100644 --- a/packages/nodes-base/nodes/SpreadsheetFile/v2/fromFile.operation.ts +++ b/packages/nodes-base/nodes/SpreadsheetFile/v2/fromFile.operation.ts @@ -209,7 +209,7 @@ export async function execute( error.message = `The file selected in 'Input Binary Field' is not in ${fileFormat} format`; errorDescription = `Try to change the operation or select a ${fileFormat} file in 'Input Binary Field'`; } - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message, diff --git a/packages/nodes-base/nodes/SpreadsheetFile/v2/toFile.operation.ts b/packages/nodes-base/nodes/SpreadsheetFile/v2/toFile.operation.ts index 85948b9915..61f8f8509e 100644 --- a/packages/nodes-base/nodes/SpreadsheetFile/v2/toFile.operation.ts +++ b/packages/nodes-base/nodes/SpreadsheetFile/v2/toFile.operation.ts @@ -29,7 +29,7 @@ export async function execute(this: IExecuteFunctions, items: INodeExecutionData returnData.push(newItem); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData.push({ json: { error: error.message, diff --git a/packages/nodes-base/nodes/Ssh/Ssh.node.ts b/packages/nodes-base/nodes/Ssh/Ssh.node.ts index ad17713ff6..c344fcf7ae 100644 --- a/packages/nodes-base/nodes/Ssh/Ssh.node.ts +++ b/packages/nodes-base/nodes/Ssh/Ssh.node.ts @@ -466,7 +466,7 @@ export class Ssh implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { if (resource === 'file' && operation === 'download') { items[i] = { json: { diff --git a/packages/nodes-base/nodes/Stackby/Stackby.node.ts b/packages/nodes-base/nodes/Stackby/Stackby.node.ts index c269849a70..72c9ef4a18 100644 --- a/packages/nodes-base/nodes/Stackby/Stackby.node.ts +++ b/packages/nodes-base/nodes/Stackby/Stackby.node.ts @@ -192,7 +192,7 @@ export class Stackby implements INodeType { responseData.map((data: any) => data.field) as INodeExecutionData[], ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -228,7 +228,7 @@ export class Stackby implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -282,7 +282,7 @@ export class Stackby implements INodeType { responseData.map((data: any) => data.field) as INodeExecutionData[], ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const itemData = generatePairedItemData(items.length); const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), @@ -332,7 +332,7 @@ export class Stackby implements INodeType { responseData.map((data: any) => data.field) as INodeExecutionData[], ); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Storyblok/Storyblok.node.ts b/packages/nodes-base/nodes/Storyblok/Storyblok.node.ts index 02045aa29a..c921e6a26d 100644 --- a/packages/nodes-base/nodes/Storyblok/Storyblok.node.ts +++ b/packages/nodes-base/nodes/Storyblok/Storyblok.node.ts @@ -349,7 +349,7 @@ export class Storyblok implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Strapi/Strapi.node.ts b/packages/nodes-base/nodes/Strapi/Strapi.node.ts index 8c991e7397..c3ff781b6f 100644 --- a/packages/nodes-base/nodes/Strapi/Strapi.node.ts +++ b/packages/nodes-base/nodes/Strapi/Strapi.node.ts @@ -389,7 +389,7 @@ export class Strapi implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Strava/Strava.node.ts b/packages/nodes-base/nodes/Strava/Strava.node.ts index 32f989051c..48f01c78f5 100644 --- a/packages/nodes-base/nodes/Strava/Strava.node.ts +++ b/packages/nodes-base/nodes/Strava/Strava.node.ts @@ -187,7 +187,7 @@ export class Strava implements INodeType { returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Stripe/Stripe.node.ts b/packages/nodes-base/nodes/Stripe/Stripe.node.ts index 79d829d61f..2c8b3042a1 100644 --- a/packages/nodes-base/nodes/Stripe/Stripe.node.ts +++ b/packages/nodes-base/nodes/Stripe/Stripe.node.ts @@ -464,7 +464,7 @@ export class Stripe implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionErrorData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Supabase/Supabase.node.ts b/packages/nodes-base/nodes/Supabase/Supabase.node.ts index 6323747b7b..d6151b2dca 100644 --- a/packages/nodes-base/nodes/Supabase/Supabase.node.ts +++ b/packages/nodes-base/nodes/Supabase/Supabase.node.ts @@ -171,7 +171,7 @@ export class Supabase implements INodeType { returnData.push(...executionData); }); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.description }), { itemData: mapPairedItemsFrom(records) }, @@ -220,7 +220,7 @@ export class Supabase implements INodeType { try { rows = await supabaseApiRequest.call(this, 'DELETE', endpoint, {}, qs); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.description }), { itemData: { item: i } }, @@ -260,7 +260,7 @@ export class Supabase implements INodeType { try { rows = await supabaseApiRequest.call(this, 'GET', endpoint, {}, qs); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.message }), { itemData: { item: i } }, @@ -326,7 +326,7 @@ export class Supabase implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.description }), { itemData: { item: i } }, @@ -402,7 +402,7 @@ export class Supabase implements INodeType { ); returnData.push(...executionData); } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray({ error: error.description }), { itemData: { item: i } }, diff --git a/packages/nodes-base/nodes/Switch/V1/SwitchV1.node.ts b/packages/nodes-base/nodes/Switch/V1/SwitchV1.node.ts index 4782da7c8e..b3c2ca30bb 100644 --- a/packages/nodes-base/nodes/Switch/V1/SwitchV1.node.ts +++ b/packages/nodes-base/nodes/Switch/V1/SwitchV1.node.ts @@ -678,7 +678,7 @@ export class SwitchV1 implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData[0].push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Switch/V2/SwitchV2.node.ts b/packages/nodes-base/nodes/Switch/V2/SwitchV2.node.ts index c940658c60..19f56fd5d0 100644 --- a/packages/nodes-base/nodes/Switch/V2/SwitchV2.node.ts +++ b/packages/nodes-base/nodes/Switch/V2/SwitchV2.node.ts @@ -699,7 +699,7 @@ export class SwitchV2 implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData[0].push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/Switch/V3/SwitchV3.node.ts b/packages/nodes-base/nodes/Switch/V3/SwitchV3.node.ts index 5c9c212b47..6892bc2d21 100644 --- a/packages/nodes-base/nodes/Switch/V3/SwitchV3.node.ts +++ b/packages/nodes-base/nodes/Switch/V3/SwitchV3.node.ts @@ -396,7 +396,7 @@ export class SwitchV3 implements INodeType { } } } catch (error) { - if (this.continueOnFail(error)) { + if (this.continueOnFail()) { returnData[0].push({ json: { error: error.message } }); continue; } diff --git a/packages/nodes-base/nodes/SyncroMSP/v1/actions/router.ts b/packages/nodes-base/nodes/SyncroMSP/v1/actions/router.ts index c57f20f530..3b5a5b3210 100644 --- a/packages/nodes-base/nodes/SyncroMSP/v1/actions/router.ts +++ b/packages/nodes-base/nodes/SyncroMSP/v1/actions/router.ts @@ -42,7 +42,7 @@ export async function router(this: IExecuteFunctions): Promise = Functions export type ContextType = 'flow' | 'node'; type BaseExecutionFunctions = FunctionsBaseWithRequiredKeys<'getMode'> & { - continueOnFail(error?: Error): boolean; + continueOnFail(): boolean; evaluateExpression(expression: string, itemIndex: number): NodeParameterValueType; getContext(type: ContextType): IContextObject; getExecuteData(): IExecuteData; diff --git a/packages/workflow/src/errors/node-operation.error.ts b/packages/workflow/src/errors/node-operation.error.ts index 1990714681..c55cd003cc 100644 --- a/packages/workflow/src/errors/node-operation.error.ts +++ b/packages/workflow/src/errors/node-operation.error.ts @@ -9,8 +9,6 @@ import { ApplicationError } from './application.error'; export class NodeOperationError extends NodeError { type: string | undefined; - obfuscate: boolean = false; - constructor( node: INode, error: Error | string | JsonObject, @@ -20,13 +18,8 @@ export class NodeOperationError extends NodeError { return error; } - let obfuscateErrorMessage = false; - if (typeof error === 'string') { error = new ApplicationError(error); - } else if (!(error instanceof ApplicationError)) { - // this error was no processed by n8n, obfuscate error message - obfuscateErrorMessage = true; } super(node, error); @@ -35,11 +28,6 @@ export class NodeOperationError extends NodeError { error.messages.forEach((message) => this.addToMessages(message)); } - if (obfuscateErrorMessage && !options.description) { - const originalMessage = typeof error === 'string' ? error : (error.message as string); - this.addToMessages(originalMessage); - this.obfuscate = true; - } if (options.message) this.message = options.message; if (options.level) this.level = options.level; if (options.functionality) this.functionality = options.functionality; diff --git a/packages/workflow/test/errors/node.error.test.ts b/packages/workflow/test/errors/node.error.test.ts index 4ec8c1d611..7d0783a65c 100644 --- a/packages/workflow/test/errors/node.error.test.ts +++ b/packages/workflow/test/errors/node.error.test.ts @@ -2,7 +2,6 @@ import { mock } from 'jest-mock-extended'; import type { INode } from '@/Interfaces'; import { NodeApiError } from '@/errors/node-api.error'; import { NodeOperationError } from '@/errors/node-operation.error'; -import { ApplicationError } from '@/errors/application.error'; describe('NodeError', () => { const node = mock(); @@ -16,50 +15,4 @@ describe('NodeError', () => { expect(wrapped1).toEqual(apiError); expect(wrapped2).toEqual(opsError); }); - - it('should obfuscate errors not processed by n8n', () => { - const error = new Error('Original error message'); - const nodeOpError = new NodeOperationError(node, error); - - expect(nodeOpError.obfuscate).toBe(true); - expect(nodeOpError.message).toBe('Original error message'); - expect(nodeOpError.messages).toContain('Original error message'); - }); - - it('should not obfuscate errors processed by n8n', () => { - const appError = new ApplicationError('Processed error message'); - const nodeOpError = new NodeOperationError(node, appError); - - expect(nodeOpError.obfuscate).toBe(false); - expect(nodeOpError.message).toBe('Processed error message'); - expect(nodeOpError.messages).not.toContain('Processed error message'); - }); - - it('should not obfuscate string errors', () => { - const errorMessage = 'String error message'; - const nodeOpError = new NodeOperationError(node, errorMessage); - - expect(nodeOpError.obfuscate).toBe(false); - expect(nodeOpError.message).toBe(errorMessage); - expect(nodeOpError.messages).toHaveLength(0); - }); - - it('should not obfuscate error if description provided', () => { - const error = new Error('Initial error message'); - const options = { description: 'Error description' }; - const nodeOpError = new NodeOperationError(node, error, options); - - expect(nodeOpError.obfuscate).toBe(false); - expect(nodeOpError.message).toBe('Initial error message'); - }); - - it('should respect provided options for message and description', () => { - const error = new Error('Initial error message'); - const options = { message: 'Overridden message', description: 'Error description' }; - const nodeOpError = new NodeOperationError(node, error, options); - - expect(nodeOpError.obfuscate).toBe(false); - expect(nodeOpError.message).toBe('Overridden message'); - expect(nodeOpError.description).toBe('Error description'); - }); });