diff options
Diffstat (limited to 'test')
-rw-r--r-- | test/handlers/switch_protocol_flush_h.erl | 50 | ||||
-rw-r--r-- | test/http_SUITE.erl | 799 | ||||
-rw-r--r-- | test/old_http_SUITE.erl | 796 | ||||
-rw-r--r-- | test/old_http_SUITE_data/http_chunked.erl (renamed from test/http_SUITE_data/http_chunked.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/http_echo_body.erl (renamed from test/http_SUITE_data/http_echo_body.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/http_errors.erl (renamed from test/http_SUITE_data/http_errors.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/http_handler.erl (renamed from test/http_SUITE_data/http_handler.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/http_loop_stream_recv.erl (renamed from test/http_SUITE_data/http_loop_stream_recv.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/http_req_attr.erl (renamed from test/http_SUITE_data/http_req_attr.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/http_set_resp.erl (renamed from test/http_SUITE_data/http_set_resp.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_empty_resource.erl (renamed from test/http_SUITE_data/rest_empty_resource.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_expires.erl (renamed from test/http_SUITE_data/rest_expires.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_expires_binary.erl (renamed from test/http_SUITE_data/rest_expires_binary.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_forbidden_resource.erl (renamed from test/http_SUITE_data/rest_forbidden_resource.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_missing_callbacks.erl (renamed from test/http_SUITE_data/rest_missing_callbacks.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_nodelete_resource.erl (renamed from test/http_SUITE_data/rest_nodelete_resource.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_param_all.erl (renamed from test/http_SUITE_data/rest_param_all.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_patch_resource.erl (renamed from test/http_SUITE_data/rest_patch_resource.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_post_charset_resource.erl (renamed from test/http_SUITE_data/rest_post_charset_resource.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_postonly_resource.erl (renamed from test/http_SUITE_data/rest_postonly_resource.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_resource_etags.erl (renamed from test/http_SUITE_data/rest_resource_etags.erl) | 0 | ||||
-rw-r--r-- | test/old_http_SUITE_data/rest_simple_resource.erl (renamed from test/http_SUITE_data/rest_simple_resource.erl) | 0 | ||||
-rw-r--r-- | test/sys_SUITE.erl | 4 |
23 files changed, 872 insertions, 777 deletions
diff --git a/test/handlers/switch_protocol_flush_h.erl b/test/handlers/switch_protocol_flush_h.erl new file mode 100644 index 0000000..3d525ee --- /dev/null +++ b/test/handlers/switch_protocol_flush_h.erl @@ -0,0 +1,50 @@ +%% This module is used to test the flushing of messages when +%% switch_protocol is executed by cowboy_http. + +-module(switch_protocol_flush_h). + +-export([init/3]). +-export([info/3]). +-export([terminate/3]). +-export([takeover/7]). +-export([validate/1]). + +init(StreamID, Req, _) -> + Pid = list_to_pid(binary_to_list(cowboy_req:header(<<"x-test-pid">>, Req))), + %% Send ourselves a few messages that may or may not be flushed. + self() ! good, + self() ! {'EXIT', Pid, normal}, + self() ! {system, a, b}, + self() ! {{self(), StreamID}, hello}, + self() ! {'$gen_call', a, b}, + self() ! {timeout, make_ref(), ?MODULE}, + self() ! {ranch_tcp, socket, <<"123">>}, + {[{switch_protocol, #{}, ?MODULE, Pid}], undefined}. + +info(_, _, State) -> + {[], State}. + +terminate(_, _, _) -> + ok. + +takeover(_, _, _, _, _, _, Pid) -> + Msgs = receive_all([]), + Pid ! {Pid, Msgs}, + exit(normal). + +receive_all(Acc) -> + receive + Msg -> + receive_all([Msg|Acc]) + after 0 -> + Acc + end. + +validate(Msgs) -> + [ + {ranch_tcp, socket, <<"123">>}, + {'$gen_call', a, b}, + {system, a, b}, + good + ] = Msgs, + ok. diff --git a/test/http_SUITE.erl b/test/http_SUITE.erl index a971e45..16d7e76 100644 --- a/test/http_SUITE.erl +++ b/test/http_SUITE.erl @@ -1,5 +1,4 @@ -%% Copyright (c) 2011-2017, Loïc Hoguin <[email protected]> -%% Copyright (c) 2011, Anthony Ramine <[email protected]> +%% Copyright (c) 2018, 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 @@ -18,779 +17,33 @@ -compile(nowarn_export_all). -import(ct_helper, [config/2]). +-import(ct_helper, [doc/1]). -import(cowboy_test, [gun_open/1]). --import(cowboy_test, [gun_open/2]). --import(cowboy_test, [gun_down/1]). --import(cowboy_test, [raw_open/1]). --import(cowboy_test, [raw_send/2]). --import(cowboy_test, [raw_recv_head/1]). --import(cowboy_test, [raw_expect_recv/2]). -%% ct. - -all() -> - [ - {group, http}, - {group, https}, - {group, http_compress}, - {group, https_compress}, - {group, parse_host}, - {group, request_timeout_infinity}, - {group, idle_timeout_infinity}, - {group, set_env}, - {group, router_compile} - ]. - -groups() -> - Tests = ct_helper:all(?MODULE) -- [ - parse_host, set_env_dispatch, path_allow_colon, - request_timeout_infinity, idle_timeout_infinity - ], - [ - {http, [], Tests}, %% @todo parallel - {https, [parallel], Tests}, - {http_compress, [parallel], Tests}, - {https_compress, [parallel], Tests}, - {parse_host, [], [ - parse_host - ]}, - {request_timeout_infinity, [], [ - request_timeout_infinity - ]}, - {idle_timeout_infinity, [], [ - idle_timeout_infinity - ]}, - {set_env, [], [ - set_env_dispatch - ]}, - {router_compile, [], [ - path_allow_colon - ]} - ]. - -init_per_group(Name = http, Config) -> - cowboy_test:init_http(Name, #{env => #{dispatch => init_dispatch(Config)}}, Config); -init_per_group(Name = https, Config) -> - cowboy_test:init_https(Name, #{env => #{dispatch => init_dispatch(Config)}}, Config); -init_per_group(Name = http_compress, Config) -> - cowboy_test:init_http(Name, #{ - env => #{dispatch => init_dispatch(Config)}, - compress => true - }, Config); -init_per_group(Name = https_compress, Config) -> - cowboy_test:init_https(Name, #{ - env => #{dispatch => init_dispatch(Config)}, - compress => true - }, Config); -init_per_group(parse_host, Config) -> - Dispatch = cowboy_router:compile([ - {'_', [ - {"/req_attr", http_req_attr, []} - ]} +all() -> [{group, clear}]. + +groups() -> [{clear, [parallel], ct_helper:all(?MODULE)}]. + +init_routes(_) -> [ + {"localhost", [ + {"/", hello_h, []} + ]} +]. + +switch_protocol_flush(Config) -> + doc("Confirm that switch_protocol does not flush unrelated messages."), + ProtoOpts = #{ + env => #{dispatch => cowboy_router:compile(init_routes(Config))}, + stream_handlers => [switch_protocol_flush_h] + }, + {ok, _} = cowboy:start_clear(switch_protocol_flush, [{port, 0}], ProtoOpts), + Port = ranch:get_port(switch_protocol_flush), + Self = self(), + ConnPid = gun_open([{port, Port}, {type, tcp}, {protocol, http}|Config]), + _ = gun:get(ConnPid, "/", [ + {<<"x-test-pid">>, pid_to_list(Self)} ]), - {ok, _} = cowboy:start_clear(parse_host, [{port, 0}], #{ - env => #{dispatch => Dispatch} - }), - Port = ranch:get_port(parse_host), - [{type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; -init_per_group(request_timeout_infinity, Config) -> - Ref = request_timeout_infinity, - {ok, Pid} = cowboy:start_clear(Ref, [{port, 0}], #{ - env => #{dispatch => init_dispatch(Config)}, - request_timeout => infinity - }), - Port = ranch:get_port(request_timeout_infinity), - [{pid, Pid}, {ref, Ref}, {type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; -init_per_group(idle_timeout_infinity, Config) -> - Ref = idle_timeout_infinity, - {ok, Pid} = cowboy:start_clear(Ref, [{port, 0}], #{ - env => #{dispatch => init_dispatch(Config)}, - idle_timeout => infinity - }), - Port = ranch:get_port(idle_timeout_infinity), - [{pid, Pid}, {ref, Ref}, {type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; -init_per_group(set_env, Config) -> - {ok, _} = cowboy:start_clear(set_env, [{port, 0}], #{ - env => #{dispatch => []} - }), - Port = ranch:get_port(set_env), - [{type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; -init_per_group(router_compile, Config) -> - Config. - -end_per_group(router_compile, _) -> - ok; -end_per_group(Name, _) -> - ok = cowboy:stop_listener(Name). - -%% Dispatch configuration. - -init_dispatch(_) -> - cowboy_router:compile([ - {"localhost", [ - {"/chunked_response", http_chunked, []}, - {"/headers/dupe", http_handler, - [{headers, #{<<"connection">> => <<"close">>}}]}, - {"/set_resp/header", http_set_resp, - [{headers, #{<<"vary">> => <<"Accept">>}}]}, - {"/set_resp/overwrite", http_set_resp, - [{headers, #{<<"server">> => <<"DesireDrive/1.0">>}}]}, - {"/set_resp/body", http_set_resp, - [{body, <<"A flameless dance does not equal a cycle">>}]}, - {"/handler_errors", http_errors, []}, - {"/echo/body", http_echo_body, []}, - {"/param_all", rest_param_all, []}, - {"/bad_accept", rest_simple_resource, []}, - {"/bad_content_type", rest_patch_resource, []}, - {"/simple", rest_simple_resource, []}, - {"/forbidden_post", rest_forbidden_resource, [true]}, - {"/simple_post", rest_forbidden_resource, [false]}, - {"/missing_get_callbacks", rest_missing_callbacks, []}, - {"/missing_put_callbacks", rest_missing_callbacks, []}, - {"/nodelete", rest_nodelete_resource, []}, - {"/post_charset", rest_post_charset_resource, []}, - {"/postonly", rest_postonly_resource, []}, - {"/patch", rest_patch_resource, []}, - {"/resetags", rest_resource_etags, []}, - {"/rest_expires", rest_expires, []}, - {"/rest_expires_binary", rest_expires_binary, []}, - {"/rest_empty_resource", rest_empty_resource, []}, - {"/loop_stream_recv", http_loop_stream_recv, []}, - {"/", http_handler, []} - ]} - ]). - -%% Convenience functions. - -do_raw(Data, Config) -> - Client = raw_open(Config), - ok = raw_send(Client, Data), - case catch raw_recv_head(Client) of - {'EXIT', _} -> closed; - Resp -> element(2, cow_http:parse_status_line(Resp)) - end. - -do_get(Path, Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, Path), - {response, _, Status, _} = gun:await(ConnPid, Ref), - gun:close(ConnPid), - Status. - -%% Tests. - -check_raw_status(Config) -> - Huge = [$0 || _ <- lists:seq(1, 5000)], - HugeCookie = lists:flatten(["whatever_man_biiiiiiiiiiiig_cookie_me_want_77=" - "Wed Apr 06 2011 10:38:52 GMT-0500 (CDT)" || _ <- lists:seq(1, 40)]), - ResponsePacket = -"HTTP/1.0 302 Found\r -Location: http://www.google.co.il/\r -Cache-Control: private\r -Content-Type: text/html; charset=UTF-8\r -Set-Cookie: PREF=ID=568f67013d4a7afa:FF=0:TM=1323014101:LM=1323014101:S=XqctDWC65MzKT0zC; expires=Tue, 03-Dec-2013 15:55:01 GMT; path=/; domain=.google.com\r -Date: Sun, 04 Dec 2011 15:55:01 GMT\r -Server: gws\r -Content-Length: 221\r -X-XSS-Protection: 1; mode=block\r -X-Frame-Options: SAMEORIGIN\r -\r -<HTML><HEAD><meta http-equiv=\"content-type\" content=\"text/html;charset=utf-8\"> -<TITLE>302 Moved</TITLE></HEAD><BODY> -<H1>302 Moved</H1> -The document has moved -<A HREF=\"http://www.google.co.il/\">here</A>. -</BODY></HTML>", - Tests = [ - {200, ["GET / HTTP/1.0\r\nHost: localhost\r\n" - "Set-Cookie: ", HugeCookie, "\r\n\r\n"]}, - {200, "\r\n\r\n\r\n\r\n\r\nGET / HTTP/1.1\r\nHost: localhost\r\n\r\n"}, - {200, "GET http://proxy/ HTTP/1.1\r\nHost: localhost\r\n\r\n"}, - {400, "\n"}, - {400, "Garbage\r\n\r\n"}, - {400, "\r\n\r\n\r\n\r\n\r\n\r\n"}, - {400, " / HTTP/1.1\r\nHost: localhost\r\n\r\n"}, - {400, "GET HTTP/1.1\r\nHost: localhost\r\n\r\n"}, - {400, "GET / HTTP/1.1\r\nHost: ninenines.eu\r\n\r\n"}, - {400, "GET http://proxy/ HTTP/1.1\r\n\r\n"}, - {400, "GET / HTTP/1.1\r\nHost: localhost:bad_port\r\n\r\n"}, - {400, ResponsePacket}, - {408, "GET / HTTP/1.1\r\n"}, - {408, "GET / HTTP/1.1\r\nHost: localhost"}, - {408, "GET / HTTP/1.1\r\nHost: localhost\r\n"}, - {408, "GET / HTTP/1.1\r\nHost: localhost\r\n\r"}, - {closed, Huge}, - {431, "GET / HTTP/1.1\r\n" ++ Huge}, - {505, "GET / HTTP/1.2\r\nHost: localhost\r\n\r\n"}, - {closed, ""}, - {closed, "\r\n"}, - {closed, "\r\n\r\n"}, - {closed, "GET / HTTP/1.1"} - ], - _ = [{Status, Packet} = begin - Ret = do_raw(Packet, Config), - {Ret, Packet} - end || {Status, Packet} <- Tests], - ok. - -check_status(Config) -> - Tests = [ - {200, "/"}, - {200, "/simple"}, - {404, "/not/found"}, - {500, "/handler_errors?case=init_before_reply"} - ], - _ = [{Status, URL} = begin - Ret = do_get(URL, Config), - {Ret, URL} - end || {Status, URL} <- Tests]. - -%% Check if sending requests whose size is around the MTU breaks something. -echo_body(Config) -> - MTU = ct_helper:get_loopback_mtu(), - _ = [begin - Body = list_to_binary(lists:duplicate(Size, $a)), - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", [], Body), - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref) - end || Size <- lists:seq(MTU - 500, MTU)], - ok. - -%% Check if sending request whose size is bigger than 1000000 bytes causes 413 -echo_body_max_length(Config) -> - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", [], << 0:10000000/unit:8 >>), - {response, nofin, 413, _} = gun:await(ConnPid, Ref), - ok. - -error_init_after_reply(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/handler_errors?case=init_after_reply"), - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - ok. - -headers_dupe(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/headers/dupe"), - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - %% Ensure that only one connection header was received. - [<<"close">>] = [V || {Name, V} <- Headers, Name =:= <<"connection">>], - gun_down(ConnPid). - -http10_chunkless(Config) -> - ConnPid = gun_open(Config, #{http_opts => #{version => 'HTTP/1.0'}}), - Ref = gun:get(ConnPid, "/chunked_response"), - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - false = lists:keyfind(<<"transfer-encoding">>, 1, Headers), - {ok, <<"chunked_handler\r\nworks fine!">>} = gun:await_body(ConnPid, Ref), - gun_down(ConnPid). - -http10_hostless(Config) -> - Name = http10_hostless, - Port10 = config(port, Config) + 10, - {Transport, Protocol} = case config(type, Config) of - tcp -> {ranch_tcp, cowboy_clear}; - ssl -> {ranch_ssl, cowboy_tls} - end, - ranch:start_listener(Name, 5, Transport, - config(opts, Config) ++ [{port, Port10}], - Protocol, #{ - env =>#{dispatch => cowboy_router:compile([ - {'_', [{"/http1.0/hostless", http_handler, []}]}])}, - max_keepalive => 50, - timeout => 500 - }), - 200 = do_raw("GET /http1.0/hostless HTTP/1.0\r\n\r\n", - [{port, Port10}|Config]), - cowboy:stop_listener(http10_hostless). - -http10_keepalive_default(Config) -> - Normal = "GET / HTTP/1.0\r\nhost: localhost\r\n\r\n", - Client = raw_open(Config), - ok = raw_send(Client, Normal), - case catch raw_recv_head(Client) of - {'EXIT', _} -> error(closed); - Data -> - %% Cowboy always advertises itself as HTTP/1.1. - {'HTTP/1.1', 200, _, Rest} = cow_http:parse_status_line(Data), - {Headers, _} = cow_http:parse_headers(Rest), - {_, <<"close">>} = lists:keyfind(<<"connection">>, 1, Headers) - end, - ok = raw_send(Client, Normal), - case catch raw_recv_head(Client) of - {'EXIT', _} -> closed; - _ -> error(not_closed) - end. - -http10_keepalive_forced(Config) -> - Keepalive = "GET / HTTP/1.0\r\nhost: localhost\r\nConnection: keep-alive\r\n\r\n", - Client = raw_open(Config), - ok = raw_send(Client, Keepalive), - case catch raw_recv_head(Client) of - {'EXIT', _} -> error(closed); - Data -> - %% Cowboy always advertises itself as HTTP/1.1. - {'HTTP/1.1', 200, _, Rest} = cow_http:parse_status_line(Data), - {Headers, _} = cow_http:parse_headers(Rest), - {_, <<"keep-alive">>} = lists:keyfind(<<"connection">>, 1, Headers) - end, - ok = raw_send(Client, Keepalive), - case catch raw_recv_head(Client) of - {'EXIT', Err} -> error({closed, Err}); - _ -> ok - end. - -keepalive_nl(Config) -> - ConnPid = gun_open(Config), - Refs = [begin - Ref = gun:get(ConnPid, "/", [{<<"connection">>, <<"keep-alive">>}]), - gun:dbg_send_raw(ConnPid, <<"\r\n">>), - Ref - end || _ <- lists:seq(1, 10)], - _ = [begin - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - false = lists:keymember(<<"connection">>, 1, Headers) - end || Ref <- Refs], - ok. - -keepalive_stream_loop(Config) -> - ConnPid = gun_open(Config), - Refs = [begin - Ref = gun:post(ConnPid, "/loop_stream_recv", - [{<<"content-type">>, <<"application/octet-stream">>}]), - _ = [gun:data(ConnPid, Ref, nofin, << ID:32 >>) - || ID <- lists:seq(1, 250)], - gun:data(ConnPid, Ref, fin, <<>>), - Ref - end || _ <- lists:seq(1, 10)], - _ = [begin - {response, fin, 200, _} = gun:await(ConnPid, Ref) - end || Ref <- Refs], - ok. - -do_nc(Config, Input) -> - Cat = os:find_executable("cat"), - Nc = os:find_executable("nc"), - case {Cat, Nc} of - {false, _} -> - {skip, {notfound, cat}}; - {_, false} -> - {skip, {notfound, nc}}; - _Good -> - %% Throw garbage at the server then check if it's still up. - StrPort = integer_to_list(config(port, Config)), - [os:cmd("cat " ++ Input ++ " | nc localhost " ++ StrPort) - || _ <- lists:seq(1, 100)], - 200 = do_get("/", Config) - end. - -nc_rand(Config) -> - do_nc(Config, "/dev/urandom"). - -nc_zero(Config) -> - do_nc(Config, "/dev/zero"). - -parse_host(Config) -> - ConnPid = gun_open(Config), - Tests = [ - {<<"example.org:8080">>, <<"example.org\n8080">>}, - {<<"example.org">>, <<"example.org\n80">>}, - {<<"192.0.2.1:8080">>, <<"192.0.2.1\n8080">>}, - {<<"192.0.2.1">>, <<"192.0.2.1\n80">>}, - {<<"[2001:db8::1]:8080">>, <<"[2001:db8::1]\n8080">>}, - {<<"[2001:db8::1]">>, <<"[2001:db8::1]\n80">>}, - {<<"[::ffff:192.0.2.1]:8080">>, <<"[::ffff:192.0.2.1]\n8080">>}, - {<<"[::ffff:192.0.2.1]">>, <<"[::ffff:192.0.2.1]\n80">>} - ], - [begin - Ref = gun:get(ConnPid, "/req_attr?attr=host_and_port", - [{<<"host">>, Host}]), - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref) - end || {Host, Body} <- Tests], - ok. - -rest_param_all(Config) -> - ConnPid = gun_open(Config), - %% Accept without param. - Ref1 = gun:get(ConnPid, "/param_all", - [{<<"accept">>, <<"text/plain">>}]), - {response, nofin, 200, _} = gun:await(ConnPid, Ref1), - {ok, <<"[]">>} = gun:await_body(ConnPid, Ref1), - %% Accept with param. - Ref2 = gun:get(ConnPid, "/param_all", - [{<<"accept">>, <<"text/plain;level=1">>}]), - {response, nofin, 200, _} = gun:await(ConnPid, Ref2), - {ok, <<"level=1">>} = gun:await_body(ConnPid, Ref2), - %% Accept with param and quality. - Ref3 = gun:get(ConnPid, "/param_all", - [{<<"accept">>, <<"text/plain;level=1;q=0.8, text/plain;level=2;q=0.5">>}]), - {response, nofin, 200, _} = gun:await(ConnPid, Ref3), - {ok, <<"level=1">>} = gun:await_body(ConnPid, Ref3), - Ref4 = gun:get(ConnPid, "/param_all", - [{<<"accept">>, <<"text/plain;level=1;q=0.5, text/plain;level=2;q=0.8">>}]), - {response, nofin, 200, _} = gun:await(ConnPid, Ref4), - {ok, <<"level=2">>} = gun:await_body(ConnPid, Ref4), - %% Without Accept. - Ref5 = gun:get(ConnPid, "/param_all"), - {response, nofin, 200, _} = gun:await(ConnPid, Ref5), - {ok, <<"'*'">>} = gun:await_body(ConnPid, Ref5), - %% Content-Type without param. - Ref6 = gun:put(ConnPid, "/param_all", - [{<<"content-type">>, <<"text/plain">>}]), - gun:data(ConnPid, Ref6, fin, "Hello world!"), - {response, fin, 204, _} = gun:await(ConnPid, Ref6), - %% Content-Type with param. - Ref7 = gun:put(ConnPid, "/param_all", - [{<<"content-type">>, <<"text/plain; charset=utf-8">>}]), - gun:data(ConnPid, Ref7, fin, "Hello world!"), - {response, fin, 204, _} = gun:await(ConnPid, Ref7), - ok. - -rest_bad_accept(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/bad_accept", - [{<<"accept">>, <<"1">>}]), - {response, fin, 400, _} = gun:await(ConnPid, Ref), - ok. - -rest_bad_content_type(Config) -> - ConnPid = gun_open(Config), - Ref = gun:patch(ConnPid, "/bad_content_type", - [{<<"content-type">>, <<"text/plain, text/html">>}], <<"Whatever">>), - {response, fin, 415, _} = gun:await(ConnPid, Ref), - ok. - -rest_expires(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/rest_expires"), - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - {_, Expires} = lists:keyfind(<<"expires">>, 1, Headers), - {_, LastModified} = lists:keyfind(<<"last-modified">>, 1, Headers), - Expires = LastModified = <<"Fri, 21 Sep 2012 22:36:14 GMT">>, - ok. - -rest_expires_binary(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/rest_expires_binary"), - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - {_, <<"0">>} = lists:keyfind(<<"expires">>, 1, Headers), - ok. - -rest_last_modified_undefined(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/simple", - [{<<"if-modified-since">>, <<"Fri, 21 Sep 2012 22:36:14 GMT">>}]), - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - ok. - -rest_keepalive(Config) -> - ConnPid = gun_open(Config), - Refs = [gun:get(ConnPid, "/simple") || _ <- lists:seq(1, 10)], - _ = [begin - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - false = lists:keymember(<<"connection">>, 1, Headers) - end || Ref <- Refs], - ok. - -rest_keepalive_post(Config) -> - ConnPid = gun_open(Config), - Refs = [begin - Ref1 = gun:post(ConnPid, "/forbidden_post", [ - {<<"content-type">>, <<"text/plain">>}, - {<<"content-length">>, <<"12">>} - ]), - gun:data(ConnPid, Ref1, fin, "Hello world!"), - Ref2 = gun:post(ConnPid, "/simple_post", [ - {<<"content-type">>, <<"text/plain">>}, - {<<"content-length">>, <<"12">>} - ]), - gun:data(ConnPid, Ref2, fin, "Hello world!"), - {Ref1, Ref2} - end || _ <- lists:seq(1, 5)], - _ = [begin - {response, fin, 403, Headers1} = gun:await(ConnPid, Ref1), - false = lists:keymember(<<"connection">>, 1, Headers1), - {response, fin, 303, Headers2} = gun:await(ConnPid, Ref2), - false = lists:keymember(<<"connection">>, 1, Headers2) - end || {Ref1, Ref2} <- Refs], - ok. - -rest_missing_get_callbacks(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/missing_get_callbacks"), - {response, fin, 500, _} = gun:await(ConnPid, Ref), - ok. - -rest_missing_put_callbacks(Config) -> - ConnPid = gun_open(Config), - Ref = gun:put(ConnPid, "/missing_put_callbacks", - [{<<"content-type">>, <<"application/json">>}], <<"{}">>), - {response, fin, 500, _} = gun:await(ConnPid, Ref), - ok. - -rest_nodelete(Config) -> - ConnPid = gun_open(Config), - Ref = gun:delete(ConnPid, "/nodelete"), - {response, fin, 500, _} = gun:await(ConnPid, Ref), - ok. - -rest_options_default(Config) -> - ConnPid = gun_open(Config), - Ref = gun:options(ConnPid, "/rest_empty_resource"), - {response, fin, 200, Headers} = gun:await(ConnPid, Ref), - {_, <<"HEAD, GET, OPTIONS">>} = lists:keyfind(<<"allow">>, 1, Headers), - ok. - -rest_patch(Config) -> - Tests = [ - {204, [{<<"content-type">>, <<"text/plain">>}], <<"whatever">>}, - {400, [{<<"content-type">>, <<"text/plain">>}], <<"false">>}, - {400, [{<<"content-type">>, <<"text/plain">>}], <<"stop">>}, - {415, [{<<"content-type">>, <<"application/json">>}], <<"bad_content_type">>} - ], - ConnPid = gun_open(Config), - _ = [begin - Ref = gun:patch(ConnPid, "/patch", Headers, Body), - {response, fin, Status, _} = gun:await(ConnPid, Ref) - end || {Status, Headers, Body} <- Tests], - ok. - -rest_post_charset(Config) -> - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/post_charset", - [{<<"content-type">>, <<"text/plain;charset=UTF-8">>}], "12345"), - {response, fin, 204, _} = gun:await(ConnPid, Ref), - ok. - -rest_postonly(Config) -> - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/postonly", - [{<<"content-type">>, <<"text/plain">>}], "12345"), - {response, fin, 204, _} = gun:await(ConnPid, Ref), - ok. - -rest_resource_get_etag(Config, Type) -> - rest_resource_get_etag(Config, Type, []). - -rest_resource_get_etag(Config, Type, Headers) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/resetags?type=" ++ Type, Headers), - {response, _, Status, RespHeaders} = gun:await(ConnPid, Ref), - case lists:keyfind(<<"etag">>, 1, RespHeaders) of - false -> {Status, false}; - {<<"etag">>, ETag} -> {Status, ETag} - end. - -rest_resource_etags(Config) -> - Tests = [ - {200, <<"W/\"etag-header-value\"">>, "tuple-weak"}, - {200, <<"\"etag-header-value\"">>, "tuple-strong"}, - {200, <<"W/\"etag-header-value\"">>, "binary-weak-quoted"}, - {200, <<"\"etag-header-value\"">>, "binary-strong-quoted"}, - {500, false, "binary-strong-unquoted"}, - {500, false, "binary-weak-unquoted"} - ], - _ = [{Status, ETag, Type} = begin - {Ret, RespETag} = rest_resource_get_etag(Config, Type), - {Ret, RespETag, Type} - end || {Status, ETag, Type} <- Tests]. - -rest_resource_etags_if_none_match(Config) -> - Tests = [ - {304, <<"W/\"etag-header-value\"">>, "tuple-weak"}, - {304, <<"\"etag-header-value\"">>, "tuple-strong"}, - {304, <<"W/\"etag-header-value\"">>, "binary-weak-quoted"}, - {304, <<"\"etag-header-value\"">>, "binary-strong-quoted"} - ], - _ = [{Status, Type} = begin - {Ret, _} = rest_resource_get_etag(Config, Type, - [{<<"if-none-match">>, ETag}]), - {Ret, Type} - end || {Status, ETag, Type} <- Tests]. - -set_env_dispatch(Config) -> - ConnPid1 = gun_open(Config), - Ref1 = gun:get(ConnPid1, "/"), - {response, fin, 400, _} = gun:await(ConnPid1, Ref1), - ok = cowboy:set_env(set_env, dispatch, - cowboy_router:compile([{'_', [{"/", http_handler, []}]}])), - ConnPid2 = gun_open(Config), - Ref2 = gun:get(ConnPid2, "/"), - {response, nofin, 200, _} = gun:await(ConnPid2, Ref2), - ok. - -path_allow_colon(_Config) -> - cowboy_router:compile([{'_', [{"/foo/bar:blah", http_handler, []}]}]), - ok. - -set_resp_body(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/set_resp/body"), - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, <<"A flameless dance does not equal a cycle">>} - = gun:await_body(ConnPid, Ref), - ok. - -set_resp_header(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/set_resp/header"), - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - {_, <<"Accept">>} = lists:keyfind(<<"vary">>, 1, Headers), - {_, _} = lists:keyfind(<<"set-cookie">>, 1, Headers), - ok. - -set_resp_overwrite(Config) -> - ConnPid = gun_open(Config), - Ref = gun:get(ConnPid, "/set_resp/overwrite"), - {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), - {_, <<"DesireDrive/1.0">>} = lists:keyfind(<<"server">>, 1, Headers), - ok. - -slowloris(Config) -> - Client = raw_open(Config), - try - [begin - ok = raw_send(Client, [C]), - receive after 250 -> ok end - end || C <- "GET / HTTP/1.1\r\nHost: localhost\r\n" - "User-Agent: Mozilla/5.0 (Windows; U; Windows NT 6.0; en-US)\r\n" - "Cookie: name=aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa\r\n\r\n"], - error(failure) - catch error:{badmatch, _} -> - ok - end. - -slowloris2(Config) -> - Client = raw_open(Config), - ok = raw_send(Client, "GET / HTTP/1.1\r\n"), - receive after 300 -> ok end, - ok = raw_send(Client, "Host: localhost\r\n"), - receive after 300 -> ok end, - Data = raw_recv_head(Client), - {_, 408, _, _} = cow_http:parse_status_line(Data), - ok. - -te_chunked(Config) -> - Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", [{<<"content-type">>, <<"text/plain">>}]), - gun:data(ConnPid, Ref, fin, Body), - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref), - ok. - -do_body_to_chunks(_, <<>>, Acc) -> - lists:reverse([<<"0\r\n\r\n">>|Acc]); -do_body_to_chunks(ChunkSize, Body, Acc) -> - BodySize = byte_size(Body), - ChunkSize2 = case BodySize < ChunkSize of - true -> BodySize; - false -> ChunkSize - end, - << Chunk:ChunkSize2/binary, Rest/binary >> = Body, - ChunkSizeBin = integer_to_binary(ChunkSize2, 16), - do_body_to_chunks(ChunkSize, Rest, - [<< ChunkSizeBin/binary, "\r\n", Chunk/binary, "\r\n" >>|Acc]). - -te_chunked_chopped(Config) -> - Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), - Body2 = iolist_to_binary(do_body_to_chunks(50, Body, [])), - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", - [{<<"content-type">>, <<"text/plain">>}]), - _ = [begin - ok = gun:dbg_send_raw(ConnPid, << C >>), - receive after 10 -> ok end - end || << C >> <= Body2], - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref), - ok. - -te_chunked_delayed(Config) -> - Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), - Chunks = do_body_to_chunks(50, Body, []), - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", - [{<<"content-type">>, <<"text/plain">>}]), - _ = [begin - ok = gun:dbg_send_raw(ConnPid, Chunk), - receive after 10 -> ok end - end || Chunk <- Chunks], - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref), - ok. - -te_chunked_split_body(Config) -> - Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), - Chunks = do_body_to_chunks(50, Body, []), - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", - [{<<"content-type">>, <<"text/plain">>}]), - _ = [begin - case Chunk of - <<"0\r\n\r\n">> -> - ok = gun:dbg_send_raw(ConnPid, Chunk); - _ -> - [Size, ChunkBody, <<>>] = - binary:split(Chunk, [<<"\r\n">>], [global]), - PartASize = random:uniform(byte_size(ChunkBody)), - <<PartA:PartASize/binary, PartB/binary>> = ChunkBody, - ok = gun:dbg_send_raw(ConnPid, [Size, <<"\r\n">>, PartA]), - receive after 10 -> ok end, - ok = gun:dbg_send_raw(ConnPid, [PartB, <<"\r\n">>]) - end - end || Chunk <- Chunks], - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref), - ok. - -te_chunked_split_crlf(Config) -> - Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), - Chunks = do_body_to_chunks(50, Body, []), - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", - [{<<"content-type">>, <<"text/plain">>}]), - _ = [begin - %% Split in the newline just before the end of the chunk. - Len = byte_size(Chunk) - (random:uniform(2) - 1), - << Chunk2:Len/binary, End/binary >> = Chunk, - ok = gun:dbg_send_raw(ConnPid, Chunk2), - receive after 10 -> ok end, - ok = gun:dbg_send_raw(ConnPid, End) - end || Chunk <- Chunks], - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref), - ok. - -te_identity(Config) -> - Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), - ConnPid = gun_open(Config), - Ref = gun:post(ConnPid, "/echo/body", [], Body), - {response, nofin, 200, _} = gun:await(ConnPid, Ref), - {ok, Body} = gun:await_body(ConnPid, Ref), - ok. - -request_timeout_infinity(Config) -> - Pid = config(pid, Config), - Ref = erlang:monitor(process, Pid), - _ = gun_open(Config), - receive - {'DOWN', Ref, process, Pid, Reason} -> - error(Reason) - after 1000 -> - ok - end. - -idle_timeout_infinity(Config) -> - Pid = config(pid, Config), - Ref = erlang:monitor(process, Pid), - ConnPid = gun_open(Config), - gun:post(ConnPid, "/echo/body", [], <<"TEST">>), receive - {'DOWN', Ref, process, Pid, Reason} -> - error(Reason) - after 1000 -> - ok + {Self, Events} -> + switch_protocol_flush_h:validate(Events) end. diff --git a/test/old_http_SUITE.erl b/test/old_http_SUITE.erl new file mode 100644 index 0000000..539ab04 --- /dev/null +++ b/test/old_http_SUITE.erl @@ -0,0 +1,796 @@ +%% Copyright (c) 2011-2017, Loïc Hoguin <[email protected]> +%% Copyright (c) 2011, Anthony Ramine <[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(old_http_SUITE). +-compile(export_all). +-compile(nowarn_export_all). + +-import(ct_helper, [config/2]). +-import(cowboy_test, [gun_open/1]). +-import(cowboy_test, [gun_open/2]). +-import(cowboy_test, [gun_down/1]). +-import(cowboy_test, [raw_open/1]). +-import(cowboy_test, [raw_send/2]). +-import(cowboy_test, [raw_recv_head/1]). +-import(cowboy_test, [raw_expect_recv/2]). + +%% ct. + +all() -> + [ + {group, http}, + {group, https}, + {group, http_compress}, + {group, https_compress}, + {group, parse_host}, + {group, request_timeout_infinity}, + {group, idle_timeout_infinity}, + {group, set_env}, + {group, router_compile} + ]. + +groups() -> + Tests = ct_helper:all(?MODULE) -- [ + parse_host, set_env_dispatch, path_allow_colon, + request_timeout_infinity, idle_timeout_infinity + ], + [ + {http, [], Tests}, %% @todo parallel + {https, [parallel], Tests}, + {http_compress, [parallel], Tests}, + {https_compress, [parallel], Tests}, + {parse_host, [], [ + parse_host + ]}, + {request_timeout_infinity, [], [ + request_timeout_infinity + ]}, + {idle_timeout_infinity, [], [ + idle_timeout_infinity + ]}, + {set_env, [], [ + set_env_dispatch + ]}, + {router_compile, [], [ + path_allow_colon + ]} + ]. + +init_per_group(Name = http, Config) -> + cowboy_test:init_http(Name, #{env => #{dispatch => init_dispatch(Config)}}, Config); +init_per_group(Name = https, Config) -> + cowboy_test:init_https(Name, #{env => #{dispatch => init_dispatch(Config)}}, Config); +init_per_group(Name = http_compress, Config) -> + cowboy_test:init_http(Name, #{ + env => #{dispatch => init_dispatch(Config)}, + compress => true + }, Config); +init_per_group(Name = https_compress, Config) -> + cowboy_test:init_https(Name, #{ + env => #{dispatch => init_dispatch(Config)}, + compress => true + }, Config); +init_per_group(parse_host, Config) -> + Dispatch = cowboy_router:compile([ + {'_', [ + {"/req_attr", http_req_attr, []} + ]} + ]), + {ok, _} = cowboy:start_clear(parse_host, [{port, 0}], #{ + env => #{dispatch => Dispatch} + }), + Port = ranch:get_port(parse_host), + [{type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; +init_per_group(request_timeout_infinity, Config) -> + Ref = request_timeout_infinity, + {ok, Pid} = cowboy:start_clear(Ref, [{port, 0}], #{ + env => #{dispatch => init_dispatch(Config)}, + request_timeout => infinity + }), + Port = ranch:get_port(request_timeout_infinity), + [{pid, Pid}, {ref, Ref}, {type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; +init_per_group(idle_timeout_infinity, Config) -> + Ref = idle_timeout_infinity, + {ok, Pid} = cowboy:start_clear(Ref, [{port, 0}], #{ + env => #{dispatch => init_dispatch(Config)}, + idle_timeout => infinity + }), + Port = ranch:get_port(idle_timeout_infinity), + [{pid, Pid}, {ref, Ref}, {type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; +init_per_group(set_env, Config) -> + {ok, _} = cowboy:start_clear(set_env, [{port, 0}], #{ + env => #{dispatch => []} + }), + Port = ranch:get_port(set_env), + [{type, tcp}, {protocol, http}, {port, Port}, {opts, []}|Config]; +init_per_group(router_compile, Config) -> + Config. + +end_per_group(router_compile, _) -> + ok; +end_per_group(Name, _) -> + ok = cowboy:stop_listener(Name). + +%% Dispatch configuration. + +init_dispatch(_) -> + cowboy_router:compile([ + {"localhost", [ + {"/chunked_response", http_chunked, []}, + {"/headers/dupe", http_handler, + [{headers, #{<<"connection">> => <<"close">>}}]}, + {"/set_resp/header", http_set_resp, + [{headers, #{<<"vary">> => <<"Accept">>}}]}, + {"/set_resp/overwrite", http_set_resp, + [{headers, #{<<"server">> => <<"DesireDrive/1.0">>}}]}, + {"/set_resp/body", http_set_resp, + [{body, <<"A flameless dance does not equal a cycle">>}]}, + {"/handler_errors", http_errors, []}, + {"/echo/body", http_echo_body, []}, + {"/param_all", rest_param_all, []}, + {"/bad_accept", rest_simple_resource, []}, + {"/bad_content_type", rest_patch_resource, []}, + {"/simple", rest_simple_resource, []}, + {"/forbidden_post", rest_forbidden_resource, [true]}, + {"/simple_post", rest_forbidden_resource, [false]}, + {"/missing_get_callbacks", rest_missing_callbacks, []}, + {"/missing_put_callbacks", rest_missing_callbacks, []}, + {"/nodelete", rest_nodelete_resource, []}, + {"/post_charset", rest_post_charset_resource, []}, + {"/postonly", rest_postonly_resource, []}, + {"/patch", rest_patch_resource, []}, + {"/resetags", rest_resource_etags, []}, + {"/rest_expires", rest_expires, []}, + {"/rest_expires_binary", rest_expires_binary, []}, + {"/rest_empty_resource", rest_empty_resource, []}, + {"/loop_stream_recv", http_loop_stream_recv, []}, + {"/", http_handler, []} + ]} + ]). + +%% Convenience functions. + +do_raw(Data, Config) -> + Client = raw_open(Config), + ok = raw_send(Client, Data), + case catch raw_recv_head(Client) of + {'EXIT', _} -> closed; + Resp -> element(2, cow_http:parse_status_line(Resp)) + end. + +do_get(Path, Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, Path), + {response, _, Status, _} = gun:await(ConnPid, Ref), + gun:close(ConnPid), + Status. + +%% Tests. + +check_raw_status(Config) -> + Huge = [$0 || _ <- lists:seq(1, 5000)], + HugeCookie = lists:flatten(["whatever_man_biiiiiiiiiiiig_cookie_me_want_77=" + "Wed Apr 06 2011 10:38:52 GMT-0500 (CDT)" || _ <- lists:seq(1, 40)]), + ResponsePacket = +"HTTP/1.0 302 Found\r +Location: http://www.google.co.il/\r +Cache-Control: private\r +Content-Type: text/html; charset=UTF-8\r +Set-Cookie: PREF=ID=568f67013d4a7afa:FF=0:TM=1323014101:LM=1323014101:S=XqctDWC65MzKT0zC; expires=Tue, 03-Dec-2013 15:55:01 GMT; path=/; domain=.google.com\r +Date: Sun, 04 Dec 2011 15:55:01 GMT\r +Server: gws\r +Content-Length: 221\r +X-XSS-Protection: 1; mode=block\r +X-Frame-Options: SAMEORIGIN\r +\r +<HTML><HEAD><meta http-equiv=\"content-type\" content=\"text/html;charset=utf-8\"> +<TITLE>302 Moved</TITLE></HEAD><BODY> +<H1>302 Moved</H1> +The document has moved +<A HREF=\"http://www.google.co.il/\">here</A>. +</BODY></HTML>", + Tests = [ + {200, ["GET / HTTP/1.0\r\nHost: localhost\r\n" + "Set-Cookie: ", HugeCookie, "\r\n\r\n"]}, + {200, "\r\n\r\n\r\n\r\n\r\nGET / HTTP/1.1\r\nHost: localhost\r\n\r\n"}, + {200, "GET http://proxy/ HTTP/1.1\r\nHost: localhost\r\n\r\n"}, + {400, "\n"}, + {400, "Garbage\r\n\r\n"}, + {400, "\r\n\r\n\r\n\r\n\r\n\r\n"}, + {400, " / HTTP/1.1\r\nHost: localhost\r\n\r\n"}, + {400, "GET HTTP/1.1\r\nHost: localhost\r\n\r\n"}, + {400, "GET / HTTP/1.1\r\nHost: ninenines.eu\r\n\r\n"}, + {400, "GET http://proxy/ HTTP/1.1\r\n\r\n"}, + {400, "GET / HTTP/1.1\r\nHost: localhost:bad_port\r\n\r\n"}, + {400, ResponsePacket}, + {408, "GET / HTTP/1.1\r\n"}, + {408, "GET / HTTP/1.1\r\nHost: localhost"}, + {408, "GET / HTTP/1.1\r\nHost: localhost\r\n"}, + {408, "GET / HTTP/1.1\r\nHost: localhost\r\n\r"}, + {closed, Huge}, + {431, "GET / HTTP/1.1\r\n" ++ Huge}, + {505, "GET / HTTP/1.2\r\nHost: localhost\r\n\r\n"}, + {closed, ""}, + {closed, "\r\n"}, + {closed, "\r\n\r\n"}, + {closed, "GET / HTTP/1.1"} + ], + _ = [{Status, Packet} = begin + Ret = do_raw(Packet, Config), + {Ret, Packet} + end || {Status, Packet} <- Tests], + ok. + +check_status(Config) -> + Tests = [ + {200, "/"}, + {200, "/simple"}, + {404, "/not/found"}, + {500, "/handler_errors?case=init_before_reply"} + ], + _ = [{Status, URL} = begin + Ret = do_get(URL, Config), + {Ret, URL} + end || {Status, URL} <- Tests]. + +%% Check if sending requests whose size is around the MTU breaks something. +echo_body(Config) -> + MTU = ct_helper:get_loopback_mtu(), + _ = [begin + Body = list_to_binary(lists:duplicate(Size, $a)), + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", [], Body), + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref) + end || Size <- lists:seq(MTU - 500, MTU)], + ok. + +%% Check if sending request whose size is bigger than 1000000 bytes causes 413 +echo_body_max_length(Config) -> + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", [], << 0:10000000/unit:8 >>), + {response, nofin, 413, _} = gun:await(ConnPid, Ref), + ok. + +error_init_after_reply(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/handler_errors?case=init_after_reply"), + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + ok. + +headers_dupe(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/headers/dupe"), + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + %% Ensure that only one connection header was received. + [<<"close">>] = [V || {Name, V} <- Headers, Name =:= <<"connection">>], + gun_down(ConnPid). + +http10_chunkless(Config) -> + ConnPid = gun_open(Config, #{http_opts => #{version => 'HTTP/1.0'}}), + Ref = gun:get(ConnPid, "/chunked_response"), + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + false = lists:keyfind(<<"transfer-encoding">>, 1, Headers), + {ok, <<"chunked_handler\r\nworks fine!">>} = gun:await_body(ConnPid, Ref), + gun_down(ConnPid). + +http10_hostless(Config) -> + Name = http10_hostless, + Port10 = config(port, Config) + 10, + {Transport, Protocol} = case config(type, Config) of + tcp -> {ranch_tcp, cowboy_clear}; + ssl -> {ranch_ssl, cowboy_tls} + end, + ranch:start_listener(Name, 5, Transport, + config(opts, Config) ++ [{port, Port10}], + Protocol, #{ + env =>#{dispatch => cowboy_router:compile([ + {'_', [{"/http1.0/hostless", http_handler, []}]}])}, + max_keepalive => 50, + timeout => 500 + }), + 200 = do_raw("GET /http1.0/hostless HTTP/1.0\r\n\r\n", + [{port, Port10}|Config]), + cowboy:stop_listener(http10_hostless). + +http10_keepalive_default(Config) -> + Normal = "GET / HTTP/1.0\r\nhost: localhost\r\n\r\n", + Client = raw_open(Config), + ok = raw_send(Client, Normal), + case catch raw_recv_head(Client) of + {'EXIT', _} -> error(closed); + Data -> + %% Cowboy always advertises itself as HTTP/1.1. + {'HTTP/1.1', 200, _, Rest} = cow_http:parse_status_line(Data), + {Headers, _} = cow_http:parse_headers(Rest), + {_, <<"close">>} = lists:keyfind(<<"connection">>, 1, Headers) + end, + ok = raw_send(Client, Normal), + case catch raw_recv_head(Client) of + {'EXIT', _} -> closed; + _ -> error(not_closed) + end. + +http10_keepalive_forced(Config) -> + Keepalive = "GET / HTTP/1.0\r\nhost: localhost\r\nConnection: keep-alive\r\n\r\n", + Client = raw_open(Config), + ok = raw_send(Client, Keepalive), + case catch raw_recv_head(Client) of + {'EXIT', _} -> error(closed); + Data -> + %% Cowboy always advertises itself as HTTP/1.1. + {'HTTP/1.1', 200, _, Rest} = cow_http:parse_status_line(Data), + {Headers, _} = cow_http:parse_headers(Rest), + {_, <<"keep-alive">>} = lists:keyfind(<<"connection">>, 1, Headers) + end, + ok = raw_send(Client, Keepalive), + case catch raw_recv_head(Client) of + {'EXIT', Err} -> error({closed, Err}); + _ -> ok + end. + +keepalive_nl(Config) -> + ConnPid = gun_open(Config), + Refs = [begin + Ref = gun:get(ConnPid, "/", [{<<"connection">>, <<"keep-alive">>}]), + gun:dbg_send_raw(ConnPid, <<"\r\n">>), + Ref + end || _ <- lists:seq(1, 10)], + _ = [begin + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + false = lists:keymember(<<"connection">>, 1, Headers) + end || Ref <- Refs], + ok. + +keepalive_stream_loop(Config) -> + ConnPid = gun_open(Config), + Refs = [begin + Ref = gun:post(ConnPid, "/loop_stream_recv", + [{<<"content-type">>, <<"application/octet-stream">>}]), + _ = [gun:data(ConnPid, Ref, nofin, << ID:32 >>) + || ID <- lists:seq(1, 250)], + gun:data(ConnPid, Ref, fin, <<>>), + Ref + end || _ <- lists:seq(1, 10)], + _ = [begin + {response, fin, 200, _} = gun:await(ConnPid, Ref) + end || Ref <- Refs], + ok. + +do_nc(Config, Input) -> + Cat = os:find_executable("cat"), + Nc = os:find_executable("nc"), + case {Cat, Nc} of + {false, _} -> + {skip, {notfound, cat}}; + {_, false} -> + {skip, {notfound, nc}}; + _Good -> + %% Throw garbage at the server then check if it's still up. + StrPort = integer_to_list(config(port, Config)), + [os:cmd("cat " ++ Input ++ " | nc localhost " ++ StrPort) + || _ <- lists:seq(1, 100)], + 200 = do_get("/", Config) + end. + +nc_rand(Config) -> + do_nc(Config, "/dev/urandom"). + +nc_zero(Config) -> + do_nc(Config, "/dev/zero"). + +parse_host(Config) -> + ConnPid = gun_open(Config), + Tests = [ + {<<"example.org:8080">>, <<"example.org\n8080">>}, + {<<"example.org">>, <<"example.org\n80">>}, + {<<"192.0.2.1:8080">>, <<"192.0.2.1\n8080">>}, + {<<"192.0.2.1">>, <<"192.0.2.1\n80">>}, + {<<"[2001:db8::1]:8080">>, <<"[2001:db8::1]\n8080">>}, + {<<"[2001:db8::1]">>, <<"[2001:db8::1]\n80">>}, + {<<"[::ffff:192.0.2.1]:8080">>, <<"[::ffff:192.0.2.1]\n8080">>}, + {<<"[::ffff:192.0.2.1]">>, <<"[::ffff:192.0.2.1]\n80">>} + ], + [begin + Ref = gun:get(ConnPid, "/req_attr?attr=host_and_port", + [{<<"host">>, Host}]), + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref) + end || {Host, Body} <- Tests], + ok. + +rest_param_all(Config) -> + ConnPid = gun_open(Config), + %% Accept without param. + Ref1 = gun:get(ConnPid, "/param_all", + [{<<"accept">>, <<"text/plain">>}]), + {response, nofin, 200, _} = gun:await(ConnPid, Ref1), + {ok, <<"[]">>} = gun:await_body(ConnPid, Ref1), + %% Accept with param. + Ref2 = gun:get(ConnPid, "/param_all", + [{<<"accept">>, <<"text/plain;level=1">>}]), + {response, nofin, 200, _} = gun:await(ConnPid, Ref2), + {ok, <<"level=1">>} = gun:await_body(ConnPid, Ref2), + %% Accept with param and quality. + Ref3 = gun:get(ConnPid, "/param_all", + [{<<"accept">>, <<"text/plain;level=1;q=0.8, text/plain;level=2;q=0.5">>}]), + {response, nofin, 200, _} = gun:await(ConnPid, Ref3), + {ok, <<"level=1">>} = gun:await_body(ConnPid, Ref3), + Ref4 = gun:get(ConnPid, "/param_all", + [{<<"accept">>, <<"text/plain;level=1;q=0.5, text/plain;level=2;q=0.8">>}]), + {response, nofin, 200, _} = gun:await(ConnPid, Ref4), + {ok, <<"level=2">>} = gun:await_body(ConnPid, Ref4), + %% Without Accept. + Ref5 = gun:get(ConnPid, "/param_all"), + {response, nofin, 200, _} = gun:await(ConnPid, Ref5), + {ok, <<"'*'">>} = gun:await_body(ConnPid, Ref5), + %% Content-Type without param. + Ref6 = gun:put(ConnPid, "/param_all", + [{<<"content-type">>, <<"text/plain">>}]), + gun:data(ConnPid, Ref6, fin, "Hello world!"), + {response, fin, 204, _} = gun:await(ConnPid, Ref6), + %% Content-Type with param. + Ref7 = gun:put(ConnPid, "/param_all", + [{<<"content-type">>, <<"text/plain; charset=utf-8">>}]), + gun:data(ConnPid, Ref7, fin, "Hello world!"), + {response, fin, 204, _} = gun:await(ConnPid, Ref7), + ok. + +rest_bad_accept(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/bad_accept", + [{<<"accept">>, <<"1">>}]), + {response, fin, 400, _} = gun:await(ConnPid, Ref), + ok. + +rest_bad_content_type(Config) -> + ConnPid = gun_open(Config), + Ref = gun:patch(ConnPid, "/bad_content_type", + [{<<"content-type">>, <<"text/plain, text/html">>}], <<"Whatever">>), + {response, fin, 415, _} = gun:await(ConnPid, Ref), + ok. + +rest_expires(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/rest_expires"), + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + {_, Expires} = lists:keyfind(<<"expires">>, 1, Headers), + {_, LastModified} = lists:keyfind(<<"last-modified">>, 1, Headers), + Expires = LastModified = <<"Fri, 21 Sep 2012 22:36:14 GMT">>, + ok. + +rest_expires_binary(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/rest_expires_binary"), + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + {_, <<"0">>} = lists:keyfind(<<"expires">>, 1, Headers), + ok. + +rest_last_modified_undefined(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/simple", + [{<<"if-modified-since">>, <<"Fri, 21 Sep 2012 22:36:14 GMT">>}]), + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + ok. + +rest_keepalive(Config) -> + ConnPid = gun_open(Config), + Refs = [gun:get(ConnPid, "/simple") || _ <- lists:seq(1, 10)], + _ = [begin + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + false = lists:keymember(<<"connection">>, 1, Headers) + end || Ref <- Refs], + ok. + +rest_keepalive_post(Config) -> + ConnPid = gun_open(Config), + Refs = [begin + Ref1 = gun:post(ConnPid, "/forbidden_post", [ + {<<"content-type">>, <<"text/plain">>}, + {<<"content-length">>, <<"12">>} + ]), + gun:data(ConnPid, Ref1, fin, "Hello world!"), + Ref2 = gun:post(ConnPid, "/simple_post", [ + {<<"content-type">>, <<"text/plain">>}, + {<<"content-length">>, <<"12">>} + ]), + gun:data(ConnPid, Ref2, fin, "Hello world!"), + {Ref1, Ref2} + end || _ <- lists:seq(1, 5)], + _ = [begin + {response, fin, 403, Headers1} = gun:await(ConnPid, Ref1), + false = lists:keymember(<<"connection">>, 1, Headers1), + {response, fin, 303, Headers2} = gun:await(ConnPid, Ref2), + false = lists:keymember(<<"connection">>, 1, Headers2) + end || {Ref1, Ref2} <- Refs], + ok. + +rest_missing_get_callbacks(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/missing_get_callbacks"), + {response, fin, 500, _} = gun:await(ConnPid, Ref), + ok. + +rest_missing_put_callbacks(Config) -> + ConnPid = gun_open(Config), + Ref = gun:put(ConnPid, "/missing_put_callbacks", + [{<<"content-type">>, <<"application/json">>}], <<"{}">>), + {response, fin, 500, _} = gun:await(ConnPid, Ref), + ok. + +rest_nodelete(Config) -> + ConnPid = gun_open(Config), + Ref = gun:delete(ConnPid, "/nodelete"), + {response, fin, 500, _} = gun:await(ConnPid, Ref), + ok. + +rest_options_default(Config) -> + ConnPid = gun_open(Config), + Ref = gun:options(ConnPid, "/rest_empty_resource"), + {response, fin, 200, Headers} = gun:await(ConnPid, Ref), + {_, <<"HEAD, GET, OPTIONS">>} = lists:keyfind(<<"allow">>, 1, Headers), + ok. + +rest_patch(Config) -> + Tests = [ + {204, [{<<"content-type">>, <<"text/plain">>}], <<"whatever">>}, + {400, [{<<"content-type">>, <<"text/plain">>}], <<"false">>}, + {400, [{<<"content-type">>, <<"text/plain">>}], <<"stop">>}, + {415, [{<<"content-type">>, <<"application/json">>}], <<"bad_content_type">>} + ], + ConnPid = gun_open(Config), + _ = [begin + Ref = gun:patch(ConnPid, "/patch", Headers, Body), + {response, fin, Status, _} = gun:await(ConnPid, Ref) + end || {Status, Headers, Body} <- Tests], + ok. + +rest_post_charset(Config) -> + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/post_charset", + [{<<"content-type">>, <<"text/plain;charset=UTF-8">>}], "12345"), + {response, fin, 204, _} = gun:await(ConnPid, Ref), + ok. + +rest_postonly(Config) -> + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/postonly", + [{<<"content-type">>, <<"text/plain">>}], "12345"), + {response, fin, 204, _} = gun:await(ConnPid, Ref), + ok. + +rest_resource_get_etag(Config, Type) -> + rest_resource_get_etag(Config, Type, []). + +rest_resource_get_etag(Config, Type, Headers) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/resetags?type=" ++ Type, Headers), + {response, _, Status, RespHeaders} = gun:await(ConnPid, Ref), + case lists:keyfind(<<"etag">>, 1, RespHeaders) of + false -> {Status, false}; + {<<"etag">>, ETag} -> {Status, ETag} + end. + +rest_resource_etags(Config) -> + Tests = [ + {200, <<"W/\"etag-header-value\"">>, "tuple-weak"}, + {200, <<"\"etag-header-value\"">>, "tuple-strong"}, + {200, <<"W/\"etag-header-value\"">>, "binary-weak-quoted"}, + {200, <<"\"etag-header-value\"">>, "binary-strong-quoted"}, + {500, false, "binary-strong-unquoted"}, + {500, false, "binary-weak-unquoted"} + ], + _ = [{Status, ETag, Type} = begin + {Ret, RespETag} = rest_resource_get_etag(Config, Type), + {Ret, RespETag, Type} + end || {Status, ETag, Type} <- Tests]. + +rest_resource_etags_if_none_match(Config) -> + Tests = [ + {304, <<"W/\"etag-header-value\"">>, "tuple-weak"}, + {304, <<"\"etag-header-value\"">>, "tuple-strong"}, + {304, <<"W/\"etag-header-value\"">>, "binary-weak-quoted"}, + {304, <<"\"etag-header-value\"">>, "binary-strong-quoted"} + ], + _ = [{Status, Type} = begin + {Ret, _} = rest_resource_get_etag(Config, Type, + [{<<"if-none-match">>, ETag}]), + {Ret, Type} + end || {Status, ETag, Type} <- Tests]. + +set_env_dispatch(Config) -> + ConnPid1 = gun_open(Config), + Ref1 = gun:get(ConnPid1, "/"), + {response, fin, 400, _} = gun:await(ConnPid1, Ref1), + ok = cowboy:set_env(set_env, dispatch, + cowboy_router:compile([{'_', [{"/", http_handler, []}]}])), + ConnPid2 = gun_open(Config), + Ref2 = gun:get(ConnPid2, "/"), + {response, nofin, 200, _} = gun:await(ConnPid2, Ref2), + ok. + +path_allow_colon(_Config) -> + cowboy_router:compile([{'_', [{"/foo/bar:blah", http_handler, []}]}]), + ok. + +set_resp_body(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/set_resp/body"), + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, <<"A flameless dance does not equal a cycle">>} + = gun:await_body(ConnPid, Ref), + ok. + +set_resp_header(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/set_resp/header"), + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + {_, <<"Accept">>} = lists:keyfind(<<"vary">>, 1, Headers), + {_, _} = lists:keyfind(<<"set-cookie">>, 1, Headers), + ok. + +set_resp_overwrite(Config) -> + ConnPid = gun_open(Config), + Ref = gun:get(ConnPid, "/set_resp/overwrite"), + {response, nofin, 200, Headers} = gun:await(ConnPid, Ref), + {_, <<"DesireDrive/1.0">>} = lists:keyfind(<<"server">>, 1, Headers), + ok. + +slowloris(Config) -> + Client = raw_open(Config), + try + [begin + ok = raw_send(Client, [C]), + receive after 250 -> ok end + end || C <- "GET / HTTP/1.1\r\nHost: localhost\r\n" + "User-Agent: Mozilla/5.0 (Windows; U; Windows NT 6.0; en-US)\r\n" + "Cookie: name=aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa\r\n\r\n"], + error(failure) + catch error:{badmatch, _} -> + ok + end. + +slowloris2(Config) -> + Client = raw_open(Config), + ok = raw_send(Client, "GET / HTTP/1.1\r\n"), + receive after 300 -> ok end, + ok = raw_send(Client, "Host: localhost\r\n"), + receive after 300 -> ok end, + Data = raw_recv_head(Client), + {_, 408, _, _} = cow_http:parse_status_line(Data), + ok. + +te_chunked(Config) -> + Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", [{<<"content-type">>, <<"text/plain">>}]), + gun:data(ConnPid, Ref, fin, Body), + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref), + ok. + +do_body_to_chunks(_, <<>>, Acc) -> + lists:reverse([<<"0\r\n\r\n">>|Acc]); +do_body_to_chunks(ChunkSize, Body, Acc) -> + BodySize = byte_size(Body), + ChunkSize2 = case BodySize < ChunkSize of + true -> BodySize; + false -> ChunkSize + end, + << Chunk:ChunkSize2/binary, Rest/binary >> = Body, + ChunkSizeBin = integer_to_binary(ChunkSize2, 16), + do_body_to_chunks(ChunkSize, Rest, + [<< ChunkSizeBin/binary, "\r\n", Chunk/binary, "\r\n" >>|Acc]). + +te_chunked_chopped(Config) -> + Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), + Body2 = iolist_to_binary(do_body_to_chunks(50, Body, [])), + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", + [{<<"content-type">>, <<"text/plain">>}]), + _ = [begin + ok = gun:dbg_send_raw(ConnPid, << C >>), + receive after 10 -> ok end + end || << C >> <= Body2], + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref), + ok. + +te_chunked_delayed(Config) -> + Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), + Chunks = do_body_to_chunks(50, Body, []), + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", + [{<<"content-type">>, <<"text/plain">>}]), + _ = [begin + ok = gun:dbg_send_raw(ConnPid, Chunk), + receive after 10 -> ok end + end || Chunk <- Chunks], + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref), + ok. + +te_chunked_split_body(Config) -> + Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), + Chunks = do_body_to_chunks(50, Body, []), + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", + [{<<"content-type">>, <<"text/plain">>}]), + _ = [begin + case Chunk of + <<"0\r\n\r\n">> -> + ok = gun:dbg_send_raw(ConnPid, Chunk); + _ -> + [Size, ChunkBody, <<>>] = + binary:split(Chunk, [<<"\r\n">>], [global]), + PartASize = random:uniform(byte_size(ChunkBody)), + <<PartA:PartASize/binary, PartB/binary>> = ChunkBody, + ok = gun:dbg_send_raw(ConnPid, [Size, <<"\r\n">>, PartA]), + receive after 10 -> ok end, + ok = gun:dbg_send_raw(ConnPid, [PartB, <<"\r\n">>]) + end + end || Chunk <- Chunks], + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref), + ok. + +te_chunked_split_crlf(Config) -> + Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), + Chunks = do_body_to_chunks(50, Body, []), + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", + [{<<"content-type">>, <<"text/plain">>}]), + _ = [begin + %% Split in the newline just before the end of the chunk. + Len = byte_size(Chunk) - (random:uniform(2) - 1), + << Chunk2:Len/binary, End/binary >> = Chunk, + ok = gun:dbg_send_raw(ConnPid, Chunk2), + receive after 10 -> ok end, + ok = gun:dbg_send_raw(ConnPid, End) + end || Chunk <- Chunks], + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref), + ok. + +te_identity(Config) -> + Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), + ConnPid = gun_open(Config), + Ref = gun:post(ConnPid, "/echo/body", [], Body), + {response, nofin, 200, _} = gun:await(ConnPid, Ref), + {ok, Body} = gun:await_body(ConnPid, Ref), + ok. + +request_timeout_infinity(Config) -> + Pid = config(pid, Config), + Ref = erlang:monitor(process, Pid), + _ = gun_open(Config), + receive + {'DOWN', Ref, process, Pid, Reason} -> + error(Reason) + after 1000 -> + ok + end. + +idle_timeout_infinity(Config) -> + Pid = config(pid, Config), + Ref = erlang:monitor(process, Pid), + ConnPid = gun_open(Config), + gun:post(ConnPid, "/echo/body", [], <<"TEST">>), + receive + {'DOWN', Ref, process, Pid, Reason} -> + error(Reason) + after 1000 -> + ok + end. diff --git a/test/http_SUITE_data/http_chunked.erl b/test/old_http_SUITE_data/http_chunked.erl index 645eefe..645eefe 100644 --- a/test/http_SUITE_data/http_chunked.erl +++ b/test/old_http_SUITE_data/http_chunked.erl diff --git a/test/http_SUITE_data/http_echo_body.erl b/test/old_http_SUITE_data/http_echo_body.erl index d803108..d803108 100644 --- a/test/http_SUITE_data/http_echo_body.erl +++ b/test/old_http_SUITE_data/http_echo_body.erl diff --git a/test/http_SUITE_data/http_errors.erl b/test/old_http_SUITE_data/http_errors.erl index 14e3d09..14e3d09 100644 --- a/test/http_SUITE_data/http_errors.erl +++ b/test/old_http_SUITE_data/http_errors.erl diff --git a/test/http_SUITE_data/http_handler.erl b/test/old_http_SUITE_data/http_handler.erl index eb31aa8..eb31aa8 100644 --- a/test/http_SUITE_data/http_handler.erl +++ b/test/old_http_SUITE_data/http_handler.erl diff --git a/test/http_SUITE_data/http_loop_stream_recv.erl b/test/old_http_SUITE_data/http_loop_stream_recv.erl index 8c6f6b0..8c6f6b0 100644 --- a/test/http_SUITE_data/http_loop_stream_recv.erl +++ b/test/old_http_SUITE_data/http_loop_stream_recv.erl diff --git a/test/http_SUITE_data/http_req_attr.erl b/test/old_http_SUITE_data/http_req_attr.erl index c6a940e..c6a940e 100644 --- a/test/http_SUITE_data/http_req_attr.erl +++ b/test/old_http_SUITE_data/http_req_attr.erl diff --git a/test/http_SUITE_data/http_set_resp.erl b/test/old_http_SUITE_data/http_set_resp.erl index e575aab..e575aab 100644 --- a/test/http_SUITE_data/http_set_resp.erl +++ b/test/old_http_SUITE_data/http_set_resp.erl diff --git a/test/http_SUITE_data/rest_empty_resource.erl b/test/old_http_SUITE_data/rest_empty_resource.erl index 8a944cd..8a944cd 100644 --- a/test/http_SUITE_data/rest_empty_resource.erl +++ b/test/old_http_SUITE_data/rest_empty_resource.erl diff --git a/test/http_SUITE_data/rest_expires.erl b/test/old_http_SUITE_data/rest_expires.erl index 8665b06..8665b06 100644 --- a/test/http_SUITE_data/rest_expires.erl +++ b/test/old_http_SUITE_data/rest_expires.erl diff --git a/test/http_SUITE_data/rest_expires_binary.erl b/test/old_http_SUITE_data/rest_expires_binary.erl index 4d6bd3c..4d6bd3c 100644 --- a/test/http_SUITE_data/rest_expires_binary.erl +++ b/test/old_http_SUITE_data/rest_expires_binary.erl diff --git a/test/http_SUITE_data/rest_forbidden_resource.erl b/test/old_http_SUITE_data/rest_forbidden_resource.erl index 0a65228..0a65228 100644 --- a/test/http_SUITE_data/rest_forbidden_resource.erl +++ b/test/old_http_SUITE_data/rest_forbidden_resource.erl diff --git a/test/http_SUITE_data/rest_missing_callbacks.erl b/test/old_http_SUITE_data/rest_missing_callbacks.erl index bf77c22..bf77c22 100644 --- a/test/http_SUITE_data/rest_missing_callbacks.erl +++ b/test/old_http_SUITE_data/rest_missing_callbacks.erl diff --git a/test/http_SUITE_data/rest_nodelete_resource.erl b/test/old_http_SUITE_data/rest_nodelete_resource.erl index b9f40bd..b9f40bd 100644 --- a/test/http_SUITE_data/rest_nodelete_resource.erl +++ b/test/old_http_SUITE_data/rest_nodelete_resource.erl diff --git a/test/http_SUITE_data/rest_param_all.erl b/test/old_http_SUITE_data/rest_param_all.erl index 784214b..784214b 100644 --- a/test/http_SUITE_data/rest_param_all.erl +++ b/test/old_http_SUITE_data/rest_param_all.erl diff --git a/test/http_SUITE_data/rest_patch_resource.erl b/test/old_http_SUITE_data/rest_patch_resource.erl index 341920d..341920d 100644 --- a/test/http_SUITE_data/rest_patch_resource.erl +++ b/test/old_http_SUITE_data/rest_patch_resource.erl diff --git a/test/http_SUITE_data/rest_post_charset_resource.erl b/test/old_http_SUITE_data/rest_post_charset_resource.erl index 0be6aa3..0be6aa3 100644 --- a/test/http_SUITE_data/rest_post_charset_resource.erl +++ b/test/old_http_SUITE_data/rest_post_charset_resource.erl diff --git a/test/http_SUITE_data/rest_postonly_resource.erl b/test/old_http_SUITE_data/rest_postonly_resource.erl index 942e55d..942e55d 100644 --- a/test/http_SUITE_data/rest_postonly_resource.erl +++ b/test/old_http_SUITE_data/rest_postonly_resource.erl diff --git a/test/http_SUITE_data/rest_resource_etags.erl b/test/old_http_SUITE_data/rest_resource_etags.erl index 25b3080..25b3080 100644 --- a/test/http_SUITE_data/rest_resource_etags.erl +++ b/test/old_http_SUITE_data/rest_resource_etags.erl diff --git a/test/http_SUITE_data/rest_simple_resource.erl b/test/old_http_SUITE_data/rest_simple_resource.erl index 68e1b95..68e1b95 100644 --- a/test/http_SUITE_data/rest_simple_resource.erl +++ b/test/old_http_SUITE_data/rest_simple_resource.erl diff --git a/test/sys_SUITE.erl b/test/sys_SUITE.erl index bb77ede..b692521 100644 --- a/test/sys_SUITE.erl +++ b/test/sys_SUITE.erl @@ -108,10 +108,6 @@ proc_lib_initial_call_tls(Config) -> %% the receiving process module. When a system message is received, %% function handle_system_msg/6 is called to handle the request. -%% @todo The flush/0 function in cowboy_http needs to be fixed -%% so that it doesn't eat up system messages. It should only -%% flush messages that are specific to cowboy_http. - bad_system_from_h1(Config) -> doc("h1: Sending a system message with a bad From value results in a process crash."), {ok, Socket} = gen_tcp:connect("localhost", config(clear_port, Config), [{active, false}]), |