session

type HistoryOption func(*HistoryProvider)

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

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

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

type Session struct {
	// Unique session identifier
	SessionID string `json:"session_id"`

	// Agent/Team/Workflow identifiers
	AgentID    string `json:"agent_id,omitempty"`
	TeamID     string `json:"team_id,omitempty"`
	WorkflowID string `json:"workflow_id,omitempty"`

	// User identifier
	UserID string `json:"user_id,omitempty"`

	// Session metadata
	Name     string                 `json:"name,omitempty"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`

	// Session state
	State map[string]interface{} `json:"state,omitempty"`

	// Agent data (for reference)
	AgentData map[string]interface{} `json:"agent_data,omitempty"`

	// Run history
	Runs []*agent.RunOutput `json:"runs,omitempty"`

	// Summary (for long sessions)
	Summary *SessionSummary `json:"summary,omitempty"`

	// Timestamps
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type SessionSummary struct {
	// Summary text
	Content string `json:"content"`

	// Number of runs in this session
	RunCount int `json:"run_count"`

	// Total tokens used
	TotalTokens int `json:"total_tokens"`

	// Created at timestamp
	CreatedAt time.Time `json:"created_at"`
}

type Storage interface {
	// Create creates a new session
	Create(ctx context.Context, session *Session) error

	// Get retrieves a session by ID
	Get(ctx context.Context, sessionID string) (*Session, error)

	// Update updates an existing session
	Update(ctx context.Context, session *Session) error

	// Delete deletes a session by ID
	Delete(ctx context.Context, sessionID string) error

	// List lists all sessions (with optional filters)
	List(ctx context.Context, filters map[string]interface{}) ([]*Session, error)

	// ListByAgent lists all sessions for a specific agent
	ListByAgent(ctx context.Context, agentID string) ([]*Session, error)

	// ListByUser lists all sessions for a specific user
	ListByUser(ctx context.Context, userID string) ([]*Session, error)

	// Close closes the storage connection
	Close() error
}

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

type SummaryOption func(*SummaryManager)