conversation

type AppendOpts struct {
	MaxContentLength int               // Truncate content if exceeds this (0 = no truncation)
	Metadata         map[string]string // Optional metadata
	SkipEmbedding    bool              // Skip embedding generation even if enabled
}

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

type ExtractionEnqueuer interface {
	EnqueueForExtraction(ctx context.Context, namespace, sourceType, sourceID, content string) error
}

type HistoryOpts struct {
	LastN             int    // Number of recent messages to retrieve (0 = use default)
	IncludeSummary    bool   // Prepend thread summary if available
	Cursor            string // Pagination cursor
	SkipAutoSummarize bool   // Skip auto-summarization check (internal use)
}

type HistoryResult struct {
	Messages   []*types.Message `json:"messages"`
	Summary    string           `json:"summary,omitempty"`
	NextCursor string           `json:"next_cursor,omitempty"`
	ThreadID   string           `json:"thread_id"`
}

type SearchMode string

type SearchOpts struct {
	ThreadID   *string    // Optional: limit search to specific thread
	TopK       int        // Number of results (0 = default 10)
	MinScore   float64    // Minimum similarity score (0-1)
	SearchMode SearchMode // Search mode: "vector" (default), "hybrid", or "text"
	Alpha      float64    // Hybrid search weight (0=pure text, 1=pure vector, 0.5=equal)
}

type SearchResult struct {
	Results []*types.MessageResult `json:"results"`
	Query   string                 `json:"query"`
}

type SummarizeOpts struct {
	KeepRecent int // Number of recent messages to keep unsummarized (default: 10)
}

type SummarizeResult struct {
	Summary            string `json:"summary"`
	MessagesSummarized int    `json:"messages_summarized"`
	MessagesKept       int    `json:"messages_kept"`
	ThreadID           string `json:"thread_id"`
}

type Summarizer interface {
	SummarizeMessages(ctx context.Context, messages []*types.Message) (string, error)
}