notification

type AttachmentInput struct {
	Data     io.Reader // raw file bytes (multipart mode)
	URL      string    // external URL to download (JSON mode)
	MimeType string    // detected or declared MIME type
	Filename string    // sanitized original filename (empty = unknown)
}

type AttachmentStorer interface {
	Store(ctx context.Context, topicID, mimeType string, originalSize int, data []byte) (token string, err error)
}

type DeviceProvider interface {
	GetSubscribedDevices(ctx context.Context, userID, topicName string) ([]PushSub, error)
	MarkSubscriptionGone(ctx context.Context, deviceID string) error
}

type DeviceResult struct {
	DeviceID         string
	StatusCode       int
	Err              error
	SubscriptionGone bool // true if device was deleted due to 410/404
}

type E2EEnvelope struct {
	BeeBuzz E2EEnvelopeToken `json:"beebuzz"`
}

type E2EEnvelopeToken struct {
	ID     string `json:"id"`
	Token  string `json:"token"`
	SentAt string `json:"sent_at"`
}

type EventTracker interface {
	// NotificationCreated is called once per Send operation after the push loop completes.
	NotificationCreated(ctx context.Context, userID, topic, source, deliveryMode string, attachmentBytes int64)
	// DeviceDelivered is called for each successful push delivery.
	DeviceDelivered(ctx context.Context, userID, deviceID string)
	// DeviceFailed is called for each failed push delivery.
	DeviceFailed(ctx context.Context, userID string, result DeviceResult)
}

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

type KeyProvider interface {
	GetDeviceKeys(ctx context.Context, userID string) ([]device.DeviceKeyDescriptor, error)
}

type KeysResponse struct {
	Data []device.DeviceKeyDescriptor `json:"data"`
}

type NotificationAttachment struct {
	Token    string `json:"token,omitempty"`
	MIME     string `json:"mime,omitempty"`
	Filename string `json:"filename,omitempty"`
}

type NotificationPayload struct {
	ID         string                  `json:"id"`
	Title      string                  `json:"title"`
	Body       string                  `json:"body"`
	TopicID    string                  `json:"topic_id,omitempty"`
	Topic      string                  `json:"topic,omitempty"`
	Priority   string                  `json:"priority,omitempty"`
	SentAt     string                  `json:"sent_at"`
	Attachment *NotificationAttachment `json:"attachment,omitempty"`
}

type PushAuthorizer interface {
	ValidateAPITokenForTopic(ctx context.Context, token, topicName string) (userID, topicID string, err error)
	ValidateAPIToken(ctx context.Context, token string) (userID string, err error)
}

type PushSub struct {
	DeviceID     string
	Endpoint     string
	P256dh       string
	Auth         string
	AgeRecipient string
}

type SendInput struct {
	TopicName    string
	Title        string
	Body         string
	Priority     string
	Source       string           // opaque source tag for analytics (e.g., "api", "webhook")
	DeliveryMode string           // delivery mode (e.g., "server_trusted", "e2e")
	Attachment   *AttachmentInput // nil when no attachment
	OpaqueBlob   []byte           // raw E2E-encrypted payload (octet-stream mode)
}

type SendReport struct {
	DeviceResults []DeviceResult
	TotalSent     int
	TotalFailed   int
}

type SendRequest struct {
	Title         string `json:"title"`
	Body          string `json:"body"`
	Priority      string `json:"priority,omitempty"`
	AttachmentURL string `json:"attachment_url,omitempty"`
}

type SendResponse struct {
	Status      SendStatus                   `json:"status"`
	SentCount   int                          `json:"sent_count"`
	TotalCount  int                          `json:"total_count"`
	FailedCount int                          `json:"failed_count"`
	DeviceKeys  []device.DeviceKeyDescriptor `json:"device_keys,omitempty"` // current paired device keys for CLI auto-sync
}

type SendStatus string

type Sender interface {
	Send(ctx context.Context, userID, topicID string, input SendInput, log *slog.Logger) (*SendReport, error)
	VAPIDPublicKey() string
}

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

type VAPIDKeys struct {
	PublicKey  string
	PrivateKey string
}

type VAPIDPublicKeyResponse struct {
	Key string `json:"key"`
}