fix: set db in the compiler to support repo sync

api/build/compile_publish.go

@@ -269,6 +269,7 @@ func CompileAndPublish(
 			WithUser(u).
 			WithLabels(cfg.Labels).
 			WithSCM(scm).
+			WithDatabase(database).
 			Compile(ctx, pipelineFile)
 		if err != nil {
 			// format the error message with extra information

compiler/engine.go

@@ -10,6 +10,7 @@ import (
 	"github.com/go-vela/server/compiler/types/pipeline"
 	"github.com/go-vela/server/compiler/types/raw"
 	"github.com/go-vela/server/compiler/types/yaml"
+	"github.com/go-vela/server/database"
 	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/scm"
 )
@@ -150,6 +151,9 @@ type Engine interface {
 	// WithSCM defines a function that sets
 	// the scm in the Engine.
 	WithSCM(scm.Service) Engine
+	// WithDatabase defines a function that sets
+	// the database in the Engine.
+	WithDatabase(database.Interface) Engine
 	// WithPrivateGitHub defines a function that sets
 	// the private github client in the Engine.
 	WithPrivateGitHub(context.Context, string, string) Engine

compiler/native/compile.go

@@ -49,7 +49,7 @@ func (c *client) Compile(ctx context.Context, v interface{}) (*pipeline.Build, *
 	// netrc can be provided directly using WithNetrc for situations like local exec
 	if c.netrc == nil && c.scm != nil {
 		// get the netrc password from the scm
-		netrc, err := c.scm.GetNetrcPassword(ctx, c.repo, c.user, p.Git)
+		netrc, err := c.scm.GetNetrcPassword(ctx, c.db, c.repo, c.user, p.Git)
 		if err != nil {
 			return nil, nil, err
 		}

compiler/native/native.go

@@ -15,6 +15,7 @@ import (
 	"github.com/go-vela/server/compiler"
 	"github.com/go-vela/server/compiler/registry"
 	"github.com/go-vela/server/compiler/registry/github"
+	"github.com/go-vela/server/database"
 	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/internal/image"
 	"github.com/go-vela/server/scm"
@@ -46,6 +47,7 @@ type client struct {
 	repo           *api.Repo
 	user           *api.User
 	labels         []string
+	db             database.Interface
 	scm            scm.Service
 	netrc          *string
 }
@@ -249,3 +251,10 @@ func (c *client) WithSCM(_scm scm.Service) compiler.Engine {
 
 	return c
 }
+
+// WithDatabase sets the database in the Engine.
+func (c *client) WithDatabase(db database.Interface) compiler.Engine {
+	c.db = db
+
+	return c
+}

scm/github/repo.go

@@ -681,7 +681,7 @@ func (c *client) GetBranch(ctx context.Context, r *api.Repo, branch string) (str
 
 // GetNetrcPassword returns a clone token using the repo's github app installation if it exists.
 // If not, it defaults to the user OAuth token.
-func (c *client) GetNetrcPassword(ctx context.Context, r *api.Repo, u *api.User, g yaml.Git) (string, error) {
+func (c *client) GetNetrcPassword(ctx context.Context, db database.Interface, r *api.Repo, u *api.User, g yaml.Git) (string, error) {
 	l := c.Logger.WithFields(logrus.Fields{
 		"org":  r.GetOrg(),
 		"repo": r.GetName(),
@@ -749,12 +749,14 @@ func (c *client) GetNetrcPassword(ctx context.Context, r *api.Repo, u *api.User,
 	if installToken != nil && len(installToken.GetToken()) != 0 {
 		l.Tracef("using github app installation token for %s/%s", r.GetOrg(), r.GetName())
 
-		// sync the install ID with the repo
-		r.SetInstallID(installID)
+		// (optional) sync the install ID with the repo
+		if db != nil {
+			r.SetInstallID(installID)
 
-		_, err = database.FromContext(ctx).UpdateRepo(ctx, r)
-		if err != nil {
-			c.Logger.Tracef("unable to update repo with install ID %d: %v", installID, err)
+			_, err = db.UpdateRepo(ctx, r)
+			if err != nil {
+				c.Logger.Tracef("unable to update repo with install ID %d: %v", installID, err)
+			}
 		}
 
 		return installToken.GetToken(), nil

scm/github/repo_test.go

@@ -1749,7 +1749,7 @@ func TestGithub_GetNetrcPassword(t *testing.T) {
 				client.AppsTransport = NewTestAppsTransport(s.URL)
 			}
 
-			got, err := client.GetNetrcPassword(context.TODO(), test.repo, test.user, test.git)
+			got, err := client.GetNetrcPassword(context.TODO(), nil, test.repo, test.user, test.git)
 			if (err != nil) != test.wantErr {
 				t.Errorf("GetNetrcPassword() error = %v, wantErr %v", err, test.wantErr)
 				return

scm/service.go

@@ -144,7 +144,7 @@ type Service interface {
 	GetHTMLURL(context.Context, *api.User, string, string, string, string) (string, error)
 	// GetNetrc defines a function that returns the netrc
 	// password injected into build steps.
-	GetNetrcPassword(context.Context, *api.Repo, *api.User, yaml.Git) (string, error)
+	GetNetrcPassword(context.Context, database.Interface, *api.Repo, *api.User, yaml.Git) (string, error)
 	// SyncRepoWithInstallation defines a function that syncs
 	// a repo with the installation, if it exists.
 	SyncRepoWithInstallation(context.Context, *api.Repo) (*api.Repo, error)