refactor(repo)!: nested repository with migration from types

api/admin/repo.go

@@ -7,11 +7,10 @@ import (
 	"fmt"
 	"net/http"
 
+	"github.com/go-vela/server/api/types"
 	"github.com/go-vela/server/database"
 	"github.com/go-vela/server/util"
 
-	"github.com/go-vela/types/library"
-
 	"github.com/gin-gonic/gin"
 	"github.com/sirupsen/logrus"
 )
@@ -55,7 +54,7 @@ func UpdateRepo(c *gin.Context) {
 	ctx := c.Request.Context()
 
 	// capture body from API request
-	input := new(library.Repo)
+	input := new(types.Repo)
 
 	err := c.Bind(input)
 	if err != nil {

api/auth/login.go

@@ -8,8 +8,8 @@ import (
 	"net/url"
 
 	"github.com/gin-gonic/gin"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/util"
-	"github.com/go-vela/types"
 	"github.com/sirupsen/logrus"
 )
 
@@ -38,7 +38,7 @@ import (
 // process a user logging in to Vela.
 func Login(c *gin.Context) {
 	// load the metadata
-	m := c.MustGet("metadata").(*types.Metadata)
+	m := c.MustGet("metadata").(*internal.Metadata)
 
 	// capture query params
 	t := util.FormParameter(c, "type")

api/auth/logout.go

@@ -8,10 +8,10 @@ import (
 	"net/url"
 
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/router/middleware/user"
 	"github.com/go-vela/server/util"
 
-	"github.com/go-vela/types"
 	"github.com/go-vela/types/constants"
 
 	"github.com/gin-gonic/gin"
@@ -41,7 +41,7 @@ import (
 // refresh token cookie.
 func Logout(c *gin.Context) {
 	// grab the metadata to help deal with the cookie
-	m := c.MustGet("metadata").(*types.Metadata)
+	m := c.MustGet("metadata").(*internal.Metadata)
 	// capture middleware values
 	u := user.Retrieve(c)
 	ctx := c.Request.Context()

api/auth/redirect.go

@@ -7,8 +7,8 @@ import (
 	"net/http"
 
 	"github.com/gin-gonic/gin"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/util"
-	"github.com/go-vela/types"
 	"github.com/sirupsen/logrus"
 )
 
@@ -68,7 +68,7 @@ import (
 // This will only handle non-headless flows (ie. web or cli).
 func GetAuthRedirect(c *gin.Context) {
 	// load the metadata
-	m := c.MustGet("metadata").(*types.Metadata)
+	m := c.MustGet("metadata").(*internal.Metadata)
 
 	logrus.Info("redirecting for final auth flow destination")
 

api/build/approve.go

@@ -10,13 +10,13 @@ import (
 
 	"github.com/gin-gonic/gin"
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/queue"
 	"github.com/go-vela/server/router/middleware/build"
 	"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/util"
-	"github.com/go-vela/types"
 	"github.com/go-vela/types/constants"
 	"github.com/sirupsen/logrus"
 )
@@ -105,23 +105,13 @@ func ApproveBuild(c *gin.Context) {
 
 	logger.Debugf("user %s approved build %s/%d for execution", u.GetName(), r.GetFullName(), b.GetNumber())
 
-	// send API call to capture the repo owner
-	owner, err := database.FromContext(c).GetUser(ctx, r.GetUserID())
-	if err != nil {
-		retErr := fmt.Errorf("unable to get owner for %s: %w", r.GetFullName(), err)
-
-		util.HandleError(c, http.StatusBadRequest, retErr)
-
-		return
-	}
-
 	// set fields
 	b.SetStatus(constants.StatusPending)
 	b.SetApprovedAt(time.Now().Unix())
 	b.SetApprovedBy(u.GetName())
 
 	// update the build in the db
-	_, err = database.FromContext(c).UpdateBuild(ctx, b)
+	_, err := database.FromContext(c).UpdateBuild(ctx, b)
 	if err != nil {
 		logrus.Errorf("Failed to update build %d during publish to queue for %s: %v", b.GetNumber(), r.GetFullName(), err)
 	}
@@ -131,7 +121,7 @@ func ApproveBuild(c *gin.Context) {
 		ctx,
 		queue.FromGinContext(c),
 		database.FromContext(c),
-		types.ToItem(b, r, owner),
+		internal.ToItem(b, r, r.GetOwner()),
 		b.GetHost(),
 	)
 

api/build/auto_cancel.go

@@ -12,6 +12,7 @@ import (
 	"time"
 
 	"github.com/gin-gonic/gin"
+	"github.com/go-vela/server/api/types"
 	"github.com/go-vela/server/database"
 	"github.com/go-vela/server/internal/token"
 	"github.com/go-vela/types/constants"
@@ -21,7 +22,7 @@ import (
 
 // AutoCancel is a helper function that checks to see if any pending or running
 // builds for the repo can be replaced by the current build.
-func AutoCancel(c *gin.Context, b *library.Build, rB *library.Build, r *library.Repo, cancelOpts *pipeline.CancelOptions) (bool, error) {
+func AutoCancel(c *gin.Context, b *library.Build, rB *library.Build, r *types.Repo, cancelOpts *pipeline.CancelOptions) (bool, error) {
 	// if build is the current build, continue
 	if rB.GetID() == b.GetID() {
 		return false, nil
@@ -73,7 +74,7 @@ func AutoCancel(c *gin.Context, b *library.Build, rB *library.Build, r *library.
 
 // cancelRunning is a helper function that determines the executor currently running a build and sends an API call
 // to that executor's worker to cancel the build.
-func cancelRunning(c *gin.Context, b *library.Build, r *library.Repo) error {
+func cancelRunning(c *gin.Context, b *library.Build, r *types.Repo) error {
 	e := new([]library.Executor)
 	// retrieve the worker
 	w, err := database.FromContext(c).GetWorkerForHostname(c, b.GetHost())

api/build/compile_publish.go

@@ -10,12 +10,13 @@ import (
 	"strings"
 	"time"
 
+	"github.com/go-vela/server/api/types"
 	"github.com/go-vela/server/compiler"
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/queue"
 	"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"
@@ -25,8 +26,8 @@ import (
 // CompileAndPublishConfig is a struct that contains information for the CompileAndPublish function.
 type CompileAndPublishConfig struct {
 	Build    *library.Build
-	Repo     *library.Repo
-	Metadata *types.Metadata
+	Repo     *types.Repo
+	Metadata *internal.Metadata
 	BaseErr  string
 	Source   string
 	Comment  string
@@ -45,27 +46,20 @@ func CompileAndPublish(
 	scm scm.Service,
 	compiler compiler.Engine,
 	queue queue.Service,
-) (bool, *pipeline.Build, *types.Item, error) {
+) (bool, *pipeline.Build, *internal.Item, error) {
 	logrus.Debugf("generating queue items for build %s/%d", cfg.Repo.GetFullName(), cfg.Build.GetNumber())
 
 	// assign variables from form for readibility
 	r := cfg.Repo
+	u := cfg.Repo.GetOwner()
 	b := cfg.Build
 	baseErr := cfg.BaseErr
 
 	// send API call to capture repo owner
 	logrus.Debugf("capturing owner of repository %s", cfg.Repo.GetFullName())
 
-	u, err := database.GetUser(c, r.GetUserID())
-	if err != nil {
-		retErr := fmt.Errorf("%s: failed to get owner for %s: %w", baseErr, r.GetFullName(), err)
-		util.HandleError(c, http.StatusBadRequest, retErr)
-
-		return false, nil, nil, retErr
-	}
-
 	// confirm current repo owner has at least write access to repo (needed for status update later)
-	_, err = scm.RepoAccess(c, u.GetName(), u.GetToken(), r.GetOrg(), r.GetName())
+	_, err := scm.RepoAccess(c, u.GetName(), u.GetToken(), r.GetOrg(), r.GetName())
 	if err != nil {
 		retErr := fmt.Errorf("unable to publish build to queue: repository owner %s no longer has write access to repository %s", u.GetName(), r.GetFullName())
 		util.HandleError(c, http.StatusUnauthorized, retErr)
@@ -199,7 +193,7 @@ func CompileAndPublish(
 		// variable to store the pipeline type for the repository
 		pipelineType = r.GetPipelineType()
 		// variable to store updated repository record
-		repo *library.Repo
+		repo *types.Repo
 	)
 
 	// implement a loop to process asynchronous operations with a retry limit
@@ -322,7 +316,7 @@ func CompileAndPublish(
 
 			return false,
 				nil,
-				&types.Item{
+				&internal.Item{
 					Build: b,
 				},
 				nil
@@ -446,7 +440,7 @@ func CompileAndPublish(
 		return false, nil, nil, retErr
 	}
 
-	return true, p, types.ToItem(b, repo, u), nil
+	return true, p, internal.ToItem(b, repo, u), nil
 }
 
 // getPRNumberFromBuild is a helper function to

api/build/create.go

@@ -9,13 +9,13 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/go-vela/server/compiler"
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/queue"
 	"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/library"
 	"github.com/sirupsen/logrus"
 )
@@ -72,7 +72,7 @@ import (
 // CreateBuild represents the API handler to create a build in the configured backend.
 func CreateBuild(c *gin.Context) {
 	// capture middleware values
-	m := c.MustGet("metadata").(*types.Metadata)
+	m := c.MustGet("metadata").(*internal.Metadata)
 	o := org.Retrieve(c)
 	r := repo.Retrieve(c)
 	u := user.Retrieve(c)

api/build/enqueue.go

@@ -8,13 +8,13 @@ import (
 	"time"
 
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/queue"
-	"github.com/go-vela/types"
 	"github.com/sirupsen/logrus"
 )
 
 // Enqueue is a helper function that pushes a queue item (build, repo, user) to the queue.
-func Enqueue(ctx context.Context, queue queue.Service, db database.Interface, item *types.Item, route string) {
+func Enqueue(ctx context.Context, queue queue.Service, db database.Interface, item *internal.Item, route string) {
 	logrus.Infof("Converting queue item to json for build %d for %s", item.Build.GetNumber(), item.Repo.GetFullName())
 
 	byteItem, err := json.Marshal(item)

api/build/get_id.go

@@ -8,6 +8,7 @@ import (
 	"strconv"
 
 	"github.com/gin-gonic/gin"
+	"github.com/go-vela/server/api/types"
 	"github.com/go-vela/server/database"
 	"github.com/go-vela/server/router/middleware/user"
 	"github.com/go-vela/server/scm"
@@ -51,7 +52,7 @@ func GetBuildByID(c *gin.Context) {
 	// Variables that will hold the library types of the build and repo
 	var (
 		b *library.Build
-		r *library.Repo
+		r *types.Repo
 	)
 
 	// Capture user from middleware

api/build/graph.go

@@ -11,13 +11,13 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/go-vela/server/compiler"
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/router/middleware/build"
 	"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"
@@ -142,7 +142,7 @@ func GetBuildGraph(c *gin.Context) {
 	o := org.Retrieve(c)
 	r := repo.Retrieve(c)
 	u := user.Retrieve(c)
-	m := c.MustGet("metadata").(*types.Metadata)
+	m := c.MustGet("metadata").(*internal.Metadata)
 	ctx := c.Request.Context()
 
 	// update engine logger with API metadata

api/build/plan.go

@@ -9,6 +9,7 @@ import (
 
 	"github.com/go-vela/server/api/service"
 	"github.com/go-vela/server/api/step"
+	"github.com/go-vela/server/api/types"
 	"github.com/go-vela/server/database"
 	"github.com/go-vela/types/library"
 	"github.com/go-vela/types/pipeline"
@@ -19,7 +20,7 @@ import (
 // and services, for the build in the configured backend.
 // TODO:
 // - return build and error.
-func PlanBuild(ctx context.Context, database database.Interface, p *pipeline.Build, b *library.Build, r *library.Repo) error {
+func PlanBuild(ctx context.Context, database database.Interface, p *pipeline.Build, b *library.Build, r *types.Repo) error {
 	// update fields in build object
 	b.SetCreated(time.Now().UTC().Unix())
 

api/build/restart.go

@@ -10,6 +10,7 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/go-vela/server/compiler"
 	"github.com/go-vela/server/database"
+	"github.com/go-vela/server/internal"
 	"github.com/go-vela/server/queue"
 	"github.com/go-vela/server/router/middleware/build"
 	"github.com/go-vela/server/router/middleware/claims"
@@ -18,7 +19,6 @@ import (
 	"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/sirupsen/logrus"
 )
@@ -73,7 +73,7 @@ import (
 // RestartBuild represents the API handler to restart an existing build in the configured backend.
 func RestartBuild(c *gin.Context) {
 	// capture middleware values
-	m := c.MustGet("metadata").(*types.Metadata)
+	m := c.MustGet("metadata").(*internal.Metadata)
 	cl := claims.Retrieve(c)
 	b := build.Retrieve(c)
 	o := org.Retrieve(c)

api/build/update.go

@@ -167,15 +167,10 @@
 		b.GetStatus() == constants.StatusFailure ||
 		b.GetStatus() == constants.StatusCanceled ||
 		b.GetStatus() == constants.StatusKilled ||
 		b.GetStatus() == constants.StatusError) && b.GetEvent() != constants.EventSchedule {
-		// send API call to capture the repo owner
-		u, err := database.FromContext(c).GetUser(ctx, r.GetUserID())
-		if err != nil {
-			logrus.Errorf("unable to get owner for build %s: %v", entry, err)
-		}
 
 		// send API call to set the status on the commit
-		err = scm.FromContext(c).Status(ctx, u, b, r.GetOrg(), r.GetName())
+		err = scm.FromContext(c).Status(ctx, r.GetOwner(), b, r.GetOrg(), r.GetName())
 		if err != nil {
 			logrus.Errorf("unable to set commit status for build %s: %v", entry, err)
 		}