123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804 |
- -module(rfc7540_SUITE).
- -compile(export_all).
- -import(ct_helper, [config/2]).
- -import(ct_helper, [doc/1]).
- -import(cowboy_test, [raw_open/1]).
- -import(cowboy_test, [raw_send/2]).
- -import(cowboy_test, [raw_recv_head/1]).
- -import(cowboy_test, [raw_recv/3]).
- all() -> [{group, clear}, {group, tls}].
- groups() ->
- Modules = ct_helper:all(?MODULE),
- Clear = [M || M <- Modules, lists:sublist(atom_to_list(M), 4) =/= "alpn"] -- [prior_knowledge_reject_tls],
- TLS = [M || M <- Modules, lists:sublist(atom_to_list(M), 4) =:= "alpn"] ++ [prior_knowledge_reject_tls],
- [{clear, [parallel], Clear}, {tls, [parallel], TLS}].
- init_per_group(Name = clear, Config) ->
- cowboy_test:init_http(Name = clear, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config))}
- }, Config);
- init_per_group(Name = tls, Config) ->
- cowboy_test:init_http2(Name = tls, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config))}
- }, Config).
- end_per_group(Name, _) ->
- ok = cowboy:stop_listener(Name).
- init_routes(_) -> [
- {"localhost", [
- {"/", hello_h, []}
- ]}
- ].
- http_upgrade_ignore_h2(Config) ->
- doc("An h2 token in an Upgrade field must be ignored. (RFC7540 3.2)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- {ok, <<"HTTP/1.1 200">>} = gen_tcp:recv(Socket, 12, 1000),
- ok.
- http_upgrade_ignore_if_http_10(Config) ->
- doc("The Upgrade header must be ignored if part of an HTTP/1.0 request. (RFC7230 6.7)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.0\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- {ok, <<"HTTP/1.1 200">>} = gen_tcp:recv(Socket, 12, 1000),
- ok.
- http_upgrade_ignore_missing_upgrade_in_connection(Config) ->
- doc("The Upgrade header must be listed in the "
- "Connection header field. (RFC7230 6.7)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- {ok, <<"HTTP/1.1 200">>} = gen_tcp:recv(Socket, 12, 1000),
- ok.
- http_upgrade_ignore_missing_http2_settings_in_connection(Config) ->
- doc("The HTTP2-Settings header must be listed in the "
- "Connection header field. (RFC7540 3.2.1, RFC7230 6.7)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- {ok, <<"HTTP/1.1 200">>} = gen_tcp:recv(Socket, 12, 1000),
- ok.
- http_upgrade_ignore_zero_http2_settings_header(Config) ->
- doc("The HTTP Upgrade request must include "
- "exactly one HTTP2-Settings header field (RFC7540 3.2, RFC7540 3.2.1)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "\r\n"]),
- {ok, <<"HTTP/1.1 200">>} = gen_tcp:recv(Socket, 12, 1000),
- ok.
- http_upgrade_reject_two_http2_settings_header(Config) ->
- doc("The HTTP Upgrade request must include "
- "exactly one HTTP2-Settings header field (RFC7540 3.2, RFC7540 3.2.1)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- {ok, <<"HTTP/1.1 400">>} = gen_tcp:recv(Socket, 12, 1000),
- ok.
- http_upgrade_reject_bad_http2_settings_header(Config) ->
- doc("The HTTP Upgrade request must include "
- "a valid HTTP2-Settings header field (RFC7540 3.2, RFC7540 3.2.1)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
-
- "HTTP2-Settings: ", base64:encode(cow_http2:settings(#{})), "\r\n",
- "\r\n"]),
- {ok, <<"HTTP/1.1 400">>} = gen_tcp:recv(Socket, 12, 1000),
- ok.
- do_recv_101(Socket) ->
- {ok, <<
- "HTTP/1.1 101 Switching Protocols\r\n"
- "connection: Upgrade\r\n"
- "upgrade: h2c\r\n"
- "\r\n"
- >>} = gen_tcp:recv(Socket, 71, 1000),
- ok.
- http_upgrade_101(Config) ->
- doc("A 101 response must be sent on successful upgrade "
- "to HTTP/2 when using the HTTP Upgrade mechanism. (RFC7540 3.2, RFC7230 6.7)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
- ok.
- http_upgrade_server_preface(Config) ->
- doc("The first frame after the upgrade must be a "
- "SETTINGS frame for the server connection preface. (RFC7540 3.2, RFC7540 3.5, RFC7540 6.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- {ok, << _:24, 4:8, 0:40 >>} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- http_upgrade_client_preface_timeout(Config) ->
- doc("Clients negotiating HTTP/2 and not sending a preface in "
- "a timely manner must be disconnected."),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {ok, << HeadersSkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, HeadersSkipLen, 1000),
- {ok, << DataSkipLen:24, 0:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, DataSkipLen, 1000),
-
- {error, closed} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- http_upgrade_reject_missing_client_preface(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.2, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{})),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
-
-
- Received = lists:reverse(lists:foldl(fun(_, Acc) ->
- case gen_tcp:recv(Socket, 9, 1000) of
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [headers|Acc];
- {ok, << SkipLen:24, 0:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [data|Acc];
- {error, _} ->
- [closed|Acc]
- end
- end, [], [1, 2, 3])),
- case Received of
- [closed|_] -> ok;
- [headers, closed|_] -> ok;
- [headers, data, closed] -> ok
- end.
- http_upgrade_reject_invalid_client_preface(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.2, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- ok = gen_tcp:send(Socket, "PRI * HTTP/2.0\r\n\r\nSM: Value\r\n\r\n"),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
-
-
- Received = lists:reverse(lists:foldl(fun(_, Acc) ->
- case gen_tcp:recv(Socket, 9, 1000) of
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [headers|Acc];
- {ok, << SkipLen:24, 0:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [data|Acc];
- {error, _} ->
- [closed|Acc]
- end
- end, [], [1, 2, 3])),
- case Received of
- [closed|_] -> ok;
- [headers, closed|_] -> ok;
- [headers, data, closed] -> ok
- end.
- http_upgrade_reject_missing_client_preface_settings(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.2, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:ping(0)]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
-
-
- Received = lists:reverse(lists:foldl(fun(_, Acc) ->
- case gen_tcp:recv(Socket, 9, 1000) of
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [headers|Acc];
- {ok, << SkipLen:24, 0:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [data|Acc];
- {error, _} ->
- [closed|Acc]
- end
- end, [], [1, 2, 3])),
- case Received of
- [closed|_] -> ok;
- [headers, closed|_] -> ok;
- [headers, data, closed] -> ok
- end.
- http_upgrade_reject_invalid_client_preface_settings(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.2, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", << 0:24, 4:8, 0:9, 1:31 >>]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
-
-
- Received = lists:reverse(lists:foldl(fun(_, Acc) ->
- case gen_tcp:recv(Socket, 9, 1000) of
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [headers|Acc];
- {ok, << SkipLen:24, 0:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [data|Acc];
- {error, _} ->
- [closed|Acc]
- end
- end, [], [1, 2, 3])),
- case Received of
- [closed|_] -> ok;
- [headers, closed|_] -> ok;
- [headers, data, closed] -> ok
- end.
- http_upgrade_accept_client_preface_empty_settings(Config) ->
- doc("The SETTINGS frame in the client preface may be empty. (RFC7540 3.2, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- http_upgrade_client_preface_settings_ack_timeout(Config) ->
- doc("The SETTINGS frames sent by the client must be acknowledged. (RFC7540 3.5, RFC7540 6.5.3)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {ok, << _:24, 7:8, _:72, 4:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- http_upgrade_response(Config) ->
- doc("A response must be sent to the initial HTTP/1.1 request "
- "after switching to HTTP/2. The response must use "
- "the stream identifier 1. (RFC7540 3.2)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings_ack()),
-
- Received = lists:reverse(lists:foldl(fun(_, Acc) ->
- case gen_tcp:recv(Socket, 9, 1000) of
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} ->
- [settings_ack|Acc];
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [headers|Acc];
- {ok, << SkipLen:24, 0:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [data|Acc]
- end
- end, [], [1, 2, 3])),
- case Received of
- [settings_ack, headers, data] -> ok;
- [headers, settings_ack, data] -> ok;
- [headers, data, settings_ack] -> ok
- end.
- http_upgrade_response_half_closed(Config) ->
- doc("The stream for the initial HTTP/1.1 request is half-closed. (RFC7540 3.2)"),
-
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
- ok = gen_tcp:send(Socket, [
- "GET / HTTP/1.1\r\n"
- "Host: localhost\r\n"
- "Connection: Upgrade, HTTP2-Settings\r\n"
- "Upgrade: h2c\r\n"
- "HTTP2-Settings: ", base64:encode(cow_http2:settings_payload(#{})), "\r\n",
- "\r\n"]),
- ok = do_recv_101(Socket),
-
- ok = gen_tcp:send(Socket, [
- "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n",
- cow_http2:settings(#{}),
- cow_http2:data(1, fin, <<"Unexpected DATA frame.">>)
- ]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- Received = lists:reverse(lists:foldl(fun(_, Acc) ->
- case gen_tcp:recv(Socket, 9, 1000) of
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} ->
- Acc;
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [headers|Acc];
- {ok, << SkipLen:24, 0:8, _:8, 1:32 >>} ->
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- [data|Acc];
- {ok, << 4:24, 3:8, 0:8, 1:32 >>} ->
-
- {ok, << 5:32 >>} = gen_tcp:recv(Socket, 4, 1000),
- [rst_stream|Acc];
- {error, _} ->
-
- Acc
- end
- end, [], [1, 2, 3, 4])),
- case Received of
- [rst_stream] -> ok;
- [headers, rst_stream] -> ok;
- [headers, data, rst_stream] -> ok
- end.
- alpn_ignore_h2c(Config) ->
- doc("An h2c ALPN protocol identifier must be ignored. (RFC7540 3.3)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2c">>, <<"http/1.1">>]}, binary, {active, false}]),
- {ok, <<"http/1.1">>} = ssl:negotiated_protocol(Socket),
- ok.
- alpn_server_preface(Config) ->
- doc("The first frame must be a SETTINGS frame "
- "for the server connection preface. (RFC7540 3.3, RFC7540 3.5, RFC7540 6.5)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- {ok, << _:24, 4:8, 0:40 >>} = ssl:recv(Socket, 9, 1000),
- ok.
- alpn_client_preface_timeout(Config) ->
- doc("Clients negotiating HTTP/2 and not sending a preface in "
- "a timely manner must be disconnected."),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = ssl:recv(Socket, 3, 6000),
- ok.
- alpn_reject_missing_client_preface(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.3, RFC7540 3.5)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- ok = ssl:send(Socket, cow_http2:settings(#{})),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = ssl:recv(Socket, 3, 1000),
- ok.
- alpn_reject_invalid_client_preface(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.3, RFC7540 3.5)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- ok = ssl:send(Socket, "PRI * HTTP/2.0\r\n\r\nSM: Value\r\n\r\n"),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = ssl:recv(Socket, 3, 1000),
- ok.
- alpn_reject_missing_client_preface_settings(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.3, RFC7540 3.5)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- ok = ssl:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:ping(0)]),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = ssl:recv(Socket, 3, 1000),
- ok.
- alpn_reject_invalid_client_preface_settings(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.3, RFC7540 3.5)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- ok = ssl:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", << 0:24, 4:8, 0:9, 1:31 >>]),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = ssl:recv(Socket, 3, 1000),
- ok.
- alpn_accept_client_preface_empty_settings(Config) ->
- doc("The SETTINGS frame in the client preface may be empty. (RFC7540 3.3, RFC7540 3.5)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- ok = ssl:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = ssl:recv(Socket, 9, 1000),
- ok.
- alpn_client_preface_settings_ack_timeout(Config) ->
- doc("Failure to acknowledge the server's SETTINGS frame "
- "results in a SETTINGS_TIMEOUT connection error. (RFC7540 3.5, RFC7540 6.5.3)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
- ok = ssl:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = ssl:recv(Socket, 9, 1000),
-
- {ok, << _:24, 7:8, _:72, 4:32 >>} = ssl:recv(Socket, 17, 6000),
- ok.
- alpn(Config) ->
- doc("Successful ALPN negotiation. (RFC7540 3.3)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]}, binary, {active, false}]),
- {ok, <<"h2">>} = ssl:negotiated_protocol(Socket),
-
-
- ok = ssl:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = ssl:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = ssl:recv(Socket, 6 + Len, 1000),
-
- ok = ssl:send(Socket, cow_http2:settings_ack()),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = ssl:recv(Socket, 9, 1000),
-
- receive after 6000 -> ok end,
-
- ok = ssl:send(Socket, cow_http2:ping(0)),
-
- {ok, << 8:24, 6:8, 0:7, 1:1, 0:96 >>} = ssl:recv(Socket, 17, 1000),
- ok.
- prior_knowledge_reject_tls(Config) ->
- doc("Implementations that support HTTP/2 over TLS must use ALPN. (RFC7540 3.4)"),
- {ok, Socket} = ssl:connect("localhost", config(port, Config), [binary, {active, false}]),
-
- ok = ssl:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
-
- {ok, <<"HTTP/1.1 400">>} = ssl:recv(Socket, 12, 1000),
- ok.
- prior_knowledge_server_preface(Config) ->
- doc("The first frame must be a SETTINGS frame "
- "for the server connection preface. (RFC7540 3.4, RFC7540 3.5, RFC7540 6.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << _:24, 4:8, 0:40 >>} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- prior_knowledge_reject_invalid_client_preface(Config) ->
- doc("An incorrect preface is an invalid HTTP/1.1 request. (RFC7540 3.4)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
-
- ok = gen_tcp:send(Socket, "PRI * HTTP/2.0\r\n\r\nSM: Value\r\n\r\n"),
-
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- prior_knowledge_reject_missing_client_preface_settings(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.4, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:ping(0)]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- prior_knowledge_reject_invalid_client_preface_settings(Config) ->
- doc("Servers must treat an invalid connection preface as a "
- "connection error of type PROTOCOL_ERROR. (RFC7540 3.4, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", << 0:24, 4:8, 0:9, 1:31 >>]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {error, closed} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- prior_knowledge_accept_client_preface_empty_settings(Config) ->
- doc("The SETTINGS frame in the client preface may be empty. (RFC7540 3.4, RFC7540 3.5)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- prior_knowledge_client_preface_settings_ack_timeout(Config) ->
- doc("The SETTINGS frames sent by the client must be acknowledged. (RFC7540 3.5, RFC7540 6.5.3)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {ok, << _:24, 7:8, _:72, 4:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- prior_knowledge(Config) ->
- doc("Streams can be initiated after a successful HTTP/2 connection "
- "with prior knowledge of server capabilities. (RFC7540 3.4)"),
- {ok, Socket} = gen_tcp:connect("localhost", config(port, Config), [binary, {active, false}]),
-
-
- ok = gen_tcp:send(Socket, ["PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", cow_http2:settings(#{})]),
-
- {ok, << Len:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len/binary >>} = gen_tcp:recv(Socket, 6 + Len, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings_ack()),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- receive after 6000 -> ok end,
-
- ok = gen_tcp:send(Socket, cow_http2:ping(0)),
-
- {ok, << 8:24, 6:8, 0:7, 1:1, 0:96 >>} = gen_tcp:recv(Socket, 17, 1000),
- ok.
|