Method readLoop

internal/ws/handler.go:197–230

readLoop blocks until the client disconnects or sends a close frame. It ignores client messages and sends periodic pings.

(conn *websocket.Conn, agent *identity.AgentIdentity)

// readLoop blocks until the client disconnects or sends a close frame.
// It ignores client messages and sends periodic pings.
func (h *Handler) readLoop(conn *websocket.Conn, agent *identity.AgentIdentity) {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	// Ping goroutine: send a ping every 30 seconds, fail if no pong within 10 seconds.
	go func() {
		ticker := time.NewTicker(30 * time.Second)
		defer ticker.Stop()
		for {
			select {
			case <-ctx.Done():
				return
			case <-ticker.C:
				pingCtx, pingCancel := context.WithTimeout(ctx, 10*time.Second)
				err := conn.Ping(pingCtx)
				pingCancel()
				if err != nil {
					log.Printf("[ws] ping failed for %s: %v", agent.Email, err)
					// Close the connection to unblock the Read below
					conn.Close(websocket.StatusGoingAway, "ping timeout")
					return
				}
			}
		}
	}()

	// Read loop: consume client messages and control frames until disconnect.
	for {
		_, _, err := conn.Read(ctx)
		if err != nil {
			return
		}
	}
}