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 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 C2CMessageEventData struct {
	ID        string `json:"id"`
	Content   string `json:"content"`
	Timestamp string `json:"timestamp"`
	Author    struct {
		UserOpenID string `json:"user_openid"`
	} `json:"author"`
}

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 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 Manager struct {
	// contains filtered or unexported fields
}

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"`
}

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"`
}