add support for restart/terminate +bump version

Author: ziv-codefresh

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

@@ -6,6 +6,7 @@ const DEFAULTS = require('../../defaults');
 const { workflow , pipeline } = require('../../../../logic').api;
 const { specifyOutputForSingle, specifyOutputForArray } = require('../../helpers/get');
 const getRoot = require('../root/get.cmd');
+const { printError } = require('../../helpers/general');
 
 const command = new Command({
     command: 'workflows [id]',
@@ -61,18 +62,18 @@ const command = new Command({
             workflows = await workflow.getWorkflowById(workflowId);
             specifyOutputForSingle(argv.output, workflows);
         } else {
-            if (_.isEmpty(pipelineIds) && !_.isEmpty(pipelineNames)) {
-                const pipelines = await pipeline.getAll();
-                _.forEach(pipelineNames, (pipelineName) => {
-                    const matchPipelines = _.find(pipelines, pipeline => pipeline.info.name.toString() === pipelineName);
-                    if (_.isArray(matchPipelines)) {
-                        _.forEach(matchPipelines, (currPipeline) => {
-                            pipelineIds.push(currPipeline.info.id);
-                        });
-                    } else {
-                        pipelineIds.push(matchPipelines.info.id);
-                    }
+            if (!_.isEmpty(pipelineNames)) {
+                const pipelines = await pipeline.getAll({
+                    name: pipelineNames,
                 });
+                if (!_.isEmpty(pipelines)) {
+                    const MatchPipelines = _.isArray(pipelines) ? pipelines : [pipelines];
+                    _.forEach(MatchPipelines, (currPipeline) => {
+                        pipelineIds.push(currPipeline.info.id);
+                    });
+                } else if (_.isEmpty(pipelineIds)) {
+                    throw new CFError('Cannot find any workflows with these pipelines names');
+                }
             }
             workflows = await workflow.getWorkflows({
                 limit,

lib/interface/cli/commands/workflow/restart.cmd.js

@@ -0,0 +1,44 @@
+const Command = require('../../Command');
+const { workflow } = require('../../../../logic/index').api;
+const { log } = require('../../../../logic').api;
+
+const restart = new Command({
+    root: true,
+    command: 'restart <id>',
+    description: 'Restart a workflow by its id',
+    builder: (yargs) => {
+        return yargs
+            .positional('id', {
+                describe: 'Workflow id',
+            })
+            .option('detach', {
+                alias: 'd',
+                describe: 'Run workflow and print workflow ID',
+            });
+    },
+    handler: async (argv) => {
+        const workflowId = await workflow.restartWorkflowById(argv.id);
+        if (argv.detach) {
+            console.log(workflowId);
+        } else {
+            await log.showWorkflowLogs(workflowId, true);
+            const workflowInstance = await workflow.getWorkflowById(workflowId);
+            switch (workflowInstance.getStatus()) {
+                case 'success':
+                    process.exit(0);
+                    break;
+                case 'error':
+                    process.exit(1);
+                    break;
+                case 'terminated':
+                    process.exit(2);
+                    break;
+                default:
+                    process.exit(100);
+                    break;
+            }
+        }
+    },
+});
+
+module.exports = restart;

lib/interface/cli/commands/workflow/terminate.cmd.js

@@ -0,0 +1,21 @@
+const Command = require('../../Command');
+const { workflow } = require('../../../../logic/index').api;
+
+const terminate = new Command({
+    root: true,
+    command: 'terminate <id>',
+    description: 'Terminate a workflow by its id',
+    builder: (yargs) => {
+        return yargs
+            .positional('id', {
+                describe: 'Workflow id',
+            });
+    },
+    handler: async (argv) => {
+        const workflowId = argv.id;
+        await workflow.terminateWorkflowById(workflowId);
+        console.log(`Workflow: ${workflowId} terminated`);
+    },
+});
+
+module.exports = terminate;

lib/logic/api/pipeline.js

@@ -13,13 +13,16 @@ const _extractFieldsForPipelineEntity = pipeline => ({
 
 
 const getAll = async (options) => {
-    const qs = {
-        name: options.name,
-        limit: options.limit,
-        page: options.page - 1,
-        repoOwner: options.repoOwner,
-        repoName: options.repoName,
-    };
+    let qs = {};
+    if (options) {
+        qs = {
+            name: options.name,
+            limit: options.limit,
+            page: options.page - 1,
+            repoOwner: options.repoOwner,
+            repoName: options.repoName,
+        };
+    }
     const RequestOptions = {
         url: '/api/pipelines',
         qs,

lib/logic/api/workflow.js

@@ -81,8 +81,30 @@ const waitForStatus = async (workflowId, desiredStatus, timeoutDate, descriptive
     }
 };
 
+
+const restartWorkflowById = async (id) => {
+    const options = {
+        url: `/api/builds/rebuild/${id}`,
+        method: 'GET',
+    };
+    const response = await sendHttpRequest(options);
+    return response;
+};
+
+const terminateWorkflowById = async (id) => {
+    const currWorkflow = await getWorkflowById(id);
+    const options = {
+        url: `/api/progress/${currWorkflow.info.progress}`,
+        method: 'DELETE',
+    };
+    const response = await sendHttpRequest(options);
+    return response;
+};
+
 module.exports = {
     getWorkflowById,
     getWorkflows,
     waitForStatus,
+    restartWorkflowById,
+    terminateWorkflowById,
 };

package.json

@@ -1,6 +1,6 @@
 {
   "name": "codefresh",
-  "version": "0.5.3",
+  "version": "0.5.4",
   "description": "Codefresh command line utility",
   "main": "index.js",
   "preferGlobal": true,