feat: add support for processing schedules

.gitignore

@@ -67,4 +67,4 @@ __debug_bin
 .history
 .ionide
 
-# End of https://www.toptal.com/developers/gitignore/api/visualstudiocode
+# End of https://www.toptal.com/developers/gitignore/api/visualstudiocode

api/build.go

@@ -14,26 +14,23 @@ import (
 	"strings"
 	"time"
 
-	"github.com/go-vela/server/internal/token"
-	"github.com/go-vela/server/router/middleware/claims"
-	"github.com/go-vela/server/router/middleware/org"
-
+	"github.com/gin-gonic/gin"
 	"github.com/go-vela/server/compiler"
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal/token"
 	"github.com/go-vela/server/queue"
 	"github.com/go-vela/server/router/middleware/build"
+	"github.com/go-vela/server/router/middleware/claims"
 	"github.com/go-vela/server/router/middleware/executors"
+	"github.com/go-vela/server/router/middleware/org"
 	"github.com/go-vela/server/router/middleware/repo"
 	"github.com/go-vela/server/router/middleware/user"
 	"github.com/go-vela/server/scm"
 	"github.com/go-vela/server/util"
-
 	"github.com/go-vela/types"
 	"github.com/go-vela/types/constants"
 	"github.com/go-vela/types/library"
 	"github.com/go-vela/types/pipeline"
-
-	"github.com/gin-gonic/gin"
 	"github.com/sirupsen/logrus"
 )
 
@@ -292,7 +289,7 @@ func CreateBuild(c *gin.Context) {
 	r.SetPipelineType(pipelineType)
 
 	// skip the build if only the init or clone steps are found
-	skip := skipEmptyBuild(p)
+	skip := SkipEmptyBuild(p)
 	if skip != "" {
 		// set build to successful status
 		input.SetStatus(constants.StatusSuccess)
@@ -342,7 +339,7 @@ func CreateBuild(c *gin.Context) {
 	input.SetPipelineID(pipeline.GetID())
 
 	// create the objects from the pipeline in the database
-	err = planBuild(database.FromContext(c), p, input, r)
+	err = PlanBuild(database.FromContext(c), p, input, r)
 	if err != nil {
 		util.HandleError(c, http.StatusInternalServerError, err)
 
@@ -371,7 +368,7 @@ func CreateBuild(c *gin.Context) {
 	}
 
 	// publish the build to the queue
-	go publishToQueue(
+	go PublishToQueue(
 		queue.FromGinContext(c),
 		database.FromContext(c),
 		p,
@@ -381,11 +378,11 @@ func CreateBuild(c *gin.Context) {
 	)
 }
 
-// skipEmptyBuild checks if the build should be skipped due to it
+// SkipEmptyBuild checks if the build should be skipped due to it
 // not containing any steps besides init or clone.
 //
 //nolint:goconst // ignore init and clone constants
-func skipEmptyBuild(p *pipeline.Build) string {
+func SkipEmptyBuild(p *pipeline.Build) string {
 	if len(p.Stages) == 1 {
 		if p.Stages[0].Name == "init" {
 			return "skipping build since only init stage found"
@@ -1221,7 +1218,7 @@ func RestartBuild(c *gin.Context) {
 	r.SetPipelineType(pipelineType)
 
 	// skip the build if only the init or clone steps are found
-	skip := skipEmptyBuild(p)
+	skip := SkipEmptyBuild(p)
 	if skip != "" {
 		// set build to successful status
 		b.SetStatus(constants.StatusSkipped)
@@ -1271,7 +1268,7 @@ func RestartBuild(c *gin.Context) {
 	b.SetPipelineID(pipeline.GetID())
 
 	// create the objects from the pipeline in the database
-	err = planBuild(database.FromContext(c), p, b, r)
+	err = PlanBuild(database.FromContext(c), p, b, r)
 	if err != nil {
 		util.HandleError(c, http.StatusInternalServerError, err)
 
@@ -1299,7 +1296,7 @@ func RestartBuild(c *gin.Context) {
 	}
 
 	// publish the build to the queue
-	go publishToQueue(
+	go PublishToQueue(
 		queue.FromGinContext(c),
 		database.FromContext(c),
 		p,
@@ -1566,12 +1563,12 @@ func getPRNumberFromBuild(b *library.Build) (int, error) {
 	return strconv.Atoi(parts[2])
 }
 
-// planBuild is a helper function to plan the build for
+// PlanBuild is a helper function to plan the build for
 // execution. This creates all resources, like steps
 // and services, for the build in the configured backend.
 // TODO:
 // - return build and error.
-func planBuild(database database.Interface, p *pipeline.Build, b *library.Build, r *library.Repo) error {
+func PlanBuild(database database.Interface, p *pipeline.Build, b *library.Build, r *library.Repo) error {
 	// update fields in build object
 	b.SetCreated(time.Now().UTC().Unix())
 

api/build_test.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2022 Target Brands, Inc. All rights reserved.
+// Copyright (c) 2023 Target Brands, Inc. All rights reserved.
 //
 // Use of this source code is governed by the LICENSE file in this repository.
 
@@ -10,7 +10,7 @@ import (
 	"github.com/go-vela/types/pipeline"
 )
 
-func Test_skipEmptyBuild(t *testing.T) {
+func Test_SkipEmptyBuild(t *testing.T) {
 	type args struct {
 		p *pipeline.Build
 	}
@@ -72,8 +72,8 @@ func Test_skipEmptyBuild(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			if got := skipEmptyBuild(tt.args.p); got != tt.want {
-				t.Errorf("skipEmptyBuild() = %v, want %v", got, tt.want)
+			if got := SkipEmptyBuild(tt.args.p); got != tt.want {
+				t.Errorf("SkipEmptyBuild() = %v, want %v", got, tt.want)
 			}
 		})
 	}

api/schedule/create.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2022 Target Brands, Inc. All rights reserved.
+// Copyright (c) 2023 Target Brands, Inc. All rights reserved.
 //
 // Use of this source code is governed by the LICENSE file in this repository.
 

api/schedule/delete.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2022 Target Brands, Inc. All rights reserved.
+// Copyright (c) 2023 Target Brands, Inc. All rights reserved.
 //
 // Use of this source code is governed by the LICENSE file in this repository.
 

api/schedule/get.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2022 Target Brands, Inc. All rights reserved.
+// Copyright (c) 2023 Target Brands, Inc. All rights reserved.
 //
 // Use of this source code is governed by the LICENSE file in this repository.
 

api/schedule/list.go

@@ -1,4 +1,4 @@
-// Copyright (c) 2022 Target Brands, Inc. All rights reserved.
+// Copyright (c) 2023 Target Brands, Inc. All rights reserved.
 //
 // Use of this source code is governed by the LICENSE file in this repository.
 

api/schedule/update.go

@@ -9,11 +9,10 @@ import (
 	"net/http"
 	"time"
 
-	"github.com/go-vela/server/router/middleware/schedule"
-
 	"github.com/gin-gonic/gin"
 	"github.com/go-vela/server/database"
 	"github.com/go-vela/server/router/middleware/repo"
+	"github.com/go-vela/server/router/middleware/schedule"
 	"github.com/go-vela/server/util"
 	"github.com/go-vela/types/library"
 	"github.com/sirupsen/logrus"

api/webhook.go

@@ -541,7 +541,7 @@ func PostWebhook(c *gin.Context) {
 		repo.SetPipelineType(pipelineType)
 
 		// skip the build if only the init or clone steps are found
-		skip := skipEmptyBuild(p)
+		skip := SkipEmptyBuild(p)
 		if skip != "" {
 			// set build to successful status
 			b.SetStatus(constants.StatusSkipped)
@@ -608,7 +608,7 @@ func PostWebhook(c *gin.Context) {
 		//   using the same Number and thus create a constraint
 		//   conflict; consider deleting the partially created
 		//   build object in the database
-		err = planBuild(database.FromContext(c), p, b, repo)
+		err = PlanBuild(database.FromContext(c), p, b, repo)
 		if err != nil {
 			retErr := fmt.Errorf("%s: %w", baseErr, err)
 
@@ -695,7 +695,7 @@ func PostWebhook(c *gin.Context) {
 	}
 
 	// publish the build to the queue
-	go publishToQueue(
+	go PublishToQueue(
 		queue.FromGinContext(c),
 		database.FromContext(c),
 		p,
@@ -705,9 +705,9 @@ func PostWebhook(c *gin.Context) {
 	)
 }
 
-// publishToQueue is a helper function that creates
+// PublishToQueue is a helper function that creates
 // a build item and publishes it to the queue.
-func publishToQueue(queue queue.Service, db database.Interface, p *pipeline.Build, b *library.Build, r *library.Repo, u *library.User) {
+func PublishToQueue(queue queue.Service, db database.Interface, p *pipeline.Build, b *library.Build, r *library.Repo, u *library.User) {
 	item := types.ToItem(p, b, r, u)
 
 	logrus.Infof("Converting queue item to json for build %d for %s", b.GetNumber(), r.GetFullName())