bot

type ApiError struct {
	Status  int
	Code    int
	Message string
}

type Attachment struct {
	Type     string // "image", "file", "video", "audio"
	FileName string // Original filename
	FilePath string // Local path after download
	FileKey  string // Platform-specific resource key
	MimeType string // Inferred MIME type
	Size     int64  // File size in bytes
}

type BotAdapter interface {
	// Start starts the bot, establishes connection and begins listening for messages
	Start(messageHandler func(BotMessage)) error

	// SendMessage sends a message to the IM platform
	// Adapter is responsible for:
	//   - Truncating to platform limits
	//   - Splitting long messages when necessary
	//   - Platform-specific formatting
	SendMessage(channel, message string) error

	// SupportsTypingIndicator returns true if the platform supports typing indicators
	SupportsTypingIndicator() bool

	// AddTypingIndicator adds a typing indicator to a message (if supported)
	// messageID is the ID of the user's message to react to
	// Returns true if successfully added
	AddTypingIndicator(messageID string) bool

	// RemoveTypingIndicator removes the typing indicator from a message
	RemoveTypingIndicator(messageID string) error

	// SetProxyManager sets the proxy manager for the bot
	SetProxyManager(mgr proxy.Manager)

	// Stop stops the bot and cleans up resources
	Stop() error
}

type BotMessage struct {
	Platform    string // feishu/discord/telegram
	UserID      string // Unique user identifier (for permission control)
	Channel     string // Channel/session ID
	MessageID   string // Message ID (for typing indicator)
	Content     string // Message content
	Timestamp   time.Time
	ThreadID    string       // Optional: thread/topic ID
	QuoteID     string       // Optional: parent message ID (reply context)
	ChatType    string       // Optional: "p2p", "group", "topic"
	SenderName  string       // Optional: display name of sender
	MessageType string       // Optional: "text", "image", "file", "audio", "video", "post"
	Attachments []Attachment // Optional: downloaded media files
}

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

type ContentBlock struct {
	Type      ContentBlockType
	Title     string            // Block title (e.g., tool name)
	Content   string            // Markdown content
	Collapsed bool              // Whether to collapse by default
	Meta      map[string]string // Tool-specific metadata (command, file_path, etc.)
}

type ContentBlockType string

type Credentials struct {
	Token     string `json:"token"`
	BaseURL   string `json:"base_url"`
	AccountID string `json:"account_id"`
	UserID    string `json:"user_id"`
}

type Debounceable interface {
	DebounceWindow() int // milliseconds; 0 = disabled
}

type DefaultTypingIndicator struct{}

type DingTalkBot struct {
	DefaultTypingIndicator
	// contains filtered or unexported fields
}

type DiscordBot struct {
	DefaultTypingIndicator
	// contains filtered or unexported fields
}

type DiscordMessage interface {
	ID() string
}

type DiscordSessionInterface interface {
	AddHandler(handler interface{}) func()
	Open() error
	Close() error
	ChannelMessageSend(channelID string, content string, options ...discordgo.RequestOption) (*discordgo.Message, error)
}

type GatewayPayload struct {
	OP int         `json:"op"`
	D  interface{} `json:"d,omitempty"`
	S  *int        `json:"s,omitempty"`
	T  string      `json:"t,omitempty"`
}

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

type IdentifyData struct {
	Token   string `json:"token"`
	Intents int    `json:"intents"`
	Shard   []int  `json:"shard"`
}

type MediaSupporter interface {
	DownloadMedia(ctx context.Context, msg *BotMessage) error
}

type MentionPolicy interface {
	ShouldRespond(msg BotMessage) bool
}

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

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

type QQBot struct {
	DefaultTypingIndicator
	// contains filtered or unexported fields
}

type QQGatewayResponse struct {
	URL string `json:"url"`
}

type QQTokenResponse struct {
	AccessToken string `json:"access_token"`
	ExpiresIn   string `json:"expires_in"` // API returns as string
}

type Quotable interface {
	FetchQuotedMessage(ctx context.Context, channelID, messageID string) (*QuotedMessage, error)
}

type QuotedMessage struct {
	SenderID   string
	SenderName string
	Content    string
	Timestamp  time.Time
}

type Replyable interface {
	SendMessageWithReply(channel, message, replyToMessageID string) error
}

type RichMessageHandle interface {
	Channel() string
	Update(blocks []ContentBlock) error // Incremental update during streaming
	Finish(blocks []ContentBlock) error // Final update, remove interactive elements
}

type RichMessageOptions struct {
	Title     string            // Optional card title
	StopText  string            // Stop button label (e.g., "Stop")
	StopData  string            // Stop button callback data
	ReplyToID string            // If set, reply to this message ID
	Meta      map[string]string // Channel-specific metadata
}

type RichMessenger interface {
	CreateRichMessage(channel string, opts RichMessageOptions) (RichMessageHandle, error)
}

type SendMessageRequest struct {
	Content string `json:"content"`
	MsgType int    `json:"msg_type"`
	MsgID   string `json:"msg_id,omitempty"`
	MsgSeq  int    `json:"msg_seq,omitempty"`
}

type SendMessageResponse struct {
	ID string `json:"id"`
}

type TelegramBot struct {
	DefaultTypingIndicator
	// contains filtered or unexported fields
}

type Threadable interface {
	ThreadScope(channelID string, msg BotMessage) string
}

type WeixinBot struct {
	DefaultTypingIndicator
	// contains filtered or unexported fields
}