Add option to cancel release (#161)

Author: Sasso

dashboard/src/actions/index.js

@@ -823,4 +823,24 @@ export const fetchServiceSpecServices = (slug) => {
       types: [ SERVICE_SPEC_SERVICES_FETCH_REQUEST, SERVICE_SPEC_SERVICES_FETCH_SUCCESS, SERVICE_SPEC_SERVICES_FETCH_FAILURE ]
     }
   }
-}
+}
+
+export const PROJECT_CANCEL_RELEASE_REQUEST = 'PROJECT_CANCEL_RELEASE_REQUEST'
+export const PROJECT_CANCEL_RELEASE_SUCCESS = 'PROJECT_CANCEL_RELEASE_SUCCESS'
+export const PROJECT_CANCEL_RELEASE_FAILURE = 'PROJECT_CANCEL_RELEASE_FAILURE'
+
+export const cancelRelease = (project_slug, payload) => {
+  return {
+    [CALL_API]: {
+      endpoint: `${API_ROOT}/projects/${project_slug}/releases/cancel`,
+      method: 'POST',
+      body: postBody(payload),
+      headers: {
+        'Accept': 'application/json',
+        'Content-Type': 'application/json',
+        'Authorization': `Bearer ${authToken()}`
+      },
+      types: [ PROJECT_CANCEL_RELEASE_REQUEST, PROJECT_CANCEL_RELEASE_SUCCESS, PROJECT_CANCEL_RELEASE_FAILURE ]
+    }
+  }
+}

dashboard/src/components/project/Deploy.js

@@ -2,7 +2,7 @@ import React, { Component } from 'react'
 import { isEmpty, map } from 'lodash'
 import { connect } from 'react-redux'
 import { Alert } from 'reactstrap'
-import { fetchProjectFeatures, createProjectRelease, createProjectRollbackTo, fetchProjectReleases, fetchProjectCurrentRelease } from '../../actions'
+import { fetchProjectFeatures, createProjectRelease, createProjectRollbackTo, fetchProjectReleases, fetchProjectCurrentRelease, cancelRelease } from '../../actions'
 import moment from 'moment'
 import Pagination from '../Pagination'
 import DockerImage from '../workflows/DockerImage'
@@ -59,6 +59,11 @@ class ProjectDeploy extends Component {
     this.props.createProjectRollbackTo(this.props.project.slug, release)
   }
 
+  onCancelRelease(release, e) {
+    e.preventDefault()
+    this.props.cancelRelease(this.props.project.slug, release)
+  }
+
   renderFeatureHash(feature) {
     if(feature.externalLink && feature.externalLink !== '' && feature.externalLink.startsWith('http')) {
       return (<a href={feature.externalLink} target="_blank">{feature.hash.substring(0,8)}</a>)
@@ -125,7 +130,7 @@ class ProjectDeploy extends Component {
     let jsx = []
     switch(release.state) {
       case 'waiting':
-        jsx.push(<i key="waiting" className="fa fa-circle-o-notch fa-spin fa-fw float-xs-right" />)
+        jsx.push(<button type="button" key="btn" className="btn btn-secondary btn-sm float-xs-right" onClick={(e) => this.onCancelRelease(release, e)}>Cancel</button>)
         break
       case 'running':
         jsx.push(<i key="running" className="fa fa-refresh fa-spin fa-fw float-xs-right" />)
@@ -352,6 +357,7 @@ export default connect(mapStateToProps, {
   fetchProjectFeatures,
   createProjectRelease,
   createProjectRollbackTo,
+  cancelRelease,
   fetchProjectReleases,
   fetchProjectCurrentRelease
 })(ProjectDeploy)

server/plugins/codeflow/api_projects.go

@@ -43,6 +43,7 @@ func (x *Projects) Register(api *rest.Api) []*rest.Route {
 		rest.Get(x.Path+"/#slug/releases", x.releases),
 		rest.Get(x.Path+"/#slug/releases/current", x.currentRelease),
 		rest.Post(x.Path+"/#slug/releases/rollback", x.createReleasesRollback),
+		rest.Post(x.Path+"/#slug/releases/cancel", x.cancelRelease),
 		rest.Get(x.Path+"/#slug/features", x.features),
 		rest.Get(x.Path+"/#slug", x.project),
 		rest.Post(x.Path, x.createProjects),
@@ -810,3 +811,45 @@ func (x *Projects) updateReleaseBuild(w rest.ResponseWriter, r *rest.Request) {
 
 	w.WriteJson(build)
 }
+
+func (x *Projects) cancelRelease(w rest.ResponseWriter, r *rest.Request) {
+	release := Release{}
+	user := User{}
+
+	if err := r.DecodeJsonPayload(&release); err != nil {
+		rest.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	if err := db.Collection("releases").FindById(release.Id, &release); err != nil {
+		if _, ok := err.(*bongo.DocumentNotFoundError); ok {
+			log.Printf("Releases::FindById::DocumentNotFoundError: _id: `%v`", release.Id)
+		} else {
+			log.Printf("Releases::FindById::Error: %s", err.Error())
+		}
+		return
+	}
+
+	if err := CurrentUser(r, &user); err != nil {
+		rest.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	if release.State == plugins.Waiting {
+		release.State = plugins.Failed
+		release.StateMessage = fmt.Sprintf("cancelled by %v", user.Username)
+
+		if err := db.Collection("releases").Save(&release); err != nil {
+			log.Printf("Releases::Save::Error: %v", err.Error())
+			log.Printf("Releases::FindById::Error: %s", err.Error())
+			return
+		}
+
+		if err := ReleaseUpdated(&release); err != nil {
+			rest.Error(w, err.Error(), http.StatusBadRequest)
+			return
+		}
+	}
+
+	w.WriteJson(release)
+}