Function bodies 590 total

breakdown.dependenciesValid function · go · L114-L178 (65 LOC)

cli/internal/projects/breakdown/guards.go

func dependenciesValid(p *state.Project) bool {
	phase, exists := p.Phases["breakdown"]
	if !exists {
		return false
	}

	// Build adjacency list and valid task ID set
	graph := make(map[string][]string)
	taskIDs := make(map[string]bool)

	for _, task := range phase.Tasks {
		// Only validate completed tasks
		if task.Status == "completed" {
			taskIDs[task.Id] = true

			// Extract dependencies from metadata
			if deps := extractTaskDependencies(task); deps != nil {
				graph[task.Id] = deps
			}
		}
	}

	// Check all dependencies point to valid task IDs
	for _, deps := range graph {
		for _, depID := range deps {
			if !taskIDs[depID] {
				return false // Invalid dependency reference
			}
		}
	}

	// Check for cycles using depth-first search
	visited := make(map[string]bool)
	recStack := make(map[string]bool)

	var hasCycle func(string) bool
	hasCycle = func(taskID string) bool {
		visited[taskID] = true
		recStack[taskID] = true

		for _, depID := range graph[taskID] {
			if !visit

breakdown.allWorkUnitsPublished function · go · L189-L222 (34 LOC)

cli/internal/projects/breakdown/guards.go

func allWorkUnitsPublished(p *state.Project) bool {
	phase, exists := p.Phases["breakdown"]
	if !exists {
		return false
	}

	hasCompleted := false

	for _, task := range phase.Tasks {
		// Only check completed tasks
		if task.Status == "completed" {
			hasCompleted = true

			// Check metadata exists
			if task.Metadata == nil {
				return false
			}

			// Check published field exists and is true
			publishedRaw, ok := task.Metadata["published"]
			if !ok {
				return false
			}

			published, ok := publishedRaw.(bool)
			if !ok || !published {
				return false
			}
		}
	}

	// Must have at least one completed task
	return hasCompleted
}

breakdown.countUnresolvedTasks function · go · L229-L242 (14 LOC)

cli/internal/projects/breakdown/guards.go

func countUnresolvedTasks(p *state.Project) int {
	phase, exists := p.Phases["breakdown"]
	if !exists {
		return 0
	}

	count := 0
	for _, task := range phase.Tasks {
		if task.Status != "completed" && task.Status != "abandoned" {
			count++
		}
	}
	return count
}

breakdown.countUnpublishedTasks function · go · L248-L270 (23 LOC)

cli/internal/projects/breakdown/guards.go

func countUnpublishedTasks(p *state.Project) int {
	phase, exists := p.Phases["breakdown"]
	if !exists {
		return 0
	}

	count := 0
	for _, task := range phase.Tasks {
		if task.Status == "completed" {
			// Count as unpublished if no metadata
			if task.Metadata == nil {
				count++
				continue
			}

			// Count as unpublished if published field missing or not true
			if published, ok := task.Metadata["published"].(bool); !ok || !published {
				count++
			}
		}
	}
	return count
}

breakdown.validateTaskForCompletion function · go · L282-L330 (49 LOC)

cli/internal/projects/breakdown/guards.go

func validateTaskForCompletion(p *state.Project, taskID string) error {
	phase, exists := p.Phases["breakdown"]
	if !exists {
		return fmt.Errorf("breakdown phase not found")
	}

	// Find task
	var task *projschema.TaskState
	for i := range phase.Tasks {
		if phase.Tasks[i].Id == taskID {
			task = &phase.Tasks[i]
			break
		}
	}
	if task == nil {
		return fmt.Errorf("task %s not found", taskID)
	}

	// Check for metadata
	if task.Metadata == nil {
		return fmt.Errorf("task %s has no metadata - set artifact_path before completing", taskID)
	}

	// Check for artifact_path
	artifactPathRaw, exists := task.Metadata["artifact_path"]
	if !exists {
		return fmt.Errorf("task %s has no artifact_path in metadata - link artifact to task before completing", taskID)
	}

	// Validate artifact_path is a non-empty string
	artifactPath, ok := artifactPathRaw.(string)
	if !ok || artifactPath == "" {
		return fmt.Errorf("task %s has no artifact_path in metadata - link artifact to task before completing"

breakdown.autoApproveArtifact function · go · L339-L385 (47 LOC)

cli/internal/projects/breakdown/guards.go

func autoApproveArtifact(p *state.Project, taskID string) error {
	phase, exists := p.Phases["breakdown"]
	if !exists {
		return fmt.Errorf("breakdown phase not found")
	}

	// Find task
	var task *projschema.TaskState
	for i := range phase.Tasks {
		if phase.Tasks[i].Id == taskID {
			task = &phase.Tasks[i]
			break
		}
	}
	if task == nil {
		return fmt.Errorf("task %s not found", taskID)
	}

	// Get artifact_path from metadata
	artifactPathRaw, exists := task.Metadata["artifact_path"]
	if !exists {
		return fmt.Errorf("task %s has invalid artifact_path in metadata", taskID)
	}

	artifactPath, ok := artifactPathRaw.(string)
	if !ok || artifactPath == "" {
		return fmt.Errorf("task %s has invalid artifact_path in metadata", taskID)
	}

	// Find and approve artifact
	found := false
	for i := range phase.Outputs {
		if phase.Outputs[i].Path == artifactPath {
			phase.Outputs[i].Approved = true
			found = true
			break
		}
	}
	if !found {
		return fmt.Errorf("artifact not found at %s", ar

breakdown.generateOrchestratorPrompt function · go · L19-L29 (11 LOC)