Method cleanupStaleSubscriptions

coderd/webpush/webpush.go:277–287

cleanupStaleSubscriptions deletes the rows the push service flagged as permanently invalid (see isStaleSubscriptionStatus) and clears the cached entries for the affected user. Failures are logged at error level rather than returned: the caller is in the middle of returning a delivery error and shoul

(ctx context.Context, userID uuid.UUID, ids []uuid.UUID)

// prune is gated on a successful database delete so a partial state cannot
// leak into the cache.
func (n *Webpusher) cleanupStaleSubscriptions(ctx context.Context, userID uuid.UUID, ids []uuid.UUID) {
	if len(ids) == 0 {
		return
	}
	// nolint:gocritic // These are known to be invalid subscriptions.
	if err := n.store.DeleteWebpushSubscriptions(dbauthz.AsNotifier(ctx), ids); err != nil {
		n.log.Error(ctx, "failed to delete stale push subscriptions", slog.Error(err))
		return
	}
	n.pruneSubscriptions(userID, ids)
}

func (n *Webpusher) subscriptionsForUser(ctx context.Context, userID uuid.UUID) ([]database.WebpushSubscription, error) {
	if subscriptions, ok := n.cachedSubscriptions(userID); ok {