Skip to content

Commit 0e62794

Browse files
heartbeat reply + interval changes
1 parent 0397b06 commit 0e62794

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

server/internal/config/session.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ func (Session) Init(cmd *cobra.Command) error {
7575
return err
7676
}
7777

78-
cmd.PersistentFlags().Int("session.heartbeat_interval", 120, "interval in seconds for sending heartbeat messages")
78+
cmd.PersistentFlags().Int("session.heartbeat_interval", 10, "interval in seconds for sending heartbeat messages")
7979
if err := viper.BindPFlag("session.heartbeat_interval", cmd.PersistentFlags().Lookup("session.heartbeat_interval")); err != nil {
8080
return err
8181
}
@@ -140,7 +140,7 @@ func (Session) InitV2(cmd *cobra.Command) error {
140140
return err
141141
}
142142

143-
cmd.PersistentFlags().Int("heartbeat_interval", 120, "V2: heartbeat interval in seconds")
143+
cmd.PersistentFlags().Int("heartbeat_interval", 10, "V2: heartbeat interval in seconds")
144144
if err := viper.BindPFlag("heartbeat_interval", cmd.PersistentFlags().Lookup("heartbeat_interval")); err != nil {
145145
return err
146146
}

server/internal/websocket/handler/handler.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package handler
22

33
import (
4+
"time"
45
"github.com/rs/zerolog"
56
"github.com/rs/zerolog/log"
67

@@ -38,7 +39,9 @@ func (h *MessageHandlerCtx) Message(session types.Session, data types.WebSocketM
3839
switch data.Event {
3940
// Client Events
4041
case event.CLIENT_HEARTBEAT:
41-
// do nothing
42+
err = session.Send("system/heartbeat", map[string]any{
43+
"timestamp": time.Now(),
44+
})
4245

4346
// System Events
4447
case event.SYSTEM_LOGS:

0 commit comments

Comments
 (0)