pushservice

type Claim struct {
	Notification
	Token string
}

type Notification struct {
	ID      string
	OwnerID string
	Kind    string
	// Content holds the JSON title and body; delivery adds the link.
	Content   []byte
	Attempt   int
	CreatedAt int64
	// Available reports that the owning account exists and is enabled.
	Available bool
	// JobState is the linked ingestion job's state, empty when it is gone;
	// ContextID is its published context once succeeded.
	JobState  string
	ContextID string
}

type Options struct {
	// PublicURL enables push when it is https, or http on a loopback host for
	// development. Its origin is the VAPID subject.
	PublicURL string
	Now       func() time.Time
}

type RateLimitedError struct{ RetryAfter time.Duration }

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

type Settings struct {
	Enabled   bool
	PublicKey string
	Devices   []Subscription
}

type Store interface {
	// PushKeys stores generated unless keys exist, and returns the stored keys.
	PushKeys(ctx context.Context, generated webpush.Keys, now int64) (webpush.Keys, error)
	// PutSubscription registers the endpoint for the subscription's owner. The
	// same owner's endpoint keeps its ID and creation time; another account's
	// endpoint moves to this owner as a new device.
	PutSubscription(ctx context.Context, subscription Subscription) (Subscription, error)
	Subscriptions(ctx context.Context, ownerID string) ([]Subscription, error)
	// DeleteSubscription returns ErrNotFound unless the owner has the subscription.
	DeleteSubscription(ctx context.Context, ownerID, id string) error
	RecordSuccess(ctx context.Context, subscriptionID string, now int64) error

	// ClaimNotifications leases up to limit pending notifications available and
	// unleased at now until leaseUntil, oldest first. Concurrent claims never
	// return the same notification.
	ClaimNotifications(ctx context.Context, now, leaseUntil int64, limit int) ([]Claim, error)
	// Undelivered lists the owner's subscriptions without a recorded outcome
	// for the notification.
	Undelivered(ctx context.Context, notificationID string) ([]Subscription, error)

	// RecordDelivery records one device's first final outcome; accepted also
	// records the device's last success.
	RecordDelivery(ctx context.Context, claim Claim, subscriptionID string, accepted bool, now int64) error
	// RetryNotification releases the claim until availableAt.
	RetryNotification(ctx context.Context, claim Claim, attempt int, availableAt int64) error
	// FinishNotification ends the claimed notification as sent or dropped.
	FinishNotification(ctx context.Context, claim Claim, state string) error
	// StreamID resolves the owner's context to its review stream; ErrNotFound
	// when it was deleted or expired.
	StreamID(ctx context.Context, ownerID, contextID string, now int64) (string, error)
}

type Subscription struct {
	ID            string
	OwnerID       string
	Endpoint      string
	P256dh        string
	Auth          string
	Label         string
	CreatedAt     int64
	LastSuccessAt *int64
}

type SubscriptionInput struct {
	Endpoint string
	P256dh   string
	Auth     string
	Label    string
}