compaction

type AnchorPolicy int

type Event struct {
	BotID     string
	SessionID string
	// ModelRecordID names the summarizer's model row in the compaction log.
	ModelRecordID string
	// Request is what the caller sends next and Sources what each of its
	// messages renders. The event decides what of it stays verbatim (retain).
	Request sdk.Request
	Sources []Source
	// Current is the input the caller's next request answers when the
	// request does not hold it: the summarizer reads it to judge what the
	// work needs.
	Current []sdk.Message
	// AnchorPolicy is how a fold keeps the request's anchors.
	AnchorPolicy AnchorPolicy
	// Window is the summarizer's context window and MaxOutputTokens its
	// output cap; Allowance is what the caller's next request may take.
	Window          int
	MaxOutputTokens int
	Allowance       int
	// FixedOutput marks a summarizer that answers within all of
	// MaxOutputTokens: the run's own model, whose output settings a fork of
	// the run's request keeps, since the provider settings the fork shares
	// with the run's requests (a thinking budget) hold for the output those
	// ask for. A pass then reads only what the window holds beside all of it,
	// as the run's own requests do. Otherwise a fork asks for less output
	// when that lets a pass read more.
	FixedOutput bool
	// Pressure is the request size that called for the event, for hooks.
	Pressure int
	// ReplacedTurnID is the turn an edit or retry replaces: the event first
	// moves the session to the checkpoint its replacement keeps.
	ReplacedTurnID string
	Summarizer     Summarizer
	// Apply splices every committed pass into the caller's request as it
	// commits, and returns the request and sources a further pass reads.
	Apply func(Pass) (sdk.Request, []Source)
	// contains filtered or unexported fields
}

type EventError struct {
	Reason Reason
	Err    error
}

type ListLogsResponse struct {
	Items      []Log `json:"items"`
	TotalCount int64 `json:"total_count"`

} // @name compaction.ListLogsResponse

type Log struct {
	ID           string     `json:"id"`
	BotID        string     `json:"bot_id"`
	SessionID    string     `json:"session_id,omitempty"`
	Status       string     `json:"status"`
	Summary      string     `json:"summary"`
	MessageCount int        `json:"message_count"`
	ErrorMessage string     `json:"error_message"`
	Usage        any        `json:"usage,omitempty"`
	ModelID      string     `json:"model_id,omitempty"`
	StartedAt    time.Time  `json:"started_at"`
	CompletedAt  *time.Time `json:"completed_at,omitempty"`

} // @name compaction.Log

type Pass struct {
	SummaryID string
	Summary   string
	// Order is the request after the pass, by the messages of the request it
	// read: the index of each that stays, or -1 for the summary, which takes
	// the place turn.PlaceSummary gives it; cut is where the newest messages
	// the event keeps start in it.
	Order []int

	// More reports candidates left that the pass could not read; the event
	// folds them in a later pass.
	More bool
	// contains filtered or unexported fields
}

type Reason string

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

type Source struct {
	// Sources are the history rows, inbound messages or summary the message
	// renders. A message with none is runtime context the caller rebuilds
	// for every request: it stays where it is and no summary stands for it.
	Sources []turn.ContextMessageSource
	// Anchor marks the run's input or a steer, which a fold keeps verbatim
	// where it is before anything else it keeps (retain).
	Anchor bool
}

type Summarizer func(context.Context, sdk.Request) (sdk.ModelResult, error)

type TriggerConfig struct {
	BotID                 string
	SessionID             string
	ModelID               string // runtime model slug sent to the provider
	ModelRecordID         string // models.id row UUID recorded as the log's provenance
	ClientType            string
	APIKey                string //nolint:gosec // runtime credential, not a hardcoded secret
	CodexAccountID        string
	BaseURL               string
	ChatCompletionsCompat string
	HTTPClient            *http.Client
	// TotalInputTokens is the history pressure that called for this
	// compaction, reported to hooks.
	TotalInputTokens int
	// SummaryWindowTokens and MaxOutputTokens are the summarizer model's
	// declared window and output cap; they size the summarizer call.
	SummaryWindowTokens int
	MaxOutputTokens     int
	// CandidatesBefore, when set, is where the caller's history ends: the
	// cutoff an edit or retry replays history before, or the turn the request
	// runs as. Rows from it on are not folded.
	CandidatesBefore *messagepkg.HistoryPosition
	// ReplacedTurnID is the turn an edit or retry replaces. The replacement
	// rewinds the session to the checkpoint that does not depend on that
	// turn when its first step commits; an event the request needs earlier
	// rewinds first, so it folds onto the checkpoint the replacement keeps.
	ReplacedTurnID string
	// Anchors are kept verbatim where they are, as AnchorPolicy keeps them: a
	// run's input and steers, or the inputs a Discuss run answers.
	Anchors      []turn.ContextMessageSource
	AnchorPolicy AnchorPolicy
	// CurrentRequest is the caller's current input, which the summarizer
	// reads to judge what the work needs.
	CurrentRequest string
	// HistoryBudgetTokens is the room the caller's request has for what the
	// history renders: the summary and the rows it keeps raw.
	HistoryBudgetTokens int
}

type TriggerModel struct {
	Slug                  string // runtime model slug sent to the provider
	RecordID              string // models.id row UUID recorded as the log's provenance
	ClientType            string
	APIKey                string //nolint:gosec // runtime credential, not a hardcoded secret
	CodexAccountID        string
	BaseURL               string
	ChatCompletionsCompat string
	WindowTokens          int // summarizer model's declared context window
	MaxOutputTokens       int // summarizer model's declared output cap, zero when unknown
}