mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-12-25 04:34:06 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

⚡ Change CLI command config -> update

Browse source
This commit is contained in:
Jan Oberhauser 2020-10-27 11:14:51 +01:00
parent 5b1c86bd72
commit ac346b125b
2 changed files with 85 additions and 70 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
packages/cli/commands/config/workflow/deactivate.ts
View file

@ -1,70 +0,0 @@
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();
}
}

85
packages/cli/commands/update/workflow.ts Normal file
View file

@ -0,0 +1,85 @@
import {
Command, flags,
} from '@oclif/command';
import {
IDataObject
} from 'n8n-workflow';
import {
Db,
GenericHelpers,
} from "../../src";
export class UpdateWorkflowCommand extends Command {
static description = '\Update workflows';
static examples = [
`$ n8n update:workflow --all --active=false`,
`$ n8n update:workflow --id=5 --active=true`,
];
static flags = {
help: flags.help({ char: 'h' }),
active: flags.string({
description: 'Active state the workflow/s should be set to',
}),
all: flags.boolean({
description: 'Operate on all workflows',
}),
id: flags.string({
description: 'The ID of the workflow to operate on',
}),
};
async run() {
const { flags } = this.parse(UpdateWorkflowCommand);
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 something else on top should be "--all" or "--id" can be set never both!`);
return;
}
const updateQuery: IDataObject = {};
if (flags.active === undefined) {
GenericHelpers.logOutput(`No update flag like "--active=true" has been set!`);
return;
} else {
if (!['false', 'true'].includes(flags.active)) {
GenericHelpers.logOutput(`Valid values for flag "--active" are only "false" or "true"!`);
return;
}
updateQuery.active = flags.active === 'true';
}
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, updateQuery);
console.log('Done');
} catch (e) {
console.error('\nGOT ERROR');
console.log('====================================');
console.error(e.message);
console.error(e.stack);
this.exit(1);
}
this.exit();
}
}