channels

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

type Attachment struct {
	Type     string `json:"type"`               // "image", "audio", "video", "document"
	URL      string `json:"url"`                // download URL or local path
	MimeType string `json:"mime_type"`          // e.g. "image/jpeg"
	Caption  string `json:"caption,omitempty"`  // optional caption
	Filename string `json:"filename,omitempty"` // original filename
}

type Channel interface {
	// Listen returns a read-only channel of inbound messages.
	// The returned channel is closed when ctx is cancelled or Close is called.
	Listen(ctx context.Context) <-chan Message

	// Send pushes an outbound message to the platform.
	Send(ctx context.Context, msg Message) error

	// Status returns the current connection status.
	Status() ChannelStatus

	// Close shuts down the connection and releases resources.
	// After Close, the channel returned by Listen will be closed.
	Close() error
}

type ChannelFactory func(name string, config json.RawMessage) (Channel, error)

type ChannelInfo struct {
	Name      string        `json:"name"`
	Platform  string        `json:"platform"`
	Status    ChannelStatus `json:"status"`
	Connected bool          `json:"connected"`
}

type ChannelRow struct {
	Name      string          `json:"name"`
	Platform  string          `json:"platform"`
	Enabled   bool            `json:"enabled"`
	Config    json.RawMessage `json:"config,omitempty"`
	AuthState json.RawMessage `json:"auth_state,omitempty"`
	UpdatedAt int64           `json:"updated_at"`
}

type ChannelStatus struct {
	Connected   bool      `json:"connected"`
	Platform    string    `json:"platform"`
	AuthState   string    `json:"auth_state"` // "paired", "pending_qr", "token_valid", etc.
	LastMessage time.Time `json:"last_message"`
	Error       string    `json:"error,omitempty"`
}

type Direction int

type DiscordConfig struct {
	// BotToken is the Discord bot token (from Developer Portal).
	BotToken string `json:"bot_token"`
	// GuildID restricts the bot to a specific guild. If empty, the bot
	// listens on all guilds it has been invited to.
	GuildID string `json:"guild_id,omitempty"`
	// ChannelIDs restricts listening to specific channel IDs.
	// If empty, all channels the bot can see are monitored.
	ChannelIDs []string `json:"channel_ids,omitempty"`
	// Intents specifies the gateway intents. Defaults to MessageContent +
	// GuildMessages + DirectMessages if empty.
	Intents int `json:"intents,omitempty"`
}

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

type DispatcherOption func(*Dispatcher)

type ErrChannelDisabled struct {
	Channel string
}

type ErrChannelNotFound struct {
	Channel string
}

type ErrNoPlatformFactory struct {
	Channel  string
	Platform string
}

type ErrSendFailed struct {
	Channel  string
	Platform string
	Cause    error
}

type InboundHandler func(ctx context.Context, msg Message) ([]Message, error)

type Message struct {
	ID          string            `json:"id"`
	ChannelName string            `json:"channel"`            // e.g. "whatsapp_main", "tg_support"
	Platform    string            `json:"platform"`           // "whatsapp", "telegram", "discord", "webhook"
	Direction   Direction         `json:"direction"`          // Inbound or Outbound
	SenderID    string            `json:"sender_id"`          // platform-specific user ID
	RecipientID string            `json:"recipient_id"`       // platform-specific recipient ID
	Text        string            `json:"text"`               // message body
	ReplyTo     string            `json:"reply_to,omitempty"` // ID of message being replied to
	Attachments []Attachment      `json:"attachments,omitempty"`
	Metadata    map[string]string `json:"metadata,omitempty"` // platform-specific extras
	Timestamp   time.Time         `json:"timestamp"`
}

type TelegramConfig struct {
	// BotToken is the Telegram bot API token (from @BotFather).
	// For security, prefer passing via environment variable and referencing
	// the env var name here.
	BotToken string `json:"bot_token"`
	// UseMTProto enables the full MTProto client (gotd/td) instead of the
	// simpler bot API. Required for user accounts, optional for bots.
	UseMTProto bool `json:"use_mtproto,omitempty"`
	// WebhookURL, if set, uses webhook mode instead of long-polling.
	// Must be a publicly reachable HTTPS URL.
	WebhookURL string `json:"webhook_url,omitempty"`
}

type WebhookConfig struct {
	// ListenAddr is the address to bind the HTTP server (e.g. ":8080").
	ListenAddr string `json:"listen_addr"`
	// Path is the URL path to listen on (e.g. "/webhook/inbound").
	Path string `json:"path"`
	// Secret is an optional shared secret for HMAC-SHA256 signature verification.
	// When set, inbound requests must include an X-Signature-256 header with
	// the hex-encoded HMAC-SHA256 of the request body.
	Secret string `json:"secret,omitempty"`
	// MaxBodyBytes limits the request body size. Defaults to 1MB.
	MaxBodyBytes int64 `json:"max_body_bytes,omitempty"`
}

type WhatsAppConfig struct {
	// DeviceName is the display name for the linked device.
	DeviceName string `json:"device_name"`
	// StorePath is the path to whatsmeow's SQLite session database.
	StorePath string `json:"store_path"`
}