implement handler for deleting pipelines

Author: bidhan-a

frontend/client/views/settings/index.vue

@@ -365,7 +365,9 @@ export default {
         .get('/api/v1/pipeline', { showProgressBar: false })
         .then(response => {
           if (response.data) {
-            this.pipelineRows = response.data
+            this.pipelineRows = response.data;
+          } else {
+            this.pipelineRows = [];
           }
         }).catch((error) => {
           this.$onError(error)
@@ -522,8 +524,20 @@ export default {
     },
 
     deletePipeline () {
-      console.log('Delete pipeline')
-      this.close()
+      this.$http
+        .delete('/api/v1/pipeline/' + this.selectPipeline.id)
+        .then(response => {
+          openNotification({
+            title: 'Pipeline deleted!',
+            message: 'Pipeline ' + this.selectPipeline.name + ' has been successfully deleted.',
+            type: 'success'
+          })
+          this.fetchData()
+          this.close()
+        })
+        .catch((error) => {
+          this.$onError(error)
+        })
     }
   }
 }

handlers/handler.go

@@ -74,6 +74,7 @@ func InitHandlers(e *echo.Echo, store *store.Store, scheduler *scheduler.Schedul
 	e.GET(p+"pipeline/name", PipelineNameAvailable)
 	e.GET(p+"pipeline", PipelineGetAll)
 	e.GET(p+"pipeline/:pipelineid", PipelineGet)
+	e.DELETE(p+"pipeline/:pipelineid", PipelineDelete)
 	e.POST(p+"pipeline/:pipelineid/start", PipelineStart)
 	e.GET(p+"pipeline/latest", PipelineGetAllWithLatestRun)
 

handlers/pipeline.go

@@ -136,6 +136,50 @@ func PipelineGet(c echo.Context) error {
 	return c.String(http.StatusNotFound, errPipelineNotFound.Error())
 }
 
+// PipelineDelete accepts a pipeline id and deletes it from the
+// store. It also removes the binary inside the pipeline folder.
+func PipelineDelete(c echo.Context) error {
+	pipelineIDStr := c.Param("pipelineid")
+
+	pipelineID, err := strconv.Atoi(pipelineIDStr)
+	if err != nil {
+		return c.String(http.StatusBadRequest, errInvalidPipelineID.Error())
+	}
+
+	// Look up pipeline for the given id
+	var foundPipeline gaia.Pipeline
+	var index int
+	var deletedPipelineIndex int
+	for pipeline := range pipeline.GlobalActivePipelines.Iter() {
+		if pipeline.ID == pipelineID {
+			foundPipeline = pipeline
+			deletedPipelineIndex = index
+		}
+		index++
+	}
+
+	if foundPipeline.Name == "" {
+		return c.String(http.StatusNotFound, err.Error())
+	}
+
+	// Delete pipeline binary
+	err = pipeline.DeleteBinary(foundPipeline)
+	if err != nil {
+		return c.String(http.StatusInternalServerError, err.Error())
+	}
+
+	// Delete pipeline from store
+	err = storeService.PipelineDelete(pipelineID)
+	if err != nil {
+		return c.String(http.StatusNotFound, err.Error())
+	}
+
+	// Remove from active pipelines
+	pipeline.GlobalActivePipelines.Remove(deletedPipelineIndex)
+
+	return c.String(http.StatusOK, "Pipeline has been deleted")
+}
+
 // PipelineStart starts a pipeline by the given id.
 // Afterwards it returns the created/scheduled pipeline run.
 func PipelineStart(c echo.Context) error {

pipeline/pipeline.go

@@ -3,6 +3,8 @@ package pipeline
 import (
 	"errors"
 	"fmt"
+	"os"
+	"path/filepath"
 	"sync"
 
 	"github.com/gaia-pipeline/gaia"
@@ -191,6 +193,12 @@ func (ap *ActivePipelines) RemoveDeletedPipelines(existingPipelineNames []string
 	}
 }
 
+// DeleteBinary deletes the binary for the given pipeline.
+func DeleteBinary(p gaia.Pipeline) error {
+	binaryFile := filepath.Join(gaia.Cfg.PipelinePath, appendTypeToName(p.Name, p.Type))
+	return os.Remove(binaryFile)
+}
+
 // appendTypeToName appends the type to the output binary name.
 // This allows us later to define the pipeline type by the name.
 func appendTypeToName(n string, pType gaia.PipelineType) string {

store/pipeline.go

@@ -310,3 +310,14 @@ func (s *Store) PipelineGetLatestRun(pipelineID int) (*gaia.PipelineRun, error)
 		})
 	})
 }
+
+// PipelineDelete deletes the pipeline with the given id.
+func (s *Store) PipelineDelete(id int) error {
+	return s.db.Update(func(tx *bolt.Tx) error {
+		// Get bucket
+		b := tx.Bucket(pipelineBucket)
+
+		// Delete pipeline
+		return b.Delete(itob(id))
+	})
+}