provider

type AgentProcessor interface {
	Process(ctx context.Context, sessionID, content string) (string, error)
}

type ChatType string

type Config struct {
	Enabled bool
	Token   string
}

type Event struct {
	// Type is the event type.
	Type EventType

	// ProviderName is the provider this event came from.
	ProviderName string

	// ChatID is the chat/conversation identifier.
	ChatID string

	// Data contains event-specific data.
	Data map[string]any

	// Timestamp is when the event occurred.
	Timestamp time.Time
}

type EventHandler func(ctx context.Context, event Event) error

type EventType string

type IncomingMessage struct {
	// ID is the unique message identifier.
	ID string

	// ProviderName is the provider this message came from (e.g., "telegram").
	ProviderName string

	// ChatID is the chat/conversation identifier.
	ChatID string

	// ChatType is the type of chat (dm, group, channel, thread).
	ChatType ChatType

	// SenderID is the sender's identifier.
	SenderID string

	// SenderName is the sender's display name.
	SenderName string

	// Content is the message text content.
	Content string

	// Media contains any attached media.
	Media []Media

	// ReplyTo is the ID of the message being replied to, if any.
	ReplyTo string

	// Timestamp is when the message was sent.
	Timestamp time.Time

	// Metadata contains provider-specific metadata.
	Metadata map[string]any
}

type Media struct {
	// Type is the media type (image, video, audio, document).
	Type MediaType

	// URL is the media URL (for remote media).
	URL string

	// Data is the raw media data (for local media).
	Data []byte

	// MimeType is the MIME type.
	MimeType string

	// Filename is the file name.
	Filename string

	// Caption is an optional caption.
	Caption string
}

type MediaType string

type MessageFormat string

type MessageHandler func(ctx context.Context, msg IncomingMessage) error

type OutgoingMessage struct {
	// Content is the message text content.
	Content string

	// Media contains media to attach.
	Media []Media

	// ReplyTo is the ID of the message to reply to, if any.
	ReplyTo string

	// Format specifies the message format.
	Format MessageFormat

	// Metadata contains provider-specific options.
	Metadata map[string]any
}

type Provider interface {
	// Name returns the provider name (e.g., "discord", "telegram", "whatsapp").
	Name() string

	// Connect establishes connection to the messaging platform.
	Connect(ctx context.Context) error

	// Disconnect closes the connection.
	Disconnect(ctx context.Context) error

	// Send sends a message to a specific chat/conversation.
	Send(ctx context.Context, chatID string, msg OutgoingMessage) error

	// OnMessage registers a handler for incoming messages.
	OnMessage(handler MessageHandler)

	// OnEvent registers a handler for platform events.
	OnEvent(handler EventHandler)
}

type RouteHandler struct {
	Pattern RoutePattern
	Handler MessageHandler
}

type RoutePattern struct {
	// Providers limits to specific providers (empty = all).
	Providers []string

	// ChatTypes limits to specific chat types (empty = all).
	ChatTypes []ChatType

	// Prefix matches messages starting with a prefix.
	Prefix string
}

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

type StreamingProvider interface {
	Provider

	// SendTyping sends a typing indicator to a chat.
	SendTyping(ctx context.Context, chatID string) error

	// SendStream sends a message as a stream of chunks.
	SendStream(ctx context.Context, chatID string, chunks <-chan string) error
}

type VoiceProcessor interface {
	// TranscribeAudio converts audio to text.
	TranscribeAudio(ctx context.Context, audio []byte, mimeType string) (string, error)
	// SynthesizeSpeech converts text to audio. Returns audio bytes and MIME type.
	SynthesizeSpeech(ctx context.Context, text string) ([]byte, string, error)
	// ResponseMode returns the voice response mode ("auto", "always", "never").
	ResponseMode() string
}