grendervill
7afd23d6d4
Уведомления в браузере и на телефоне: сервер сам решает, кому их слать, и подписывает запрос VAPID-ключом, поэтому уведомление приходит, даже когда клиент закрыт. Сервер: - миграция 00021: `push_subscriptions` (эндпоинт уникален, ключи, счётчик неудач, время последней доставки); - `internal/push` — VAPID-ключи (приватный PKCS#8 из конфига, публичный выводится из него), правила уведомлений повторяют `web/src/lib/desktopNotifications.ts` (упоминания и личные беседы, без своих и системных сообщений), очередь доставки, TTL 12 часов, Topic по комнате; - 404/410 от push-сервиса удаляют подписку сразу, 5 неудач подряд — тоже, иначе копились бы мёртвые эндпоинты; retention чистит «молчащие» подписки; - `internal/httpx/safeurl.go` — общий запрет внутренних адресов с проверкой адреса в момент подключения (DNS rebinding): эндпоинт подписки приходит от клиента, и без проверки сервер сам себе организует SSRF; - `internal/gateway/presence.go` — `IsUserOnline`: если получатель в клиенте, уведомление покажет клиент, дублировать на телефон не нужно; - ручки `GET /push/config`, `GET|POST|DELETE /push/subscriptions`, лимиты 10 подписок и 20 уведомлений в минуту; ключ p256dh проверяется как настоящая точка P-256; - установщик генерирует `VAPID_PRIVATE_KEY` (openssl, PKCS#8 DER в base64) и `VAPID_SUBJECT`, ключ переиспользуется при переустановке; для ручной установки есть `glchat vapid-keys`; `features.web_push_enabled` виден в `/meta`. Тесты: правила и VAPID, доставка с поддельным push-эндпоинтом (шифрование, заголовки VAPID/TTL/Topic, очистка мёртвых подписок), ручки и лимиты, отправка при личном сообщении и упоминании, пропуск онлайн-получателей, миграция на чистой БД.
39 lines
1.4 KiB
Go
39 lines
1.4 KiB
Go
package gateway
|
|
|
|
// Присутствие в Gateway: кто прямо сейчас держит соединение. Нужно Web Push
|
|
// (AGENT.md 7.16, Фаза 7): если у получателя есть активная сессия, уведомление
|
|
// покажет сам клиент по своим правилам, и дублировать его на телефон не нужно.
|
|
//
|
|
// Файл отдельный, чтобы не трогать горячий gateway.go: логика читает те же
|
|
// поля и под тем же мьютексом, что и рассылка.
|
|
|
|
// IsUserOnline сообщает, есть ли у пользователя хотя бы одно соединение.
|
|
func (s *Service) IsUserOnline(userID uint64) bool {
|
|
if s == nil || userID == 0 {
|
|
return false
|
|
}
|
|
s.mu.RLock()
|
|
defer s.mu.RUnlock()
|
|
for _, session := range s.sessions {
|
|
if session.userID == userID {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
// OnlineUsers возвращает количество уникальных пользователей с соединением —
|
|
// используется в тестах и диагностике.
|
|
func (s *Service) OnlineUsers() int {
|
|
if s == nil {
|
|
return 0
|
|
}
|
|
s.mu.RLock()
|
|
defer s.mu.RUnlock()
|
|
seen := make(map[uint64]struct{}, len(s.sessions))
|
|
for _, session := range s.sessions {
|
|
seen[session.userID] = struct{}{}
|
|
}
|
|
return len(seen)
|
|
}
|