memory

type AfterStoreHook func(ctx context.Context, obs *Observation)

type Compressor interface {
	CompressObservation(ctx context.Context, raw RawObservation) (*Observation, error)
}

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

type Observation struct {
	ID              int64
	SessionID       string
	Project         string
	Title           string
	Type            ObservationType
	Text            string
	SourceFiles     []string // stored as JSON array
	ToolName        string
	PromptNumber    int
	DiscoveryTokens int
	CreatedAt       time.Time
}

type ObservationType string

type RawObservation struct {
	SessionID  string
	Project    string
	ToolName   string
	ToolInput  map[string]any
	ToolOutput map[string]any
	Timestamp  time.Time
}

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

type SearchQuery struct {
	Query   string
	Project string
	Type    ObservationType
	Limit   int
	Offset  int
}

type SearchResult struct {
	Rows  []SearchResultRow `json:"results"`
	Total int               `json:"total"`
}

type SearchResultRow struct {
	ID        int64           `json:"id"`
	Title     string          `json:"title"`
	Type      ObservationType `json:"type"`
	CreatedAt time.Time       `json:"created_at"`
	ReadCost  int             `json:"read"`
	WorkCost  int             `json:"work"`
}

type Session struct {
	ID          int64
	SessionID   string
	Project     string
	UserPrompt  string
	StartedAt   time.Time
	CompletedAt *time.Time
	Status      string // "active", "completed", "failed"
}

type SessionSummary struct {
	ID              int64
	SessionID       string
	Project         string
	Request         string
	Investigated    string
	Learned         string
	Completed       string
	NextSteps       string
	DiscoveryTokens int
	CreatedAt       time.Time
}

type Store interface {
	CreateSession(ctx context.Context, s *Session) error
	CompleteSession(ctx context.Context, sessionID string) error
	InsertObservation(ctx context.Context, obs *Observation) error
	GetObservations(ctx context.Context, ids []int64) ([]*Observation, error)
	RecentObservations(ctx context.Context, project string, limit int) ([]*Observation, error)
	UpsertSummary(ctx context.Context, sum *SessionSummary) error
	RecentSummaries(ctx context.Context, project string, limit int) ([]*SessionSummary, error)
	Search(ctx context.Context, q SearchQuery) (*SearchResult, error)
	Timeline(ctx context.Context, anchorID int64, before, after int) ([]*Observation, error)
	Close() error
}

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

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