authoritiesvc

type MergeResult struct {
	Loser  string `json:"loser"`
	Winner string `json:"winner"`
	// Rewritten counts the Work grains repointed at the winner. On a failure it
	// is what the pass managed before it stopped, and it is meaningful: the works
	// it counts really are repointed (tasks/305).
	Rewritten int `json:"rewritten"`
	// Carriers is how many Works named the loser when the pass began. Rewritten <
	// Carriers means the merge did not finish and the heading is still live; the
	// same request run again resumes, because the loop skips works that no longer
	// name the loser.
	Carriers int `json:"carriers"`
	// Complete reports that every carrier was rewritten AND the loser was retired.
	// It distinguishes the two ways Merge can return an error with work behind it:
	// a rewrite that stopped partway (Complete false, retry to finish) from a
	// finished merge whose index reload failed (Complete true, nothing to redo).
	Complete bool `json:"complete"`
}

type Service struct {
	Blob  blob.Store
	Vocab *vocab.Index
	// Queue, when set, receives audit entries and the auto-linker's
	// PIPELINE suggestions.
	Queue *suggest.Service
	// Trigger, when set, gets one grains-changed event per merge rewrite.
	Trigger trigger.Notifier
	// Prefix is the grain tree root in the blob store ("" = repo-layout
	// paths straight from bibframe paths).
	Prefix string
	// AuthoritiesPrefix is the vocab reload scan prefix; empty means
	// Prefix + "data/authorities/".
	AuthoritiesPrefix string
	// Schemes filters the vocab reload (nil = every authority graph).
	Schemes []string
	// SchemesFn, when set, supersedes Schemes -- the tasks/067 seam: installed
	// vocabulary snapshots widen the effective filter at reload time, so an
	// authority edit's reload never drops an installed scheme.
	SchemesFn func(context.Context) ([]string, error)
	// Summaries, when set, is the shared maintained summary source
	// (workindex, tasks/109) merge rewrites scan instead of a per-run
	// corpus walk; nil falls back to ScanSummaries.
	Summaries ingest.SummarySource
	Logger    *slog.Logger
}