diff options
Diffstat (limited to 'test/ws_SUITE.erl')
| -rw-r--r-- | test/ws_SUITE.erl | 38 |
1 files changed, 37 insertions, 1 deletions
diff --git a/test/ws_SUITE.erl b/test/ws_SUITE.erl index 5b7c528..709eb89 100644 --- a/test/ws_SUITE.erl +++ b/test/ws_SUITE.erl @@ -40,7 +40,8 @@ groups() -> init_per_suite(Config) -> Routes = [ {"/", ws_echo_h, []}, - {"/reject", ws_reject_h, []} + {"/reject", ws_reject_h, []}, + {"/subprotocol", ws_subprotocol_h, []} ], {ok, _} = cowboy:start_clear(ws, [], #{ enable_connect_protocol => true, @@ -219,6 +220,41 @@ send_many_close(Config) -> {ws, close} = gun:await(ConnPid, StreamRef), gun:close(ConnPid). +subprotocol_match(Config) -> + doc("Websocket subprotocol successfully negotiated."), + Protocols = [{P, gun_ws_h} || P <- [<<"dummy">>, <<"echo">>, <<"junk">>]], + {ok, ConnPid} = gun:open("localhost", config(port, Config)), + {ok, _} = gun:await_up(ConnPid), + StreamRef = gun:ws_upgrade(ConnPid, "/subprotocol", [], #{ + protocols => Protocols + }), + {upgrade, [<<"websocket">>], _} = gun:await(ConnPid, StreamRef), + Frame = {text, <<"Hello!">>}, + gun:ws_send(ConnPid, StreamRef, Frame), + {ws, Frame} = gun:await(ConnPid, StreamRef), + gun:close(ConnPid). + +subprotocol_nomatch(Config) -> + doc("Websocket subprotocol negotiation failure."), + Protocols = [{P, gun_ws_h} || P <- [<<"dummy">>, <<"junk">>]], + {ok, ConnPid} = gun:open("localhost", config(port, Config)), + {ok, _} = gun:await_up(ConnPid), + StreamRef = gun:ws_upgrade(ConnPid, "/subprotocol", [], #{ + protocols => Protocols + }), + {response, nofin, 400, _} = gun:await(ConnPid, StreamRef), + {ok, <<"nomatch">>} = gun:await_body(ConnPid, StreamRef), + gun:close(ConnPid). + +subprotocol_required_but_missing(Config) -> + doc("Websocket subprotocol not negotiated but required by the server."), + {ok, ConnPid} = gun:open("localhost", config(port, Config)), + {ok, _} = gun:await_up(ConnPid), + StreamRef = gun:ws_upgrade(ConnPid, "/subprotocol", []), + {response, nofin, 400, _} = gun:await(ConnPid, StreamRef), + {ok, <<"undefined">>} = gun:await_body(ConnPid, StreamRef), + gun:close(ConnPid). + %% Internal. do_await_enable_connect_protocol(http, _) -> |