smelter

type ConsolidateOptions struct {
	// AnvilPath is the on-disk path to the anvil root. Both
	// .forge/warden-rules.yaml and .forge/warden-rules.archive.yaml are
	// resolved relative to it.
	AnvilPath string
	// AnvilName is used in log messages and event payloads.
	AnvilName string
	// Consolidator is the AI invocation hook used by Pass 1. When nil, Pass
	// 1 is skipped.
	Consolidator warden.ConsolidationRunner
	// DedupThreshold is the Jaccard similarity threshold (0.0–1.0) above
	// which two rules in the same category are considered duplicates. When
	// <= 0, Pass 1 is skipped.
	DedupThreshold float64
	// ArchiveAfterDays is the staleness threshold in days for Pass 2. When
	// <= 0, Pass 2 is skipped.
	ArchiveAfterDays int
	// Now optionally overrides the reference time used by the staleness
	// pass. Zero defaults to time.Now().UTC().
	Now time.Time
	// EventLogger is an optional callback for surfacing per-pass progress
	// to an external sink. The scheduled smelter wires this to the state
	// DB; CLI invocations may pass nil. Called with (eventName, message).
	EventLogger func(name, message string)
}

type ConsolidateResult struct {
	// Passes captures the per-pass outcomes in the standard PassResults
	// shape so the same commit-message and summary helpers work for both
	// scheduled and off-cycle runs.
	Passes PassResults
	// Pass1Archived lists the original rules superseded by Pass 1 merges.
	// Surfaced so callers that drive the smelter flushAnvil path (which
	// writes them to the archive store) can reuse the same result.
	Pass1Archived []warden.Rule
	// InitialCount is the rule count loaded from the active file before
	// any pass ran.
	InitialCount int
	// FinalActive is the rule count in the active file after all passes
	// completed and persistence (when any pass produced changes) ran.
	FinalActive int
	// ArchiveCount is the entry count in the archive file after the run.
	// Zero when no archive file exists.
	ArchiveCount int
	// FirstError is the first non-fatal error encountered during Pass 1
	// (typically an AI runner failure for a single cluster). The run
	// proceeds despite this; callers may choose to surface it in their
	// summary.
	FirstError error
}

type Option func(*Smelter)

type PassResults struct {
	// Added lists the IDs of rules newly inserted from the pending queue
	// (Pass 1, before consolidation). IDs are taken from the rule YAML.
	Added []string

	// Consolidated holds the per-cluster merge outcomes from Pass 1.
	Consolidated []warden.MergeResult

	// Archived holds the stale rules moved to the archive store by Pass 2
	// (ArchiveReason="stale"). Pass 1 duplicates archived with
	// ArchiveReason="duplicate" are *not* included here — they are surfaced
	// through Consolidated.
	Archived []warden.ArchivedRule

	// Backfilled lists the IDs of rules whose Paths field was populated by
	// Pass 3 from the changed files of the rule's source PR(s).
	Backfilled []string
}

type Smelter struct {
	// contains filtered or unexported fields
}