Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423package models
import ( "strings" "testing"
"tangled.org/core/api/tangled" "tangled.org/core/workflow")
func sp(s string) *string { return &s }
func TestBuildCloneStep_PushTrigger(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Submodules: false, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPush), Push: &tangled.Pipeline_PushTriggerData{ NewSha: "abc123", OldSha: "def456", Ref: "refs/heads/main", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
if step.Kind() != StepKindSystem { t.Errorf("Expected StepKindSystem, got %v", step.Kind()) }
if step.Name() != "Clone repository into workspace" { t.Errorf("Expected 'Clone repository into workspace', got '%s'", step.Name()) }
commands := step.Commands() if len(commands) != 4 { t.Errorf("Expected 4 commands, got %d", len(commands)) }
// Verify commands contain expected git operations allCmds := strings.Join(commands, " ") if !strings.Contains(allCmds, "git init") { t.Error("Commands should contain 'git init'") } if !strings.Contains(allCmds, "git remote add origin") { t.Error("Commands should contain 'git remote add origin'") } if !strings.Contains(allCmds, "git fetch") { t.Error("Commands should contain 'git fetch'") } if !strings.Contains(allCmds, "abc123") { t.Error("Commands should contain commit SHA") } if !strings.Contains(allCmds, "git checkout FETCH_HEAD") { t.Error("Commands should contain 'git checkout FETCH_HEAD'") } if !strings.Contains(allCmds, "https://example.com/did:plc:boltless") { t.Error("Commands should contain expected repo URL") }}
func TestBuildCloneStep_PullRequestTrigger(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPullRequest), PullRequest: &tangled.Pipeline_PullRequestTriggerData{ SourceSha: "pr-sha-789", SourceBranch: "feature-branch", TargetBranch: "main", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "pr-sha-789") { t.Error("Commands should contain PR commit SHA") }}
func TestBuildCloneStep_SourceRepo(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Skip: false, }, } sourceRepoDid := "did:plc:fork" tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPullRequest), PullRequest: &tangled.Pipeline_PullRequestTriggerData{ SourceSha: "pr-sha-789", SourceBranch: "feature-branch", TargetBranch: "main", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "fork.example.com", Did: "did:plc:user456", Repo: sp("fork-repo"), RepoDid: &sourceRepoDid, }, SourceRepo: &sourceRepoDid, }
step := BuildCloneStep(twf, tr, false)
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "https://fork.example.com/did:plc:fork") { t.Error("Commands should clone from source repo URL") } if strings.Contains(allCmds, "https://target.example.com/did:plc:target") { t.Error("Commands should not clone from target repo URL when sourceRepo is set") }}
func TestBuildCloneStep_ManualTrigger(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindManual), Manual: &tangled.Pipeline_ManualTriggerData{ Sha: "manualsha456", Inputs: nil, }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
allCmds := strings.Join(step.Commands(), " ") // Should still have basic git commands if !strings.Contains(allCmds, "git init") { t.Error("Commands should contain 'git init'") } if !strings.Contains(allCmds, "git fetch") { t.Error("Commands should contain 'git fetch'") } // Manual triggers now carry an explicit SHA, which the fetch targets if !strings.Contains(allCmds, "manualsha456") { t.Error("Commands should contain the manual trigger SHA") }}
func TestBuildCloneStep_SkipFlag(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Skip: true, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPush), Push: &tangled.Pipeline_PushTriggerData{ NewSha: "abc123", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
// Empty step when skip is true if step.Name() != "" { t.Error("Expected empty step name when Skip is true") } if len(step.Commands()) != 0 { t.Errorf("Expected no commands when Skip is true, got %d commands", len(step.Commands())) }}
func TestBuildCloneStep_DevMode(t *testing.T) { twf := tangled.Pipeline_Workflow{ Engine: "nixery", Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPush), Push: &tangled.Pipeline_PushTriggerData{ NewSha: "abc123", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "knot.tngl.boltless.dev", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, true)
// In dev mode, sslVerify should be disabled allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "git -c http.sslVerify=false fetch") { t.Error("Expected sslVerify to be disabled in dev mode clone commands") }}
func TestBuildCloneStep_DepthAndSubmodules(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 10, Submodules: true, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPush), Push: &tangled.Pipeline_PushTriggerData{ NewSha: "abc123", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "--depth=10") { t.Error("Commands should contain '--depth=10'") }
if !strings.Contains(allCmds, "--recurse-submodules=yes") { t.Error("Commands should contain '--recurse-submodules=yes'") }}
func TestBuildCloneStep_DefaultDepth(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 0, // Default should be 1 Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPush), Push: &tangled.Pipeline_PushTriggerData{ NewSha: "abc123", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "--depth=1") { t.Error("Commands should default to '--depth=1'") }}
func TestBuildCloneStep_NilPushData(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPush), Push: nil, // Nil push data should create error step Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
// Should return an error step if !strings.Contains(step.Name(), "error") { t.Error("Expected error in step name when push data is nil") }
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "Failed to get clone info") { t.Error("Commands should contain error message") } if !strings.Contains(allCmds, "exit 1") { t.Error("Commands should exit with error") }}
func TestBuildCloneStep_NilPRData(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPullRequest), PullRequest: nil, // Nil PR data should create error step Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
// Should return an error step if !strings.Contains(step.Name(), "error") { t.Error("Expected error in step name when pull request data is nil") }
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "Failed to get clone info") { t.Error("Commands should contain error message") }}
func TestBuildCloneStep_UnknownTriggerKind(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: &tangled.Pipeline_CloneOpts{ Depth: 1, Skip: false, }, } tr := tangled.Pipeline_TriggerMetadata{ Kind: "unknown_trigger", Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
// Should return an error step if !strings.Contains(step.Name(), "error") { t.Error("Expected error in step name for unknown trigger kind") }
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "unknown trigger kind") { t.Error("Commands should contain error message about unknown trigger kind") }}
func TestBuildCloneStep_NilCloneOpts(t *testing.T) { twf := tangled.Pipeline_Workflow{ Clone: nil, // Nil clone options should use defaults } tr := tangled.Pipeline_TriggerMetadata{ Kind: string(workflow.TriggerKindPush), Push: &tangled.Pipeline_PushTriggerData{ NewSha: "abc123", }, Repo: &tangled.Pipeline_TriggerRepo{ Knot: "example.com", Did: "did:plc:user123", Repo: sp("my-repo"), RepoDid: sp("did:plc:boltless"), }, }
step := BuildCloneStep(twf, tr, false)
// Should still work with default options if step.Kind() != StepKindSystem { t.Errorf("Expected StepKindSystem, got %v", step.Kind()) }
allCmds := strings.Join(step.Commands(), " ") if !strings.Contains(allCmds, "--depth=1") { t.Error("Commands should default to '--depth=1' when Clone is nil") } if !strings.Contains(allCmds, "git init") { t.Error("Commands should contain 'git init'") }}