(userID uuid.UUID)
| 332 | } |
| 333 | |
| 334 | func (n *Webpusher) subscriptionGeneration(userID uuid.UUID) uint64 { |
| 335 | n.cacheMu.RLock() |
| 336 | generation := n.subscriptionGenerations[userID] |
| 337 | n.cacheMu.RUnlock() |
| 338 | return generation |
| 339 | } |
| 340 | |
| 341 | func (n *Webpusher) storeSubscriptions(userID uuid.UUID, generation uint64, subscriptions []database.WebpushSubscription) { |
| 342 | n.cacheMu.Lock() |
no outgoing calls
no test coverage detected