notification

type CLIUtils struct{}

type DeleteSubscriptionRequest struct {
	Endpoint string `json:"endpoint" validate:"required"`
}

type DeviceInfo struct {
	UserAgent  string `json:"user_agent,omitempty"`
	DeviceType string `json:"device_type,omitempty"` // "desktop", "mobile", "tablet"
	Browser    string `json:"browser,omitempty"`     // "chrome", "firefox", "safari"
	OS         string `json:"os,omitempty"`          // "windows", "macos", "linux", "android", "ios"
	DeviceHash string `json:"device_hash,omitempty"` // Hash of device fingerprint
}

type HistoryResponse struct {
	Notifications []NotificationHistory `json:"notifications"`
	Total         int                   `json:"total"`
	HasMore       bool                  `json:"has_more"`
}

type JSONLStorage = JSONStorage

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

type NotificationHistory struct {
	ID             string                 `json:"id"`
	UserID         string                 `json:"user_id"`
	SubscriptionID string                 `json:"subscription_id"`
	Title          string                 `json:"title"`
	Body           string                 `json:"body"`
	Type           string                 `json:"type"`
	SessionID      string                 `json:"session_id"`
	Data           map[string]interface{} `json:"data"`
	SentAt         time.Time              `json:"sent_at"`
	Delivered      bool                   `json:"delivered"`
	Clicked        bool                   `json:"clicked"`
	ErrorMessage   *string                `json:"error_message"`
}

type NotificationResult struct {
	Subscription Subscription
	Error        error
}

type SendNotificationRequest struct {
	Title     string `json:"title"`
	Body      string `json:"body"`
	URL       string `json:"url,omitempty"`
	Icon      string `json:"icon,omitempty"`
	SessionID string `json:"session_id,omitempty"`
	UserID    string `json:"user_id,omitempty"`
}

type SendNotificationResponse struct {
	Success bool   `json:"success"`
	Message string `json:"message,omitempty"`
}

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

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

type Storage interface {
	// Subscription methods
	AddSubscription(userID string, sub Subscription) error
	GetSubscriptions(userID string) ([]Subscription, error)
	GetAllSubscriptions() ([]Subscription, error)
	UpdateSubscription(userID string, subscriptionID string, updates Subscription) error
	DeleteSubscription(userID string, endpoint string) error

	// History methods
	AddNotificationHistory(userID string, notification NotificationHistory) error
	GetNotificationHistory(userID string, limit, offset int, filters map[string]string) ([]NotificationHistory, int, error)
	RotateNotificationHistory(userID string, maxEntries int) error
}

type SubscribeRequest struct {
	Endpoint string            `json:"endpoint" validate:"required"`
	Keys     map[string]string `json:"keys" validate:"required"`
}

type SubscribeResponse struct {
	Success        bool   `json:"success"`
	SubscriptionID string `json:"subscription_id"`
}

type Subscription struct {
	ID                string            `json:"id"`
	UserID            string            `json:"user_id"`
	UserType          string            `json:"user_type"`
	Username          string            `json:"username"`
	Type              string            `json:"type"` // "webpush" (default), "slack"
	Endpoint          string            `json:"endpoint"`
	Keys              map[string]string `json:"keys"`
	SessionIDs        []string          `json:"session_ids"`
	NotificationTypes []string          `json:"notification_types"`
	DeviceInfo        *DeviceInfo       `json:"device_info,omitempty"`
	CreatedAt         time.Time         `json:"created_at"`
	UpdatedAt         time.Time         `json:"updated_at"`
	LastUsed          time.Time         `json:"last_used,omitempty"`
	Active            bool              `json:"active"`
}

type SubscriptionReader interface {
	// GetSubscriptions returns all subscriptions for a user (including inactive)
	GetSubscriptions(userID string) ([]Subscription, error)
	// GetAllSubscriptions returns all subscriptions across all users (including inactive)
	GetAllSubscriptions() ([]Subscription, error)
}

type SubscriptionSecretSyncer interface {
	// Sync creates or updates the subscription storage for a user
	// It reads the current subscriptions from the storage and syncs them to the external storage
	Sync(userID string) error
}

type SubscriptionWriter interface {
	// UpdateSubscriptions replaces all subscriptions for a user with the provided list.
	UpdateSubscriptions(userID string, subs []Subscription) error
}

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

type WebhookRequest struct {
	SessionID string                 `json:"session_id"`
	UserID    string                 `json:"user_id"`
	EventType string                 `json:"event_type"`
	Timestamp time.Time              `json:"timestamp"`
	Data      map[string]interface{} `json:"data"`
}