compaction

type CutPointResult struct {
	FirstKeptIndex int
	TurnStartIndex int
	IsSplitTurn    bool
}

type EventData struct {
	// BeforeSeq is legacy: highest summarized seq when FirstKeptSeq is unset.
	BeforeSeq agentkit.EventSeq `json:"beforeSeq,omitempty"`
	// FirstKeptSeq is the first retained event after compaction (Pi firstKeptEntryId).
	FirstKeptSeq agentkit.EventSeq `json:"firstKeptSeq,omitempty"`
	// RetainedTail is verbatim recent history kept for the model after compaction.
	RetainedTail []agentkit.ModelMessage `json:"retainedTail,omitempty"`
	TokensBefore int                     `json:"tokensBefore,omitempty"`
	Summary      agentkit.ModelMessage   `json:"summary"`
	Kind         string                  `json:"kind"`
}

type IndexedMessage struct {
	Message     agentkit.ModelMessage
	Seq         agentkit.EventSeq
	IsTurnStart bool
}

type Preparation struct {
	FirstKeptSeq        agentkit.EventSeq
	FirstKeptIndex      int
	MessagesToSummarize []agentkit.ModelMessage
	TurnPrefixMessages  []agentkit.ModelMessage
	RetainedTail        []agentkit.ModelMessage
	PreviousSummary     string
	TokensBefore        int
	IsSplitTurn         bool
}

type Request struct {
	SessionID agentkit.SessionID
	AgentID   agentkit.AgentID
	Session   agentkit.Session
	Messages  []agentkit.ModelMessage
	// Force skips automatic thresholds such as minMessages (manual /compact).
	Force bool
}

type Result struct {
	Applied  bool
	Event    agentkit.SessionEvent
	Messages []agentkit.ModelMessage
}

type RetryConfig struct {
	Enabled     *bool `json:"enabled"`
	MaxRetries  int   `json:"maxRetries"`
	BaseDelayMs int   `json:"baseDelayMs"`
}

type RetryPolicy struct {
	Enabled     bool
	MaxRetries  int
	BaseDelayMs int
}

type Service interface {
	Compact(context.Context, Request) (Result, error)
}

type SummarizationRetryCallbacks struct {
	OnScheduled func(attempt, maxAttempts, delayMs int, errorMessage string)
	OnFinished  func(success bool, attempt int, finalError string)
}