bus

type BusError struct {
	Message string
}

type InboundMessage struct {
	ID        string                 `json:"id"`
	Channel   string                 `json:"channel"`    // telegram, whatsapp, feishu, cli, system
	AccountID string                 `json:"account_id"` // 账号ID（用于多账号场景）
	SenderID  string                 `json:"sender_id"`  // 发送者ID
	ChatID    string                 `json:"chat_id"`    // 聊天ID
	Content   string                 `json:"content"`    // 消息内容
	Media     []Media                `json:"media"`      // 媒体文件
	Metadata  map[string]interface{} `json:"metadata"`   // 元数据
	Timestamp time.Time              `json:"timestamp"`
}

type Media struct {
	Type     string `json:"type"`     // image, video, audio, document
	URL      string `json:"url"`      // 文件URL
	Base64   string `json:"base64"`   // Base64编码内容
	MimeType string `json:"mimetype"` // MIME类型
}

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

type OutboundMessage struct {
	ID        string                 `json:"id"`
	Channel   string                 `json:"channel"`  // telegram, whatsapp, feishu, cli
	ChatID    string                 `json:"chat_id"`  // 聊天ID
	Content   string                 `json:"content"`  // 消息内容
	Media     []Media                `json:"media"`    // 媒体文件
	ReplyTo   string                 `json:"reply_to"` // 回复的消息ID
	Metadata  map[string]interface{} `json:"metadata"` // 元数据
	Timestamp time.Time              `json:"timestamp"`
}

type OutboundSubscription struct {
	ID      string
	Channel <-chan *OutboundMessage
	// contains filtered or unexported fields
}

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

type StreamMessage struct {
	ID         string                 `json:"id"`
	Channel    string                 `json:"channel"`
	ChatID     string                 `json:"chat_id"`
	Content    string                 `json:"content"`
	ChunkIndex int                    `json:"chunk_index"`
	IsComplete bool                   `json:"is_complete"`
	IsThinking bool                   `json:"is_thinking"`
	IsFinal    bool                   `json:"is_final"`
	Metadata   map[string]interface{} `json:"metadata"`
	Error      string                 `json:"error,omitempty"`
}

type StreamingMessageBus struct {
	*MessageBus
	// contains filtered or unexported fields
}

type SystemMessage struct {
	InboundMessage
	TaskID    string `json:"task_id"`    // 任务ID
	TaskLabel string `json:"task_label"` // 任务标签
	Status    string `json:"status"`     // completed, failed
}