import { OptionsWithUri } from 'request'; import { readFile as fsReadFile, } from 'fs'; import { promisify } from 'util'; const fsReadFileAsync = promisify(fsReadFile); import { IExecuteFunctions } from 'n8n-core'; import { ILoadOptionsFunctions, INodeExecutionData, INodePropertyOptions, INodeType, INodeTypeDescription, IExecuteWorkflowInfo, IWorkflowBase, } from 'n8n-workflow'; export class ExecuteWorkflow implements INodeType { description: INodeTypeDescription = { displayName: 'Execute Workflow', name: 'executeWorkflow', icon: 'fa:network-wired', group: ['transform'], version: 1, subtitle: '={{"Workflow: " + $parameter["workflowId"]}}', description: 'Execute another workflow', defaults: { name: 'Execute Workflow', color: '#ff6d5a', }, inputs: ['main'], outputs: ['main'], properties: [ { displayName: 'Source', name: 'source', type: 'options', options: [ { name: 'Database', value: 'database', description: 'Load the workflow from the database by ID.', }, { name: 'Local File', value: 'localFile', description: 'Load the workflow from a locally saved file.', }, { name: 'Parameter', value: 'parameter', description: 'Load the workflow from a parameter.', }, { name: 'URL', value: 'url', description: 'Load the workflow from an URL.', }, ], default: 'database', description: 'Where to get the workflow to execute from.', }, // ---------------------------------- // source:database // ---------------------------------- { displayName: 'Workflow', name: 'workflowId', type: 'options', displayOptions: { show: { source: [ 'database', ], }, }, typeOptions: { loadOptionsMethod: 'getWorkflows', }, default: '', required: true, description: 'The workflow to execute.', }, // ---------------------------------- // source:localFile // ---------------------------------- { displayName: 'Workflow Path', name: 'workflowPath', type: 'string', displayOptions: { show: { source: [ 'localFile', ], }, }, default: '', placeholder: '/data/workflow.json', required: true, description: 'The path to local JSON workflow file to execute.', }, // ---------------------------------- // source:parameter // ---------------------------------- { displayName: 'Workflow JSON', name: 'workflowJson', type: 'string', typeOptions: { alwaysOpenEditWindow: true, editor: 'code', rows: 10, }, displayOptions: { show: { source: [ 'parameter', ], }, }, default: '\n\n\n', required: true, description: 'The workflow JSON code to execute.', }, // ---------------------------------- // source:url // ---------------------------------- { displayName: 'Workflow URL', name: 'workflowUrl', type: 'string', displayOptions: { show: { source: [ 'url', ], }, }, default: '', placeholder: 'https://example.com/workflow.json', required: true, description: 'The URL from which to load the workflow from.', }, ] }; methods = { loadOptions: { async getWorkflows(this: ILoadOptionsFunctions): Promise { const options: OptionsWithUri = { method: 'GET', uri: this.getRestApiUrl() + '/workflows', json: true }; const returnData: INodePropertyOptions[] = []; const responseData = await this.helpers.request!(options); for (const workflowData of responseData.data) { returnData.push({ name: workflowData.name, value: workflowData.id, }); } return returnData; } }, }; async execute(this: IExecuteFunctions): Promise { const items = this.getInputData(); const source = this.getNodeParameter('source', 0) as string; const workflowInfo: IExecuteWorkflowInfo = {}; if (source === 'database') { // Read workflow from database workflowInfo.id = this.getNodeParameter('workflowId', 0) as string; } else if (source === 'localFile') { // Read workflow from filesystem const workflowPath = this.getNodeParameter('workflowPath', 0) as string; let workflowJson; try { workflowJson = await fsReadFileAsync(workflowPath, { encoding: 'utf8' }) as string; } catch (error) { if (error.code === 'ENOENT') { throw new Error(`The file "${workflowPath}" could not be found.`); } throw error; } workflowInfo.code = JSON.parse(workflowJson) as IWorkflowBase; } else if (source === 'parameter') { // Read workflow from parameter const workflowJson = this.getNodeParameter('workflowJson', 0) as string; workflowInfo.code = JSON.parse(workflowJson) as IWorkflowBase; } else if (source === 'url') { // Read workflow from url const workflowUrl = this.getNodeParameter('workflowUrl', 0) as string; const requestOptions = { headers: { 'accept': 'application/json,text/*;q=0.99', }, method: 'GET', uri: workflowUrl, json: true, gzip: true, }; const response = await this.helpers.request(requestOptions); workflowInfo.code = response; } const receivedData = await this.executeWorkflow(workflowInfo, items); return receivedData; } }