Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119package models
import ( "strings"
"github.com/go-git/go-git/v5/plumbing" "tangled.org/core/api/tangled" "tangled.org/core/workflow")
// PipelineEnvVars builds the standard CI environment variables for a pipelinefunc PipelineEnvVars(tr *tangled.Pipeline_TriggerMetadata, pipelineId PipelineId) map[string]string { return PipelineEnvVarsForSource(tr, pipelineId, nil)}
func PipelineEnvVarsForSource(tr *tangled.Pipeline_TriggerMetadata, pipelineId PipelineId, sourceRepo *tangled.Pipeline_TriggerRepo) map[string]string { if tr == nil { return nil }
env := make(map[string]string)
// standard CI env vars env["CI"] = "true"
env["TANGLED_PIPELINE_ID"] = pipelineId.AtUri().String() env["TANGLED_PIPELINE_KIND"] = tr.Kind
if tr.SourceRepo != nil && *tr.SourceRepo != "" { env["TANGLED_PIPELINE_SOURCE"] = *tr.SourceRepo } else if tr.Repo != nil && tr.Repo.RepoDid != nil { env["TANGLED_PIPELINE_SOURCE"] = *tr.Repo.RepoDid }
// prefer source repo, e.g. if this is a wf running on a fork repoInfo := tr.Repo if sourceRepo != nil { repoInfo = sourceRepo } if repoInfo != nil { env["TANGLED_REPO_KNOT"] = repoInfo.Knot env["TANGLED_REPO_DID"] = repoInfo.Did if repoInfo.Repo != nil { env["TANGLED_REPO_NAME"] = *repoInfo.Repo } if repoInfo.RepoDid != nil { env["TANGLED_REPO_REPO_DID"] = *repoInfo.RepoDid } env["TANGLED_REPO_DEFAULT_BRANCH"] = repoInfo.DefaultBranch env["TANGLED_REPO_URL"] = BuildRepoURL(repoInfo) }
switch workflow.TriggerKind(tr.Kind) { case workflow.TriggerKindPush: if tr.Push != nil { refName := plumbing.ReferenceName(tr.Push.Ref) refType := "branch" if refName.IsTag() { refType = "tag" }
env["TANGLED_REF"] = tr.Push.Ref env["TANGLED_REF_NAME"] = refName.Short() env["TANGLED_REF_TYPE"] = refType env["TANGLED_SHA"] = tr.Push.NewSha env["TANGLED_COMMIT_SHA"] = tr.Push.NewSha }
case workflow.TriggerKindPullRequest: if tr.PullRequest != nil { // for PRs, ref is the source branch env["TANGLED_REF"] = "refs/heads/" + tr.PullRequest.SourceBranch env["TANGLED_REF_NAME"] = tr.PullRequest.SourceBranch env["TANGLED_REF_TYPE"] = "branch" env["TANGLED_SHA"] = tr.PullRequest.SourceSha env["TANGLED_COMMIT_SHA"] = tr.PullRequest.SourceSha
// PR-specific env vars env["TANGLED_PIPELINE_SOURCE_BRANCH"] = tr.PullRequest.SourceBranch env["TANGLED_PIPELINE_TARGET_BRANCH"] = tr.PullRequest.TargetBranch env["TANGLED_PR_SOURCE_BRANCH"] = tr.PullRequest.SourceBranch env["TANGLED_PR_TARGET_BRANCH"] = tr.PullRequest.TargetBranch env["TANGLED_PR_SOURCE_SHA"] = tr.PullRequest.SourceSha }
case workflow.TriggerKindManual: if tr.Manual != nil { env["TANGLED_SHA"] = tr.Manual.Sha env["TANGLED_COMMIT_SHA"] = tr.Manual.Sha if tr.Manual.Ref != nil && *tr.Manual.Ref != "" { refName := plumbing.ReferenceName(*tr.Manual.Ref) refType := "branch" if refName.IsTag() { refType = "tag" } env["TANGLED_REF"] = *tr.Manual.Ref env["TANGLED_REF_NAME"] = refName.Short() env["TANGLED_REF_TYPE"] = refType } // include manual inputs if present for _, pair := range tr.Manual.Inputs { env["TANGLED_INPUT_"+strings.ToUpper(pair.Key)] = pair.Value } }
case workflow.TriggerKindSchedule: if tr.Schedule != nil { refName := plumbing.ReferenceName(tr.Schedule.Ref) env["TANGLED_REF"] = tr.Schedule.Ref env["TANGLED_REF_NAME"] = refName.Short() env["TANGLED_REF_TYPE"] = "branch" env["TANGLED_SHA"] = tr.Schedule.Sha env["TANGLED_COMMIT_SHA"] = tr.Schedule.Sha env["TANGLED_SCHEDULED_AT"] = tr.Schedule.ScheduledAt } } return env}