session

type CreateRequest struct {
	AppName  string
	UserID   string
	AgentID  string
	Metadata map[string]any
}

type Event struct {
	// 基础字段
	ID           string
	Timestamp    time.Time
	InvocationID string

	// Agent 相关
	AgentID string
	Branch  string // 多 Agent 分支隔离: "agent1.agent2.agent3"
	Author  string // 事件作者 (user/agent/system)

	// 内容
	Content types.Message

	// 推理/思考内容 (Kimi thinking, DeepSeek reasoner 等)
	Reasoning string

	// 动作
	Actions EventActions

	// 长时运行工具 ID 列表
	LongRunningToolIDs []string

	// 元数据
	Metadata map[string]any
}

type EventActions struct {
	// StateDelta 状态增量更新
	StateDelta map[string]any

	// ArtifactDelta Artifact 版本变化 (filename -> version)
	ArtifactDelta map[string]int64

	// SkipSummarization 是否跳过总结
	SkipSummarization bool

	// TransferToAgent 转移到指定 Agent
	TransferToAgent string

	// Escalate 升级到上级 Agent
	Escalate bool

	// CustomActions 自定义动作
	CustomActions map[string]any
}

type EventFilter struct {
	AgentID   string
	Branch    string
	Author    string
	StartTime *time.Time
	EndTime   *time.Time
	Limit     int
	Offset    int
}

type EventOptions struct {
	InvocationID string
	Branch       string
	Limit        int
	Offset       int
}

type Events interface {
	// All 返回所有事件的迭代器，保持顺序
	All() iter.Seq[*Event]

	// Len 返回事件总数
	Len() int

	// At 返回指定索引的事件
	At(i int) *Event

	// Filter 根据条件过滤事件
	Filter(predicate func(*Event) bool) []Event

	// Last 返回最后一个事件
	Last() *Event
}

type GetRequest struct {
	AppName   string
	UserID    string
	SessionID string
}

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

type ListOptions struct {
	AppName string
	Limit   int
	Offset  int
}

type ListRequest struct {
	AppName string
	UserID  string
	Limit   int
	Offset  int
}

type ReadonlyState interface {
	Get(key string) (any, error)
	All() iter.Seq2[string, any]
	Has(key string) bool
}

type SearchOptions struct {
	Query         string    // 搜索关键词
	AgentID       string    // 限定 Agent ID
	StartTime     time.Time // 开始时间
	EndTime       time.Time // 结束时间
	Limit         int       // 返回结果数量限制
	Offset        int       // 偏移量
	MatchMode     string    // 匹配模式: "exact", "contains", "fuzzy"
	OnlyUser      bool      // 只搜索用户消息
	OnlyAssistant bool      // 只搜索助手消息
}

type SearchResult struct {
	AgentID      string        `json:"agent_id"`
	MessageIndex int           `json:"message_index"`
	Message      types.Message `json:"message"`
	Snippet      string        `json:"snippet"`
	Relevance    float64       `json:"relevance"`
	Timestamp    time.Time     `json:"timestamp"`
}

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

type SearcherConfig struct {
	Store store.Store
}

type Service interface {
	// Create 创建新会话
	Create(ctx context.Context, req *CreateRequest) (Session, error)

	// Get 获取会话
	Get(ctx context.Context, req *GetRequest) (Session, error)

	// Update 更新会话
	Update(ctx context.Context, req *UpdateRequest) error

	// Delete 删除会话
	Delete(ctx context.Context, sessionID string) error

	// List 列出会话
	List(ctx context.Context, req *ListRequest) ([]*Session, error)

	// AppendEvent 添加事件
	AppendEvent(ctx context.Context, sessionID string, event *Event) error

	// GetEvents 获取事件列表
	GetEvents(ctx context.Context, sessionID string, filter *EventFilter) ([]Event, error)

	// UpdateState 更新状态
	UpdateState(ctx context.Context, sessionID string, delta map[string]any) error
}

type Session interface {
	// ID 返回会话的唯一标识符
	ID() string

	// AppName 返回应用名称
	AppName() string

	// UserID 返回用户 ID
	UserID() string

	// AgentID 返回关联的 Agent ID
	AgentID() string

	// State 返回会话状态管理器
	State() State

	// Events 返回事件列表
	Events() Events

	// LastUpdateTime 返回最后更新时间
	LastUpdateTime() time.Time

	// Metadata 返回会话元数据
	Metadata() map[string]any
}

type SessionData struct {
	ID             string
	AppName        string
	UserID         string
	AgentID        string
	CreatedAt      time.Time
	LastUpdateTime time.Time
	Metadata       map[string]any
}

type SessionSummary struct {
	Text          string    `json:"text"`
	MessageCount  int       `json:"message_count"`
	GeneratedAt   time.Time `json:"generated_at"`
	TokensUsed    int       `json:"tokens_used"`
	KeyTopics     []string  `json:"key_topics"`
	Participants  []string  `json:"participants"`
	IsIncremental bool      `json:"is_incremental"`
}

type State interface {
	// Get 获取指定 key 的值
	// 如果 key 不存在，返回 ErrStateKeyNotExist
	Get(key string) (any, error)

	// Set 设置 key-value，覆盖已存在的值
	Set(key string, value any) error

	// Delete 删除指定 key
	Delete(key string) error

	// All 返回所有 key-value 的迭代器
	All() iter.Seq2[string, any]

	// Has 检查 key 是否存在
	Has(key string) bool
}

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

type SummarizerConfig struct {
	Provider               provider.Provider
	MaxMessagesPerCall     int     // 每次摘要的最大消息数
	MinMessagesToSummarize int     // 触发摘要的最小消息数
	Temperature            float64 // 摘要生成温度
	SystemPrompt           string  // 自定义系统提示词
}

type UpdateRequest struct {
	SessionID string
	Metadata  map[string]any
}