Added the functionality to save a drop-in pipeline.

Author: Skarlso

cmd/gaia/main.go

@@ -44,7 +44,7 @@ func init() {
 	flag.BoolVar(&gaia.Cfg.DevMode, "dev", false, "If true, gaia will be started in development mode. Don't use this in production!")
 	flag.BoolVar(&gaia.Cfg.VersionSwitch, "version", false, "If true, will print the version and immediately exit")
 	flag.BoolVar(&gaia.Cfg.Poll, "poll", false, "Instead of using a Webhook, keep polling git for changes on pipelines")
-	flag.IntVar(&gaia.Cfg.PVal, "pval", 1, "The interval in minutes in which to poll Github for changes")
+	flag.IntVar(&gaia.Cfg.PVal, "pval", 1, "The interval in minutes in which to poll vcs for changes")
 	// Default values
 	gaia.Cfg.Bolt.Mode = 0600
 }

pipeline/git_test.go

@@ -116,7 +116,7 @@ func TestUpdateAllPipelinesAlreadyUpToDateWithMoreThanOnePipeline(t *testing.T)
 	}
 }
 
-func TestUpdateAllPipelinesTenPipelines(t *testing.T) {
+func TestUpdateAllPipelinesHundredPipelines(t *testing.T) {
 	if _, ok := os.LookupEnv("GAIA_RUN_HUNDRED_PIPELINE_TEST"); !ok {
 		t.Skip()
 	}

pipeline/ticker.go

@@ -135,6 +135,18 @@ func checkActivePipelines() {
 				continue
 			}
 
+			// Pipeline is a drop-in build. Set up a template for it.
+			shouldStore := false
+			if pipeline == nil {
+				pipeline = &gaia.Pipeline{
+					Name:     pName,
+					Type:     pType,
+					ExecPath: filepath.Join(gaia.Cfg.PipelinePath, file.Name()),
+					Created:  time.Now(),
+				}
+				shouldStore = true
+			}
+
 			// We calculate a SHA256 Checksum and store it.
 			// We use this to estimate if a pipeline has been changed.
 			pipeline.SHA256Sum, err = getSHA256Sum(pipeline.ExecPath)
@@ -146,6 +158,11 @@ func checkActivePipelines() {
 			// Let us try to start the plugin and receive all implemented jobs
 			schedulerService.SetPipelineJobs(pipeline)
 
+			// We encountered a drop-in pipeline previously. Now is the time to save it.
+			if shouldStore {
+				storeService.PipelinePut(pipeline)
+			}
+
 			// We do not update the pipeline in store if it already exists there.
 			// We only updated the SHA256 Checksum and the jobs but this is not importent
 			// to store and should not have any side effects.