ZenWebsocket.Client.Frames (ZenWebsocket v0.8.0)

Inbound WebSocket frame routing for ZenWebsocket.Client.

Summary

Routes a Gun WebSocket frame: heartbeat tracking, control-frame decode, then data dispatch.

Restores subscriptions after reconnection if configured.

Routes data frames to heartbeat, subscription, JSON-RPC, or the user handler.

Sends a text frame, correlating JSON-RPC requests that carry an id.

@spec handle_ws(map(), pid(), reference(), term()) ::
  {:noreply, map()} | {:stop, term(), map()}

Routes a Gun WebSocket frame: heartbeat tracking, control-frame decode, then data dispatch.

@spec maybe_restore_subscriptions(map()) :: map()

Restores subscriptions after reconnection if configured.

@spec route_data_frame(term(), map()) :: map()

Routes data frames to heartbeat, subscription, JSON-RPC, or the user handler.

@spec send_text(map(), pid(), reference(), binary(), GenServer.from()) ::
  {:noreply, map()} | {:reply, term(), map()}

Sends a text frame, correlating JSON-RPC requests that carry an id.