Function runGitFetchUpstream

cli/flow/main.go:3806–3867

(ctx *snap.Context)

}

func runGitFetchUpstream(ctx *snap.Context) error {
	if err := ensureGitRepository(); err != nil {
		return err
	}

	remote := "upstream"
	remoteSpecified := false
	fetchAll := false
	prune := true

	for i := 0; i < ctx.NArgs(); i++ {
		arg := strings.TrimSpace(ctx.Arg(i))
		if arg == "" {
			continue
		}

		switch {
		case arg == "--all":
			fetchAll = true
		case arg == "--no-prune":
			prune = false
		case strings.HasPrefix(arg, "--"):
			fmt.Fprintf(ctx.Stderr(), "Usage: %s gitFetchUpstream [--all] [--no-prune] [remote]\n", commandName)
			return fmt.Errorf("unknown flag %q", arg)
		default:
			remoteSpecified = true
			remote = arg
		}
	}

	if fetchAll && remoteSpecified {
		fmt.Fprintf(ctx.Stderr(), "Usage: %s gitFetchUpstream [--all] [--no-prune] [remote]\n", commandName)
		return fmt.Errorf("cannot specify a remote when using --all")
	}

	args := []string{"fetch"}
	var summary string
	if fetchAll {
		args = append(args, "--all")
		summary = "all remotes"
	} else {
		exists, _, err := gitRemoteState(remote)
		if err != nil {
			return err
		}
		if !exists {
			return fmt.Errorf("git remote %q not found", remote)
		}
		args = append(args, remote)
		summary = remote
	}
	if prune {
		args = append(args, "--prune")
	}

	if err := runGitCommandStreaming(ctx, args...); err != nil {
		return fmt.Errorf("git %s: %w", strings.Join(args, " "), err)
	}