[POC] Automatically update pipelines every minute.

Author: Skarlso

pipeline/git.go

@@ -106,3 +106,33 @@ func gitCloneRepo(repo *gaia.GitRepo) error {
 
 	return nil
 }
+
+func updateAllCurrentPipelines() {
+	// Get all active pipelines
+	for pipeline := range GlobalActivePipelines.Iter() {
+		r, err := git.PlainOpen(pipeline.Repo.LocalDest)
+		if err != nil {
+			// ignore for now
+			return
+		}
+
+		beforPull, _ := r.Head()
+		tree, _ := r.Worktree()
+		tree.Pull(&git.PullOptions{
+			RemoteName: "origin",
+		})
+		afterPull, _ := r.Head()
+
+		// if there are no changes...
+		if beforPull.Hash() == afterPull.Hash() {
+			continue
+		}
+
+		// otherwise build the pipeline
+		b := newBuildPipeline(pipeline.Type)
+		createPipeline := &gaia.CreatePipeline{}
+		createPipeline.Pipeline = pipeline
+		b.ExecuteBuild(createPipeline)
+	}
+
+}

pipeline/ticker.go

@@ -18,7 +18,8 @@ import (
 const (
 	// tickerIntervalSeconds defines how often the ticker will tick.
 	// Definition in seconds.
-	tickerIntervalSeconds = 5
+	tickerIntervalSeconds     = 5
+	pollTicketIntervalMinutes = 1
 )
 
 // storeService is an instance of store.
@@ -52,6 +53,17 @@ func InitTicker(store *store.Store, scheduler *scheduler.Scheduler) {
 			}
 		}
 	}()
+
+	pollTicket := time.NewTicker(pollTicketIntervalMinutes * time.Minute)
+	go func() {
+		defer pollTicket.Stop()
+		for {
+			select {
+			case <-pollTicket.C:
+				updateAllCurrentPipelines()
+			}
+		}
+	}()
 }
 
 // checkActivePipelines looks up all files in the pipeline folder.