mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2025-02-23 03:45:47 -05:00
chore: Remove ScheduleList
- Introduced in0d55f64e6c
and removed indf1e7d0067
.
This commit is contained in:
parent
5423e22aeb
commit
581a2ca341
3 changed files with 24 additions and 89 deletions
|
@ -16,12 +16,6 @@ code.gitea.io/gitea/models
|
||||||
IsErrSHANotFound
|
IsErrSHANotFound
|
||||||
IsErrMergeDivergingFastForwardOnly
|
IsErrMergeDivergingFastForwardOnly
|
||||||
|
|
||||||
code.gitea.io/gitea/models/actions
|
|
||||||
ScheduleList.GetUserIDs
|
|
||||||
ScheduleList.GetRepoIDs
|
|
||||||
ScheduleList.LoadTriggerUser
|
|
||||||
ScheduleList.LoadRepos
|
|
||||||
|
|
||||||
code.gitea.io/gitea/models/auth
|
code.gitea.io/gitea/models/auth
|
||||||
WebAuthnCredentials
|
WebAuthnCredentials
|
||||||
|
|
||||||
|
|
|
@ -14,6 +14,8 @@ import (
|
||||||
"code.gitea.io/gitea/modules/timeutil"
|
"code.gitea.io/gitea/modules/timeutil"
|
||||||
"code.gitea.io/gitea/modules/util"
|
"code.gitea.io/gitea/modules/util"
|
||||||
webhook_module "code.gitea.io/gitea/modules/webhook"
|
webhook_module "code.gitea.io/gitea/modules/webhook"
|
||||||
|
|
||||||
|
"xorm.io/builder"
|
||||||
)
|
)
|
||||||
|
|
||||||
// ActionSchedule represents a schedule of a workflow file
|
// ActionSchedule represents a schedule of a workflow file
|
||||||
|
@ -140,3 +142,25 @@ func CleanRepoScheduleTasks(ctx context.Context, repo *repo_model.Repository, ca
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type FindScheduleOptions struct {
|
||||||
|
db.ListOptions
|
||||||
|
RepoID int64
|
||||||
|
OwnerID int64
|
||||||
|
}
|
||||||
|
|
||||||
|
func (opts FindScheduleOptions) ToConds() builder.Cond {
|
||||||
|
cond := builder.NewCond()
|
||||||
|
if opts.RepoID > 0 {
|
||||||
|
cond = cond.And(builder.Eq{"repo_id": opts.RepoID})
|
||||||
|
}
|
||||||
|
if opts.OwnerID > 0 {
|
||||||
|
cond = cond.And(builder.Eq{"owner_id": opts.OwnerID})
|
||||||
|
}
|
||||||
|
|
||||||
|
return cond
|
||||||
|
}
|
||||||
|
|
||||||
|
func (opts FindScheduleOptions) ToOrders() string {
|
||||||
|
return "`id` DESC"
|
||||||
|
}
|
||||||
|
|
|
@ -1,83 +0,0 @@
|
||||||
// Copyright 2023 The Gitea Authors. All rights reserved.
|
|
||||||
// SPDX-License-Identifier: MIT
|
|
||||||
|
|
||||||
package actions
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
|
|
||||||
"code.gitea.io/gitea/models/db"
|
|
||||||
repo_model "code.gitea.io/gitea/models/repo"
|
|
||||||
user_model "code.gitea.io/gitea/models/user"
|
|
||||||
"code.gitea.io/gitea/modules/container"
|
|
||||||
|
|
||||||
"xorm.io/builder"
|
|
||||||
)
|
|
||||||
|
|
||||||
type ScheduleList []*ActionSchedule
|
|
||||||
|
|
||||||
// GetUserIDs returns a slice of user's id
|
|
||||||
func (schedules ScheduleList) GetUserIDs() []int64 {
|
|
||||||
return container.FilterSlice(schedules, func(schedule *ActionSchedule) (int64, bool) {
|
|
||||||
return schedule.TriggerUserID, true
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
func (schedules ScheduleList) GetRepoIDs() []int64 {
|
|
||||||
return container.FilterSlice(schedules, func(schedule *ActionSchedule) (int64, bool) {
|
|
||||||
return schedule.RepoID, true
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
func (schedules ScheduleList) LoadTriggerUser(ctx context.Context) error {
|
|
||||||
userIDs := schedules.GetUserIDs()
|
|
||||||
users := make(map[int64]*user_model.User, len(userIDs))
|
|
||||||
if err := db.GetEngine(ctx).In("id", userIDs).Find(&users); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
for _, schedule := range schedules {
|
|
||||||
if schedule.TriggerUserID == user_model.ActionsUserID {
|
|
||||||
schedule.TriggerUser = user_model.NewActionsUser()
|
|
||||||
} else {
|
|
||||||
schedule.TriggerUser = users[schedule.TriggerUserID]
|
|
||||||
if schedule.TriggerUser == nil {
|
|
||||||
schedule.TriggerUser = user_model.NewGhostUser()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (schedules ScheduleList) LoadRepos(ctx context.Context) error {
|
|
||||||
repoIDs := schedules.GetRepoIDs()
|
|
||||||
repos, err := repo_model.GetRepositoriesMapByIDs(ctx, repoIDs)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
for _, schedule := range schedules {
|
|
||||||
schedule.Repo = repos[schedule.RepoID]
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
type FindScheduleOptions struct {
|
|
||||||
db.ListOptions
|
|
||||||
RepoID int64
|
|
||||||
OwnerID int64
|
|
||||||
}
|
|
||||||
|
|
||||||
func (opts FindScheduleOptions) ToConds() builder.Cond {
|
|
||||||
cond := builder.NewCond()
|
|
||||||
if opts.RepoID > 0 {
|
|
||||||
cond = cond.And(builder.Eq{"repo_id": opts.RepoID})
|
|
||||||
}
|
|
||||||
if opts.OwnerID > 0 {
|
|
||||||
cond = cond.And(builder.Eq{"owner_id": opts.OwnerID})
|
|
||||||
}
|
|
||||||
|
|
||||||
return cond
|
|
||||||
}
|
|
||||||
|
|
||||||
func (opts FindScheduleOptions) ToOrders() string {
|
|
||||||
return "`id` DESC"
|
|
||||||
}
|
|
Loading…
Add table
Reference in a new issue