channels

type ATMessageEventData struct {
	ID        string `json:"id"`
	Content   string `json:"content"`
	Timestamp string `json:"timestamp"`
	Author    struct {
		ID       string `json:"id"`
		Username string `json:"username"`
	} `json:"author"`
	ChannelID string `json:"channel_id"`
	GuildID   string `json:"guild_id"`
}

type AcpSessionRouter interface {
	RouteToAcpSession(channel, accountID, conversationID string) string
	IsACPThreadBinding(channel, accountID, conversationID string) bool
}

type BaseChannel interface {
	// Name 返回通道名称
	Name() string

	// AccountID 返回通道账号ID
	AccountID() string

	// Start 启动通道
	Start(ctx context.Context) error

	// Stop 停止通道
	Stop() error

	// Send 发送消息
	Send(msg *bus.OutboundMessage) error

	// SendStream 发送流式消息
	SendStream(chatID string, stream <-chan *bus.StreamMessage) error

	// IsAllowed 检查发送者是否允许
	IsAllowed(senderID string) bool
}

type BaseChannelConfig struct {
	Enabled    bool     `mapstructure:"enabled" json:"enabled"`
	AccountID  string   `mapstructure:"account_id" json:"account_id"` // 账号ID
	Name       string   `mapstructure:"name" json:"name"`             // 账号显示名称
	AllowedIDs []string `mapstructure:"allowed_ids" json:"allowed_ids"`
}

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

type BindInput struct {
	TargetSessionKey string
	TargetKind       string
	Conversation     ThreadBindingConversation
	Placement        string
	Metadata         ThreadBindingMetadata
}

type C2CMessageEventData struct {
	ID        string `json:"id"`
	Content   string `json:"content"`
	Timestamp string `json:"timestamp"`
	Author    struct {
		UserOpenID string `json:"user_openid"`
	} `json:"author"`
}

type CapabilityScope string

type CapabilityType string

type ChannelCapabilities struct {
	// Reactions support
	Reactions CapabilityScope `mapstructure:"reactions" json:"reactions"`
	// Inline buttons support
	InlineButtons CapabilityScope `mapstructure:"inline_buttons" json:"inline_buttons"`
	// Thread support
	Threads CapabilityScope `mapstructure:"threads" json:"threads"`
	// Poll support
	Polls CapabilityScope `mapstructure:"polls" json:"polls"`
	// Streaming support
	Streaming CapabilityScope `mapstructure:"streaming" json:"streaming"`
	// Media support
	Media CapabilityScope `mapstructure:"media" json:"media"`
	// Native slash commands
	NativeCommands CapabilityScope `mapstructure:"native_commands" json:"native_commands"`
}

type ChannelCapabilityConfig struct {
	// Reactions support: "off", "dm", "group", "all", "allowlist"
	Reactions string `mapstructure:"reactions" json:"reactions"`
	// Inline buttons support
	InlineButtons string `mapstructure:"inline_buttons" json:"inline_buttons"`
	// Thread support
	Threads string `mapstructure:"threads" json:"threads"`
	// Poll support
	Polls string `mapstructure:"polls" json:"polls"`
	// Streaming support
	Streaming string `mapstructure:"streaming" json:"streaming"`
	// Media support
	Media string `mapstructure:"media" json:"media"`
	// Native commands support
	NativeCommands string `mapstructure:"native_commands" json:"native_commands"`
}

type ChatContext struct {
	IsPrivateMessage bool
	IsGroupMessage   bool
	IsWhitelisted    bool
	ChatType         string // "private", "group", "supergroup", etc.
	ChatID           string
}

type DingTalkChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type DiscordChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type DiscordConfig struct {
	BaseChannelConfig
	Token string `mapstructure:"token" json:"token"`
}

type DiscordReaction struct {
	EmojiID   string `json:"emoji_id"`
	EmojiName string `json:"emoji_name"`
	Animated  bool   `json:"animated"`
	Count     int    `json:"count"`
}

type DiscordReactionDetail struct {
	Emoji DiscordReaction
	Users []DiscordReactionUser `json:"users"`
}

type DiscordReactionUser struct {
	ID       string `json:"id"`
	Username string `json:"username"`
	Tag      string `json:"tag"`
}

type FeishuChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type GoogleChatChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type GoogleChatConfig struct {
	BaseChannelConfig
	ProjectID   string `mapstructure:"project_id" json:"project_id"`
	Credentials string `mapstructure:"credentials" json:"credentials"` // Service account credentials JSON
}

type GroupATMessageEventData struct {
	ID        string `json:"id"`
	Content   string `json:"content"`
	Timestamp string `json:"timestamp"`
	Author    struct {
		MemberOpenID string `json:"member_openid"`
	} `json:"author"`
	GroupOpenID string `json:"group_openid"`
}

type HelloData struct {
	HeartbeatInterval int `json:"heartbeat_interval"`
}

type InfoflowChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type InfoflowConfig struct {
	BaseChannelConfig
	WebhookURL  string `json:"webhook_url" mapstructure:"webhook_url"`
	Token       string `json:"token" mapstructure:"token"`
	AESKey      string `json:"aes_key" mapstructure:"aes_key"`
	WebhookPort int    `json:"webhook_port" mapstructure:"webhook_port"`
}

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

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

type PreparedAcpThreadBinding struct {
	Channel        string
	AccountID      string
	ConversationID string
}

type QQChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type ReadyData struct {
	SessionID string `json:"session_id"`
	Version   int    `json:"version"`
	User      struct {
		ID       string `json:"id"`
		Username string `json:"username"`
		Bot      bool   `json:"bot"`
	} `json:"user"`
}

type SlackChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type SlackConfig struct {
	BaseChannelConfig
	Token         string `mapstructure:"token" json:"token"`
	SigningSecret string `mapstructure:"signing_secret" json:"signing_secret"`
}

type TeamsActor struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type TeamsAttachment struct {
	ContentType string                 `json:"contentType"`
	Content     map[string]interface{} `json:"content"`
}

type TeamsChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type TeamsConfig struct {
	BaseChannelConfig
	AppID       string `mapstructure:"app_id" json:"app_id"`
	AppPassword string `mapstructure:"app_password" json:"app_password"`
	TenantID    string `mapstructure:"tenant_id" json:"tenant_id"`
	WebhookURL  string `mapstructure:"webhook_url" json:"webhook_url"` // For outgoing webhooks
}

type TeamsConversation struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type TeamsEntity struct {
	Type string                 `json:"type"`
	Data map[string]interface{} `json:"data,omitempty"`
}

type TeamsWebhookMessage struct {
	Type         string            `json:"type"`
	ID           string            `json:"id"`
	Timestamp    string            `json:"timestamp"`
	ServiceURL   string            `json:"serviceUrl"`
	ChannelID    string            `json:"channelId"`
	From         TeamsActor        `json:"from"`
	Conversation TeamsConversation `json:"conversation"`
	Text         string            `json:"text"`
	Attachments  []TeamsAttachment `json:"attachments"`
	Entities     []TeamsEntity     `json:"entities"`
}

type TelegramChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type TelegramConfig struct {
	BaseChannelConfig
	Token              string `mapstructure:"token" json:"token"`
	InlineButtonsScope string `mapstructure:"inline_buttons_scope" json:"inline_buttons_scope"`
}

type TelegramInlineButton struct {
	// Text is the button label
	Text string `json:"text"`
	// CallbackData is the data sent when button is clicked (for callback buttons)
	CallbackData string `json:"callback_data,omitempty"`
	// URL is the URL to open (for URL buttons)
	URL string `json:"url,omitempty"`
	// WebAppURL is the URL of a Web App to open (for web app buttons)
	WebAppURL string `json:"web_app_url,omitempty"`
}

type TelegramInlineButtonsScope string

type TelegramInlineKeyboardRow struct {
	Buttons []TelegramInlineButton `json:"buttons"`
}

type ThreadBindingCapabilities struct {
	AdapterAvailable bool     // Whether the adapter is available
	BindSupported    bool     // Whether thread binding is supported
	Placements       []string // Supported placement types
}

type ThreadBindingConversation struct {
	Channel        string // Channel type (telegram, discord, etc.)
	AccountID      string // Account identifier
	ConversationID string // Thread/conversation identifier
}

type ThreadBindingMetadata struct {
	ThreadName string         // Display name for the thread
	AgentID    string         // Associated agent ID
	Label      string         // Optional label
	BoundBy    string         // Who created the binding ("user" or "system")
	IntroText  string         // Introduction text
	SessionCwd string         // Working directory
	Details    map[string]any // Additional details
}

type ThreadBindingPolicy struct {
	Channel       string // Channel type
	AccountID     string // Account identifier
	Kind          string // Binding kind ("acp" or "subagent")
	Enabled       bool   // Whether thread bindings are enabled
	SpawnEnabled  bool   // Whether spawning new bindings is allowed
	IdleTimeoutMs int    // Idle timeout in milliseconds
	MaxAgeMs      int    // Maximum age in milliseconds
}

type ThreadBindingRecord struct {
	ID               string                    // Unique binding ID
	TargetSessionKey string                    // The ACP session key
	TargetKind       string                    // "session" or "subagent"
	Conversation     ThreadBindingConversation // Channel conversation info
	Placement        string                    // "child" or "peer"
	Metadata         ThreadBindingMetadata     // Binding metadata
	CreatedAt        time.Time                 // Creation time
	ExpiresAt        *time.Time                // Optional expiration
}

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

type ThreadBindingStorage interface {
	// Load loads all bindings from storage.
	Load() ([]*ThreadBindingRecord, error)
	// Save saves a binding to storage.
	Save(record *ThreadBindingRecord) error
	// Delete removes a binding from storage.
	Delete(bindingID string) error
	// List returns all bindings.
	List() ([]*ThreadBindingRecord, error)
}

type WSPayload struct {
	Op int             `json:"op"`
	D  json.RawMessage `json:"d"`
	S  uint32          `json:"s"`
	T  string          `json:"t"`
}

type WeWorkChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type WhatsAppChannel struct {
	*BaseChannelImpl
	// contains filtered or unexported fields
}

type WhatsAppConfig struct {
	BaseChannelConfig
	BridgeURL string `mapstructure:"bridge_url" json:"bridge_url"`
}

type WhatsAppMessage struct {
	ID        string `json:"id"`
	From      string `json:"from"`
	ChatID    string `json:"chat_id"`
	Text      string `json:"text"`
	Type      string `json:"type"`
	Timestamp int64  `json:"timestamp"`
}