diff --git a/pkg/server/converge/websessions.go b/pkg/server/converge/websessions.go index 745de7a..a868204 100644 --- a/pkg/server/converge/websessions.go +++ b/pkg/server/converge/websessions.go @@ -71,6 +71,8 @@ func GetUserLocation(r *http.Request) (*time.Location, error) { } func (session *WebSession) WriteNotifications(location *time.Location) { + timer := time.NewTicker(10 * time.Second) + defer timer.Stop() for { select { case notification, ok := <-session.notifications: @@ -83,6 +85,12 @@ func (session *WebSession) WriteNotifications(location *time.Location) { log.Printf("WS connection closed: %v", err) return } + case <-timer.C: + _, err := session.conn.Write(make([]byte, 0, 0)) + if err != nil { + log.Printf("WS connection closed: %v", err) + return + } } } }