aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--test/handlers/echo_h.erl5
-rw-r--r--test/req_SUITE.erl156
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.