devui

type AgentEndData struct {
	RunID    string         `json:"run_id"`
	Output   any            `json:"output"`
	Duration int64          `json:"duration_ms"` // 毫秒
	Metadata map[string]any `json:"metadata,omitempty"`
}

type AgentStartData struct {
	RunID    string         `json:"run_id"`
	Input    any            `json:"input"`
	Metadata map[string]any `json:"metadata,omitempty"`
}

type Breakpoint struct {
	// NodeID 断点所在节点
	NodeID string `json:"node_id"`

	// Condition 条件表达式（可选，空表示无条件断点）
	Condition string `json:"condition,omitempty"`

	// Enabled 是否启用
	Enabled bool `json:"enabled"`
}

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

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

type CollectorStats struct {
	TotalEvents   int64 `json:"total_events"`
	AgentRuns     int64 `json:"agent_runs"`
	LLMCalls      int64 `json:"llm_calls"`
	ToolCalls     int64 `json:"tool_calls"`
	RetrieverRuns int64 `json:"retriever_runs"`
	Errors        int64 `json:"errors"`
	Subscribers   int   `json:"subscribers"`
	BufferSize    int   `json:"buffer_size"`
}

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

type DiffResult struct {
	// SessionA 会话 A ID
	SessionA string `json:"session_a"`

	// SessionB 会话 B ID
	SessionB string `json:"session_b"`

	// StepDiffs 步骤差异
	StepDiffs []StepDiff `json:"step_diffs"`

	// Summary 差异摘要
	Summary string `json:"summary"`
}

type ErrorData struct {
	RunID   string `json:"run_id"`
	Source  string `json:"source"` // agent, llm, tool, retriever, graph
	Message string `json:"message"`
	Stack   string `json:"stack,omitempty"`
}

type Event struct {
	// ID 事件唯一标识
	ID string `json:"id"`

	// Type 事件类型
	Type EventType `json:"type"`

	// Timestamp 事件发生时间
	Timestamp time.Time `json:"timestamp"`

	// TraceID 链路追踪 ID（可选）
	TraceID string `json:"trace_id,omitempty"`

	// SpanID Span ID（可选）
	SpanID string `json:"span_id,omitempty"`

	// ParentID 父 Span ID（可选）
	ParentID string `json:"parent_id,omitempty"`

	// AgentID Agent 标识（可选）
	AgentID string `json:"agent_id,omitempty"`

	// AgentName Agent 名称（可选）
	AgentName string `json:"agent_name,omitempty"`

	// Data 事件数据
	// 根据事件类型存储不同的数据结构
	Data map[string]any `json:"data"`
}

type EventType string

type ExecutionResult struct {
	// RunID 执行 ID
	RunID string `json:"run_id"`

	// GraphID 图定义 ID
	GraphID string `json:"graph_id"`

	// Status 执行状态: completed / failed
	Status string `json:"status"`

	// FinalState 最终状态
	FinalState map[string]any `json:"final_state"`

	// NodeResults 各节点的执行结果
	NodeResults []NodeResult `json:"node_results"`

	// DurationMs 总执行耗时（毫秒）
	DurationMs int64 `json:"duration_ms"`

	// Error 错误信息（如有）
	Error string `json:"error,omitempty"`
}

type GraphDefinition struct {
	// ID 图定义的唯一标识
	ID string `json:"id"`

	// Name 图名称
	Name string `json:"name"`

	// Description 图描述（可选）
	Description string `json:"description,omitempty"`

	// Version 版本号，每次更新自增
	Version int `json:"version"`

	// Nodes 节点列表
	Nodes []GraphNodeDef `json:"nodes"`

	// Edges 边列表
	Edges []GraphEdgeDef `json:"edges"`

	// EntryPoint 入口节点 ID
	EntryPoint string `json:"entry_point"`

	// Metadata 元数据（可选）
	Metadata map[string]any `json:"metadata,omitempty"`

	// CreatedAt 创建时间
	CreatedAt time.Time `json:"created_at"`

	// UpdatedAt 最后更新时间
	UpdatedAt time.Time `json:"updated_at"`
}

type GraphEdgeDef struct {
	// ID 边的唯一标识
	ID string `json:"id"`

	// Source 源节点 ID
	Source string `json:"source"`

	// Target 目标节点 ID
	Target string `json:"target"`

	// Label 边的标签（可选，用于条件路由显示）
	Label string `json:"label,omitempty"`

	// Condition 条件表达式（可选，用于条件路由）
	Condition string `json:"condition,omitempty"`
}

type GraphNodeData struct {
	RunID    string         `json:"run_id"`
	GraphID  string         `json:"graph_id"`
	NodeID   string         `json:"node_id"`
	NodeName string         `json:"node_name"`
	State    map[string]any `json:"state,omitempty"`
	Duration int64          `json:"duration_ms,omitempty"` // 毫秒
}

type GraphNodeDef struct {
	// ID 节点唯一标识
	ID string `json:"id"`

	// Name 节点显示名称
	Name string `json:"name"`

	// Type 节点类型
	Type string `json:"type"`

	// Position 画布上的坐标位置
	Position Position `json:"position"`

	// Description 节点描述（可选）
	Description string `json:"description,omitempty"`

	// Config 节点配置（可选，按类型不同配置不同）
	Config map[string]any `json:"config,omitempty"`
}

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

type LLMRequestData struct {
	RunID       string  `json:"run_id"`
	Provider    string  `json:"provider"`
	Model       string  `json:"model"`
	Messages    any     `json:"messages"`
	Temperature float64 `json:"temperature,omitempty"`
}

type LLMResponseData struct {
	RunID            string `json:"run_id"`
	Model            string `json:"model"`
	Response         any    `json:"response"`
	PromptTokens     int    `json:"prompt_tokens"`
	CompletionTokens int    `json:"completion_tokens"`
	TotalTokens      int    `json:"total_tokens"`
	Duration         int64  `json:"duration_ms"` // 毫秒
}

type LLMStreamData struct {
	RunID   string `json:"run_id"`
	Model   string `json:"model"`
	Content string `json:"content"`
	Index   int    `json:"index"`
}

type NodeResult struct {
	// NodeID 节点 ID
	NodeID string `json:"node_id"`

	// NodeName 节点名称
	NodeName string `json:"node_name"`

	// NodeType 节点类型
	NodeType string `json:"node_type"`

	// Status 执行状态: completed / skipped / failed
	Status string `json:"status"`

	// DurationMs 执行耗时（毫秒）
	DurationMs int64 `json:"duration_ms"`

	// Output 节点输出
	Output map[string]any `json:"output,omitempty"`
}

type NodeTypeInfo struct {
	// Type 节点类型标识
	Type string `json:"type"`

	// Name 显示名称
	Name string `json:"name"`

	// Description 类型描述
	Description string `json:"description"`

	// Icon 图标（emoji）
	Icon string `json:"icon"`

	// Color 主题颜色
	Color string `json:"color"`

	// Category 分类
	Category string `json:"category"`
}

type Option func(*Options)

type Options struct {
	// Addr 监听地址，默认仅本机回环 "127.0.0.1:8080"
	Addr string

	// EnableSSE 是否启用 SSE 事件推送，默认 true
	EnableSSE bool

	// EnableMetrics 是否启用指标展示，默认 true
	EnableMetrics bool

	// StaticDir 自定义静态文件目录
	// 如果为空，使用内嵌的静态文件
	StaticDir string

	// MaxEvents 最大事件缓存数，默认 1000
	MaxEvents int

	// APIPrefix API 前缀，默认 "/api"
	APIPrefix string

	// CORSEnabled 是否启用 CORS，默认 false。启用时仍只允许 AllowedOrigins。
	CORSEnabled bool

	// AllowedOrigins 是允许跨域访问的精确 Origin 列表；不支持通配符。
	AllowedOrigins []string

	// AuthToken 是 Builder 写端点的 bearer/CSRF token。loopback 模式
	// 可为空并通过同源 bootstrap 建立短期 session；非 loopback 必须显式配置。
	AuthToken string

	// ReadTimeout HTTP 读取超时
	ReadTimeout time.Duration

	// WriteTimeout HTTP 写入超时
	WriteTimeout time.Duration
}

type Position struct {
	X float64 `json:"x"`
	Y float64 `json:"y"`
}

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

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

type ReplaySession struct {
	// ID 会话 ID
	ID string `json:"id"`

	// RunID 关联的执行 ID
	RunID string `json:"run_id"`

	// GraphID 关联的图 ID
	GraphID string `json:"graph_id,omitempty"`

	// GraphName 图名称
	GraphName string `json:"graph_name,omitempty"`

	// StartTime 开始时间
	StartTime time.Time `json:"start_time"`

	// EndTime 结束时间
	EndTime time.Time `json:"end_time,omitempty"`

	// Status 会话状态: recording / completed / failed
	Status string `json:"status"`

	// Steps 执行步骤列表（按时间排序）
	Steps []ReplayStep `json:"steps"`

	// FinalState 最终状态
	FinalState map[string]any `json:"final_state,omitempty"`

	// Error 错误信息（如有）
	Error string `json:"error,omitempty"`

	// Metadata 额外元数据
	Metadata map[string]any `json:"metadata,omitempty"`
}

type ReplayState struct {
	// SessionID 会话 ID
	SessionID string `json:"session_id"`

	// CurrentStep 当前步骤索引
	CurrentStep int `json:"current_step"`

	// TotalSteps 总步骤数
	TotalSteps int `json:"total_steps"`

	// IsPlaying 是否正在播放
	IsPlaying bool `json:"is_playing"`

	// Step 当前步骤详情
	Step *ReplayStep `json:"step,omitempty"`

	// Breakpoints 断点列表
	Breakpoints []Breakpoint `json:"breakpoints,omitempty"`
}

type ReplayStep struct {
	// Index 步骤序号（从 0 开始）
	Index int `json:"index"`

	// Timestamp 时间戳
	Timestamp time.Time `json:"timestamp"`

	// Type 步骤类型: node_start, node_end, edge, condition, error
	Type string `json:"type"`

	// NodeID 相关节点 ID
	NodeID string `json:"node_id,omitempty"`

	// NodeName 节点名称
	NodeName string `json:"node_name,omitempty"`

	// NodeType 节点类型
	NodeType string `json:"node_type,omitempty"`

	// StateSnapshot 该步骤的状态快照
	StateSnapshot map[string]any `json:"state_snapshot,omitempty"`

	// Input 节点输入
	Input map[string]any `json:"input,omitempty"`

	// Output 节点输出
	Output map[string]any `json:"output,omitempty"`

	// DurationMs 步骤耗时
	DurationMs int64 `json:"duration_ms,omitempty"`

	// Message 步骤描述
	Message string `json:"message,omitempty"`
}

type RetrieverEndData struct {
	RunID     string `json:"run_id"`
	Query     string `json:"query"`
	DocCount  int    `json:"doc_count"`
	Documents any    `json:"documents,omitempty"`
	Duration  int64  `json:"duration_ms"` // 毫秒
}

type RetrieverStartData struct {
	RunID string `json:"run_id"`
	Query string `json:"query"`
	TopK  int    `json:"top_k"`
}

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

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

type Server struct {
	*http.Server
	// contains filtered or unexported fields
}

type StepDiff struct {
	// StepIndex 步骤索引
	StepIndex int `json:"step_index"`

	// Field 差异字段
	Field string `json:"field"`

	// ValueA A 的值
	ValueA any `json:"value_a"`

	// ValueB B 的值
	ValueB any `json:"value_b"`
}

type ToolCallData struct {
	RunID    string         `json:"run_id"`
	ToolID   string         `json:"tool_id"`
	ToolName string         `json:"tool_name"`
	Input    map[string]any `json:"input"`
}

type ToolResultData struct {
	RunID    string `json:"run_id"`
	ToolID   string `json:"tool_id"`
	ToolName string `json:"tool_name"`
	Output   any    `json:"output"`
	Duration int64  `json:"duration_ms"` // 毫秒
	Error    string `json:"error,omitempty"`
}