package spindle
import (
"context"
"errors"
"testing"
"time"
"tangled.org/core/spindle/models"
pipelinecodec "tangled.org/core/spindle/pipeline"
"tangled.org/core/spindle/xrpc"
"tangled.org/core/workflow"
)
func (e *pushEnv) enqueue(t *testing.T) {
t.Helper()
repoDid := testRepoDid.String()
actor := testBob.String()
raw := workflow.PipelineSpec{
TriggerMetadata: &workflow.TriggerMetadata{
Kind: string(workflow.TriggerKindPush),
Repo: &workflow.TriggerRepo{Knot: e.w.knotRef().Host, RepoDid: &repoDid, Did: testOwner.String()},
Push: &workflow.PushTriggerData{Ref: "refs/heads/main", OldSha: zeroSha, NewSha: testHexNew},
Actor: &actor,
},
Workflows: []*workflow.WorkflowSpec{{Name: "ci.yml"}},
}
record, err := pipelinecodec.FromTangled(models.PipelineId("late"), time.Now(), raw)
if err != nil {
t.Fatal(err)
}
// error ignored on purpose, the pipeline count is what matters
_ = e.n.s.processPipeline(context.Background(), testRepoDid, raw, record, nil, false)
}
func TestPauseThatLandsBeforeTheEnqueueStartsNothing(t *testing.T) {
e := newClosedPushEnv(t, false, listOwner)
e.disallow(t)
e.enqueue(t)
e.wantPipelines(t, 0, "for an owner who was paused before the insert")
}
func TestWipeThatLandsBeforeTheEnqueueLeavesNoOrphan(t *testing.T) {
e := newPushEnv(t)
if err := e.n.s.WipeRepo(context.Background(), testRepoDid, "test"); err != nil {
t.Fatal(err)
}
e.enqueue(t)
e.wantPipelines(t, 0, "for a repo that was wiped before the insert")
var jobs int
if err := e.n.s.db.QueryRow("select count(*) from jobs where repo_did = ?", testRepoDid.String()).Scan(&jobs); err != nil || jobs != 0 {
t.Fatalf("%d jobs for a wiped repo, err %v, want none", jobs, err)
}
}
func TestPausedManualTriggerRefusesBeforeAnyCheckout(t *testing.T) {
e := newClosedPushEnv(t, false, listOwner)
sha := e.repo.commit(t)
e.disallow(t)
fetches := e.w.gitFetches.Load()
_, err := e.n.s.TriggerManual(context.Background(), testBob, testRepoDid, sha, "", nil, nil)
if !errors.Is(err, xrpc.ErrOwnerPaused) {
t.Fatalf("err = %v, want ErrOwnerPaused", err)
}
if got := e.w.gitFetches.Load(); got != fetches {
t.Fatalf("%d git fetches for a paused manual trigger, want none", got-fetches)
}
}