enhance: any status, error wrapping, and fetch improvements

.github/workflows/codeql-analysis.yml

@@ -39,7 +39,7 @@ jobs:
 
     # Initializes the CodeQL tools for scanning.
     - name: Initialize CodeQL
-      uses: github/codeql-action/init@eb055d739abdc2e8de2e5f4ba1a8b246daa779aa # v3.26.0
+      uses: github/codeql-action/init@883d8588e56d1753a8a58c1c86e88976f0c23449 # v3.26.3
       with:
         languages: ${{ matrix.language }}
         # If you wish to specify custom queries, you can do so here or in a config file.
@@ -50,7 +50,7 @@ jobs:
     # Autobuild attempts to build any compiled languages  (C/C++, C#, or Java).
     # If this step fails, then you should remove it and run the build manually (see below)
     - name: Autobuild
-      uses: github/codeql-action/autobuild@eb055d739abdc2e8de2e5f4ba1a8b246daa779aa # v3.26.0
+      uses: github/codeql-action/autobuild@883d8588e56d1753a8a58c1c86e88976f0c23449 # v3.26.3
 
     # ℹ️ Command-line programs to run using the OS shell.
     # 📚 https://git.io/JvXDl
@@ -64,4 +64,4 @@ jobs:
     #   make release
 
     - name: Perform CodeQL Analysis
-      uses: github/codeql-action/analyze@eb055d739abdc2e8de2e5f4ba1a8b246daa779aa # v3.26.0
+      uses: github/codeql-action/analyze@883d8588e56d1753a8a58c1c86e88976f0c23449 # v3.26.3

cmd/vela-downstream/build.go

@@ -79,6 +79,7 @@ func (b *Build) Validate() error {
 		constants.StatusPending,
 		constants.StatusRunning,
 		constants.StatusSuccess,
+		"any",
 	}
 
 	// iterate through the build statuses provided

cmd/vela-downstream/config.go

@@ -17,6 +17,8 @@ type Config struct {
 	Server string
 	// user token to authenticate with the Vela server
 	Token string
+	// depth of builds search in downstream repo
+	Depth int
 	// the app name utilizing this config
 	AppName string
 	// the app version utilizing this config

cmd/vela-downstream/main.go

@@ -131,6 +131,13 @@ func main() {
 			Name:     "config.token",
 			Usage:    "user token to authenticate with the Vela server",
 		},
+		&cli.IntFlag{
+			EnvVars:  []string{"PARAMETER_DEPTH", "DOWNSTREAM_DEPTH"},
+			FilePath: "/vela/parameters/downstream/depth,/vela/secrets/downstream/depth",
+			Name:     "config.depth",
+			Usage:    "number of builds to search for downstream repositories",
+			Value:    50,
+		},
 
 		// Repo Flags
 
@@ -192,6 +199,7 @@ func run(c *cli.Context) error {
 		Config: &Config{
 			Server:     c.String("config.server"),
 			Token:      c.String("config.token"),
+			Depth:      c.Int("config.depth"),
 			AppName:    c.App.Name,
 			AppVersion: c.App.Version,
 		},

cmd/vela-downstream/plugin.go

@@ -8,9 +8,8 @@
 	"time"
 
 	"github.com/go-vela/sdk-go/vela"
-	"github.com/go-vela/server/api/types"
+	api "github.com/go-vela/server/api/types"
 	"github.com/go-vela/types/constants"
-	"github.com/go-vela/types/library"
 	"github.com/sirupsen/logrus"
 )
 
@@ -34,7 +33,7 @@
 		return err
 	}
 
-	rBMap := make(map[*library.Repo]int)
+	rBMap := make(map[*api.Repo]int)
 
 	// parse list of repos to trigger builds on
 	repos, err := p.Repo.Parse(p.Build.Branch)
@@ -45,9 +44,9 @@
 	// iterate through each repo from provided configuration
 	for _, repo := range repos {
 		// create new build type to store last successful build
-		build := types.Build{}
+		build := api.Build{}
 
-		logrus.Infof("listing last 500 builds for %s", repo.GetFullName())
+		logrus.Infof("searching last %d %s builds with branch %s for %s", p.Config.Depth, p.Build.Event, repo.GetBranch(), repo.GetFullName())
 
 		// create options for listing builds
 		//
@@ -60,30 +59,38 @@
 				// set the default starting page for options
 				Page: 1,
 				// set the max per page for options
-				PerPage: 100,
+				PerPage: 10,
 			},
 		}
 
-		// create new slice of builds to store API results
-		builds := []types.Build{}
-
 		// loop to capture *ALL* the builds
 		for {
 			// send API call to capture a list of builds for the repo
 			//
 			// https://pkg.go.dev/github.com/go-vela/sdk-go/vela#BuildService.GetAll
-			b, resp, err := client.Build.GetAll(repo.GetOrg(), repo.GetName(), opts)
+			builds, resp, err := client.Build.GetAll(repo.GetOrg(), repo.GetName(), opts)
 			if err != nil {
 				return fmt.Errorf("unable to list builds for %s: %w", repo.GetFullName(), err)
 			}
 
-			// add the results to the list of builds
-			builds = append(builds, *b...)
+			// iterate through list of builds for the repo
+			for _, b := range *builds {
+				// check if the build branch, event and status match
+				if contains(p.Build.Status, b.GetStatus()) || contains(p.Build.Status, "any") {
+					// update the build object to the current build
+					build = b
+
+					logrus.Infof("found %s build %s/%d on branch %s with status %s", p.Build.Event, repo.GetFullName(), build.GetNumber(), repo.GetBranch(), build.GetStatus())
+
+					// break out of the loop
+					break
+				}
+			}
 
 			// break the loop if there is no more results
-			// to page through or after 5 pages of results
+			// to page through or after 50 pages of results
 			// giving us up to a total of 500 builds
-			if resp.NextPage == 0 || resp.NextPage > 5 {
+			if resp.NextPage == 0 || resp.NextPage > 50 {
 				break
 			}
 
@@ -92,24 +99,6 @@
 			opts.ListOptions.Page = resp.NextPage
 		}
 
-		logrus.Debugf("searching for latest %s build on branch %s with status %s",
-			p.Build.Event,
-			repo.GetBranch(),
-			p.Build.Status,
-		)
-
-		// iterate through list of builds for the repo
-		for _, b := range builds {
-			// check if the build branch, event and status match
-			if contains(p.Build.Status, b.GetStatus()) {
-				// update the build object to the current build
-				build = b
-
-				// break out of the loop
-				break
-			}
-		}
-
 		// check if we found a build to restart
 		if build.GetNumber() == 0 {
 			msg := fmt.Sprintf("no %s build on branch %s with status %s found for %s",
@@ -125,7 +114,7 @@
 				continue
 			}
 
 			return fmt.Errorf(msg)
 		}
 
 		logrus.Infof("restarting build %s/%d", repo.GetFullName(), build.GetNumber())
@@ -135,7 +124,7 @@
 		// https://pkg.go.dev/github.com/go-vela/sdk-go/vela#BuildService.Restart
 		b, _, err := client.Build.Restart(repo.GetOrg(), repo.GetName(), build.GetNumber())
 		if err != nil {
-			return fmt.Errorf("unable to restart build %s/%d", repo.GetFullName(), build.GetNumber())
+			return fmt.Errorf("unable to restart build %s/%d: %w", repo.GetFullName(), build.GetNumber(), err)
 		}
 
 		// set map value for status checking
@@ -159,7 +148,7 @@
 
 // Report is a plugin method that checks the build statuses of all the builds kicked off from the plugin.
 // It will continue to check the statuses on 30 second intervals until the timeout is reached.
-func (p *Plugin) Report(client *vela.Client, rBMap map[*library.Repo]int) error {
+func (p *Plugin) Report(client *vela.Client, rBMap map[*api.Repo]int) error {
 	logrus.Info("waiting for 30 seconds to check status of downstream builds...")
 	// sleep to allow for all restart processing
 	time.Sleep(30 * time.Second)

cmd/vela-downstream/repo.go

@@ -6,7 +6,7 @@ import (
 	"fmt"
 	"strings"
 
-	"github.com/go-vela/types/library"
+	api "github.com/go-vela/server/api/types"
 
 	"github.com/sirupsen/logrus"
 )
@@ -18,17 +18,17 @@ type Repo struct {
 }
 
 // Parse verifies the Repo is properly configured.
-func (r *Repo) Parse(branch string) ([]*library.Repo, error) {
+func (r *Repo) Parse(branch string) ([]*api.Repo, error) {
 	logrus.Trace("parsing repos from provided configuration")
 
 	// create new repos type to store parsed repos
-	repos := []*library.Repo{}
+	repos := []*api.Repo{}
 
 	for _, name := range r.Names {
 		logrus.Tracef("parsing repo %s", name)
 
 		// create new repo type to store parsed repo information
-		repo := new(library.Repo)
+		repo := new(api.Repo)
 
 		// split the repo on / to account for org/repo as input
 		parts := strings.Split(name, "/")

cmd/vela-downstream/repo_test.go

@@ -6,7 +6,7 @@ import (
 	"reflect"
 	"testing"
 
-	"github.com/go-vela/types/library"
+	api "github.com/go-vela/server/api/types"
 )
 
 func TestDownstream_Repo_Parse(t *testing.T) {
@@ -15,19 +15,19 @@ func TestDownstream_Repo_Parse(t *testing.T) {
 		Names: []string{"go-vela/hello-world@test", "go-vela/hello-world"},
 	}
 
-	r1 := new(library.Repo)
+	r1 := new(api.Repo)
 	r1.SetOrg("go-vela")
 	r1.SetName("hello-world")
 	r1.SetFullName("go-vela/hello-world")
 	r1.SetBranch("test")
 
-	r2 := new(library.Repo)
+	r2 := new(api.Repo)
 	r2.SetOrg("go-vela")
 	r2.SetName("hello-world")
 	r2.SetFullName("go-vela/hello-world")
 	r2.SetBranch("main")
 
-	want := []*library.Repo{r1, r2}
+	want := []*api.Repo{r1, r2}
 
 	// run test
 	got, err := r.Parse("main")