Something went wrong. Try again.
forked from tangled.org/core
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172package models
import ( "fmt" "strings"
"tangled.org/core/hostutil" "tangled.org/core/workflow")
type CloneStep struct { name string kind StepKind commands []string}
func (s CloneStep) Name() string { return s.name}
func (s CloneStep) Commands() []string { return s.commands}
func (s CloneStep) Command() string { return strings.Join(s.commands, "\n")}
func (s CloneStep) Kind() StepKind { return s.kind}
// BuildCloneStep generates git clone commands.// The caller must ensure the current working directory is set to the desired// workspace directory before executing these commands.//// The generated commands are:// - git init --object-format=sha1|sha256// - git remote add origin <url>// - git fetch --depth=<d> --recurse-submodules=<yes|no> <sha>// - git checkout FETCH_HEAD//// Supports all trigger types (push, PR, manual) and clone options.func BuildCloneStep(twf workflow.WorkflowSpec, tr workflow.TriggerMetadata, dev bool) CloneStep { if twf.Clone != nil && twf.Clone.Skip { return CloneStep{} }
commitSHA, err := ExtractCommitSHA(tr) if err != nil { return CloneStep{ kind: StepKindSystem, name: "Clone repository into workspace (error)", commands: []string{fmt.Sprintf("echo 'Failed to get clone info: %s' && exit 1", err.Error())}, } }
var objectFormat string switch len(commitSHA) { case 40: objectFormat = "sha1" case 64: objectFormat = "sha256" default: return CloneStep{ kind: StepKindSystem, name: "Clone repository into workspace (error)", commands: []string{"echo 'Failed to determine repo object format' && exit 1"}, } }
repoURL := BuildRepoURL(tr.Repo)
var cloneOpts workflow.CloneSpec if twf.Clone != nil { cloneOpts = *twf.Clone } fetchArgs := buildFetchArgs(cloneOpts, commitSHA)
// In dev mode we point at Caddy via host-gateway with a self-signed cert, // so skip the TLS check for the fetch call. fetchCmd := "git fetch" if dev { fetchCmd = "git -c http.sslVerify=false fetch" }
return CloneStep{ kind: StepKindSystem, name: "Clone repository into workspace", commands: []string{ fmt.Sprintf("git init --object-format=%s", objectFormat), fmt.Sprintf("git remote add origin %s", repoURL), fmt.Sprintf("%s %s", fetchCmd, strings.Join(fetchArgs, " ")), "git checkout FETCH_HEAD", }, }}
func ExtractCommitSHA(tr workflow.TriggerMetadata) (string, error) { switch workflow.TriggerKind(tr.Kind) { case workflow.TriggerKindPush: if tr.Push == nil { return "", fmt.Errorf("push trigger metadata is nil") } return tr.Push.NewSha, nil
case workflow.TriggerKindPullRequest: if tr.PullRequest == nil { return "", fmt.Errorf("pull request trigger metadata is nil") } return tr.PullRequest.SourceSha, nil
case workflow.TriggerKindManual: if tr.Manual == nil { return "", fmt.Errorf("manual trigger metadata is nil") } return tr.Manual.Sha, nil
case workflow.TriggerKindSchedule: if tr.Schedule == nil { return "", fmt.Errorf("schedule trigger metadata is nil") } return tr.Schedule.Sha, nil
default: return "", fmt.Errorf("unknown trigger kind: %s", tr.Kind) }}
// BuildRepoURL constructs the repository URL from repo metadata.func BuildRepoURL(repo *workflow.TriggerRepo) string { if repo == nil || repo.RepoDid == nil { return "" } host, noSSL, _ := hostutil.ParseHostname(repo.Knot) scheme := "https" if noSSL { scheme = "http" } return fmt.Sprintf("%s://%s/%s", scheme, host, *repo.RepoDid)}
// buildFetchArgs constructs the arguments for git fetch based on clone optionsfunc buildFetchArgs(clone workflow.CloneSpec, sha string) []string { args := []string{}
// Set fetch depth (default to 1 for shallow clone) depth := clone.Depth if depth == 0 { depth = 1 } args = append(args, fmt.Sprintf("--depth=%d", depth))
// Add submodules if requested if clone.Submodules { args = append(args, "--recurse-submodules=yes") }
// Add tags if requested if clone.Tags { args = append(args, "--tags") }
// Add remote and SHA args = append(args, "origin") if sha != "" { args = append(args, sha) }
return args}