Method pruneSubscriptions

coderd/webpush/webpush.go:355–391

(userID uuid.UUID, staleIDs []uuid.UUID)

}

func (n *Webpusher) pruneSubscriptions(userID uuid.UUID, staleIDs []uuid.UUID) {
	if len(staleIDs) == 0 {
		return
	}

	stale := make(map[uuid.UUID]struct{}, len(staleIDs))
	for _, id := range staleIDs {
		stale[id] = struct{}{}
	}

	n.cacheMu.Lock()
	defer n.cacheMu.Unlock()

	entry, ok := n.subscriptionCache[userID]
	if !ok {
		return
	}
	if !n.clock.Now().Before(entry.expiresAt) {
		delete(n.subscriptionCache, userID)
		return
	}

	filtered := make([]database.WebpushSubscription, 0, len(entry.subscriptions))
	for _, subscription := range entry.subscriptions {
		if _, shouldDelete := stale[subscription.ID]; shouldDelete {
			continue
		}
		filtered = append(filtered, subscription)
	}
	if len(filtered) == 0 {
		delete(n.subscriptionCache, userID)
		return
	}

	entry.subscriptions = filtered
	n.subscriptionCache[userID] = entry
}

// InvalidateUser clears the cached subscriptions for a user and advances
// its invalidation generation. Local subscribe and unsubscribe handlers call