1// SPDX-License-Identifier: AGPL-3.0-or-later
2
3package usecase
4
5import (
6 "context"
7
8 "bnema.dev/ermite-actions/expr"
9 "bnema.dev/ermite-actions/template"
10 "bnema.dev/ermite-actions/workflow"
11 "bnema.dev/ermite/internal/domain"
12)
13
14// AuthorOf exposes authorOf to the tests.
15func AuthorOf(p domain.Principal) string { return authorOf(p) }
16
17// Sweep exposes the daily sweep to the tests.
18func (c *CI) Sweep(ctx context.Context) { c.sweep(ctx) }
19
20// RunTitle gives the title of a run as startRun sets it: the evaluated
21// run-name, else commitTitle.
22func (c *CI) RunTitle(ctx context.Context, wf *workflow.Workflow, githubJSON, commitTitle string) string {
23 if name, ok := c.evalRunName(ctx, wf, githubJSON, expr.NewDictionary()); ok {
24 return name
25 }
26 return commitTitle
27}
28
29// CheckRunID exposes checkRunID to the tests.
30func CheckRunID(ctx context.Context, run domain.CIRun, index, combo int) int64 {
31 return checkRunID(ctx, run, index, combo)
32}
33
34// SecretUse is the result of SecretsUsedBy.
35type SecretUse = secretUse
36
37// SecretsUsedBy exposes secretsUsedBy to the tests.
38func SecretsUsedBy(workflowYAML, jobID string) SecretUse {
39 return secretsUsedBy(workflowYAML, jobID)
40}
41
42// SecretWalks is the number of YAML walks made so far.
43func SecretWalks() int64 { return secretWalks.Load() }
44
45// SecretUseCache is a wfCache exposed to the tests.
46type SecretUseCache struct{ c *wfCache }
47
48// NewSecretUseCache builds a cache for up to max runs.
49func NewSecretUseCache(max int) *SecretUseCache { return &SecretUseCache{newWfCache(max)} }
50
51// Use is wfCache.secretUse.
52func (s *SecretUseCache) Use(runID int64, yaml, jobKey string) SecretUse {
53 return s.c.secretUse(runID, yaml, jobKey)
54}
55
56// Drop is wfCache.drop.
57func (s *SecretUseCache) Drop(runID int64) { s.c.drop(runID) }
58
59// EvalConcurrency exposes evalConcurrency to the tests.
60func EvalConcurrency(ctx context.Context, tok template.Token, env template.Env) (domain.CIConcurrency, error) {
61 return evalConcurrency(ctx, tok, env)
62}
63
64// MatchPullRequest exposes the pull_request filter to the tests.
65func MatchPullRequest(wf *workflow.Workflow, action, base string, files []string, truncated bool) bool {
66 return matchPullRequest(wf, action, base, files, truncated)
67}
68
69// MatchWorkflowRun exposes the workflow_run filter to the tests.
70func MatchWorkflowRun(wf *workflow.Workflow, name, action, headBranch string) bool {
71 return matchWorkflowRun(wf, name, action, headBranch)
72}
73
74// ResolveDispatchInputs exposes resolveDispatchInputs to the tests.
75func ResolveDispatchInputs(defs []workflow.Input, given map[string]string) (map[string]string, error) {
76 return resolveDispatchInputs(defs, given)
77}
78
79// PullFilesLink exposes the Link header of the files endpoint to the tests.
80func PullFilesLink(base string, page, perPage, total int) string {
81 return pullFilesLink(base, page, perPage, total)
82}
83
84// FilePatch exposes the patch text of a file of the files endpoint to the tests.
85func FilePatch(f domain.FileDiff) (string, bool) { return filePatch(f) }