Method Run

util/gitutil/cli.go:204–318

Run executes a git command with the given args.

(ctx context.Context, args ...string)

// Run executes a git command with the given args.
func (cli *GitCLI) Run(ctx context.Context, args ...string) (_ []byte, rerr error) {
	ctx, span := Tracer(ctx).Start(ctx, strings.Join(append([]string{"git"}, args...), " "), trace.WithAttributes(
		attribute.Bool(telemetry.UIEncapsulatedAttr, true),
	))
	defer telemetry.EndWithCause(span, &rerr)

	stdio := telemetry.SpanStdio(ctx, InstrumentationLibrary)
	defer stdio.Close()

	gitBinary := "git"
	if cli.git != "" {
		gitBinary = cli.git
	}
	proxyEnvVars := [...]string{
		"HTTP_PROXY", "HTTPS_PROXY", "NO_PROXY", "ALL_PROXY",
		"http_proxy", "https_proxy", "no_proxy", "all_proxy",
	}

	var cmd *exec.Cmd
	if cli.exec == nil {
		cmd = exec.CommandContext(ctx, gitBinary)
	} else {
		cmd = exec.Command(gitBinary)
	}

	cmd.Dir = cli.dir
	if cmd.Dir == "" {
		cmd.Dir = cli.workTree
	}

	// Block sneaky repositories from using repos from the filesystem as submodules.
	cmd.Args = append(cmd.Args, "-c", "protocol.file.allow=user")
	if cli.workTree != "" {
		cmd.Args = append(cmd.Args, "--work-tree", cli.workTree)
	}
	if cli.gitDir != "" {
		cmd.Args = append(cmd.Args, "--git-dir", cli.gitDir)
	}
	cmd.Args = append(cmd.Args, cli.args...)
	cmd.Args = append(cmd.Args, args...)

	buf := bytes.NewBuffer(nil)
	errbuf := bytes.NewBuffer(nil)
	cmd.Stdin = nil
	cmd.Stdout = io.MultiWriter(buf, stdio.Stdout)
	cmd.Stderr = io.MultiWriter(errbuf, stdio.Stderr)
	if cli.streams != nil {
		stdout, stderr, flush := cli.streams(ctx)
		if stdout != nil {
			cmd.Stdout = io.MultiWriter(stdout, cmd.Stdout)
		}
		if stderr != nil {
			cmd.Stderr = io.MultiWriter(stderr, cmd.Stderr)
		}
		defer stdout.Close()
		defer stderr.Close()
		defer func() {
			if rerr != nil {