Method propagateToWorktree

repository/git.go:211–254

(ctx context.Context, env *environment.Environment, explanation string)

}

func (r *Repository) propagateToWorktree(ctx context.Context, env *environment.Environment, explanation string) (rerr error) {
	slog.Info("Propagating to worktree...",
		"environment.id", env.ID,
		"workdir", env.State.Config.Workdir,
		"id", env.ID)
	defer func() {
		slog.Info("Propagating to worktree... (DONE)",
			"environment.id", env.ID,
			"workdir", env.State.Config.Workdir,
			"id", env.ID,
			"err", rerr)
	}()

	if err := r.exportEnvironment(ctx, env); err != nil {
		return err
	}

	worktreePath, err := r.WorktreePath(env.ID)
	if err != nil {
		return fmt.Errorf("failed to get worktree path: %w", err)
	}

	if err := r.commitWorktreeChanges(ctx, worktreePath, explanation); err != nil {
		return fmt.Errorf("failed to commit worktree changes: %w", err)
	}

	if err := r.saveState(ctx, env); err != nil {
		return fmt.Errorf("failed to add notes: %w", err)
	}

	if err := r.lockManager.WithLock(ctx, LockTypeUserRepo, func() error {
		slog.Info("Fetching container-use remote in source repository")
		_, err := RunGitCommand(ctx, r.userRepoPath, "fetch", containerUseRemote, env.ID)
		return err
	}); err != nil {
		return err
	}

	if err := r.propagateGitNotes(ctx, gitNotesStateRef); err != nil {
		return err
	}

	return nil
}

func (r *Repository) exportEnvironment(ctx context.Context, env *environment.Environment) error {
	worktreePointer := fmt.Sprintf("gitdir: %s", filepath.Join(r.forkRepoPath, "worktrees", env.ID))