Documentation
¶
Overview ¶
Package crucible orchestrates parent beads with children on feature branches.
The Crucible is where separate beads are melted together into a single unified PR. It auto-detects parent-child bead relationships, creates a feature branch, dispatches children in topological order through the pipeline, merges their PRs, and produces a final PR against main.
Index ¶
- Constants
- Variables
- func FetchBead(ctx context.Context, beadID, dir string) (poller.Bead, error)
- func FetchChildren(ctx context.Context, parentID, dir string) ([]poller.Bead, error)
- func IsCrucibleCandidate(b poller.Bead) bool
- func MergePR(ctx context.Context, prNumber int, dir string) error
- func TopoSort(beads []poller.Bead) ([]poller.Bead, error)
- type Params
- type Result
- type Status
Constants ¶
const FeatureBranchPrefix = "feature/"
FeatureBranchPrefix is the branch prefix for Crucible feature branches.
Variables ¶
var ErrCycle = errors.New("dependency cycle detected among children")
ErrCycle is returned when the children contain a dependency cycle.
Functions ¶
func FetchBead ¶
FetchBead calls `bd show <beadID> --json` and returns the parsed bead. bd show returns dependents as an array of objects with dependency_type, not a flat "blocks" array, so we extract blocks from the dependents.
func FetchChildren ¶
FetchChildren calls `bd show <parentID> --json` to get the parent's blocks, then recursively fetches all descendants (children, grandchildren, etc.). This ensures the Crucible processes the entire dependency tree, not just direct children.
func IsCrucibleCandidate ¶
IsCrucibleCandidate returns true if a bead has children (blocks other beads) and is therefore a Crucible candidate.
Types ¶
type Params ¶
type Params struct {
DB *state.DB
Logger *slog.Logger
WorktreeManager *worktree.Manager
PromptBuilder *prompt.Builder
ParentBead poller.Bead
AnvilName string
AnvilConfig config.AnvilConfig
ExtraFlags []string
Providers []provider.Provider
SchematicConfig *schematic.Config
GoRaceDetection bool
SmithTimeout time.Duration
MaxPipelineIterations int
// StatusCallback is called when crucible state changes (for TUI tracking).
StatusCallback func(Status)
// AutoMergeCrucibleChildren controls whether child PRs are automatically
// merged (squash) into the feature branch after the pipeline succeeds.
// When false, child PRs are created but not merged (human review required).
// Default: true (zero value auto-merges).
AutoMergeCrucibleChildren bool
// Test injection points — when non-nil these replace the real implementations.
PipelineRunner func(ctx context.Context, p pipeline.Params) *pipeline.Outcome
PRCreator func(ctx context.Context, p ghpr.CreateParams) (*ghpr.PR, error)
ChildFetcher func(ctx context.Context, parentID, dir string) ([]poller.Bead, error)
PRMerger func(ctx context.Context, prNumber int, dir string) error
BeadClaimer func(ctx context.Context, beadID, dir string) error
BeadCloser func(ctx context.Context, beadID, dir string) error
BeadResetter func(ctx context.Context, beadID, dir string) error
EpicBranchCreator func(ctx context.Context, dir, branch string) error
SchematicRunner func(ctx context.Context, cfg schematic.Config, bead poller.Bead, anvilPath string, pv provider.Provider) *schematic.Result
}
Params holds all dependencies needed to run a Crucible.
type Result ¶
type Result struct {
Success bool
FinalPR *ghpr.PR // Non-nil when final PR was created successfully.
ChildrenDone int
ChildrenTotal int
Error error
PausedChildID string // Non-empty if paused due to child failure.
}
Result is returned when the Crucible finishes or pauses.
type Status ¶
type Status struct {
ParentID string
Anvil string
Branch string
Phase string // "started", "parent", "dispatching", "waiting", "final_pr", "complete", "paused"
TotalChildren int
CompletedChildren int
CurrentChild string
StartedAt time.Time
}
Status tracks the current state of a Crucible for monitoring.
Source Files