Function runGitMirrorPull

cli/flow/main.go:4149–4211

(ctx *snap.Context, opts gitMirrorOptions)

}

func runGitMirrorPull(ctx *snap.Context, opts gitMirrorOptions) error {
	remote, err := resolveGitMirrorRemote(opts.remote)
	if err != nil {
		return err
	}
	branch, err := resolveGitMirrorBranch(opts.branch)
	if err != nil {
		return err
	}
	strategy := strings.ToLower(strings.TrimSpace(opts.strategy))
	if strategy == "" {
		strategy = "rebase"
	}

	remoteRef, err := fetchMirrorBranch(ctx, remote, branch)
	if err != nil {
		return err
	}

	localRef := fmt.Sprintf("refs/heads/%s", branch)
	localExists, err := gitRefExists(localRef)
	if err != nil {
		return fmt.Errorf("check local branch %s: %w", branch, err)
	}
	if !localExists {
		if err := runGitCommandStreaming(ctx, "checkout", "-b", branch, remoteRef); err != nil {
			return fmt.Errorf("git checkout -b %s %s: %w", branch, remoteRef, err)
		}
		fmt.Fprintf(ctx.Stdout(), "✔️ Created local branch %s from %s\n", branch, remoteRef)
		return nil
	}

	current, err := currentGitBranch()
	if err != nil {
		return err
	}
	if current != branch {
		if err := runGitCommandStreaming(ctx, "checkout", branch); err != nil {
			return fmt.Errorf("git checkout %s: %w", branch, err)
		}
	}

	switch strategy {
	case "rebase":
		if err := runGitCommandStreaming(ctx, "rebase", remoteRef); err != nil {
			return fmt.Errorf("git rebase %s: %w", remoteRef, err)
		}
	case "merge":
		if err := runGitCommandStreaming(ctx, "merge", "--no-ff", remoteRef); err != nil {
			return fmt.Errorf("git merge --no-ff %s: %w", remoteRef, err)
		}
	case "ff-only":
		if err := runGitCommandStreaming(ctx, "merge", "--ff-only", remoteRef); err != nil {
			return fmt.Errorf("git merge --ff-only %s: %w", remoteRef, err)
		}
	default:
		printGitMirrorUsage(ctx.Stderr())
		return fmt.Errorf("unsupported --strategy %q", strategy)