%% Copyright (c) 2011-2013, Loïc Hoguin %% Copyright (c) 2011, Anthony Ramine %% %% 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(http_SUITE). -include_lib("common_test/include/ct.hrl"). %% ct. -export([all/0]). -export([groups/0]). -export([init_per_suite/1]). -export([end_per_suite/1]). -export([init_per_group/2]). -export([end_per_group/2]). %% Tests. -export([check_raw_status/1]). -export([check_status/1]). -export([chunked_response/1]). -export([echo_body/1]). -export([error_chain_handle_after_reply/1]). -export([error_chain_handle_before_reply/1]). -export([error_handle_after_reply/1]). -export([error_init_after_reply/1]). -export([error_init_reply_handle_error/1]). -export([headers_dupe/1]). -export([http10_chunkless/1]). -export([http10_hostless/1]). -export([keepalive_max/1]). -export([keepalive_nl/1]). -export([multipart/1]). -export([nc_rand/1]). -export([nc_zero/1]). -export([onrequest/1]). -export([onrequest_reply/1]). -export([onresponse_capitalize/1]). -export([onresponse_crash/1]). -export([onresponse_reply/1]). -export([pipeline/1]). -export([rest_bad_accept/1]). -export([rest_created_path/1]). -export([rest_expires/1]). -export([rest_keepalive/1]). -export([rest_keepalive_post/1]). -export([rest_missing_get_callbacks/1]). -export([rest_missing_put_callbacks/1]). -export([rest_nodelete/1]). -export([rest_patch/1]). -export([rest_resource_etags/1]). -export([rest_resource_etags_if_none_match/1]). -export([set_resp_body/1]). -export([set_resp_header/1]). -export([set_resp_overwrite/1]). -export([slowloris/1]). -export([slowloris2/1]). -export([static_attribute_etag/1]). -export([static_function_etag/1]). -export([static_mimetypes_function/1]). -export([static_specify_file/1]). -export([static_specify_file_catchall/1]). -export([static_test_file/1]). -export([static_test_file_css/1]). -export([stream_body_set_resp/1]). -export([stream_body_set_resp_close/1]). -export([te_chunked/1]). -export([te_chunked_chopped/1]). -export([te_chunked_delayed/1]). -export([te_identity/1]). %% ct. all() -> [ {group, http}, {group, https}, {group, http_compress}, {group, https_compress}, {group, onrequest}, {group, onresponse}, {group, onresponse_capitalize} ]. groups() -> Tests = [ check_raw_status, check_status, chunked_response, echo_body, error_chain_handle_after_reply, error_chain_handle_before_reply, error_handle_after_reply, error_init_after_reply, error_init_reply_handle_error, headers_dupe, http10_chunkless, http10_hostless, keepalive_max, keepalive_nl, multipart, nc_rand, nc_zero, pipeline, rest_bad_accept, rest_created_path, rest_expires, rest_keepalive, rest_keepalive_post, rest_missing_get_callbacks, rest_missing_put_callbacks, rest_nodelete, rest_patch, rest_resource_etags, rest_resource_etags_if_none_match, set_resp_body, set_resp_header, set_resp_overwrite, slowloris, slowloris2, static_attribute_etag, static_function_etag, static_mimetypes_function, static_specify_file, static_specify_file_catchall, static_test_file, static_test_file_css, stream_body_set_resp, stream_body_set_resp_close, te_chunked, te_chunked_chopped, te_chunked_delayed, te_identity ], [ {http, [], Tests}, {https, [], Tests}, {http_compress, [], Tests}, {https_compress, [], Tests}, {onrequest, [], [ onrequest, onrequest_reply ]}, {onresponse, [], [ onresponse_crash, onresponse_reply ]}, {onresponse_capitalize, [], [ onresponse_capitalize ]} ]. init_per_suite(Config) -> application:start(crypto), application:start(ranch), application:start(cowboy), Config. end_per_suite(_Config) -> application:stop(cowboy), application:stop(ranch), application:stop(crypto), ok. init_per_group(http, Config) -> Port = 33080, Transport = ranch_tcp, Config1 = init_static_dir(Config), {ok, _} = cowboy:start_http(http, 100, [{port, Port}], [ {env, [{dispatch, init_dispatch(Config1)}]}, {max_keepalive, 50}, {timeout, 500} ]), {ok, Client} = cowboy_client:init([]), [{scheme, <<"http">>}, {port, Port}, {opts, []}, {transport, Transport}, {client, Client}|Config1]; init_per_group(https, Config) -> Port = 33081, Transport = ranch_ssl, Opts = [ {certfile, ?config(data_dir, Config) ++ "cert.pem"}, {keyfile, ?config(data_dir, Config) ++ "key.pem"}, {password, "cowboy"} ], Config1 = init_static_dir(Config), application:start(public_key), application:start(ssl), {ok, _} = cowboy:start_https(https, 100, Opts ++ [{port, Port}], [ {env, [{dispatch, init_dispatch(Config1)}]}, {max_keepalive, 50}, {timeout, 500} ]), {ok, Client} = cowboy_client:init(Opts), [{scheme, <<"https">>}, {port, Port}, {opts, Opts}, {transport, Transport}, {client, Client}|Config1]; init_per_group(http_compress, Config) -> Port = 33082, Transport = ranch_tcp, Config1 = init_static_dir(Config), {ok, _} = cowboy:start_http(http_compress, 100, [{port, Port}], [ {compress, true}, {env, [{dispatch, init_dispatch(Config1)}]}, {max_keepalive, 50}, {timeout, 500} ]), {ok, Client} = cowboy_client:init([]), [{scheme, <<"http">>}, {port, Port}, {opts, []}, {transport, Transport}, {client, Client}|Config1]; init_per_group(https_compress, Config) -> Port = 33083, Transport = ranch_ssl, Opts = [ {certfile, ?config(data_dir, Config) ++ "cert.pem"}, {keyfile, ?config(data_dir, Config) ++ "key.pem"}, {password, "cowboy"} ], Config1 = init_static_dir(Config), application:start(public_key), application:start(ssl), {ok, _} = cowboy:start_https(https_compress, 100, Opts ++ [{port, Port}], [ {compress, true}, {env, [{dispatch, init_dispatch(Config1)}]}, {max_keepalive, 50}, {timeout, 500} ]), {ok, Client} = cowboy_client:init(Opts), [{scheme, <<"https">>}, {port, Port}, {opts, Opts}, {transport, Transport}, {client, Client}|Config1]; init_per_group(onrequest, Config) -> Port = 33084, Transport = ranch_tcp, {ok, _} = cowboy:start_http(onrequest, 100, [{port, Port}], [ {env, [{dispatch, init_dispatch(Config)}]}, {max_keepalive, 50}, {onrequest, fun onrequest_hook/1}, {timeout, 500} ]), {ok, Client} = cowboy_client:init([]), [{scheme, <<"http">>}, {port, Port}, {opts, []}, {transport, Transport}, {client, Client}|Config]; init_per_group(onresponse, Config) -> Port = 33085, Transport = ranch_tcp, {ok, _} = cowboy:start_http(onresponse, 100, [{port, Port}], [ {env, [{dispatch, init_dispatch(Config)}]}, {max_keepalive, 50}, {onresponse, fun onresponse_hook/4}, {timeout, 500} ]), {ok, Client} = cowboy_client:init([]), [{scheme, <<"http">>}, {port, Port}, {opts, []}, {transport, Transport}, {client, Client}|Config]; init_per_group(onresponse_capitalize, Config) -> Port = 33086, Transport = ranch_tcp, {ok, _} = cowboy:start_http(onresponse_capitalize, 100, [{port, Port}], [ {env, [{dispatch, init_dispatch(Config)}]}, {max_keepalive, 50}, {onresponse, fun onresponse_capitalize_hook/4}, {timeout, 500} ]), {ok, Client} = cowboy_client:init([]), [{scheme, <<"http">>}, {port, Port}, {opts, []}, {transport, Transport}, {client, Client}|Config]. end_per_group(Group, Config) when Group =:= https; Group =:= https_compress -> cowboy:stop_listener(https), application:stop(ssl), application:stop(public_key), end_static_dir(Config), ok; end_per_group(Group, Config) when Group =:= http; Group =:= http_compress -> cowboy:stop_listener(http), end_static_dir(Config); end_per_group(Name, _) -> cowboy:stop_listener(Name), ok. %% Dispatch configuration. init_dispatch(Config) -> cowboy_router:compile([ {"localhost", [ {"/chunked_response", chunked_handler, []}, {"/init_shutdown", http_handler_init_shutdown, []}, {"/long_polling", http_handler_long_polling, []}, {"/headers/dupe", http_handler, [{headers, [{<<"connection">>, <<"close">>}]}]}, {"/set_resp/header", http_handler_set_resp, [{headers, [{<<"vary">>, <<"Accept">>}]}]}, {"/set_resp/overwrite", http_handler_set_resp, [{headers, [{<<"server">>, <<"DesireDrive/1.0">>}]}]}, {"/set_resp/body", http_handler_set_resp, [{body, <<"A flameless dance does not equal a cycle">>}]}, {"/stream_body/set_resp", http_handler_stream_body, [{reply, set_resp}, {body, <<"stream_body_set_resp">>}]}, {"/stream_body/set_resp_close", http_handler_stream_body, [ {reply, set_resp_close}, {body, <<"stream_body_set_resp_close">>}]}, {"/static/[...]", cowboy_static, [{directory, ?config(static_dir, Config)}, {mimetypes, [{<<".css">>, [<<"text/css">>]}]}]}, {"/static_mimetypes_function/[...]", cowboy_static, [{directory, ?config(static_dir, Config)}, {mimetypes, {fun(Path, data) when is_binary(Path) -> [<<"text/html">>] end, data}}]}, {"/handler_errors", http_handler_errors, []}, {"/static_attribute_etag/[...]", cowboy_static, [{directory, ?config(static_dir, Config)}, {etag, {attributes, [filepath, filesize, inode, mtime]}}]}, {"/static_function_etag/[...]", cowboy_static, [{directory, ?config(static_dir, Config)}, {etag, {fun static_function_etag/2, etag_data}}]}, {"/static_specify_file/[...]", cowboy_static, [{directory, ?config(static_dir, Config)}, {mimetypes, [{<<".css">>, [<<"text/css">>]}]}, {file, <<"test_file.css">>}]}, {"/multipart", http_handler_multipart, []}, {"/echo/body", http_handler_echo_body, []}, {"/bad_accept", rest_simple_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, []}, {"/patch", rest_patch_resource, []}, {"/created_path", rest_created_path_resource, []}, {"/resetags", rest_resource_etags, []}, {"/rest_expires", rest_expires, []}, {"/loop_timeout", http_handler_loop_timeout, []}, {"/", http_handler, []} ]} ]). init_static_dir(Config) -> Dir = filename:join(?config(priv_dir, Config), "static"), Level1 = fun(Name) -> filename:join(Dir, Name) end, ok = file:make_dir(Dir), ok = file:write_file(Level1("test_file"), "test_file\n"), ok = file:write_file(Level1("test_file.css"), "test_file.css\n"), ok = file:write_file(Level1("test_noread"), "test_noread\n"), ok = file:change_mode(Level1("test_noread"), 8#0333), ok = file:write_file(Level1("test.html"), "test.html\n"), ok = file:make_dir(Level1("test_dir")), [{static_dir, Dir}|Config]. end_static_dir(Config) -> Dir = ?config(static_dir, Config), Level1 = fun(Name) -> filename:join(Dir, Name) end, ok = file:delete(Level1("test_file")), ok = file:delete(Level1("test_file.css")), ok = file:delete(Level1("test_noread")), ok = file:delete(Level1("test.html")), ok = file:del_dir(Level1("test_dir")), ok = file:del_dir(Dir), Config. %% Convenience functions. quick_raw(Data, Config) -> Client = ?config(client, Config), Transport = ?config(transport, Config), {ok, Client2} = cowboy_client:connect( Transport, "localhost", ?config(port, Config), Client), {ok, Client3} = cowboy_client:raw_request(Data, Client2), case cowboy_client:response(Client3) of {ok, Status, _, _} -> Status; {error, _} -> closed end. build_url(Path, Config) -> {scheme, Scheme} = lists:keyfind(scheme, 1, Config), {port, Port} = lists:keyfind(port, 1, Config), PortBin = list_to_binary(integer_to_list(Port)), PathBin = list_to_binary(Path), << Scheme/binary, "://localhost:", PortBin/binary, PathBin/binary >>. quick_get(URL, Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url(URL, Config), Client), {ok, Status, _, _} = cowboy_client:response(Client2), Status. body_to_chunks(_, <<>>, Acc) -> lists:reverse([<<"0\r\n\r\n">>|Acc]); 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 = list_to_binary(integer_to_list(ChunkSize2, 16)), body_to_chunks(ChunkSize, Rest, [<< ChunkSizeBin/binary, "\r\n", Chunk/binary, "\r\n" >>|Acc]). %% 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 302 Moved

302 Moved

The document has moved here. ", 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, "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"}, {505, 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"}, {414, Huge}, {400, "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 = quick_raw(Packet, Config), {Ret, Packet} end || {Status, Packet} <- Tests]. check_status(Config) -> Tests = [ {102, "/long_polling"}, {200, "/"}, {200, "/simple"}, {204, "/loop_timeout"}, {400, "/static/%2f"}, {400, "/static/%2e"}, {400, "/static/%2e%2e"}, {403, "/static/test_dir"}, {403, "/static/test_dir/"}, {403, "/static/test_noread"}, {404, "/not/found"}, {404, "/static/not_found"}, {500, "/handler_errors?case=handler_before_reply"}, {500, "/handler_errors?case=init_before_reply"}, {666, "/init_shutdown"} ], _ = [{Status, URL} = begin Ret = quick_get(URL, Config), {Ret, URL} end || {Status, URL} <- Tests]. chunked_response(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/chunked_response", Config), Client), {ok, 200, Headers, Client3} = cowboy_client:response(Client2), true = lists:keymember(<<"transfer-encoding">>, 1, Headers), {ok, Transport, Socket} = cowboy_client:transport(Client3), {ok, <<"11\r\nchunked_handler\r\n\r\nB\r\nworks fine!\r\n0\r\n\r\n">>} = Transport:recv(Socket, 44, 1000), {error, closed} = cowboy_client:response(Client3). %% Check if sending requests whose size is around the MTU breaks something. echo_body(Config) -> Client = ?config(client, Config), {ok, [{mtu, MTU}]} = inet:ifget("lo", [mtu]), [begin Body = list_to_binary(lists:duplicate(Size, $a)), {ok, Client2} = cowboy_client:request(<<"POST">>, build_url("/echo/body", Config), [{<<"connection">>, <<"close">>}], Body, Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, Body, _} = cowboy_client:response_body(Client3) end || Size <- lists:seq(MTU - 500, MTU)]. error_chain_handle_after_reply(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client), {ok, Client3} = cowboy_client:request(<<"GET">>, build_url("/handler_errors?case=handle_after_reply", Config), Client2), {ok, 200, _, Client4} = cowboy_client:response(Client3), {ok, 200, _, Client5} = cowboy_client:response(Client4), {error, closed} = cowboy_client:response(Client5). error_chain_handle_before_reply(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client), {ok, Client3} = cowboy_client:request(<<"GET">>, build_url("/handler_errors?case=handle_before_reply", Config), Client2), {ok, 200, _, Client4} = cowboy_client:response(Client3), {ok, 500, _, Client5} = cowboy_client:response(Client4), {error, closed} = cowboy_client:response(Client5). error_handle_after_reply(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/handler_errors?case=handle_after_reply", Config), Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {error, closed} = cowboy_client:response(Client3). error_init_after_reply(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/handler_errors?case=init_after_reply", Config), Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {error, closed} = cowboy_client:response(Client3). error_init_reply_handle_error(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/handler_errors?case=init_reply_handle_error", Config), Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {error, closed} = cowboy_client:response(Client3). headers_dupe(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/headers/dupe", Config), Client), {ok, 200, Headers, Client3} = cowboy_client:response(Client2), {<<"connection">>, <<"close">>} = lists:keyfind(<<"connection">>, 1, Headers), Connections = [H || H = {Name, _} <- Headers, Name =:= <<"connection">>], 1 = length(Connections), {error, closed} = cowboy_client:response(Client3). http10_chunkless(Config) -> Client = ?config(client, Config), Transport = ?config(transport, Config), {ok, Client2} = cowboy_client:connect( Transport, "localhost", ?config(port, Config), Client), Data = "GET /chunked_response HTTP/1.0\r\nHost: localhost\r\n\r\n", {ok, Client3} = cowboy_client:raw_request(Data, Client2), {ok, 200, Headers, Client4} = cowboy_client:response(Client3), false = lists:keyfind(<<"transfer-encoding">>, 1, Headers), %% Hack: we just try to get 28 bytes and compare. {ok, Transport, Socket} = cowboy_client:transport(Client4), Buffer = element(7, Client4), Buffer2 = case Transport:recv(Socket, 28 - byte_size(Buffer), 1000) of {ok, Recv} -> << Buffer/binary, Recv/binary >>; _ -> Buffer end, <<"chunked_handler\r\nworks fine!">> = Buffer2. http10_hostless(Config) -> Port10 = ?config(port, Config) + 10, Name = list_to_atom("http10_hostless_" ++ integer_to_list(Port10)), ranch:start_listener(Name, 5, ?config(transport, Config), ?config(opts, Config) ++ [{port, Port10}], cowboy_protocol, [ {env, [{dispatch, cowboy_router:compile([ {'_', [{"/http1.0/hostless", http_handler, []}]}])}]}, {max_keepalive, 50}, {timeout, 500}] ), 200 = quick_raw("GET /http1.0/hostless HTTP/1.0\r\n\r\n", [{port, Port10}|Config]), cowboy:stop_listener(http10). keepalive_max(Config) -> Client = ?config(client, Config), URL = build_url("/", Config), ok = keepalive_max_loop(Client, URL, 50). keepalive_max_loop(Client, _, 0) -> {error, closed} = cowboy_client:response(Client), ok; keepalive_max_loop(Client, URL, N) -> Headers = [{<<"connection">>, <<"keep-alive">>}], {ok, Client2} = cowboy_client:request(<<"GET">>, URL, Headers, Client), {ok, 200, RespHeaders, Client3} = cowboy_client:response(Client2), Expected = case N of 1 -> <<"close">>; N -> <<"keep-alive">> end, {<<"connection">>, Expected} = lists:keyfind(<<"connection">>, 1, RespHeaders), keepalive_max_loop(Client3, URL, N - 1). keepalive_nl(Config) -> Client = ?config(client, Config), URL = build_url("/", Config), ok = keepalive_nl_loop(Client, URL, 10). keepalive_nl_loop(Client, _, 0) -> {error, closed} = cowboy_client:response(Client), ok; keepalive_nl_loop(Client, URL, N) -> Headers = [{<<"connection">>, <<"keep-alive">>}], {ok, Client2} = cowboy_client:request(<<"GET">>, URL, Headers, Client), {ok, 200, RespHeaders, Client3} = cowboy_client:response(Client2), {<<"connection">>, <<"keep-alive">>} = lists:keyfind(<<"connection">>, 1, RespHeaders), {ok, Transport, Socket} = cowboy_client:transport(Client2), ok = Transport:send(Socket, <<"\r\n">>), %% empty line keepalive_nl_loop(Client3, URL, N - 1). multipart(Config) -> Client = ?config(client, Config), Body = << "This is a preamble." "\r\n--OHai\r\nX-Name:answer\r\n\r\n42" "\r\n--OHai\r\nServer:Cowboy\r\n\r\nIt rocks!\r\n" "\r\n--OHai--" "This is an epiloque." >>, {ok, Client2} = cowboy_client:request(<<"POST">>, build_url("/multipart", Config), [{<<"content-type">>, <<"multipart/x-makes-no-sense; boundary=OHai">>}], Body, Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, RespBody, _} = cowboy_client:response_body(Client3), Parts = binary_to_term(RespBody), Parts = [ {[{<<"x-name">>, <<"answer">>}], <<"42">>}, {[{<<"server">>, <<"Cowboy">>}], <<"It rocks!\r\n">>} ]. nc_reqs(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. {port, Port} = lists:keyfind(port, 1, Config), StrPort = integer_to_list(Port), [os:cmd("cat " ++ Input ++ " | nc localhost " ++ StrPort) || _ <- lists:seq(1, 100)], 200 = quick_get("/", Config) end. nc_rand(Config) -> nc_reqs(Config, "/dev/urandom"). nc_zero(Config) -> nc_reqs(Config, "/dev/zero"). onrequest(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client), {ok, 200, Headers, Client3} = cowboy_client:response(Client2), {<<"server">>, <<"Serenity">>} = lists:keyfind(<<"server">>, 1, Headers), {ok, <<"http_handler">>, _} = cowboy_client:response_body(Client3). onrequest_reply(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/?reply=1", Config), Client), {ok, 200, Headers, Client3} = cowboy_client:response(Client2), {<<"server">>, <<"Cowboy">>} = lists:keyfind(<<"server">>, 1, Headers), {ok, <<"replied!">>, _} = cowboy_client:response_body(Client3). %% Hook for the above onrequest tests. onrequest_hook(Req) -> case cowboy_req:qs_val(<<"reply">>, Req) of {undefined, Req2} -> cowboy_req:set_resp_header(<<"server">>, <<"Serenity">>, Req2); {_, Req2} -> {ok, Req3} = cowboy_req:reply( 200, [], <<"replied!">>, Req2), Req3 end. onresponse_capitalize(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client), {ok, Transport, Socket} = cowboy_client:transport(Client2), {ok, Data} = Transport:recv(Socket, 0, 1000), false = nomatch =:= binary:match(Data, <<"Content-Length">>). %% Hook for the above onresponse_capitalize test. onresponse_capitalize_hook(Status, Headers, Body, Req) -> Headers2 = [{cowboy_bstr:capitalize_token(N), V} || {N, V} <- Headers], {ok, Req2} = cowboy_req:reply(Status, Headers2, Body, Req), Req2. onresponse_crash(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/handler_errors?case=init_before_reply", Config), Client), {ok, 777, Headers, _} = cowboy_client:response(Client2), {<<"x-hook">>, <<"onresponse">>} = lists:keyfind(<<"x-hook">>, 1, Headers). onresponse_reply(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client), {ok, 777, Headers, Client3} = cowboy_client:response(Client2), {<<"x-hook">>, <<"onresponse">>} = lists:keyfind(<<"x-hook">>, 1, Headers), %% Make sure we don't get the body initially sent. {error, closed} = cowboy_client:response_body(Client3). %% Hook for the above onresponse tests. onresponse_hook(_, Headers, _, Req) -> {ok, Req2} = cowboy_req:reply( <<"777 Lucky">>, [{<<"x-hook">>, <<"onresponse">>}|Headers], Req), Req2. pipeline(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client), {ok, Client3} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client2), {ok, Client4} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client3), {ok, Client5} = cowboy_client:request(<<"GET">>, build_url("/", Config), Client4), {ok, Client6} = cowboy_client:request(<<"GET">>, build_url("/", Config), [{<<"connection">>, <<"close">>}], Client5), {ok, 200, _, Client7} = cowboy_client:response(Client6), {ok, 200, _, Client8} = cowboy_client:response(Client7), {ok, 200, _, Client9} = cowboy_client:response(Client8), {ok, 200, _, Client10} = cowboy_client:response(Client9), {ok, 200, _, Client11} = cowboy_client:response(Client10), {error, closed} = cowboy_client:response(Client11). rest_bad_accept(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/bad_accept", Config), [{<<"accept">>, <<"1">>}], Client), {ok, 400, _, _} = cowboy_client:response(Client2). rest_created_path(Config) -> Headers = [{<<"content-type">>, <<"text/plain">>}], Body = <<"Whatever">>, Client = ?config(client, Config), URL = build_url("/created_path", Config), {ok, Client2} = cowboy_client:request(<<"POST">>, URL, Headers, Body, Client), {ok, 303, ResHeaders, _} = cowboy_client:response(Client2), {<<"location">>, _Location} = lists:keyfind(<<"location">>, 1, ResHeaders), ok. rest_expires(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/rest_expires", Config), Client), {ok, 200, RespHeaders, _} = cowboy_client:response(Client2), {_, Expires} = lists:keyfind(<<"expires">>, 1, RespHeaders), {_, LastModified} = lists:keyfind(<<"last-modified">>, 1, RespHeaders), Expires = LastModified = <<"Fri, 21 Sep 2012 22:36:14 GMT">>, ok. rest_keepalive(Config) -> Client = ?config(client, Config), URL = build_url("/simple", Config), ok = rest_keepalive_loop(Client, URL, 10). rest_keepalive_loop(_, _, 0) -> ok; rest_keepalive_loop(Client, URL, N) -> Headers = [{<<"connection">>, <<"keep-alive">>}], {ok, Client2} = cowboy_client:request(<<"GET">>, URL, Headers, Client), {ok, 200, RespHeaders, Client3} = cowboy_client:response(Client2), {<<"connection">>, <<"keep-alive">>} = lists:keyfind(<<"connection">>, 1, RespHeaders), rest_keepalive_loop(Client3, URL, N - 1). rest_keepalive_post(Config) -> Client = ?config(client, Config), ok = rest_keepalive_post_loop(Config, Client, forbidden_post, 10). rest_keepalive_post_loop(_, _, _, 0) -> ok; rest_keepalive_post_loop(Config, Client, simple_post, N) -> Headers = [ {<<"connection">>, <<"keep-alive">>}, {<<"content-type">>, <<"text/plain">>} ], {ok, Client2} = cowboy_client:request(<<"POST">>, build_url("/simple_post", Config), Headers, "12345", Client), {ok, 303, RespHeaders, Client3} = cowboy_client:response(Client2), {<<"connection">>, <<"keep-alive">>} = lists:keyfind(<<"connection">>, 1, RespHeaders), rest_keepalive_post_loop(Config, Client3, forbidden_post, N - 1); rest_keepalive_post_loop(Config, Client, forbidden_post, N) -> Headers = [ {<<"connection">>, <<"keep-alive">>}, {<<"content-type">>, <<"text/plain">>} ], {ok, Client2} = cowboy_client:request(<<"POST">>, build_url("/forbidden_post", Config), Headers, "12345", Client), {ok, 403, RespHeaders, Client3} = cowboy_client:response(Client2), {<<"connection">>, <<"keep-alive">>} = lists:keyfind(<<"connection">>, 1, RespHeaders), rest_keepalive_post_loop(Config, Client3, simple_post, N - 1). rest_missing_get_callbacks(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/missing_get_callbacks", Config), Client), {ok, 500, _, _} = cowboy_client:response(Client2). rest_missing_put_callbacks(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"PUT">>, build_url("/missing_put_callbacks", Config), [{<<"content-type">>, <<"application/json">>}], <<"{}">>, Client), {ok, 500, _, _} = cowboy_client:response(Client2). rest_nodelete(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"DELETE">>, build_url("/nodelete", Config), Client), {ok, 500, _, _} = cowboy_client:response(Client2). rest_patch(Config) -> Tests = [ {204, [{<<"content-type">>, <<"text/plain">>}], <<"whatever">>}, {422, [{<<"content-type">>, <<"text/plain">>}], <<"false">>}, {400, [{<<"content-type">>, <<"text/plain">>}], <<"halt">>}, {415, [{<<"content-type">>, <<"application/json">>}], <<"bad_content_type">>} ], Client = ?config(client, Config), _ = [begin {ok, Client2} = cowboy_client:request(<<"PATCH">>, build_url("/patch", Config), Headers, Body, Client), {ok, Status, _, _} = cowboy_client:response(Client2), ok end || {Status, Headers, Body} <- Tests]. rest_resource_get_etag(Config, Type) -> rest_resource_get_etag(Config, Type, []). rest_resource_get_etag(Config, Type, Headers) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/resetags?type=" ++ Type, Config), Headers, Client), {ok, Status, RespHeaders, _} = cowboy_client:response(Client2), 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_resp_body(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/set_resp/body", Config), Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, <<"A flameless dance does not equal a cycle">>, _} = cowboy_client:response_body(Client3). set_resp_header(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/set_resp/header", Config), Client), {ok, 200, Headers, _} = cowboy_client:response(Client2), {<<"vary">>, <<"Accept">>} = lists:keyfind(<<"vary">>, 1, Headers), {<<"set-cookie">>, _} = lists:keyfind(<<"set-cookie">>, 1, Headers). set_resp_overwrite(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/set_resp/overwrite", Config), Client), {ok, 200, Headers, _} = cowboy_client:response(Client2), {<<"server">>, <<"DesireDrive/1.0">>} = lists:keyfind(<<"server">>, 1, Headers). slowloris(Config) -> Client = ?config(client, Config), Transport = ?config(transport, Config), {ok, Client2} = cowboy_client:connect( Transport, "localhost", ?config(port, Config), Client), try [begin {ok, _} = cowboy_client:raw_request([C], Client2), receive after 25 -> 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 = ?config(client, Config), Transport = ?config(transport, Config), {ok, Client2} = cowboy_client:connect( Transport, "localhost", ?config(port, Config), Client), {ok, _} = cowboy_client:raw_request("GET / HTTP/1.1\r\n", Client2), receive after 300 -> ok end, {ok, _} = cowboy_client:raw_request("Host: localhost\r\n", Client2), receive after 300 -> ok end, {ok, 408, _, _} = cowboy_client:response(Client2). static_attribute_etag(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/static_attribute_etag/test.html", Config), Client), {ok, Client3} = cowboy_client:request(<<"GET">>, build_url("/static_attribute_etag/test.html", Config), Client2), {ok, 200, Headers1, Client4} = cowboy_client:response(Client3), {ok, 200, Headers2, _} = cowboy_client:response(Client4), {<<"etag">>, ETag1} = lists:keyfind(<<"etag">>, 1, Headers1), {<<"etag">>, ETag2} = lists:keyfind(<<"etag">>, 1, Headers2), false = ETag1 =:= undefined, ETag1 = ETag2. static_function_etag(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/static_function_etag/test.html", Config), Client), {ok, Client3} = cowboy_client:request(<<"GET">>, build_url("/static_function_etag/test.html", Config), Client2), {ok, 200, Headers1, Client4} = cowboy_client:response(Client3), {ok, 200, Headers2, _} = cowboy_client:response(Client4), {<<"etag">>, ETag1} = lists:keyfind(<<"etag">>, 1, Headers1), {<<"etag">>, ETag2} = lists:keyfind(<<"etag">>, 1, Headers2), false = ETag1 =:= undefined, ETag1 = ETag2. %% Callback function for generating the ETag for the above test. static_function_etag(Arguments, etag_data) -> {_, Filepath} = lists:keyfind(filepath, 1, Arguments), {_, _Filesize} = lists:keyfind(filesize, 1, Arguments), {_, _INode} = lists:keyfind(inode, 1, Arguments), {_, _Modified} = lists:keyfind(mtime, 1, Arguments), ChecksumCommand = lists:flatten(io_lib:format("sha1sum ~s", [Filepath])), [Checksum|_] = string:tokens(os:cmd(ChecksumCommand), " "), {strong, iolist_to_binary(Checksum)}. static_mimetypes_function(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/static_mimetypes_function/test.html", Config), Client), {ok, 200, Headers, _} = cowboy_client:response(Client2), {<<"content-type">>, <<"text/html">>} = lists:keyfind(<<"content-type">>, 1, Headers). static_specify_file(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/static_specify_file", Config), Client), {ok, 200, Headers, Client3} = cowboy_client:response(Client2), {<<"content-type">>, <<"text/css">>} = lists:keyfind(<<"content-type">>, 1, Headers), {ok, <<"test_file.css\n">>, _} = cowboy_client:response_body(Client3). static_specify_file_catchall(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/static_specify_file/none", Config), Client), {ok, 200, Headers, Client3} = cowboy_client:response(Client2), {<<"content-type">>, <<"text/css">>} = lists:keyfind(<<"content-type">>, 1, Headers), {ok, <<"test_file.css\n">>, _} = cowboy_client:response_body(Client3). static_test_file(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/static/test_file", Config), Client), {ok, 200, Headers, _} = cowboy_client:response(Client2), {<<"content-type">>, <<"application/octet-stream">>} = lists:keyfind(<<"content-type">>, 1, Headers). static_test_file_css(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/static/test_file.css", Config), Client), {ok, 200, Headers, _} = cowboy_client:response(Client2), {<<"content-type">>, <<"text/css">>} = lists:keyfind(<<"content-type">>, 1, Headers). stream_body_set_resp(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/stream_body/set_resp", Config), Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, <<"stream_body_set_resp">>, _} = cowboy_client:response_body(Client3). stream_body_set_resp_close(Config) -> Client = ?config(client, Config), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/stream_body/set_resp_close", Config), Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, Transport, Socket} = cowboy_client:transport(Client3), case element(7, Client3) of <<"stream_body_set_resp_close">> -> ok; Buffer -> {ok, Rest} = Transport:recv(Socket, 26 - byte_size(Buffer), 1000), <<"stream_body_set_resp_close">> = << Buffer/binary, Rest/binary >>, ok end, {error, closed} = Transport:recv(Socket, 0, 1000). te_chunked(Config) -> Client = ?config(client, Config), Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), Chunks = body_to_chunks(50, Body, []), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/echo/body", Config), [{<<"transfer-encoding">>, <<"chunked">>}], Chunks, Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, Body, _} = cowboy_client:response_body(Client3). te_chunked_chopped(Config) -> Client = ?config(client, Config), Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), Body2 = iolist_to_binary(body_to_chunks(50, Body, [])), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/echo/body", Config), [{<<"transfer-encoding">>, <<"chunked">>}], Client), {ok, Transport, Socket} = cowboy_client:transport(Client2), _ = [begin ok = Transport:send(Socket, << C >>), ok = timer:sleep(10) end || << C >> <= Body2], {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, Body, _} = cowboy_client:response_body(Client3). te_chunked_delayed(Config) -> Client = ?config(client, Config), Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), Chunks = body_to_chunks(50, Body, []), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/echo/body", Config), [{<<"transfer-encoding">>, <<"chunked">>}], Client), {ok, Transport, Socket} = cowboy_client:transport(Client2), _ = [begin ok = Transport:send(Socket, Chunk), ok = timer:sleep(10) end || Chunk <- Chunks], {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, Body, _} = cowboy_client:response_body(Client3). te_identity(Config) -> Client = ?config(client, Config), Body = list_to_binary(io_lib:format("~p", [lists:seq(1, 100)])), {ok, Client2} = cowboy_client:request(<<"GET">>, build_url("/echo/body", Config), [], Body, Client), {ok, 200, _, Client3} = cowboy_client:response(Client2), {ok, Body, _} = cowboy_client:response_body(Client3).