0
Fork 0
mirror of https://github.com/ninenines/cowboy.git synced 2025-07-14 12:20:24 +00:00

Confirm Websocket pong frames are received by handlers

This commit is contained in:
Loïc Hoguin 2024-01-16 12:20:38 +01:00
parent 920adb9b82
commit 08a8d7b9e9
No known key found for this signature in database
GPG key ID: 8A9DF795F6FED764
2 changed files with 36 additions and 1 deletions

View file

@ -68,7 +68,8 @@ init_dispatch() ->
{"/ws_timeout_cancel", ws_timeout_cancel, []},
{"/ws_max_frame_size", ws_max_frame_size, []},
{"/ws_deflate_opts", ws_deflate_opts_h, []},
{"/ws_dont_validate_utf8", ws_dont_validate_utf8_h, []}
{"/ws_dont_validate_utf8", ws_dont_validate_utf8_h, []},
{"/ws_ping", ws_ping_h, []}
]}
]).
@ -472,6 +473,17 @@ ws_max_frame_size_intermediate_fragment_close(Config) ->
{error, closed} = gen_tcp:recv(Socket, 0, 6000),
ok.
ws_ping(Config) ->
doc("Server initiated pings can receive a pong in response."),
{ok, Socket, _} = do_handshake("/ws_ping", Config),
%% Receive a server-sent ping.
{ok, << 1:1, 0:3, 9:4, 0:1, 0:7 >>} = gen_tcp:recv(Socket, 0, 6000),
%% Send a pong back with a 0 mask.
ok = gen_tcp:send(Socket, << 1:1, 0:3, 10:4, 1:1, 0:7, 0:32 >>),
%% Receive a text frame as a result.
{ok, << 1:1, 0:3, 1:4, 0:1, 4:7, "OK!!" >>} = gen_tcp:recv(Socket, 0, 6000),
ok.
ws_send_close(Config) ->
doc("Server-initiated close frame ends the connection."),
{ok, Socket, _} = do_handshake("/ws_send_close", Config),