mirror of
https://github.com/go-gitea/gitea.git
synced 2026-05-27 15:25:25 +00:00
71 lines
2.2 KiB
Go
71 lines
2.2 KiB
Go
// Copyright 2026 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package actions
|
|
|
|
import (
|
|
"context"
|
|
"maps"
|
|
"slices"
|
|
|
|
actions_model "gitea.dev/models/actions"
|
|
"gitea.dev/models/db"
|
|
git_model "gitea.dev/models/git"
|
|
repo_model "gitea.dev/models/repo"
|
|
"gitea.dev/modules/log"
|
|
)
|
|
|
|
// CommitActionsStatusMap maps CommitStatus.ID to the live ActionRunJob status
|
|
// for Gitea Actions rows.
|
|
type CommitActionsStatusMap map[int64]actions_model.Status
|
|
|
|
// IconStatus returns the action status name to route the icon through
|
|
// repo/icons/action_status, or "" when the row isn't from Gitea Actions.
|
|
func (m CommitActionsStatusMap) IconStatus(s *git_model.CommitStatus) string {
|
|
if status, ok := m[s.ID]; ok {
|
|
return status.String()
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// GetCommitActionsStatusMap resolves the live ActionRunJob.Status for every
|
|
// CommitStatus row backed by Gitea Actions. Rows from other sources (external
|
|
// CIs, API) are left untouched and rendered from their stored State.
|
|
func GetCommitActionsStatusMap(ctx context.Context, statuses []*git_model.CommitStatus) CommitActionsStatusMap {
|
|
if len(statuses) == 0 {
|
|
return nil
|
|
}
|
|
statusByJobID := make(map[int64]*git_model.CommitStatus)
|
|
repoByID := make(map[int64]*repo_model.Repository)
|
|
for _, status := range statuses {
|
|
if status == nil || status.TargetURL == "" {
|
|
continue
|
|
}
|
|
if status.Repo == nil {
|
|
status.Repo = repoByID[status.RepoID]
|
|
}
|
|
// ParseGiteaActionsTargetURL lazy-loads status.Repo on miss; cache the
|
|
// outcome so later entries with the same RepoID skip that load.
|
|
_, jobID, ok := status.ParseGiteaActionsTargetURL(ctx)
|
|
repoByID[status.RepoID] = status.Repo
|
|
if ok {
|
|
statusByJobID[jobID] = status
|
|
}
|
|
}
|
|
if len(statusByJobID) == 0 {
|
|
return nil
|
|
}
|
|
jobs := make(map[int64]*actions_model.ActionRunJob, len(statusByJobID))
|
|
if err := db.GetEngine(ctx).In("id", slices.Collect(maps.Keys(statusByJobID))).Cols("id", "status").Find(&jobs); err != nil {
|
|
log.Error("db.Find: failed to find action run jobs: %v", err)
|
|
return nil
|
|
}
|
|
info := make(CommitActionsStatusMap, len(jobs))
|
|
for jobID, status := range statusByJobID {
|
|
if job, ok := jobs[jobID]; ok {
|
|
info[status.ID] = job.Status
|
|
}
|
|
}
|
|
return info
|
|
}
|