channels

type ChannelError struct {
	Code    string
	Message string
	Err     error
}

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

type ChatChannel interface {
	// Name returns the platform name (e.g., "telegram", "whatsapp", "dingtalk").
	Name() chat_apps.Platform

	// ValidateWebhook verifies the incoming webhook request.
	// Returns an error if the request signature is invalid or the request is malformed.
	ValidateWebhook(ctx context.Context, headers map[string]string, body []byte) error

	// ParseMessage parses the incoming webhook payload into an IncomingMessage.
	// The payload format is platform-specific (JSON for most platforms).
	ParseMessage(ctx context.Context, payload []byte) (*chat_apps.IncomingMessage, error)

	// SendMessage sends a single message to the chat platform.
	SendMessage(ctx context.Context, msg *chat_apps.OutgoingMessage) error

	// SendChunkedMessage sends streaming content chunks.
	// The channels function closes when all chunks are sent or an error occurs.
	// This is used for streaming AI responses.
	SendChunkedMessage(ctx context.Context, chatID string, chunks <-chan string) error

	// DownloadMedia downloads media from the platform's CDN.
	// Returns the media data, MIME type, and an error if any.
	DownloadMedia(ctx context.Context, url string) ([]byte, string, error)

	// Close closes any open connections and releases resources.
	Close() error
}

type MediaHandler interface {
	// ProcessAudio converts audio data to text using Whisper.
	ProcessAudio(ctx context.Context, data []byte, mimeType string) (string, error)

	// ProcessImage extracts text from images using OCR.
	ProcessImage(ctx context.Context, data []byte) (string, error)
}