reflect

type CandidateGateConfig struct {
	Weights        map[string]float64
	CoreFields     []string
	CoreFloor      int
	Threshold      float64
	Cap            int
	TieBreakFields []string
}

type CandidateGateDecision struct {
	Ref               CandidateRef
	NormalizedOverall float64
	Scores            map[string]int
	Reason            RejectReason
}

type CandidateGateInput struct {
	Ref     CandidateRef
	Content string
	Scores  map[string]int
}

type CandidateGateResult struct {
	Accepted []CandidateGateDecision
	Rejected []CandidateGateDecision
}

type CandidateGateSettings struct {
	FactWeights       map[string]float64
	FactThreshold     float64
	FactSubjectCap    int
	SkillWeights      map[string]float64
	SkillThreshold    float64
	SkillCandidateCap int
}

type CandidateRef string

type Config struct {
	StateStore pkgplugins.StateStore
	Memory     memory.Provider
	Store      Store
	// Snapshots loads credential-aware per-agent snapshots for review.
	Snapshots  config.SnapshotLoader
	SkillStore reflectSkillStore
	// SkillAuthorizer applies Skill domain rules to Reflect's staged writes.
	SkillAuthorizer   skillWriteAuthorizer
	UsageCuratorStore UsageCuratorStore
	Log               *slog.Logger
	Providers         func(api, apiKey, baseURL string) (providers.StreamFunc, error)
	CandidateGates    CandidateGateSettings
	// UsageCuratorSettings defaults to armed. Operators may switch to shadow to
	// stop lifecycle writes while keeping scans and telemetry active.
	UsageCuratorSettings UsageCuratorSettings
	// Services provides the per-agent session registry used for review target
	// listing and owner-scoped memory coordinates.
	Services agent.ServiceManager
}

type RejectReason string

type ReviewSkip struct {
	Reason ReviewSkipReason
	Role   string
	At     time.Time
	// Seq fields identify the skipped review boundary when the history source
	// can provide stable ordering. They stay zero for timestamp-only fallback.
	FirstSeq int64
	LastSeq  int64
	Size     int
}

type ReviewSkipReason string

type ReviewUnit struct {
	Text            string
	ReviewFromAt    time.Time
	ReviewFromSeq   int64
	LastIncludedAt  time.Time
	LastIncludedSeq int64
	// Truncated means more fresh content exists after LastIncluded*, but it did
	// not fit in this bounded window and must be picked up by a later cycle.
	Truncated       bool
	Skipped         []ReviewSkip
	FreshCount      int
	PrivateOneToOne bool
	SkillUsage      []reviewSkillUsage
}

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

type Store interface {
	ListEnabledAgents(ctx context.Context) ([]config.Agent, error)
}

type UsageCuratorMode string

type UsageCuratorSettings struct {
	Mode               UsageCuratorMode
	KnowledgeMaxIdle   time.Duration
	SkillMaxIdle       time.Duration
	SkillLowUseIdle    time.Duration
	SkillLowUseMaxUses int64
	RunInterval        time.Duration
	Now                func() time.Time
}

type UsageCuratorStore interface {
	ListReflectUsagePairs(ctx context.Context) ([]usageCuratorPair, error)
	ListStaleReflectKnowledge(ctx context.Context, q usageCuratorKnowledgeQuery) ([]usageCuratorKnowledgeCandidate, error)
	ListStaleReflectSkills(ctx context.Context, q usageCuratorSkillQuery) ([]usageCuratorSkillCandidate, error)
}