inbox

type IdleNotificationPayload struct {
	IdleReason      string `json:"idle_reason"` // "available" | "interrupted" | "failed"
	Summary         string `json:"summary,omitempty"`
	CompletedTaskID string `json:"completed_task_id,omitempty"`
	CompletedStatus string `json:"completed_status,omitempty"` // "resolved" | "blocked" | "failed"
	FailureReason   string `json:"failure_reason,omitempty"`
}

type Inbox interface {
	// Send 向此 Inbox 投递一条消息(非阻塞).
	// 如果 Inbox 已满或已关闭,返回错误.
	Send(msg *Message) error

	// Recv 阻塞等待下一条消息,ctx 取消时返回 ctx.Err().
	// Inbox 关闭后,Recv 返回 ErrInboxClosed.
	Recv(ctx context.Context) (*Message, error)

	// Poll 非阻塞尝试获取下一条消息,无消息返回 nil, nil.
	// Inbox 关闭后,Poll 返回 nil, ErrInboxClosed.
	Poll() (*Message, error)

	// Close 关闭 Inbox,所有等待中的 Recv 返回错误.
	// Close 是幂等的,多次调用不 panic.
	Close() error
}

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

type Message struct {
	ID        string          `json:"id"`
	Type      MessageType     `json:"type"`
	From      string          `json:"from"` // 发送方 agent 名称
	To        string          `json:"to"`   // 接收方 agent 名称
	Timestamp time.Time       `json:"timestamp"`
	Payload   json.RawMessage `json:"payload"` // 类型特定的数据
}

type MessageType string

type PermissionRequestPayload struct {
	RequestID   string         `json:"request_id"`
	ToolName    string         `json:"tool_name"`
	ToolUseID   string         `json:"tool_use_id"`
	Description string         `json:"description"`
	Input       map[string]any `json:"input"`
}

type PermissionResponsePayload struct {
	RequestID    string         `json:"request_id"`
	Approved     bool           `json:"approved"`
	UpdatedInput map[string]any `json:"updated_input,omitempty"`
	Reason       string         `json:"reason,omitempty"`
}

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

type TaskAssignmentPayload struct {
	TaskID      string `json:"task_id"`
	Subject     string `json:"subject"`
	Description string `json:"description"`
	AssignedBy  string `json:"assigned_by"`
}

type UDSInboxMessage struct {
	Type      string          `json:"type"`                  // "progress", "log", "result"
	ToolUseID string          `json:"tool_use_id,omitempty"` // 关联的工具调用 ID(可选)
	Data      string          `json:"data"`                  // 消息主体内容
	Meta      json.RawMessage `json:"meta,omitempty"`        // 额外元数据(可选)
}

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