gateway

type AdapterStatus struct {
	LastMessageAt time.Time `json:"last_message_at,omitempty"`
	Error         string    `json:"error,omitempty"`
	BotName       string    `json:"bot_name,omitempty"`
	Connected     bool      `json:"connected"`
	MessageCount  int64     `json:"message_count"`
}

type AdapterType string

type ChannelInfo struct {
	ID       string `json:"id"`
	Name     string `json:"name"`
	Platform string `json:"platform"`
}

type ChannelStore interface {
	SaveChannel(ctx context.Context, bcChannel, platform, platformID string) error
	LoadChannels(ctx context.Context) ([]PersistedChannel, error)
}

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

type Notification struct {
	Timestamp time.Time       `json:"timestamp"`
	Raw       json.RawMessage `json:"raw"`
	Channel   string          `json:"channel"`
	Platform  string          `json:"platform"`
	Sender    string          `json:"sender"`
	Content   string          `json:"content"` // human-readable text for display/storage
	Mentions  []string        `json:"mentions"`
}

type NotificationAdapter interface {
	// Name returns the adapter identifier ("slack", "github", "telegram").
	Name() string

	// Type returns the connection pattern (socket, webhook, or poll).
	Type() AdapterType

	// Start connects to the platform and begins receiving notifications.
	// Calls handler for each inbound event with raw JSON payload.
	// Blocks until ctx is canceled. For webhook adapters, this is a no-op.
	Start(ctx context.Context, handler func(Notification)) error

	// Stop gracefully disconnects from the platform.
	Stop() error

	// HTTPHandler returns an http.Handler for webhook-based adapters.
	// Socket and poll adapters return nil.
	HTTPHandler() http.Handler

	// Channels returns discovered channels/groups the bot has access to.
	Channels() []ChannelInfo

	// Status returns the adapter's connection state for the web UI.
	Status() AdapterStatus
}

type PersistedChannel struct {
	BCChannel  string
	Platform   string
	PlatformID string
}