Add CLI command to deactivate workflows

This commit is contained in:
Jan Oberhauser 2020-10-24 14:37:45 +02:00
parent 78c846277b
commit 205a033717
2 changed files with 71 additions and 16 deletions

View file

@ -10,7 +10,7 @@ process.env.NODE_CONFIG_DIR = process.env.NODE_CONFIG_DIR || path.join(__dirname
var versionFlags = [ // tslint:disable-line:no-var-keyword
'-v',
'-V',
'--version'
'--version',
];
if (versionFlags.includes(process.argv.slice(-1)[0])) {
console.log(require('../package').version);
@ -22,21 +22,6 @@ if (process.argv.length === 2) {
process.argv.push('start');
}
var command = process.argv[2]; // tslint:disable-line:no-var-keyword
// Check if the command the user did enter is supported else stop
var supportedCommands = [ // tslint:disable-line:no-var-keyword
'execute',
'help',
'start',
];
if (!supportedCommands.includes(command)) {
console.log('\nThe command "' + command + '" is not known!\n');
process.argv.pop();
process.argv.push('--help');
}
if (parseInt(process.versions.node.split('.')[0], 10) < 10) {
console.log('\nThe Node.js version is too old to run n8n. Please use version 10 or later!\n');
process.exit(0);

View file

@ -0,0 +1,70 @@
import {
Command, flags,
} from '@oclif/command';
import {
IDataObject
} from 'n8n-workflow';
import {
Db,
GenericHelpers,
} from "../../../src";
export class DeactivateCommand extends Command {
static description = '\nDeactivates workflows';
static examples = [
`$ n8n config:workflow:deactivate --all`,
`$ n8n config:workflow:deactivate --id=5`,
];
static flags = {
help: flags.help({ char: 'h' }),
all: flags.boolean({
description: 'Deactivates all workflows',
}),
id: flags.string({
description: 'Deactivats the workflow with the given ID',
}),
};
async run() {
const { flags } = this.parse(DeactivateCommand);
if (!flags.all && !flags.id) {
GenericHelpers.logOutput(`Either option "--all" or "--id" have to be set!`);
return;
}
if (flags.all && flags.id) {
GenericHelpers.logOutput(`Either "--all" or "--id" can be set never both!`);
return;
}
try {
await Db.init();
const findQuery: IDataObject = {};
if (flags.id) {
console.log(`Deactivating workflow with ID: ${flags.id}`);
findQuery.id = flags.id;
} else {
console.log('Deactivating all workflows');
findQuery.active = true;
}
await Db.collections.Workflow!.update(findQuery, { active: false });
console.log('Done');
} catch (e) {
console.error('\nGOT ERROR');
console.log('====================================');
console.error(e.message);
console.error(e.stack);
this.exit(1);
}
this.exit();
}
}