schedule_spec_list.go

// Copyright 2023 The Gitea Authors. All rights reserved.
// SPDX-License-Identifier: MIT

package actions

import (
	"context"

	"gitea.dev/models/db"
	repo_model "gitea.dev/models/repo"
	"gitea.dev/modules/container"

	"xorm.io/builder"
)

type SpecList []*ActionScheduleSpec

func (specs SpecList) GetScheduleIDs() []int64 {
	return container.FilterSlice(specs, func(spec *ActionScheduleSpec) (int64, bool) {
		return spec.ScheduleID, true
	})
}

func (specs SpecList) LoadSchedules(ctx context.Context) error {
	scheduleIDs := specs.GetScheduleIDs()
	schedules, err := GetSchedulesMapByIDs(ctx, scheduleIDs)
	if err != nil {
		return err
	}
	for _, spec := range specs {
		spec.Schedule = schedules[spec.ScheduleID]
	}

	repoIDs := specs.GetRepoIDs()
	repos, err := repo_model.GetRepositoriesMapByIDs(ctx, repoIDs)
	if err != nil {
		return err
	}
	for _, spec := range specs {
		spec.Repo = repos[spec.RepoID]
	}

	return nil
}

func (specs SpecList) GetRepoIDs() []int64 {
	return container.FilterSlice(specs, func(spec *ActionScheduleSpec) (int64, bool) {
		return spec.RepoID, true
	})
}

type FindSpecOptions struct {
	db.ListOptions
	Next     int64
	BeforeID int64
}

func (opts FindSpecOptions) ToConds() builder.Cond {
	cond := builder.NewCond().And(builder.Gt{"next": 0}) // an unsatisfiable spec stores a negative "next" and would stay due forever

	if opts.Next > 0 {
		cond = cond.And(builder.Lte{"next": opts.Next})
	}
	if opts.BeforeID > 0 {
		cond = cond.And(builder.Lt{"id": opts.BeforeID})
	}

	return cond
}

func (opts FindSpecOptions) ToOrders() string {
	return "`id` DESC"
}

func FindSpecs(ctx context.Context, opts FindSpecOptions) (SpecList, int64, error) {
	specs, total, err := db.FindAndCount[ActionScheduleSpec](ctx, opts)
	if err != nil {
		return nil, 0, err
	}

	if err := SpecList(specs).LoadSchedules(ctx); err != nil {
		return nil, 0, err
	}
	return specs, total, nil
}