notifysource

type Config struct {
	ID              string            `json:"id"`
	Type            string            `json:"type"`
	Enabled         bool              `json:"enabled"`
	IntervalMinutes int               `json:"intervalMinutes"`
	Query           string            `json:"query,omitempty"`
	Options         map[string]string `json:"options,omitempty"`
}

type Factory func(cfg Config, tokens TokenAccessor) (Source, error)

type Notification struct {
	Title      string            `json:"title"`
	Body       string            `json:"body"`
	ReceivedAt time.Time         `json:"receivedAt"`
	Meta       map[string]string `json:"meta,omitempty"`
}

type PollResult struct {
	Items  []Notification
	Cursor string // opaque cursor for next poll (e.g., Gmail historyId)
}

type Source interface {
	// Type returns the source type identifier (e.g., "gmail", "discord").
	Type() string

	// Poll checks for new items since the given cursor.
	// An empty cursor means first poll (source should return recent items).
	Poll(ctx context.Context, cursor string) (*PollResult, error)

	// Validate checks if credentials and configuration are valid.
	Validate(ctx context.Context) error
}

type TokenAccessor interface {
	GetToken(key string) (string, error)
	SetToken(key, value string, expiresAt time.Time) error
	GetTokenExpiry(key string) (string, time.Time, error)
}