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
	SkillStore pkgplugins.SkillStore
	// SkillAuthorizer applies Skill domain rules to reflect's staged writes (the
	// reconciliation-plan/usage-curator path); when nil those fail closed.
	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 per-agent session registries for review target listing.
	// When set, reflect uses Registry.ListForReview and Registry.MemoryScope
	// instead of calling memory.SessionManager directly.
	Services agent.ServiceManager
}

type RecentlyForgottenItems struct {
	Knowledge []RecentlyForgottenKnowledgeItem
}

type RecentlyForgottenKnowledgeItem struct {
	Kind                        string
	FactID                      string
	Content                     string
	DeprecatedAt                time.Time
	CuratorRule                 string
	LastUsedAt                  string
	MemoryVersionAfterDeprecate int64
	DeprecatedChangelogID       string
}

type RecentlyForgottenQuery struct {
	UserID  string
	AgentID string
	Kind    string
	Limit   int32
}

type RejectReason string

type RestoreForgottenRequest struct {
	Kind       string
	ID         string
	UserID     string
	AgentID    string
	RestoredBy string
	Reason     string
}

type RestoreForgottenResult struct {
	Kind      string
	Restored  bool
	Knowledge *memory.Fact
}

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
	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 SQLForgottenRestoreService struct {
	// contains filtered or unexported fields
}

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

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

type Store interface {
	ListEnabledAgents(ctx context.Context) ([]config.Agent, error)
	Snapshot(ctx context.Context, agentID string) (*config.Snapshot, 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)
}