memory

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

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

type BleveStoreConfig struct {
	// BasePath is the directory for all storage files
	BasePath string
}

type Consolidator interface {
	// Extract extracts key insights from a transcript.
	Extract(ctx context.Context, transcript []Message) ([]string, error)
}

type FILResult struct {
	Findings []string `json:"findings"`
	Insights []string `json:"insights"`
	Lessons  []string `json:"lessons"`
}

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

type Memory struct {
	ID        string    `json:"id"`
	Content   string    `json:"content"`
	Category  string    `json:"category"` // "finding" | "insight" | "lesson"
	Source    string    `json:"source"`   // "GOAL:step-name", "session:xyz", etc.
	CreatedAt time.Time `json:"created_at"`
}

type MemoryResult struct {
	Memory
	Score float32 `json:"score"` // relevance score (BM25, normalized)
}

type Message struct {
	Role    string `json:"role"`
	Content string `json:"content"`
}

type Observation struct {
	// Findings are factual discoveries (e.g., "API rate limit is 100/min")
	Findings []string `json:"findings,omitempty"`

	// Insights are conclusions or inferences (e.g., "REST is better than GraphQL for this use case")
	Insights []string `json:"insights,omitempty"`

	// Lessons are learnings for future (e.g., "Avoid library X - it lacks TypeScript support")
	Lessons []string `json:"lessons,omitempty"`

	// StepName identifies the source step
	StepName string `json:"step_name,omitempty"`

	// StepType is the type of step (GOAL, AGENT, RUN)
	StepType string `json:"step_type,omitempty"`
}

type ObservationDocument struct {
	ID        string    `json:"id"`
	Content   string    `json:"content"`
	Category  string    `json:"category"` // "finding" | "insight" | "lesson"
	Source    string    `json:"source"`   // "GOAL:step-name" for provenance
	CreatedAt time.Time `json:"created_at"`
}

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

type ObservationItem struct {
	ID       string `json:"id"`
	Content  string `json:"content"`
	Category string `json:"category"` // "finding" | "insight" | "lesson"
}

type RecallOpts struct {
	Limit     int        // max results, default 10
	MinScore  float32    // minimum relevance score, default 0.0
	TimeRange *TimeRange // optional time filter
}

type SearchResult struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type Store interface {
	// Observation storage (primary API)
	RememberObservation(ctx context.Context, content, category, source string) (string, error) // returns ID
	RememberFIL(ctx context.Context, findings, insights, lessons []string, source string) ([]string, error)
	RetrieveByID(ctx context.Context, id string) (*ObservationItem, error)
	RecallByCategory(ctx context.Context, query, category string, limit int) ([]string, error)
	RecallFIL(ctx context.Context, query string, limitPerCategory int) (*FILResult, error)

	// Generic recall (returns all categories mixed)
	Recall(ctx context.Context, query string, opts RecallOpts) ([]MemoryResult, error)

	// Key-value operations
	Get(key string) (string, error)
	Set(key, value string) error
	List(prefix string) ([]string, error)
	Search(query string) ([]SearchResult, error)

	// Session consolidation
	ConsolidateSession(ctx context.Context, sessionID string, transcript []Message) error

	// Lifecycle
	Close() error
}

type TimeRange struct {
	Start time.Time
	End   time.Time
}

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

type ToolsMemoryResult struct {
	ID       string  `json:"id"`
	Content  string  `json:"content"`
	Category string  `json:"category"` // "finding" | "insight" | "lesson"
	Score    float32 `json:"score"`
}

type ToolsObservationItem struct {
	ID       string `json:"id"`
	Content  string `json:"content"`
	Category string `json:"category"`
}