configstore: add ability to org members to restart stop cancel a proj…

…ect run update project type add MembersCanPerformRunActions
agola-io · Oct 12, 2023 · 90db6db · 90db6db
1 parent d34a652
commit 90db6db
Show file tree

Hide file tree

Showing 23 changed files with 1,255 additions and 143 deletions.
diff --git a/internal/services/configstore/action/project.go b/internal/services/configstore/action/project.go
@@ -93,6 +93,8 @@ type CreateUpdateProjectRequest struct {
 	SkipSSHHostKeyCheck        bool
 	PassVarsToForkedPR         bool
 	DefaultBranch              string
+	//MembersCanPerformRunActions define if users of the organization can restart stop cancel a project run
+	MembersCanPerformRunActions bool
 }
 
 func (h *ActionHandler) CreateProject(ctx context.Context, req *CreateUpdateProjectRequest) (*types.Project, error) {
@@ -163,6 +165,7 @@ func (h *ActionHandler) CreateProject(ctx context.Context, req *CreateUpdateProj
 		project.SkipSSHHostKeyCheck = req.SkipSSHHostKeyCheck
 		project.PassVarsToForkedPR = req.PassVarsToForkedPR
 		project.DefaultBranch = req.DefaultBranch
+		project.MembersCanPerformRunActions = req.MembersCanPerformRunActions
 
 		// generate the Secret and the WebhookSecret
 		// TODO(sgotti) move this to the gateway?
@@ -273,6 +276,7 @@ func (h *ActionHandler) UpdateProject(ctx context.Context, curProjectRef string,
 		project.SkipSSHHostKeyCheck = req.SkipSSHHostKeyCheck
 		project.PassVarsToForkedPR = req.PassVarsToForkedPR
 		project.DefaultBranch = req.DefaultBranch
+		project.MembersCanPerformRunActions = req.MembersCanPerformRunActions
 
 		if err := h.d.UpdateProject(tx, project); err != nil {
 			return errors.WithStack(err)

diff --git a/internal/services/configstore/api/project.go b/internal/services/configstore/api/project.go
@@ -171,18 +171,19 @@ func (h *CreateProjectHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
 	}
 
 	areq := &action.CreateUpdateProjectRequest{
-		Name:                       req.Name,
-		Parent:                     req.Parent,
-		Visibility:                 req.Visibility,
-		RemoteRepositoryConfigType: req.RemoteRepositoryConfigType,
-		RemoteSourceID:             req.RemoteSourceID,
-		LinkedAccountID:            req.LinkedAccountID,
-		RepositoryID:               req.RepositoryID,
-		RepositoryPath:             req.RepositoryPath,
-		SSHPrivateKey:              req.SSHPrivateKey,
-		SkipSSHHostKeyCheck:        req.SkipSSHHostKeyCheck,
-		PassVarsToForkedPR:         req.PassVarsToForkedPR,
-		DefaultBranch:              req.DefaultBranch,
+		Name:                        req.Name,
+		Parent:                      req.Parent,
+		Visibility:                  req.Visibility,
+		RemoteRepositoryConfigType:  req.RemoteRepositoryConfigType,
+		RemoteSourceID:              req.RemoteSourceID,
+		LinkedAccountID:             req.LinkedAccountID,
+		RepositoryID:                req.RepositoryID,
+		RepositoryPath:              req.RepositoryPath,
+		SSHPrivateKey:               req.SSHPrivateKey,
+		SkipSSHHostKeyCheck:         req.SkipSSHHostKeyCheck,
+		PassVarsToForkedPR:          req.PassVarsToForkedPR,
+		DefaultBranch:               req.DefaultBranch,
+		MembersCanPerformRunActions: req.MembersCanPerformRunActions,
 	}
 
 	project, err := h.ah.CreateProject(ctx, areq)
@@ -230,18 +231,19 @@ func (h *UpdateProjectHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
 	}
 
 	areq := &action.CreateUpdateProjectRequest{
-		Name:                       req.Name,
-		Parent:                     req.Parent,
-		Visibility:                 req.Visibility,
-		RemoteRepositoryConfigType: req.RemoteRepositoryConfigType,
-		RemoteSourceID:             req.RemoteSourceID,
-		LinkedAccountID:            req.LinkedAccountID,
-		RepositoryID:               req.RepositoryID,
-		RepositoryPath:             req.RepositoryPath,
-		SSHPrivateKey:              req.SSHPrivateKey,
-		SkipSSHHostKeyCheck:        req.SkipSSHHostKeyCheck,
-		PassVarsToForkedPR:         req.PassVarsToForkedPR,
-		DefaultBranch:              req.DefaultBranch,
+		Name:                        req.Name,
+		Parent:                      req.Parent,
+		Visibility:                  req.Visibility,
+		RemoteRepositoryConfigType:  req.RemoteRepositoryConfigType,
+		RemoteSourceID:              req.RemoteSourceID,
+		LinkedAccountID:             req.LinkedAccountID,
+		RepositoryID:                req.RepositoryID,
+		RepositoryPath:              req.RepositoryPath,
+		SSHPrivateKey:               req.SSHPrivateKey,
+		SkipSSHHostKeyCheck:         req.SkipSSHHostKeyCheck,
+		PassVarsToForkedPR:          req.PassVarsToForkedPR,
+		DefaultBranch:               req.DefaultBranch,
+		MembersCanPerformRunActions: req.MembersCanPerformRunActions,
 	}
 
 	project, err := h.ah.UpdateProject(ctx, projectRef, areq)

diff --git a/internal/services/configstore/db/ddl.go b/internal/services/configstore/db/ddl.go
diff --git a/internal/services/configstore/db/dml.go b/internal/services/configstore/db/dml.go