summaryrefslogtreecommitdiffstats
path: root/routers
diff options
context:
space:
mode:
authoryp05327 <576951401@qq.com>2023-04-19 21:51:20 +0900
committerGitHub <noreply@github.com>2023-04-19 20:51:20 +0800
commit01214c8ada993bf5f54a4149979d140443d69410 (patch)
tree17623b98c522109f794faef46c77a8c6a8335ab5 /routers
parent5e7543fcf441afb30aba6188edac754ef32b9ac3 (diff)
downloadgitea-01214c8ada993bf5f54a4149979d140443d69410.tar.gz
gitea-01214c8ada993bf5f54a4149979d140443d69410.zip
Add runner check in repo action page (#24124)
![image](https://user-images.githubusercontent.com/18380374/232996647-13c2b9f1-c9e9-42d9-acbf-8a6e16b175a6.png) Maybe we can also add online runner check? e.g. : Target runner is offline.
Diffstat (limited to 'routers')
-rw-r--r--routers/web/repo/actions/actions.go46
1 files changed, 40 insertions, 6 deletions
diff --git a/routers/web/repo/actions/actions.go b/routers/web/repo/actions/actions.go
index dd2dc55bd5..fc7ac2d714 100644
--- a/routers/web/repo/actions/actions.go
+++ b/routers/web/repo/actions/actions.go
@@ -4,6 +4,7 @@
package actions
import (
+ "bytes"
"net/http"
actions_model "code.gitea.io/gitea/models/actions"
@@ -11,11 +12,14 @@ import (
"code.gitea.io/gitea/models/unit"
"code.gitea.io/gitea/modules/actions"
"code.gitea.io/gitea/modules/base"
+ "code.gitea.io/gitea/modules/container"
"code.gitea.io/gitea/modules/context"
"code.gitea.io/gitea/modules/git"
"code.gitea.io/gitea/modules/setting"
"code.gitea.io/gitea/modules/util"
"code.gitea.io/gitea/services/convert"
+
+ "github.com/nektos/act/pkg/model"
)
const (
@@ -24,9 +28,8 @@ const (
)
type Workflow struct {
- Entry git.TreeEntry
- IsInvalid bool
- ErrMsg string
+ Entry git.TreeEntry
+ ErrMsg string
}
// MustEnableActions check if actions are enabled in settings
@@ -73,6 +76,23 @@ func List(ctx *context.Context) {
ctx.Error(http.StatusInternalServerError, err.Error())
return
}
+
+ // Get all runner labels
+ opts := actions_model.FindRunnerOptions{
+ RepoID: ctx.Repo.Repository.ID,
+ WithAvailable: true,
+ }
+ runners, err := actions_model.FindRunners(ctx, opts)
+ if err != nil {
+ ctx.ServerError("FindRunners", err)
+ return
+ }
+ allRunnerLabels := make(container.Set[string])
+ for _, r := range runners {
+ allRunnerLabels.AddMultiple(r.AgentLabels...)
+ allRunnerLabels.AddMultiple(r.CustomLabels...)
+ }
+
workflows = make([]Workflow, 0, len(entries))
for _, entry := range entries {
workflow := Workflow{Entry: *entry}
@@ -81,10 +101,24 @@ func List(ctx *context.Context) {
ctx.Error(http.StatusInternalServerError, err.Error())
return
}
- _, err = actions.GetEventsFromContent(content)
+ wf, err := model.ReadWorkflow(bytes.NewReader(content))
if err != nil {
- workflow.IsInvalid = true
- workflow.ErrMsg = err.Error()
+ workflow.ErrMsg = ctx.Locale.Tr("actions.runs.invalid_workflow_helper", err.Error())
+ workflows = append(workflows, workflow)
+ continue
+ }
+ // Check whether have matching runner
+ for _, j := range wf.Jobs {
+ runsOnList := j.RunsOn()
+ for _, ro := range runsOnList {
+ if !allRunnerLabels.Contains(ro) {
+ workflow.ErrMsg = ctx.Locale.Tr("actions.runs.no_matching_runner_helper", ro)
+ break
+ }
+ }
+ if workflow.ErrMsg != "" {
+ break
+ }
}
workflows = append(workflows, workflow)
}