Merge pull request #115 from codefresh-io/triggers

implement trigger methods

Author: alexei-led

.gitignore

@@ -1,6 +1,7 @@
 node_modules
 yarn-error.log
 .idea/
+.vscode
 *.log
 coverage
 .DS_Store

lib/interface/cli/commands/root/version.cmd.js

@@ -1,19 +1,42 @@
 const Command = require('../../Command');
 const cliPackage = require('./../../../../../package.json');
+const { version } = require('../../../../logic').api;
 
-const version = new Command({
+const versionCmd = new Command({
     root: true,
     requiresAuthentication: false,
     command: 'version',
     cliDocs: {
         description: 'Print version',
     },
     builder: (yargs) => {
-        return yargs;
+        return yargs
+            .option('component', {
+                describe: 'print component version',
+                alias: 'c',
+                choices: ['client', 'api', 'hermes', 'nomios'],
+                default: 'client',
+            });
     },
-    handler: async () => {
-        console.log(cliPackage.version);
+    handler: async (argv) => {
+        let ver = '';
+        switch (argv.component) {
+            case 'api':
+                ver = await version.getServerVersion();
+                ver = ver.current_commit;
+                break;
+            case 'hermes':
+                ver = await version.getHermesVersion();
+                break;
+            case 'nomios':
+                ver = await version.getNomiosVersion();
+                break;
+            case 'client':
+            default:
+                ver = cliPackage.version;
+        }
+        console.log(argv.component, 'version:', ver);
     },
 });
 
-module.exports = version;
+module.exports = versionCmd;

lib/interface/cli/commands/trigger/create.cmd.js

@@ -0,0 +1,39 @@
+const debug = require('debug')('codefresh:cli:create:trigger');
+const Command = require('../../Command');
+const { trigger } = require('../../../../logic').api;
+const createRoot = require('../root/create.cmd');
+
+const command = new Command({
+    command: 'trigger <event-uri> <pipeline> [pipelines...]',
+    aliases: ['t'],
+    parent: createRoot,
+    cliDocs: {
+        description: 'Set pipeline(s) trigger: connect the `trigger-event` to the pipeline(s). *Note:* `trigger-event` exists only if there is at least one connected pipeline.',
+    },
+    webDocs: {
+        category: 'Triggers',
+        title: 'Set Pipeline Trigger',
+    },
+    builder: (yargs) => {
+        return yargs
+            .positional('event-uri', {
+                describe: '`trigger-event` URI (as defined by trigger `type[/kind]`)',
+                require: true,
+            })
+            .positional('pipeline', {
+                describe: 'pipeline(s) to be triggered by the specified `trigger-event`',
+                require: true,
+            });
+    },
+    handler: async (argv) => {
+        /* eslint-disable prefer-destructuring */
+        const pipelines = [].concat(argv.pipeline).concat(argv.pipelines);
+        const eventURI = argv['event-uri'];
+        /* eslint-enable prefer-destructuring */
+        await trigger.addPipelineTrigger(eventURI, pipelines);
+        console.log(`Trigger : ${eventURI} was successfully added to the pipeline(s): ${pipelines}`);
+    },
+});
+
+module.exports = command;
+

lib/interface/cli/commands/trigger/delete.cmd.js

@@ -0,0 +1,42 @@
+const debug = require('debug')('codefresh:cli:delete:trigger');
+const Command = require('../../Command');
+const CFError = require('cf-errors');
+const _ = require('lodash');
+const { trigger } = require('../../../../logic').api;
+const deleteRoot = require('../root/delete.cmd');
+
+const command = new Command({
+    command: 'trigger <event-uri> <pipeline>',
+    aliases: ['t'],
+    parent: deleteRoot,
+    cliDocs: {
+        description: 'Remove pipeline trigger. *Note:* this may also remove `trigger-event` definition, if there are no pipelines left, that are connected to it.',
+    },
+    webDocs: {
+        category: 'Triggers',
+        title: 'Remove Pipeline Trigger',
+    },
+    builder: (yargs) => {
+        return yargs
+            .positional('event-uri', {
+                describe: '`trigger-event` URI (as defined by trigger `type[/kind]`)',
+                required: true,
+            })
+            .positional('pipeline', {
+                describe: 'pipeline ID',
+                required: true,
+            });
+    },
+    handler: async (argv) => {
+        /* eslint-disable prefer-destructuring */
+        const eventURI = argv['event-uri'];
+        const pipeline = argv.pipeline;
+        /* eslint-enable prefer-destructuring */
+
+        await trigger.deletePipelineTrigger(eventURI, pipeline);
+        console.log(`Trigger: ${eventURI} has been removed from ${pipeline} pipeline`);
+    },
+});
+
+module.exports = command;
+

lib/interface/cli/commands/trigger/event/get.cmd.js

@@ -0,0 +1,42 @@
+const debug = require('debug')('codefresh:cli:get:trigger-event');
+const Command = require('../../../Command');
+const _ = require('lodash');
+const { trigger } = require('../../../../../logic').api;
+const { specifyOutputForSingle, specifyOutputForArray } = require('../../../helpers/get');
+const getRoot = require('../../root/get.cmd');
+
+const command = new Command({
+    command: 'trigger-event <event-uri>',
+    aliases: ['te', 'event'],
+    parent: getRoot,
+    cliDocs: {
+        description: 'Get detailed information about specified `trigger-event`',
+    },
+    webDocs: {
+        category: 'Triggers',
+        title: 'Get Trigger Event',
+    },
+    builder: (yargs) => {
+        return yargs
+            .positional('event-uri', {
+                describe: '`trigger-event` uri (as defined by trigger `type[/kind]`)',
+                require: true,
+            });
+    },
+    handler: async (argv) => {
+        /* eslint-disable prefer-destructuring */
+        const eventURI = argv['event-uri'];
+        /* eslint-enable prefer-destructuring */
+
+        const info = await trigger.getEventInfo(eventURI);
+
+        if (_.isArray(info)) {
+            specifyOutputForArray(argv.output, info);
+        } else {
+            specifyOutputForSingle(argv.output, info);
+        }
+    },
+});
+
+module.exports = command;
+

lib/interface/cli/commands/trigger/get.cmd.js

@@ -0,0 +1,42 @@
+const debug = require('debug')('codefresh:cli:get:triggers');
+const Command = require('../../Command');
+const _ = require('lodash');
+const { trigger } = require('../../../../logic').api;
+const { specifyOutputForSingle, specifyOutputForArray } = require('../../helpers/get');
+const getRoot = require('../root/get.cmd');
+
+const command = new Command({
+    command: 'triggers <pipeline>',
+    aliases: ['t'],
+    parent: getRoot,
+    cliDocs: {
+        description: 'Get pipeline triggers',
+    },
+    webDocs: {
+        category: 'Triggers',
+        title: 'Get Pipeline Triggers',
+    },
+    builder: (yargs) => {
+        return yargs
+            .positional('pipeline', {
+                describe: 'pipeline id',
+                require: true,
+            });
+    },
+    handler: async (argv) => {
+        /* eslint-disable prefer-destructuring */
+        const pipeline = argv.pipeline;
+        /* eslint-enable prefer-destructuring */
+
+        const triggers = await trigger.getPipelineTriggers(pipeline);
+
+        if (_.isArray(triggers)) {
+            specifyOutputForArray(argv.output, triggers);
+        } else {
+            specifyOutputForSingle(argv.output, triggers);
+        }
+    },
+});
+
+module.exports = command;
+

lib/interface/cli/commands/trigger/type/get.cmd.js

@@ -0,0 +1,50 @@
+const debug = require('debug')('codefresh:cli:get:trigger-types');
+const Command = require('../../../Command');
+const _ = require('lodash');
+const { trigger } = require('../../../../../logic').api;
+const { specifyOutputForSingle, specifyOutputForArray } = require('../../../helpers/get');
+const getRoot = require('../../root/get.cmd');
+
+const command = new Command({
+    command: 'trigger-types [type] [kind]',
+    aliases: ['tt'],
+    parent: getRoot,
+    cliDocs: {
+        description: 'Get a list of system-wide available `trigger-types` or specified `trigger-type`',
+    },
+    webDocs: {
+        category: 'Triggers',
+        title: 'Get Trigger Types',
+    },
+    builder: (yargs) => {
+        return yargs
+            .positional('type', {
+                describe: '`trigger-type` type name (e.g. `registry`, `cron`)',
+            })
+            .positional('kind', {
+                describe: '`trigger-type` kind (e.g. `dockerhub`, `cfcr`, `gcr`, `acr`); only some `trigger-types` may have kinds',
+            });
+    },
+    handler: async (argv) => {
+        /* eslint-disable prefer-destructuring */
+        const type = argv.type;
+        const kind = argv.kind;
+        /* eslint-enable prefer-destructuring */
+
+        let types;
+        if (type && kind) {
+            types = await trigger.getType(type, kind);
+        } else {
+            types = await trigger.getAllTypes();
+        }
+
+        if (_.isArray(types)) {
+            specifyOutputForArray(argv.output, types);
+        } else {
+            specifyOutputForSingle(argv.output, types);
+        }
+    },
+});
+
+module.exports = command;
+

lib/logic/api/index.js

@@ -1,4 +1,5 @@
 const user = require('./user');
+const trigger = require('./trigger');
 const pipeline = require('./pipeline');
 const pipeline2 = require('./pipeline2');
 const context = require('./context');
@@ -7,9 +8,11 @@ const composition = require('./composition');
 const environment = require('./environment');
 const workflow = require('./workflow');
 const log = require('./log');
+const version = require('./version');
 
 module.exports = {
     user,
+    trigger,
     pipeline,
     pipeline2,
     context,
@@ -18,4 +21,5 @@ module.exports = {
     environment,
     workflow,
     log,
+    version,
 };