depsweep

type DepgraphSource struct {
	Bin       string
	Dir       string
	ExtraArgs []string
	Timeout   time.Duration
}

type PlanConsumer struct {
	Key            string `json:"key"`
	Dir            string `json:"dir"`
	CurrentVersion string `json:"currentVersion"`
	TargetVersion  string `json:"targetVersion"`
	DependencyKey  string `json:"dependencyKey"`
	IsMajorBump    bool   `json:"isMajorBump"`
}

type PlanDepKey struct {
	Key string `json:"key"`
}

type PlanModule struct {
	Key   string `json:"key"`
	Label string `json:"label"`
	Dir   string `json:"dir"`

	HasUnreleasedWork bool   `json:"hasUnreleasedWork"`
	CurrentVersion    string `json:"currentVersion"`
	NextVersion       string `json:"nextVersion"`
	SuggestedBump     string `json:"suggestedBump"`

	HasOutdatedConsumers bool           `json:"hasOutdatedConsumers"`
	OutdatedConsumers    []PlanConsumer `json:"outdatedConsumers"`
	StaleBuild           bool           `json:"staleBuild"`
	StaleDeps            []PlanStaleDep `json:"staleDeps"`
	Wave                 int            `json:"wave"`
	ConsumerCount        int            `json:"consumerCount"`
	Dependencies         []PlanDepKey   `json:"dependencies"`
}

type PlanSource interface {
	Plan(ctx context.Context) ([]PlanModule, error)
}

type PlanStaleDep struct {
	Key        string `json:"key"`
	OldVersion string `json:"oldVersion"`
	NewVersion string `json:"newVersion"`
}

type Skip struct {
	Repo   string
	Reason string
}

type SweepStats struct {
	// Minted counts fresh tasks enqueued.
	Minted int
	// Known counts mints whose task already existed (dedup hit).
	Known int
	// Skips carries every skipped plan row with its reason.
	Skips []Skip
}

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

type SweeperConfig struct {
	// Source supplies the plan. Required.
	Source PlanSource
	// PushReleases makes release payloads push master+tag after tagging,
	// which is what unblocks consumer bumps (they resolve the tag through
	// the module proxy). Default false: tags stay local and a human pushes
	// — consumers then retry until the tag lands (bounded by the retry
	// ladder; the DLQ is the surface if the push never comes).
	PushReleases bool
	// IncludeUnreleased also releases modules whose ONLY work is
	// unreleased feature commits (the release-suggestions lens). Default
	// false: the sweep converges dependency state; feature releases carry
	// version decisions a human should see. Stale builds always release —
	// their content is dependency pins that are already committed.
	IncludeUnreleased bool
	// Log receives one line per mint/skip. nil logs nothing.
	Log *slog.Logger
}

type WorkSpec struct {
	// Repo is the module key (task project + dedup identity).
	Repo string
	// Dir is the absolute module directory (payload Repo field).
	Dir string
	// Bumps are the exact pins to apply (consumer work).
	Bumps []executor.DepBump
	// Release is the tag to cut after verification (release work).
	Release *executor.DepBumpRelease
	// DepRepos are plan dependency repo keys whose tasks this spec's task
	// must wait for (the plan DAG becomes the queue DAG).
	DepRepos []string
	// DedupKey makes minting idempotent per exact work spec.
	DedupKey string
}