llm

type API string

type Action string

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

type AnthropicConfig = Config

type Candidate struct {
	ID      string `json:"id"`
	Content string `json:"content"`
}

type Client interface {
	Consolidator
	Completer
	Distiller
}

type Completer interface {
	Complete(ctx context.Context, system, user string) (string, error)
}

type Config struct {
	BaseURL string // OpenAI: e.g. https://host/v1 ; Anthropic: e.g. https://api.minimax.io/anthropic
	APIKey  string
	Model   string
	// MaxTokens caps the completion length (defaults to defaultMaxTokens). A
	// budget is required for reasoning models, which otherwise spend the server
	// default on hidden reasoning and return empty content.
	MaxTokens  int
	HTTPClient *http.Client
}

type Consolidator interface {
	Consolidate(ctx context.Context, in Input) (Decision, error)
}

type Decision struct {
	Action Action `json:"action"`
	// Target is the candidate ID affected by update/supersede (empty for new).
	Target string `json:"target"`
	// Content is the merged text to persist for an update (else the new content).
	Content string `json:"content"`
	// Summary is an optional one-line summary of the resulting memory.
	Summary string `json:"summary"`
	// Reason explains the decision (for logs/debugging).
	Reason string `json:"reason"`
}

type DistillInput struct {
	Episodes []string `json:"episodes"`
}

type Distiller interface {
	Distill(ctx context.Context, in DistillInput) ([]Fact, error)
}

type Fact struct {
	Content string `json:"content"`
	Summary string `json:"summary,omitempty"`
}

type Input struct {
	New        string      `json:"new"`
	Tier       string      `json:"tier"`
	Candidates []Candidate `json:"candidates"`
}

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

type OpenAIConfig = Config