Added flag to simplify output to execute command and created executeAll

Also created a command that lists workflows so it can be used by
other applications that wish to interact with n8n via CLI.

packages/cli/commands/execute.ts

@@ -40,6 +40,9 @@ export class Execute extends Command {
 		id: flags.string({
 			description: 'id of the workflow to execute',
 		}),
+		rawOutput: flags.boolean({
+			description: 'Outputs only JSON data, with no other text',
+		}),
 	};
 
 
@@ -172,9 +175,10 @@ export class Execute extends Command {
 				error.stack = data.data.resultData.error.stack;
 				throw error;
 			}
-
+			if (flags.rawOutput === undefined) {
 				this.log('Execution was successfull:');
 				this.log('====================================');
+			}
 			this.log(JSON.stringify(data, null, 2));
 		} catch (e) {
 			console.error('\nGOT ERROR');

packages/cli/commands/executeAll.ts

@@ -0,0 +1,174 @@
+import * as fs from 'fs';
+import { Command, flags } from '@oclif/command';
+import {
+	UserSettings,
+} from 'n8n-core';
+import {
+	INode,
+} from 'n8n-workflow';
+
+import {
+	ActiveExecutions,
+	CredentialsOverwrites,
+	CredentialTypes,
+	Db,
+	ExternalHooks,
+	GenericHelpers,
+	IWorkflowBase,
+	IWorkflowExecutionDataProcess,
+	LoadNodesAndCredentials,
+	NodeTypes,
+	WorkflowCredentials,
+	WorkflowHelpers,
+	WorkflowRunner,
+} from "../src";
+
+import { 
+	sep 
+}  from 'path';
+
+
+export class ExecuteAll extends Command {
+	static description = '\nExecutes all workflows once';
+	
+	static examples = [
+		`$ n8n executeAll`,
+		`$ n8n executeAll --debug`,
+		`$ n8n executeAll --snapshot=/data/snapshots`,
+	];
+	
+	static flags = {
+		help: flags.help({ char: 'h' }),
+		debug: flags.boolean({
+			description: 'Toggles on displaying all errors and debug messages.',
+		}),
+		snapshot: flags.string({
+			description: 'Enables snapshot saving. You must inform an existing folder to save snapshots via this param.',
+		}),
+	};
+	
+	
+	async run() {
+		const { flags } = this.parse(ExecuteAll);
+		
+		const debug = flags.debug !== undefined;
+
+		if (flags.snapshot !== undefined) {
+			if (fs.existsSync(flags.snapshot)) {
+				if (!fs.lstatSync(flags.snapshot).isDirectory()) {
+					GenericHelpers.logOutput(`The paramenter --snapshot must be an existing directory`);
+					return;
+				}
+			} else {
+				GenericHelpers.logOutput(`The paramenter --snapshot must be an existing directory`);
+				return;
+			}
+		}
+		
+		// Start directly with the init of the database to improve startup time
+		const startDbInitPromise = Db.init();
+		
+		// Load all node and credential types
+		const loadNodesAndCredentials = LoadNodesAndCredentials();
+		const loadNodesAndCredentialsPromise = loadNodesAndCredentials.init();
+		
+		// Wait till the database is ready
+		await startDbInitPromise;
+		
+		const allWorkflows = await Db.collections!.Workflow!.find();
+		if (debug) {
+			this.log(`Found ${allWorkflows.length} workflows to execute.`);
+		}
+		
+		// Make sure the settings exist
+		await UserSettings.prepareUserSettings();
+		
+		// Wait till the n8n-packages have been read
+		await loadNodesAndCredentialsPromise;
+		
+		// Load the credentials overwrites if any exist
+		const credentialsOverwrites = CredentialsOverwrites();
+		await credentialsOverwrites.init();
+		
+		// Load all external hooks
+		const externalHooks = ExternalHooks();
+		await externalHooks.init();
+		
+		// Add the found types to an instance other parts of the application can use
+		const nodeTypes = NodeTypes();
+		await nodeTypes.init(loadNodesAndCredentials.nodeTypes);
+		const credentialTypes = CredentialTypes();
+		await credentialTypes.init(loadNodesAndCredentials.credentialTypes);
+		
+		// Check if the workflow contains the required "Start" node
+		// "requiredNodeTypes" are also defined in editor-ui/views/NodeView.vue
+		const requiredNodeTypes = ['n8n-nodes-base.start'];
+		for (let i = 0; i < allWorkflows.length; i++) {
+			const workflowData = allWorkflows[i];
+			
+			if (debug) {
+				this.log(`Starting execution of workflow ID ${workflowData.id}.`);
+			}
+			
+			let startNode: INode | undefined= undefined;
+			for (const node of workflowData!.nodes) {
+				if (requiredNodeTypes.includes(node.type)) {
+					startNode = node;
+					break;
+				}
+			}
+			
+			if (startNode === undefined) {
+				// If the workflow does not contain a start-node we can not know what
+				// should be executed and with which data to start.
+				GenericHelpers.logOutput(`Workflow ID ${workflowData.id} cannot be started as it does not contain a "Start" node.`);
+				continue;
+			}
+			
+			try {
+				const credentials = await WorkflowCredentials(workflowData!.nodes);
+				
+				const runData: IWorkflowExecutionDataProcess = {
+					credentials,
+					executionMode: 'cli',
+					startNodes: [startNode.name],
+					workflowData: workflowData!,
+				};
+				
+				const workflowRunner = new WorkflowRunner();
+				const executionId = await workflowRunner.run(runData);
+				
+				const activeExecutions = ActiveExecutions.getInstance();
+				const data = await activeExecutions.getPostExecutePromise(executionId);
+				
+				if (data === undefined) {
+					GenericHelpers.logOutput(`Workflow ${workflowData.id} did not return any data.`);
+					continue;
+				}
+				
+				if (data.data.resultData.error) {
+					GenericHelpers.logOutput(`Workflow ${workflowData.id} failed.`);
+					if (debug) {
+						this.log(JSON.stringify(data, null, 2));
+						console.log(data.data.resultData.error);
+					}
+					continue;
+				}
+				GenericHelpers.logOutput(`Workflow ${workflowData.id} succeeded.`);
+				if (flags.snapshot !== undefined) {
+					const fileName = (flags.snapshot.endsWith(sep) ? flags.snapshot : flags.snapshot + sep) + `${workflowData.id}-snapshot.json`;
+					fs.writeFileSync(fileName,JSON.stringify(data, null, 2));
+				}
+			} catch (e) {
+				GenericHelpers.logOutput(`Workflow ${workflowData.id} failed.`);
+				if (debug) {
+					console.error(e.message);
+					console.error(e.stack);
+				}
+			}
+			
+		}
+		
+		this.exit();
+	}
+}

packages/cli/commands/list/workflow.ts

@@ -0,0 +1,66 @@
+import {
+	Command, flags,
+} from '@oclif/command';
+
+import {
+	IDataObject
+} from 'n8n-workflow';
+
+import {
+	Db,
+} from "../../src";
+
+
+export class ListWorkflowCommand extends Command {
+	static description = '\nList workflows';
+
+	static examples = [
+		`$ n8n list:workflow`,
+		`$ n8n list:workflow --active=true --onlyId`,
+		`$ n8n list:workflow --active=false`,
+	];
+
+	static flags = {
+		help: flags.help({ char: 'h' }),
+		active: flags.string({
+			description: 'Filters workflows by active status. Can be true or false',
+		}),
+		onlyId: flags.boolean({
+			description: 'Outputs workflow IDs only, one per line.',
+		}),
+	};
+
+	async run() {
+		const { flags } = this.parse(ListWorkflowCommand);
+
+		if (flags.active !== undefined && !['true', 'false'].includes(flags.active)) {
+			this.error('The --active flag has to be passed using true or false');
+		}
+
+		try {
+			await Db.init();
+
+			const findQuery: IDataObject = {};
+			if (flags.active !== undefined) {
+				findQuery.active = flags.active === 'true';
+			}
+
+			const workflows = await Db.collections.Workflow!.find(findQuery);
+			if (flags.onlyId) {
+				workflows.map(workflow => console.log(workflow.id));
+			} else {
+				workflows.map(workflow => console.log(workflow.id + "|" + workflow.name));
+			}
+			
+
+		} catch (e) {
+			console.error('\nGOT ERROR');
+			console.log('====================================');
+			console.error(e.message);
+			console.error(e.stack);
+			this.exit(1);
+		}
+
+		this.exit();
+	}
+}