sonirico / go-hyperliquid / 21688282661

push

github

fix: add read deadline to WebSocket readPump, reconnect on stall (#128)

readPump called conn.ReadMessage() with no deadline. If the server
stopped sending frames without closing the connection the goroutine
blocked in a TLS read indefinitely, starving all subscribers.

Changes:
- Set conn.SetReadDeadline before every ReadMessage call (default 90 s,
  chosen to exceed the 50 s ping interval so normal pong cycles do not
  false-positive).
- On a net timeout error the connection is closed and reconnect() is
  invoked from the deferred cleanup, reusing the existing exponential-
  backoff path.
- Expose WsOptReadTimeout so callers can tune the deadline.
- Resolve the long-standing TODO in PongDispatcher: keepalive is now
  implicit — every successful read resets the deadline on the next
  iteration.
- Add TestReadPumpReconnectsOnTimeout: mock server that holds the
  connection open without sending; asserts the client reconnects within
  the test window.

Co-authored-by: coder-ishan <ishansingh2609@gmail.com>

17 of 20 new or added lines in 2 files covered. (85.0%)

3459 of 18907 relevant lines covered (18.29%)

281.94 hits per line