Function findTaskChangesFromDiff

apps/cli/internal/cli/commit_msg.go:400–448

findTaskChangesFromDiff runs git diff --cached, parses all status changes, and matches them against scanned tasks.

(tasks []*model.Task, scanDir string)

// findTaskChangesFromDiff runs git diff --cached, parses all status changes,
// and matches them against scanned tasks.
func findTaskChangesFromDiff(tasks []*model.Task, scanDir string) (TaskChanges, error) {
	var changes TaskChanges

	diffOutput, err := gitDiffFunc(scanDir)
	if err != nil {
		return changes, fmt.Errorf("git diff failed: %w", err)
	}

	dr := parseDiffResult(diffOutput)
	if dr.IsEmpty() {
		return changes, nil
	}

	gitRoot, err := resolveGitRoot(scanDir)
	if err != nil {
		return changes, err
	}

	// Build absolute path sets for each category.
	absMap := func(files []string) map[string]bool {
		m := make(map[string]bool, len(files))
		for _, f := range files {
			m[filepath.Clean(filepath.Join(gitRoot, f))] = true
		}
		return m
	}
	completedSet := absMap(dr.Completed)
	addedSet := absMap(dr.Added)
	startedSet := absMap(dr.Started)
	blockedSet := absMap(dr.Blocked)
	cancelledSet := absMap(dr.Cancelled)

	for _, t := range tasks {
		cleaned := filepath.Clean(t.FilePath)
		switch {
		case completedSet[cleaned]:
			changes.Completed = append(changes.Completed, t)
		case addedSet[cleaned]:
			changes.Added = append(changes.Added, t)
		case startedSet[cleaned]:
			changes.Started = append(changes.Started, t)
		case blockedSet[cleaned]:
			changes.Blocked = append(changes.Blocked, t)
		case cancelledSet[cleaned]:
			changes.Cancelled = append(changes.Cancelled, t)
		}
	}
	return changes, nil
}

// gitRootFunc resolves the git repository root. Override in tests.
var gitRootFunc = defaultGitRoot