diff options
Diffstat (limited to 'test')
| -rw-r--r-- | test/handlers/echo_h.erl | 5 | ||||
| -rw-r--r-- | test/req_SUITE.erl | 156 |
2 files changed, 160 insertions, 1 deletions
diff --git a/test/handlers/echo_h.erl b/test/handlers/echo_h.erl index 6db43fe..cdb9be4 100644 --- a/test/handlers/echo_h.erl +++ b/test/handlers/echo_h.erl @@ -11,6 +11,9 @@ echo(What, Req, Opts) -> F = binary_to_atom(What, latin1), Value = case cowboy_req:F(Req) of V when is_integer(V) -> integer_to_binary(V); + V when is_atom(V) -> atom_to_binary(V, latin1); + V when is_list(V); is_tuple(V) -> io_lib:format("~p", [V]); V -> V end, - {ok, cowboy_req:reply(200, #{}, Value, Req), Opts}. + cowboy_req:reply(200, #{}, Value, Req), + {ok, Req, Opts}. diff --git a/test/req_SUITE.erl b/test/req_SUITE.erl new file mode 100644 index 0000000..39c975c --- /dev/null +++ b/test/req_SUITE.erl @@ -0,0 +1,156 @@ +%% Copyright (c) 2016, Loïc Hoguin <[email protected]> +%% +%% Permission to use, copy, modify, and/or distribute this software for any +%% purpose with or without fee is hereby granted, provided that the above +%% copyright notice and this permission notice appear in all copies. +%% +%% THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES +%% WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF +%% MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR +%% ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES +%% WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN +%% ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF +%% OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. + +-module(req_SUITE). +-compile(export_all). + +-import(ct_helper, [config/2]). +-import(ct_helper, [doc/1]). +-import(cowboy_test, [gun_open/1]). + +%% ct. + +all() -> + cowboy_test:common_all(). + +groups() -> + AllTests = ct_helper:all(?MODULE), + [ + {http, [parallel], AllTests}, + {https, [parallel], AllTests}, + {h2, [parallel], AllTests}, + {h2c, [parallel], AllTests} + %% @todo With compression enabled. + ]. + +init_per_group(Name, Config) -> + cowboy_test:init_common_groups(Name, Config, ?MODULE). + +end_per_group(Name, _) -> + cowboy:stop_listener(Name). + +%% Routes. + +init_dispatch(_) -> + cowboy_router:compile([{"[...]", [ + {"/no/:key", echo_h, []}, + {"/args/:key/:arg[/:default]", echo_h, []}, + {"/:key/[...]", echo_h, []} + ]}]). + +%% Internal. + +do_body(Method, Path, Config) -> + do_body(Method, Path, [], Config). + +do_body(Method, Path, Headers, Config) -> + ConnPid = gun_open(Config), + Ref = gun:request(ConnPid, Method, Path, Headers), + {response, IsFin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = case IsFin of + nofin -> gun:await_body(ConnPid, Ref); + fin -> {ok, <<>>} + end, + gun:close(ConnPid), + Body. + +do_get_body(Path, Config) -> + do_get_body(Path, [], Config). + +do_get_body(Path, Headers, Config) -> + do_body("GET", Path, Headers, Config). + +%% Tests. + +host(Config) -> + doc("Request URI host."), + <<"localhost">> = do_get_body("/host", Config), + ok. + +host_info(Config) -> + doc("Request host_info."), + <<"[<<\"localhost\">>]">> = do_get_body("/host_info", Config), + ok. + +method(Config) -> + doc("Request method."), + <<"GET">> = do_body("GET", "/method", Config), + <<"HEAD">> = do_body("HEAD", "/method", Config), + <<"OPTIONS">> = do_body("OPTIONS", "/method", Config), + <<"PATCH">> = do_body("PATCH", "/method", Config), + <<"POST">> = do_body("POST", "/method", Config), + <<"PUT">> = do_body("PUT", "/method", Config), + <<"ZZZZZZZZ">> = do_body("ZZZZZZZZ", "/method", Config), + ok. + +%% @todo Do we really want a key/value list here instead of a map? +parse_qs(Config) -> + doc("Parsed request URI query string."), + <<"[]">> = do_get_body("/parse_qs", Config), + <<"[{<<\"abc\">>,true}]">> = do_get_body("/parse_qs?abc", Config), + <<"[{<<\"a\">>,<<\"b\">>},{<<\"c\">>,<<\"d e\">>}]">> = do_get_body("/parse_qs?a=b&c=d+e", Config), + ok. + +path(Config) -> + doc("Request URI path."), + <<"/path/to/the/resource">> = do_get_body("/path/to/the/resource", Config), + <<"/path/to/the/resource">> = do_get_body("/path/to/the/resource?query", Config), + <<"/path/to/the/resource">> = do_get_body("/path/to/the/resource?query#fragment", Config), + <<"/path/to/the/resource">> = do_get_body("/path/to/the/resource#fragment", Config), + ok. + +path_info(Config) -> + doc("Request path_info."), + <<"undefined">> = do_get_body("/no/path_info", Config), + <<"[]">> = do_get_body("/path_info", Config), + <<"[]">> = do_get_body("/path_info/", Config), + <<"[<<\"to\">>,<<\"the\">>,<<\"resource\">>]">> = do_get_body("/path_info/to/the/resource", Config), + <<"[<<\"to\">>,<<\"the\">>,<<\"resource\">>]">> = do_get_body("/path_info/to/the/resource?query", Config), + <<"[<<\"to\">>,<<\"the\">>,<<\"resource\">>]">> = do_get_body("/path_info/to/the/resource?query#fragment", Config), + <<"[<<\"to\">>,<<\"the\">>,<<\"resource\">>]">> = do_get_body("/path_info/to/the/resource#fragment", Config), + ok. + +peer(Config) -> + doc("Request peer."), + <<"{{127,0,0,1},", _/bits >> = do_get_body("/peer", Config), + ok. + +port(Config) -> + doc("Request URI port."), + Port = integer_to_binary(config(port, Config)), + Port = do_get_body("/port", Config), + ok. + +qs(Config) -> + doc("Request URI query string."), + <<>> = do_get_body("/qs", Config), + <<"abc">> = do_get_body("/qs?abc", Config), + <<"a=b&c=d+e">> = do_get_body("/qs?a=b&c=d+e", Config), + ok. + +scheme(Config) -> + doc("Request URI scheme."), + Transport = config(type, Config), + case do_get_body("/scheme", Config) of + <<"http">> when Transport =:= tcp -> ok; + <<"https">> when Transport =:= ssl -> ok + end. + +version(Config) -> + doc("Request HTTP version."), + Protocol = config(protocol, Config), + case do_get_body("/version", Config) of + <<"HTTP/1.1">> when Protocol =:= http -> ok; + <<"HTTP/2">> when Protocol =:= http2 -> ok + end. |