12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683368436853686368736883689369036913692369336943695369636973698369937003701370237033704370537063707370837093710371137123713371437153716371737183719372037213722372337243725372637273728372937303731373237333734373537363737373837393740374137423743374437453746374737483749375037513752375337543755375637573758375937603761376237633764376537663767376837693770377137723773377437753776377737783779378037813782378337843785378637873788378937903791379237933794379537963797379837993800380138023803380438053806380738083809381038113812381338143815381638173818381938203821382238233824382538263827382838293830383138323833383438353836383738383839384038413842384338443845384638473848384938503851385238533854385538563857385838593860386138623863386438653866386738683869387038713872387338743875387638773878387938803881388238833884388538863887388838893890389138923893389438953896389738983899390039013902390339043905390639073908390939103911391239133914391539163917391839193920392139223923392439253926392739283929393039313932393339343935393639373938393939403941394239433944394539463947394839493950395139523953395439553956395739583959396039613962396339643965396639673968396939703971397239733974397539763977397839793980398139823983398439853986398739883989399039913992399339943995399639973998399940004001400240034004400540064007400840094010401140124013401440154016401740184019402040214022402340244025402640274028402940304031403240334034403540364037403840394040404140424043404440454046404740484049405040514052405340544055405640574058405940604061406240634064406540664067406840694070407140724073407440754076407740784079408040814082408340844085408640874088408940904091409240934094409540964097409840994100410141024103410441054106410741084109411041114112411341144115411641174118411941204121412241234124412541264127412841294130413141324133413441354136413741384139414041414142414341444145414641474148414941504151415241534154415541564157415841594160416141624163416441654166416741684169417041714172417341744175417641774178417941804181418241834184418541864187418841894190419141924193419441954196419741984199420042014202420342044205420642074208 |
- -module(rfc7540_SUITE).
- -compile(export_all).
- -compile(nowarn_export_all).
- -import(ct_helper, [config/2]).
- -import(ct_helper, [doc/1]).
- -import(ct_helper, [get_remote_pid_tcp/1]).
- -import(cowboy_test, [gun_open/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) ->
- [{protocol, http2}|cowboy_test:init_http(Name, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config))},
-
- stream_window_data_threshold => 0
- }, Config)];
- init_per_group(Name = tls, Config) ->
- cowboy_test:init_http2(Name, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config))},
-
- stream_window_data_threshold => 0
- }, Config).
- end_per_group(Name, _) ->
- ok = cowboy:stop_listener(Name).
- init_routes(_) -> [
- {"localhost", [
- {"/", hello_h, []},
- {"/echo/:key", echo_h, []},
- {"/delay_hello", delay_hello_h, 1200},
- {"/long_polling", long_polling_h, []},
- {"/loop_handler_abort", loop_handler_abort_h, []},
- {"/resp/:key[/:arg]", resp_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(iolist_to_binary(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),
-
- 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];
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} ->
- [settings_ack|Acc]
- end
- end, [], [1, 2, 3])),
- case Received of
- [settings_ack|_] -> ok;
- [headers, settings_ack|_] -> ok;
- [headers, data, settings_ack] -> ok
- end.
- 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),
-
-
- Received = lists:reverse(lists:foldl(fun(_, Acc) ->
- case gen_tcp:recv(Socket, 9, 6000) 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, << 8:24, 7:8, 0:40 >>} ->
-
- {ok, << 1:32, 4:32 >>} = gen_tcp:recv(Socket, 8, 1000),
- [goaway|Acc];
- {error, _} ->
-
- Acc
- end
- end, [], [1, 2, 3, 4])),
- case Received of
- [goaway] -> ok;
- [headers, goaway] -> ok;
- [headers, data, goaway] -> ok
- end.
- 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 /long_polling 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];
- {ok, << 8:24, 7:8, 0:40 >>} ->
-
- {ok, << 1:32, 5:32 >>} = gen_tcp:recv(Socket, 8, 1000),
- [goaway|Acc];
- {error, _} ->
-
- Acc
- end
- end, [], [1, 2, 3, 4])),
- case Received of
- [rst_stream] -> ok;
- [headers, rst_stream] -> ok;
- [headers, data, goaway] -> ok
- end.
- alpn_ignore_h2c(Config) ->
- doc("An h2c ALPN protocol identifier must be ignored. (RFC7540 3.3)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2c">>, <<"http/1.1">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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."),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [{alpn_advertised_protocols, [<<"h2">>]},
- binary, {active, false}|TlsOpts]),
- {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)"),
- TlsOpts = ct_helper:get_certs_from_ets(),
- {ok, Socket} = ssl:connect("localhost", config(port, Config),
- [binary, {active, false}|TlsOpts]),
-
- 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.
- do_handshake(Config) ->
- {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),
- {ok, Socket}.
- 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} = do_handshake(Config),
-
- 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.
- ignore_unknown_frames(Config) ->
- doc("Frames of unknown type must be ignored and discarded. (RFC7540 4.1)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 10:24, 99:8, 0:40, 0:80 >>,
- cow_http2:data(1, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_data_unknown_flags(Config) ->
- doc("Undefined DATA frame flags must be ignored. (RFC7540 4.1, RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 100:24, 0:8,
- 1:1, 1:1, 1:1, 1:1,
- 0:1,
- 1:1, 1:1,
- 1:1,
- 0:1, 1:31, 0:100/unit:8 >>
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_headers_unknown_flags(Config) ->
- doc("Undefined HEADERS frame flags must be ignored. (RFC7540 4.1, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- Len = iolist_size(HeadersBlock),
- ok = gen_tcp:send(Socket, [
- << Len:24, 1:8,
- 1:1, 1:1,
- 0:1,
- 1:1,
- 0:1,
- 1:1,
- 1:1,
- 0:1,
- 0:1, 1:31 >>,
- HeadersBlock,
- cow_http2:data(1, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_priority_unknown_flags(Config) ->
- doc("Undefined PRIORITY frame flags must be ignored. (RFC7540 4.1, RFC7540 6.3)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 5:24, 2:8,
- 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1,
- 0:1, 1:31, 0:1, 3:31, 0:8 >>,
- cow_http2:data(1, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_rst_stream_unknown_flags(Config) ->
- doc("Undefined RST_STREAM frame flags must be ignored. (RFC7540 4.1, RFC7540 6.4)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 4:24, 3:8,
- 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1,
- 0:1, 1:31, 8:32 >>,
- cow_http2:headers(3, nofin, HeadersBlock),
- cow_http2:data(3, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 3:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 3:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_settings_unknown_flags(Config) ->
- doc("Undefined SETTINGS frame flags must be ignored. (RFC7540 4.1, RFC7540 6.5)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 6:24, 4:8,
- 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1,
- 0:1,
- 0:32, 2:16, 0:32 >>),
-
- {ok, << 0:24, 4:8, 0:7, 1:1, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- ignore_push_promise_unknown_flags(Config) ->
- doc("Undefined PUSH_PROMISE frame flags must be ignored. (RFC7540 4.1, RFC7540 6.6)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 4:24, 5:8,
- 1:1, 1:1, 1:1, 1:1,
- 0:1,
- 1:1,
- 1:1, 1:1,
- 0:1, 1:31, 0:1, 3:31 >>
- ),
-
-
-
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_ping_unknown_flags(Config) ->
- doc("Undefined PING frame flags must be ignored. (RFC7540 4.1, RFC7540 6.7)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 8:24, 6:8,
- 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1,
- 0:1,
- 0:32, 0:64 >>),
-
- {ok, << 8:24, 6:8, _:7, 1:1, _:32, 0:64 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_goaway_unknown_flags(Config) ->
- doc("Undefined GOAWAY frame flags must be ignored. (RFC7540 4.1, RFC7540 6.8)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 8:24, 7:8,
- 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1,
- 0:32, 0:64 >>),
-
- {ok, << _:24, 7:8, _:72, 0:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_window_update_unknown_flags(Config) ->
- doc("Undefined WINDOW_UPDATE frame flags must be ignored. (RFC7540 4.1, RFC7540 6.9)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 4:24, 8:8,
- 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1, 1:1,
- 0:32, 1000:32 >>),
-
- ok = gen_tcp:send(Socket, cow_http2:ping(0)),
-
- {ok, << 8:24, 6:8, _:7, 1:1, _:32, 0:64 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_continuation_unknown_flags(Config) ->
- doc("Undefined CONTINUATION frame flags must be ignored. (RFC7540 4.1, RFC7540 6.10)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- Len = iolist_size(HeadersBlock),
- ok = gen_tcp:send(Socket, [
- << 0:24, 1:8, 0:8, 0:1, 1:31 >>,
- << Len:24, 9:8,
- 1:1, 1:1, 1:1, 1:1, 1:1,
- 1:1,
- 1:1, 1:1,
- 0:1, 1:31 >>,
- HeadersBlock,
- cow_http2:data(1, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_data_reserved_bit(Config) ->
- doc("Reserved 1-bit field of DATA frame must be ignored. (RFC7540 4.1, RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 100:24, 0:8, 0:7, 1:1,
- 1:1,
- 1:31, 0:100/unit:8 >>
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_headers_reserved_bit(Config) ->
- doc("Reserved 1-bit field of HEADERS frame must be ignored. (RFC7540 4.1, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- Len = iolist_size(HeadersBlock),
- ok = gen_tcp:send(Socket, [
- << Len:24, 1:8, 0:5, 1:1, 0:2,
- 1:1,
- 1:31 >>,
- HeadersBlock,
- cow_http2:data(1, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_priority_reserved_bit(Config) ->
- doc("Reserved 1-bit field of PRIORITY frame must be ignored. (RFC7540 4.1, RFC7540 6.3)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 5:24, 2:8, 0:8,
- 1:1,
- 1:31, 0:1, 3:31, 0:8 >>,
- cow_http2:data(1, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_rst_stream_reserved_bit(Config) ->
- doc("Reserved 1-bit field of RST_STREAM frame must be ignored. (RFC7540 4.1, RFC7540 6.4)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 4:24, 3:8, 0:8,
- 1:1,
- 1:31, 8:32 >>,
- cow_http2:headers(3, nofin, HeadersBlock),
- cow_http2:data(3, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 3:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 3:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- ignore_settings_reserved_bit(Config) ->
- doc("Reserved 1-bit field of SETTINGS frame must be ignored. (RFC7540 4.1, RFC7540 6.5)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 6:24, 4:8, 0:8,
- 1:1,
- 0:31, 2:16, 0:32 >>),
-
- {ok, << 0:24, 4:8, 0:7, 1:1, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- ignore_push_promise_reserved_bit(Config) ->
- doc("Reserved 1-bit field of PUSH_PROMISE frame must be ignored. (RFC7540 4.1, RFC7540 6.6)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 4:24, 5:8, 0:5, 1:1, 0:2,
- 1:1,
- 1:31, 0:1, 3:31 >>
- ),
-
-
-
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_ping_reserved_bit(Config) ->
- doc("Reserved 1-bit field of PING frame must be ignored. (RFC7540 4.1, RFC7540 6.7)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 8:24, 6:8, 0:8,
- 1:1,
- 0:31, 0:64 >>),
-
- {ok, << 8:24, 6:8, _:7, 1:1, _:32, 0:64 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_goaway_reserved_bit(Config) ->
- doc("Reserved 1-bit field of GOAWAY frame must be ignored. (RFC7540 4.1, RFC7540 6.8)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 8:24, 7:8, 0:8,
- 1:1,
- 0:31, 0:64 >>),
-
- {ok, << _:24, 7:8, _:72, 0:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_window_update_reserved_bit(Config) ->
- doc("Reserved 1-bit field of WINDOW_UPDATE frame must be ignored. (RFC7540 4.1, RFC7540 6.9)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 4:24, 8:8, 0:8,
- 1:1,
- 0:31, 1000:32 >>),
-
- ok = gen_tcp:send(Socket, cow_http2:ping(0)),
-
- {ok, << 8:24, 6:8, _:7, 1:1, _:32, 0:64 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ignore_continuation_reserved_bit(Config) ->
- doc("Reserved 1-bit field of CONTINUATION frame must be ignored. (RFC7540 4.1, RFC7540 6.10)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- Len = iolist_size(HeadersBlock),
- ok = gen_tcp:send(Socket, [
- << 0:24, 1:8, 0:8, 0:1, 1:31 >>,
- << Len:24, 9:8, 0:5, 1:1, 0:2,
- 1:1,
- 1:31 >>,
- HeadersBlock,
- cow_http2:data(1, fin, << 0:100/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 100:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:100/unit:8 >>} = gen_tcp:recv(Socket, 100, 1000),
- ok.
- max_frame_size_allow_exactly_default(Config) ->
- doc("All implementations must allow frame sizes of at least 16384. (RFC7540 4.1, RFC7540 4.2)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, fin, << 0:16384/unit:8 >>)
- ]),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = case gen_tcp:recv(Socket, 9, 1000) of
-
- {ok, <<4:24, 8:8, 0:40>>} ->
- {ok, _} = gen_tcp:recv(Socket, 4 + 13, 1000),
- gen_tcp:recv(Socket, 9, 1000);
- Res ->
- Res
- end,
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 16384:24, 0:8, 1:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, << 0:16384/unit:8 >>} = gen_tcp:recv(Socket, 16384, 1000),
- ok.
- max_frame_size_reject_larger_than_default(Config) ->
- doc("A FRAME_SIZE_ERROR connection error must be sent when receiving "
- "frames larger than the default 16384 length. (RFC7540 4.1, RFC7540 4.2)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, fin, << 0:16385/unit:8 >>)
- ]),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- max_frame_size_allow_exactly_custom(Config0) ->
- doc("An endpoint that sets SETTINGS_MAX_FRAME_SIZE must allow frames "
- "of up to that size. (RFC7540 4.2, RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- max_frame_size_received => 30000
- }, Config0),
- try
-
- {ok, Socket} = do_handshake(Config),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, fin, <<0:30000/unit:8>>)
- ]),
-
- {ok, << Len2:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Len2, 6000),
-
- {error, timeout} = gen_tcp:recv(Socket, 0, 1000),
- gen_tcp:close(Socket)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- max_frame_size_reject_larger_than_custom(Config0) ->
- doc("An endpoint that sets SETTINGS_MAX_FRAME_SIZE must reject frames "
- "of up to that size with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- max_frame_size_received => 30000
- }, Config0),
- try
-
- {ok, Socket} = do_handshake(Config),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, fin, <<0:30001/unit:8>>)
- ]),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- data_reject_frame_size_0_padded_flag(Config) ->
- doc("DATA frames of size 0 with the PADDED flag set must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 0:24, 0:8, 0:4, 1:1, 0:2, 1:1, 0:1, 1:31 >>
- ]),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- data_reject_frame_size_too_small_padded_flag(Config) ->
- doc("DATA frames with Pad Length >= Length must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- << 10:24, 0:8, 0:4, 1:1, 0:2, 1:1, 0:1, 1:31, 10:8, 0:80 >>
- ]),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- headers_reject_frame_size_0_padded_flag(Config) ->
- doc("HEADERS frames of size 0 with the PADDED flag set must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 0:24, 1:8, 0:4, 1:1, 0:2, 1:1, 0:1, 1:31 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- headers_reject_frame_size_too_small_padded_flag(Config) ->
- doc("HEADERS frames with no priority flag and Pad Length >= Length "
- "must be rejected with a PROTOCOL_ERROR connection error. (RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 10:24, 1:8, 0:4, 1:1, 0:2, 1:1, 0:1, 1:31, 10:8, 0:80 >>),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- headers_reject_frame_size_too_small_priority_flag(Config) ->
- doc("HEADERS frames of size smaller than 5 with the PRIORITY flag set must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 4:24, 1:8,
- 0:2, 1:1, 0:4, 1:1, 0:1, 1:31, 0:1, 3:31, 0:8 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- headers_reject_frame_size_5_padded_and_priority_flags(Config) ->
- doc("HEADERS frames of size smaller than 6 with the PADDED "
- "and PRIORITY flags set must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 5:24, 1:8,
- 0:2, 1:1, 0:1, 1:1, 0:2, 1:1, 0:1, 1:31, 0:8, 0:1, 3:31, 0:8 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- headers_reject_frame_size_too_small_padded_and_priority_flags(Config) ->
- doc("HEADERS frames of size smaller than Length+6 with the PADDED and PRIORITY flags set "
- "must be rejected with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 15:24, 1:8,
- 0:2, 1:1, 0:1, 1:1, 0:2, 1:1, 0:1, 1:31, 10:8, 0:1, 3:31, 0:8, 0:80 >>),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- priority_reject_frame_size_too_small(Config) ->
- doc("PRIORITY frames of size smaller than 5 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.3)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 4:24, 2:8, 0:9, 1:31, 0:1, 3:31, 0:8 >>),
-
- {ok, << _:24, 3:8, _:40, 6:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- priority_reject_frame_size_too_large(Config) ->
- doc("PRIORITY frames of size larger than 5 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.3)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 6:24, 2:8, 0:9, 1:31, 0:1, 3:31, 0:16 >>),
-
- {ok, << _:24, 3:8, _:40, 6:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- rst_stream_reject_frame_size_too_small(Config) ->
- doc("RST_STREAM frames of size smaller than 4 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.4)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, fin, HeadersBlock),
- << 3:24, 3:8, 0:9, 1:31, 8:32 >>
- ]),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- rst_stream_reject_frame_size_too_large(Config) ->
- doc("RST_STREAM frames of size larger than 4 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.4)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, fin, HeadersBlock),
- << 5:24, 3:8, 0:9, 1:31, 8:32 >>
- ]),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- settings_reject_bad_frame_size(Config) ->
- doc("SETTINGS frames must have a size multiple of 6 or be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.5)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 5:24, 4:8, 0:40, 1:16, 4096:32 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- settings_ack_reject_non_empty_frame_size(Config) ->
- doc("SETTINGS frames with the ACK flag set and a non-empty payload "
- "must be rejected with a FRAME_SIZE_ERROR connection error (RFC7540 4.2, 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, << 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, << 6:24, 4:8, 0:7, 1:1, 0:32, 1:16, 4096:32 >>),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- push_promise_reject_frame_size_too_small(Config) ->
- doc("PUSH_PROMISE frames of size smaller than 4 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.6)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 3:24, 5:8, 0:5, 1:1, 0:3, 1:31, 0:1, 3:31 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- push_promise_reject_frame_size_4_padded_flag(Config) ->
- doc("PUSH_PROMISE frames of size smaller than 5 with the PADDED flag set must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.6)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 4:24, 5:8, 0:4, 1:1, 1:1, 0:3, 1:31, 0:1, 0:8, 3:31 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- push_promise_reject_frame_size_too_small_padded_flag(Config) ->
- doc("PUSH_PROMISE frames of size smaller than Length+5 with the PADDED flag set "
- "must be rejected with a PROTOCOL_ERROR connection error. (RFC7540 4.2, RFC7540 6.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- Len = 14 + iolist_size(HeadersBlock),
- ok = gen_tcp:send(Socket, [
- << Len:24, 5:8, 0:4, 1:1, 1:1, 0:3, 1:31, 10:8, 0:1, 3:31 >>,
- HeadersBlock,
- << 0:80 >>
- ]),
-
-
-
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ping_reject_frame_size_too_small(Config) ->
- doc("PING frames of size smaller than 8 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.7)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 7:24, 6:8, 0:40, 0:56 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- ping_reject_frame_size_too_large(Config) ->
- doc("PING frames of size larger than 8 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.7)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 9:24, 6:8, 0:40, 0:72 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- goaway_reject_frame_size_too_small(Config) ->
- doc("GOAWAY frames of size smaller than 8 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.8)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 7:24, 7:8, 0:40, 0:56 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- goaway_allow_frame_size_too_large(Config) ->
- doc("GOAWAY frames of size larger than 8 must be allowed. (RFC7540 6.8)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 12:24, 7:8, 0:40, 0:64, 99999:32 >>),
-
- {ok, << _:24, 7:8, _:72, 0:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- window_update_reject_frame_size_too_small(Config) ->
- doc("WINDOW_UPDATE frames of size smaller than 4 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.9)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 3:24, 8:8, 0:40, 1000:24 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- window_update_reject_frame_size_too_large(Config) ->
- doc("WINDOW_UPDATE frames of size larger than 4 must be rejected "
- "with a FRAME_SIZE_ERROR connection error. (RFC7540 4.2, RFC7540 6.9)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 5:24, 8:8, 0:40, 1000:40 >>),
-
- {ok, << _:24, 7:8, _:72, 6:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- headers_compression_error(Config) ->
- doc("A decoding error in a HEADERS frame's header block must be rejected "
- "with a COMPRESSION_ERROR connection error. (RFC7540 4.3, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 10:24, 1:8, 0:5, 1:1, 0:1, 1:1, 0:1, 1:31, 0:10/unit:8 >>),
-
- {ok, << _:24, 7:8, _:72, 9:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- continuation_compression_error(Config) ->
- doc("A decoding error in a CONTINUATION frame's header block must be rejected "
- "with a COMPRESSION_ERROR connection error. (RFC7540 4.3, RFC7540 6.10)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, [
- << 0:24, 1:8, 0:7, 1:1, 0:1, 1:31 >>,
- << 10:24, 9:8, 0:5, 1:1, 0:3, 1:31, 0:10/unit:8 >>
- ]),
-
- {ok, << _:24, 7:8, _:72, 9:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- continuation_with_frame_interleaved_error(Config) ->
- doc("Frames interleaved in a header block must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 4.3, RFC7540 6.2, RFC7540 6.10)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, [
- << 0:24, 1:8, 0:7, 1:1, 0:1, 1:31 >>,
- cow_http2:ping(0)
- ]),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- continuation_wrong_stream_error(Config) ->
- doc("CONTINUATION frames with an incorrect stream identifier must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 4.3, RFC7540 6.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, [
- << 0:24, 1:8, 0:7, 1:1, 0:1, 1:31 >>,
- << 0:24, 9:8, 0:9, 3:31 >>
- ]),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- idle_stream_reject_data(Config) ->
- doc("DATA frames received on an idle stream must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 5.1, RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:data(1, fin, <<"Unexpected DATA frame.">>)),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- idle_stream_accept_headers(Config) ->
- doc("HEADERS frames received on an idle stream must be accepted. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- idle_stream_accept_priority(Config) ->
- doc("PRIORITY frames received on an idle stream must be accepted. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:priority(1, shared, 3, 123)),
-
- {error, timeout} = gen_tcp:recv(Socket, 7, 1000),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- idle_stream_reject_rst_stream(Config) ->
- doc("RST_STREAM frames received on an idle stream must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, no_error)),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- idle_stream_reject_push_promise(Config) ->
- doc("PUSH_PROMISE frames received on an idle stream must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:push_promise(1, 3, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- idle_stream_reject_window_update(Config) ->
- doc("WINDOW_UPDATE frames received on an idle stream must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:window_update(1, 12345)),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- half_closed_remote_reject_data(Config) ->
- doc("DATA frames received on a half-closed (remote) stream must be rejected "
- "with a STREAM_CLOSED stream error. (RFC7540 5.1, RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:data(1, fin, <<"Unexpected DATA frame.">>)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 5:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- half_closed_remote_reject_headers(Config) ->
- doc("HEADERS frames received on a half-closed (remote) stream must be rejected "
- "with a STREAM_CLOSED connection error. (RFC7540 4.3, RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 5:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- half_closed_remote_accept_priority(Config) ->
- doc("PRIORITY frames received on a half-closed stream must be accepted. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:priority(1, shared, 3, 123)),
-
- {ok, << _:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- half_closed_remote_accept_rst_stream(Config) ->
- doc("RST_STREAM frames received on a half-closed stream must be accepted. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, no_error)),
-
- {error, timeout} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- half_closed_remote_accept_window_update(Config) ->
- doc("WINDOW_UPDATE frames received on a half-closed stream must be accepted. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:window_update(1, 12345)),
-
- {ok, << _:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- rst_stream_closed_reject_data(Config) ->
- doc("DATA frames received on a stream closed via RST_STREAM must be rejected "
- "with a STREAM_CLOSED connection error. (RFC7540 5.1, RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, cancel)),
-
- ok = gen_tcp:send(Socket, cow_http2:data(1, fin, <<"Unexpected DATA frame.">>)),
-
- {ok, << _:24, 7:8, _:72, 5:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- rst_stream_closed_reject_headers(Config) ->
- doc("HEADERS frames received on a stream closed via RST_STREAM must be rejected "
- "with a STREAM_CLOSED connection error. (RFC7540 4.3, RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, cancel)),
-
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 5:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- rst_stream_closed_accept_priority(Config) ->
- doc("PRIORITY frames received on a stream closed via RST_STREAM "
- "must be accepted. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, cancel)),
-
- ok = gen_tcp:send(Socket, cow_http2:priority(1, shared, 3, 123)),
-
- {error, timeout} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- rst_stream_closed_ignore_rst_stream(Config) ->
- doc("RST_STREAM frames received on a stream closed via RST_STREAM "
- "must be ignored to avoid looping. (RFC7540 5.1, RFC7540 5.4.2)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, cancel)),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, cancel)),
-
- {error, timeout} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- rst_stream_closed_reject_window_update(Config) ->
- doc("WINDOW_UPDATE frames received on a stream closed via RST_STREAM "
- "must be rejected with a STREAM_CLOSED stream error. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, cancel)),
-
- ok = gen_tcp:send(Socket, cow_http2:window_update(1, 12345)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 5:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- stream_closed_reject_data(Config) ->
- doc("DATA frames received on a stream closed normally must be rejected "
- "with a STREAM_CLOSED connection error. (RFC7540 5.1, RFC7540 6.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << Length1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length1, 6000),
- {ok, << Length2:24, 0:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length2, 6000),
-
- ok = gen_tcp:send(Socket, cow_http2:data(1, fin, <<"Unexpected DATA frame.">>)),
-
- {ok, << _:24, 7:8, _:72, 5:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- stream_closed_reject_headers(Config) ->
- doc("HEADERS frames received on a stream closed normally must be rejected "
- "with a STREAM_CLOSED connection error. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << Length1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length1, 6000),
- {ok, << Length2:24, 0:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length2, 6000),
-
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 5:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- stream_closed_accept_priority(Config) ->
- doc("PRIORITY frames received on a stream closed normally must be accepted. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << Length1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length1, 6000),
- {ok, << Length2:24, 0:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length2, 6000),
-
- ok = gen_tcp:send(Socket, cow_http2:priority(1, shared, 3, 123)),
-
- {error, timeout} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- stream_closed_accept_rst_stream(Config) ->
- doc("RST_STREAM frames received on a stream closed normally "
- "must be accepted for a short period. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << Length1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length1, 6000),
- {ok, << Length2:24, 0:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length2, 6000),
-
- ok = gen_tcp:send(Socket, cow_http2:rst_stream(1, cancel)),
-
- {error, timeout} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- stream_closed_accept_window_update(Config) ->
- doc("WINDOW_UPDATE frames received on a stream closed normally "
- "must be accepted for a short period. (RFC7540 5.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << Length1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length1, 6000),
- {ok, << Length2:24, 0:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length2, 6000),
-
- ok = gen_tcp:send(Socket, cow_http2:window_update(1, 12345)),
-
- {error, timeout} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- reject_streamid_even(Config) ->
- doc("HEADERS frames received with an even-numbered streamid "
- "must be rejected with a PROTOCOL_ERROR connection error. (RFC7540 5.1.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(2, fin, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- reject_streamid_0(Config) ->
- doc("HEADERS frames received with streamid 0 (zero) "
- "must be rejected with a PROTOCOL_ERROR connection error. (RFC7540 5.1.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(0, fin, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- http_upgrade_reject_reuse_streamid_1(Config) ->
- doc("Attempts to reuse streamid 1 after upgrading to HTTP/2 "
- "must be rejected with a STREAM_CLOSED connection error. (RFC7540 5.1.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",
- "\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,
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 5:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- reject_streamid_lower(Config) ->
- doc("HEADERS frames received with streamid lower than the previous stream "
- "must be rejected with a STREAM_CLOSED connection error. (RFC7540 5.1.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(5, fin, HeadersBlock)),
-
- {ok, << Length1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length1, 6000),
- {ok, << Length2:24, 0:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Length2, 6000),
-
- ok = gen_tcp:send(Socket, cow_http2:headers(3, fin, HeadersBlock)),
-
- {ok, << _:24, 7:8, _:72, 5:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- reject_self_dependent_stream_headers(Config) ->
- doc("HEADERS frames opening a stream that depends on itself "
- "must be rejected with a PROTOCOL_ERROR connection error. (RFC7540 5.3.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 5:24, 1:8,
- 0:2, 1:1, 0:4, 1:1, 0:1, 1:31, 0:1, 1:31, 0:8 >>),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- reject_self_dependent_stream_headers_with_padding(Config) ->
- doc("HEADERS frames opening a stream that depends on itself "
- "must be rejected with a PROTOCOL_ERROR connection error. (RFC7540 5.3.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 6:24, 1:8,
- 0:2, 1:1, 0:1, 1:1, 0:2, 1:1, 0:1, 1:31, 0:8, 0:1, 1:31, 0:8 >>),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- reject_self_dependent_stream_priority(Config) ->
- doc("PRIORITY frames making a stream depend on itself "
- "must be rejected with a PROTOCOL_ERROR stream error. (RFC7540 5.3.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:priority(1, shared, 1, 123)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- continuation_with_extension_frame_interleaved_error(Config) ->
- doc("Extension frames interleaved in a header block must be rejected "
- "with a PROTOCOL_ERROR connection error. "
- "(RFC7540 4.3, RFC7540 5.5, RFC7540 6.2, RFC7540 6.10)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, [
- << 0:24, 1:8, 0:7, 1:1, 0:1, 1:31 >>,
- << 0:24, 128:8, 0:8, 0:32 >>
- ]),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- settings_header_table_size_client(Config) ->
- doc("The SETTINGS_HEADER_TABLE_SIZE setting can be used to "
- "inform the server of the maximum header table size "
- "used by the client to decode header blocks. (RFC7540 6.5.2)"),
- HeaderTableSize = 128,
-
- {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(#{header_table_size => HeaderTableSize})]),
-
- {ok, << Len0:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len0/binary >>} = gen_tcp:recv(Socket, 6 + Len0, 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),
-
- DecodeState = cow_hpack:set_max_size(HeaderTableSize, cow_hpack:init()),
- EncodeState = cow_hpack:init(),
-
- {ReqHeadersBlock1, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ], EncodeState),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, ReqHeadersBlock1)),
-
- {ok, << Len1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, RespHeadersBlock1} = gen_tcp:recv(Socket, Len1, 6000),
- {RespHeaders, _} = cow_hpack:decode(RespHeadersBlock1, DecodeState),
- {_, <<"200">>} = lists:keyfind(<<":status">>, 1, RespHeaders),
-
-
- ok.
- settings_header_table_size_server(Config0) ->
- doc("The SETTINGS_HEADER_TABLE_SIZE setting can be used to "
- "inform the client of the maximum header table size "
- "used by the server to decode header blocks. (RFC7540 6.5.2)"),
- HeaderTableSize = 128,
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- max_decode_table_size => HeaderTableSize
- }, Config0),
- try
-
- {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(#{header_table_size => HeaderTableSize})]),
-
- {ok, << Len0:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, Data = <<_:48, _:Len0/binary>>} = gen_tcp:recv(Socket, 6 + Len0, 1000),
-
- {ok, {settings, #{header_table_size := HeaderTableSize}}, <<>>}
- = cow_http2:parse(<<Len0:24, Data/binary>>),
-
- ok = gen_tcp:send(Socket, cow_http2:settings_ack()),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- DecodeState = cow_hpack:init(),
- EncodeState = cow_hpack:set_max_size(HeaderTableSize, cow_hpack:init()),
-
- {ReqHeadersBlock1, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ], EncodeState),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, ReqHeadersBlock1)),
-
- {ok, << Len1:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, RespHeadersBlock1} = gen_tcp:recv(Socket, Len1, 6000),
- {RespHeaders, _} = cow_hpack:decode(RespHeadersBlock1, DecodeState),
- {_, <<"200">>} = lists:keyfind(<<":status">>, 1, RespHeaders)
-
-
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- settings_max_concurrent_streams(Config0) ->
- doc("The SETTINGS_MAX_CONCURRENT_STREAMS setting can be used to "
- "restrict the number of concurrent streams. (RFC7540 5.1.2, RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- max_concurrent_streams => 1
- }, Config0),
- try
- {ok, Socket} = do_handshake(Config),
-
- Headers = [
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {ReqHeadersBlock1, EncodeState} = cow_hpack:encode(Headers),
- {ReqHeadersBlock2, _} = cow_hpack:encode(Headers, EncodeState),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, fin, ReqHeadersBlock1),
- cow_http2:headers(3, fin, ReqHeadersBlock2)
- ]),
-
- {ok, << _:24, 3:8, _:8, 3:32, 7:32 >>} = gen_tcp:recv(Socket, 13, 6000)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- settings_max_concurrent_streams_0(Config0) ->
- doc("The SETTINGS_MAX_CONCURRENT_STREAMS setting can be set to "
- "0 to refuse all incoming streams. (RFC7540 5.1.2, RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- max_concurrent_streams => 0
- }, Config0),
- try
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 7:32 >>} = gen_tcp:recv(Socket, 13, 6000)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- settings_initial_window_size(Config0) ->
- doc("The SETTINGS_INITIAL_WINDOW_SIZE setting can be used to "
- "change the initial window size of streams. (RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- initial_connection_window_size => 100000,
- initial_stream_window_size => 100000
- }, Config0),
- try
-
-
- {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, << Len1:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len1/binary >>} = gen_tcp:recv(Socket, 6 + Len1, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings_ack()),
-
- {ok, << 4:24, 8:8, 0:40, _:32 >>} = gen_tcp:recv(Socket, 13, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, fin, <<0:15000/unit:8>>)
- ]),
-
- {ok, << Len2:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Len2, 6000),
-
- {error, timeout} = gen_tcp:recv(Socket, 0, 1000),
- gen_tcp:close(Socket)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- settings_initial_window_size_after_ack(Config0) ->
- doc("The SETTINGS_INITIAL_WINDOW_SIZE setting can be used to "
- "change the initial window size of streams. It is applied "
- "to all existing streams upon receipt of the SETTINGS ack. (RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- initial_stream_window_size => 0
- }, Config0),
- try
-
-
- {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, << Len1:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len1/binary >>} = gen_tcp:recv(Socket, 6 + Len1, 1000),
-
-
-
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:settings_ack(),
- cow_http2:data(1, fin, <<0:32/unit:8>>)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 3:32 >>} = gen_tcp:recv(Socket, 13, 6000)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- settings_initial_window_size_before_ack(Config0) ->
- doc("The SETTINGS_INITIAL_WINDOW_SIZE setting can be used to "
- "change the initial window size of streams. It is only "
- "applied upon receipt of the SETTINGS ack. (RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- initial_stream_window_size => 0
- }, Config0),
- try
-
-
- {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, << Len1:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len1/binary >>} = gen_tcp:recv(Socket, 6 + Len1, 1000),
-
-
-
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, fin, <<0:15000/unit:8>>)
- ]),
-
- {ok, << Len2:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Len2, 6000),
-
- {error, timeout} = gen_tcp:recv(Socket, 0, 1000),
- gen_tcp:close(Socket)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- settings_max_frame_size(Config0) ->
- doc("The SETTINGS_MAX_FRAME_SIZE setting can be used to "
- "change the maximum frame size allowed. (RFC7540 6.5.2)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- max_frame_size_received => 30000
- }, Config0),
- try
-
- {ok, Socket} = do_handshake(Config),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, fin, <<0:25000/unit:8>>)
- ]),
-
- {ok, << Len2:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, _} = gen_tcp:recv(Socket, Len2, 6000),
-
- {error, timeout} = gen_tcp:recv(Socket, 0, 1000),
- gen_tcp:close(Socket)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- settings_max_frame_size_reject_too_small(Config) ->
- doc("A SETTINGS_MAX_FRAME_SIZE smaller than 16384 must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 6.5.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 6:24, 4:8, 0:40, 5:16, 16383:32 >>),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- settings_max_frame_size_reject_too_large(Config) ->
- doc("A SETTINGS_MAX_FRAME_SIZE larger than 16777215 must be rejected "
- "with a PROTOCOL_ERROR connection error. (RFC7540 6.5.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, << 6:24, 4:8, 0:40, 5:16, 16777216:32 >>),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- client_settings_disable_push(Config) ->
- doc("PUSH_PROMISE frames must not be sent when the setting "
- "SETTINGS_ENABLE_PUSH is disabled. (RFC7540 6.5.2, RFC7540 6.6, RFC7540 8.2)"),
-
- {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(#{
- enable_push => false
- })]),
-
- {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),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/resp/push">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- graceful_shutdown_client_stays(Config) ->
- doc("A server gracefully shutting down must send a GOAWAY frame with the "
- "last stream identifier set to 2^31-1 and a NO_ERROR code. After allowing "
- "time for any in-flight stream creation the server can send another GOAWAY "
- "frame with an updated last stream identifier. (RFC7540 6.8)"),
- {ok, Socket} = do_handshake(Config),
- ServerConnPid = get_remote_pid_tcp(Socket),
- ok = sys:terminate(ServerConnPid, whatever),
-
- {ok, <<_:24, 7:8, 0:8, 0:1, 0:31, 0:1, 16#7fffffff:31, 0:32>>} = gen_tcp:recv(Socket, 17, 500),
-
- {ok, <<_:24, 7:8, 0:8, 0:1, 0:31, 0:1, 0:31, 0:32>>} = gen_tcp:recv(Socket, 17, 1500),
- {error, closed} = gen_tcp:recv(Socket, 3, 1000),
- ok.
- graceful_shutdown_race_condition(Config) ->
- doc("A server in the process of gracefully shutting down must discard frames "
- "for streams initiated by the receiver with identifiers higher than the "
- "identified last stream. This may include frames that alter connection "
- "state such as HEADERS frames. (RFC7540 6.8)"),
- {ok, Socket} = do_handshake(Config),
- ServerConnPid = get_remote_pid_tcp(Socket),
- ok = sys:terminate(ServerConnPid, whatever),
-
- {ok, <<_:24, 7:8, 0:8, 0:1, 0:31, 0:1, 16#7fffffff:31, 0:32>>} = gen_tcp:recv(Socket, 17, 500),
-
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/delay_hello">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, <<_:24, 7:8, 0:8, 0:1, 0:31, 0:1, 1:31, 0:32>>} = gen_tcp:recv(Socket, 17, 2000),
-
- ok = gen_tcp:send(Socket, cow_http2:headers(3, fin, HeadersBlock)),
-
- {ok, <<RespHeadersPayloadLength:24, 1, 4, 0:1, 1:31>>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _RespHeaders} = gen_tcp:recv(Socket, RespHeadersPayloadLength, 1000),
- {ok, <<12:24, 0, 1, 0:1, 1:31, "Hello world!">>} = gen_tcp:recv(Socket, 21, 1000),
- {error, closed} = gen_tcp:recv(Socket, 3, 1000),
- ok.
- window_update_reject_0(Config) ->
- doc("WINDOW_UPDATE frames with an increment of 0 for the connection "
- "flow control window must be rejected with a "
- "PROTOCOL_ERROR connection error. (RFC7540 6.9.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, [
- cow_http2:window_update(0)
- ]),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- window_update_reject_0_stream(Config) ->
- doc("WINDOW_UPDATE frames with an increment of 0 for a stream "
- "flow control window must be rejected with a "
- "PROTOCOL_ERROR stream error. (RFC7540 6.9.1)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, fin, HeadersBlock),
- cow_http2:window_update(1, 0)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- data_reject_overflow(Config0) ->
- doc("DATA frames that cause the connection flow control window "
- "to overflow must be rejected with a FLOW_CONTROL_ERROR "
- "connection error. (RFC7540 6.9.1)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- initial_stream_window_size => 100000
- }, Config0),
- try
- {ok, Socket} = do_handshake(Config),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, fin, <<0:15000/unit:8>>)
- ]),
-
- {ok, << _:24, 7:8, _:72, 3:32 >>} = gen_tcp:recv(Socket, 17, 6000)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- data_reject_overflow_stream(Config0) ->
- doc("DATA frames that cause the stream flow control window "
- "to overflow must be rejected with a FLOW_CONTROL_ERROR "
- "stream error. (RFC7540 6.9.1)"),
-
- Config = cowboy_test:init_http(?FUNCTION_NAME, #{
- env => #{dispatch => cowboy_router:compile(init_routes(Config0))},
- initial_connection_window_size => 100000
- }, Config0),
- try
-
-
- {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, << Len1:24 >>} = gen_tcp:recv(Socket, 3, 1000),
- {ok, << 4:8, 0:40, _:Len1/binary >>} = gen_tcp:recv(Socket, 6 + Len1, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings_ack()),
-
- {ok, << 4:24, 8:8, 0:40, _:32 >>} = gen_tcp:recv(Socket, 13, 1000),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
-
- Headers = [
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ],
- {HeadersBlock, _} = cow_hpack:encode(Headers),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, nofin, <<0:15000/unit:8>>),
- cow_http2:data(1, fin, <<0:15000/unit:8>>)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 3:32 >>} = gen_tcp:recv(Socket, 13, 6000)
- after
- cowboy:stop_listener(?FUNCTION_NAME)
- end.
- window_update_reject_overflow(Config) ->
- doc("WINDOW_UPDATE frames that cause the connection flow control "
- "window to exceed 2^31-1 must be rejected with a "
- "FLOW_CONTROL_ERROR connection error. (RFC7540 6.9.1)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, [
- cow_http2:window_update(16#7fffffff)
- ]),
-
- {ok, << _:24, 7:8, _:72, 3:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- window_update_reject_overflow_stream(Config) ->
- doc("WINDOW_UPDATE frames that cause a stream flow control "
- "window to exceed 2^31-1 must be rejected with a "
- "FLOW_CONTROL_ERROR stream error. (RFC7540 6.9.1)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, fin, HeadersBlock),
- cow_http2:window_update(1, 16#7fffffff)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 3:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- settings_initial_window_size_changes(Config) ->
- doc("When the value of SETTINGS_INITIAL_WINDOW_SIZE changes, the server "
- "must adjust the size of the flow control windows of the active "
- "streams. (RFC7540 6.9.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{initial_window_size => 0})),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {error, timeout} = gen_tcp:recv(Socket, 9, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{initial_window_size => 5})),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {ok, << 5:24, 0:8, 0:8, 1:32, "Hello" >>} = gen_tcp:recv(Socket, 14, 1000),
- {error, timeout} = gen_tcp:recv(Socket, 9, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{initial_window_size => 12})),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {ok, << 7:24, 0:8, 1:8, 1:32, " world!" >>} = gen_tcp:recv(Socket, 16, 1000),
- ok.
- settings_initial_window_size_changes_negative(Config) ->
- doc("When the value of SETTINGS_INITIAL_WINDOW_SIZE changes, the server "
- "must adjust the size of the flow control windows of the active "
- "streams even if their window end up negative. (RFC7540 6.9.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{initial_window_size => 5})),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- {ok, _} = gen_tcp:recv(Socket, SkipLen, 1000),
- {ok, << 5:24, 0:8, 0:8, 1:32, "Hello" >>} = gen_tcp:recv(Socket, 14, 1000),
- {error, timeout} = gen_tcp:recv(Socket, 9, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{initial_window_size => 0})),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{initial_window_size => 12})),
-
- {ok, << 0:24, 4:8, 1:8, 0:32 >>} = gen_tcp:recv(Socket, 9, 1000),
-
- {ok, << 7:24, 0:8, 1:8, 1:32, " world!" >>} = gen_tcp:recv(Socket, 16, 1000),
- ok.
- settings_initial_window_size_reject_overflow(Config) ->
- doc("A SETTINGS_INITIAL_WINDOW_SIZE that causes a flow control window "
- "to exceed 2^31-1 must be rejected with a FLOW_CONTROL_ERROR "
- "connection error. (RFC7540 6.5.2, RFC7540 6.9.2)"),
- {ok, Socket} = do_handshake(Config),
-
- ok = gen_tcp:send(Socket, cow_http2:settings(#{initial_window_size => 16#80000000})),
-
- {ok, << _:24, 7:8, _:72, 3:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- accept_trailers(Config) ->
- doc("Trailing HEADERS frames must be accepted. (RFC7540 8.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, EncodeState} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"trailer">>, <<"x-checksum">>}
- ]),
- {TrailersBlock, _} = cow_hpack:encode([
- {<<"x-checksum">>, <<"md5:4cc909a007407f3706399b6496babec3">>}
- ], EncodeState),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:10000/unit:8>>),
- cow_http2:headers(1, fin, TrailersBlock)
- ]),
-
- {ok, << _:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- accept_trailers_continuation(Config) ->
- doc("Trailing HEADERS and CONTINUATION frames must be accepted. (RFC7540 8.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, EncodeState} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"trailer">>, <<"x-checksum">>}
- ]),
- {TrailersBlock, _} = cow_hpack:encode([
- {<<"x-checksum">>, <<"md5:4cc909a007407f3706399b6496babec3">>}
- ], EncodeState),
- Len = iolist_size(TrailersBlock),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:10000/unit:8>>),
- <<0:24, 1:8, 0:7, 1:1, 0:1, 1:31>>,
- <<Len:24, 9:8, 0:5, 1:1, 0:3, 1:31>>,
- TrailersBlock
- ]),
-
- {ok, << _:24, 1:8, _:40 >>} = gen_tcp:recv(Socket, 9, 6000),
- ok.
- reject_trailers_nofin(Config) ->
- doc("Trailing HEADERS frames received without the END_STREAM flag "
- "set must be rejected with a PROTOCOL_ERROR connection error. "
- "(RFC7540 8.1, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, EncodeState} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"trailer">>, <<"x-checksum">>}
- ]),
- {TrailersBlock, _} = cow_hpack:encode([
- {<<"x-checksum">>, <<"md5:4cc909a007407f3706399b6496babec3">>}
- ], EncodeState),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:10000/unit:8>>),
- cow_http2:headers(1, nofin, TrailersBlock)
- ]),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- reject_trailers_nofin_continuation(Config) ->
- doc("Trailing HEADERS frames received without the END_STREAM flag "
- "set must be rejected with a PROTOCOL_ERROR connection error. "
- "(RFC7540 8.1, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, EncodeState} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"trailer">>, <<"x-checksum">>}
- ]),
- {TrailersBlock, _} = cow_hpack:encode([
- {<<"x-checksum">>, <<"md5:4cc909a007407f3706399b6496babec3">>}
- ], EncodeState),
- Len = iolist_size(TrailersBlock),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:10000/unit:8>>),
- <<0:24, 1:8, 0:9, 1:31>>,
- <<Len:24, 9:8, 0:5, 1:1, 0:3, 1:31>>,
- TrailersBlock
- ]),
-
- {ok, << _:24, 7:8, _:72, 1:32 >>} = gen_tcp:recv(Socket, 17, 6000),
- ok.
- headers_informational_nofin(Config) ->
- doc("Informational HEADERS frames must not have the END_STREAM flag set. (RFC7540 8.1)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/echo/read_body">>},
- {<<"expect">>, <<"100-continue">>},
- {<<"content-length">>, <<"1000000">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- {ok, << Len:24, 1:8, 0:5, 1:1, 0:2, _:32 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, RespHeadersBlock} = gen_tcp:recv(Socket, Len, 6000),
-
- {RespHeaders, _} = cow_hpack:decode(RespHeadersBlock),
- {_, <<"100">>} = lists:keyfind(<<":status">>, 1, RespHeaders),
- ok.
- headers_reject_uppercase_header_name(Config) ->
- doc("Requests containing uppercase header names must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"HELLO">>, <<"world">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_response_pseudo_headers(Config) ->
- doc("Requests containing response pseudo-headers must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.1, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<":status">>, <<"200">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_unknown_pseudo_headers(Config) ->
- doc("Requests containing unknown pseudo-headers must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.1, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<":upgrade">>, <<"websocket">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_pseudo_headers_in_trailers(Config) ->
- doc("Requests containing pseudo-headers in trailers must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.1, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, EncodeState} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"trailer">>, <<"x-checksum">>}
- ]),
- {TrailersBlock, _} = cow_hpack:encode([
- {<<"x-checksum">>, <<"md5:4cc909a007407f3706399b6496babec3">>},
- {<<":path">>, <<"/">>}
- ], EncodeState),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<0:10000/unit:8>>),
- cow_http2:headers(1, fin, TrailersBlock)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_pseudo_headers_after_regular_headers(Config) ->
- doc("Requests containing pseudo-headers after regular headers must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.1, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<"content-length">>, <<"0">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_connection_header(Config) ->
- doc("Requests containing a connection header must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"connection">>, <<"close">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_keep_alive_header(Config) ->
- doc("Requests containing a keep-alive header must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"keep-alive">>, <<"timeout=5, max=1000">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_proxy_authenticate_header(Config) ->
- doc("Requests containing a connection header must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"proxy-authenticate">>, <<"Basic">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_proxy_authorization_header(Config) ->
- doc("Requests containing a connection header must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"proxy-authorization">>, <<"Basic YWxhZGRpbjpvcGVuc2VzYW1l">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_transfer_encoding_header(Config) ->
- doc("Requests containing a connection header must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"transfer-encoding">>, <<"chunked">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_upgrade_header(Config) ->
- doc("Requests containing a connection header must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"upgrade">>, <<"websocket">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- accept_te_header_value_trailers(Config) ->
- doc("Requests containing a TE header with a value of \"trailers\" "
- "must be accepted. (RFC7540 8.1.2.2)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"te">>, <<"trailers">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 1:8, _:8, 1:32 >>} = gen_tcp:recv(Socket, 9, 1000),
- ok.
- reject_te_header_other_values(Config) ->
- doc("Requests containing a TE header with a value other than \"trailers\" must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"te">>, <<"trailers, deflate;q=0.5">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- response_dont_send_header_in_connection(Config) ->
- doc("Intermediaries must remove HTTP/1.1 connection headers when "
- "transforming an HTTP/1.1 messages to HTTP/2. The server must "
- "not send them either. All headers listed in the connection "
- "header must be removed. (RFC7540 8.1.2.2)"),
- do_response_dont_send_http11_header(Config, <<"custom-header">>).
- response_dont_send_connection_header(Config) ->
- doc("Intermediaries must remove HTTP/1.1 connection headers when "
- "transforming an HTTP/1.1 messages to HTTP/2. The server must "
- "not send them either. The connection header must be removed. (RFC7540 8.1.2.2)"),
- do_response_dont_send_http11_header(Config, <<"connection">>).
- response_dont_send_keep_alive_header(Config) ->
- doc("Intermediaries must remove HTTP/1.1 connection headers when "
- "transforming an HTTP/1.1 messages to HTTP/2. The server must "
- "not send them either. The keep-alive header must be removed "
- "even if not listed in the connection header. (RFC7540 8.1.2.2)"),
- do_response_dont_send_http11_header(Config, <<"keep-alive">>).
- response_dont_send_proxy_connection_header(Config) ->
- doc("Intermediaries must remove HTTP/1.1 connection headers when "
- "transforming an HTTP/1.1 messages to HTTP/2. The server must "
- "not send them either. The proxy-connection header must be removed "
- "even if not listed in the connection header. (RFC7540 8.1.2.2)"),
- do_response_dont_send_http11_header(Config, <<"proxy-connection">>).
- response_dont_send_transfer_encoding_header(Config) ->
- doc("Intermediaries must remove HTTP/1.1 connection headers when "
- "transforming an HTTP/1.1 messages to HTTP/2. The server must "
- "not send them either. The transfer-encoding header must be removed "
- "even if not listed in the connection header. (RFC7540 8.1.2.2)"),
- do_response_dont_send_http11_header(Config, <<"transfer-encoding">>).
- response_dont_send_upgrade_header(Config) ->
- doc("Intermediaries must remove HTTP/1.1 connection headers when "
- "transforming an HTTP/1.1 messages to HTTP/2. The server must "
- "not send them either. The upgrade header must be removed "
- "even if not listed in the connection header. (RFC7540 8.1.2.2)"),
- do_response_dont_send_http11_header(Config, <<"upgrade">>).
- do_response_dont_send_http11_header(Config, Name) ->
- ConnPid = gun_open(Config),
- Ref = gun:get(ConnPid, "/resp/set_resp_headers_http11"),
- {response, nofin, 200, Headers} = gun:await(ConnPid, Ref),
- false = lists:keyfind(Name, 1, Headers),
- ok.
- reject_userinfo(Config) ->
- doc("An authority containing a userinfo component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"user@localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_empty_path(Config) ->
- doc("A request containing an empty path component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<>>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_missing_pseudo_header_method(Config) ->
- doc("A request without a method component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_many_pseudo_header_method(Config) ->
- doc("A request containing more than one method component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_missing_pseudo_header_scheme(Config) ->
- doc("A request without a scheme component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_many_pseudo_header_scheme(Config) ->
- doc("A request containing more than one scheme component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_missing_pseudo_header_authority(Config) ->
- doc("A request without an authority or host component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- accept_host_header_on_missing_pseudo_header_authority(Config) ->
- doc("A request without an authority but with a host header must be accepted. "
- "(RFC7540 8.1.2.3, RFC7540 8.1.3)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":path">>, <<"/">>},
- {<<"host">>, <<"localhost">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << Len:24, 1:8, _:8, _:32 >>} = gen_tcp:recv(Socket, 9, 6000),
- {ok, RespHeadersBlock} = gen_tcp:recv(Socket, Len, 6000),
- {RespHeaders, _} = cow_hpack:decode(RespHeadersBlock),
- {_, <<"200">>} = lists:keyfind(<<":status">>, 1, RespHeaders),
- ok.
- reject_many_pseudo_header_authority(Config) ->
- doc("A request containing more than one authority component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_missing_pseudo_header_path(Config) ->
- doc("A request without a path component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_many_pseudo_header_path(Config) ->
- doc("A request containing more than one path component must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.3, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<":path">>, <<"/">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_data_size_smaller_than_content_length(Config) ->
- doc("Requests that have a content-length header whose value does not "
- "match the total length of the DATA frames must be rejected with "
- "a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"content-length">>, <<"12">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, fin, <<"Hello!">>)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_data_size_larger_than_content_length(Config) ->
- doc("Requests that have a content-length header whose value does not "
- "match the total length of the DATA frames must be rejected with "
- "a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"content-length">>, <<"12">>}
- ]),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<"Hello! World! Universe!">>),
- cow_http2:data(1, fin, <<"Multiverse!">>)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_content_length_without_data(Config) ->
- doc("Requests that have a content-length header whose value does not "
- "match the total length of the DATA frames must be rejected with "
- "a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"content-length">>, <<"12">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, fin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_data_size_different_than_content_length_with_trailers(Config) ->
- doc("Requests that have a content-length header whose value does not "
- "match the total length of the DATA frames must be rejected with "
- "a PROTOCOL_ERROR stream error. (RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
-
- {HeadersBlock, EncodeState} = cow_hpack:encode([
- {<<":method">>, <<"POST">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/long_polling">>},
- {<<"content-length">>, <<"12">>},
- {<<"trailer">>, <<"x-checksum">>}
- ]),
- {TrailersBlock, _} = cow_hpack:encode([
- {<<"x-checksum">>, <<"md5:4cc909a007407f3706399b6496babec3">>}
- ], EncodeState),
- ok = gen_tcp:send(Socket, [
- cow_http2:headers(1, nofin, HeadersBlock),
- cow_http2:data(1, nofin, <<"Hello!">>),
- cow_http2:headers(1, fin, TrailersBlock)
- ]),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- reject_duplicate_content_length_header(Config) ->
- doc("A request with duplicate content-length headers must be rejected "
- "with a PROTOCOL_ERROR stream error. (RFC7230 3.3.2, RFC7540 8.1.2.6)"),
- {ok, Socket} = do_handshake(Config),
-
- {HeadersBlock, _} = cow_hpack:encode([
- {<<":method">>, <<"GET">>},
- {<<":scheme">>, <<"http">>},
- {<<":authority">>, <<"localhost">>},
- {<<":path">>, <<"/">>},
- {<<"content-length">>, <<"12">>},
- {<<"content-length">>, <<"12">>}
- ]),
- ok = gen_tcp:send(Socket, cow_http2:headers(1, nofin, HeadersBlock)),
-
- {ok, << _:24, 3:8, _:8, 1:32, 1:32 >>} = gen_tcp:recv(Socket, 13, 6000),
- ok.
- push_has_no_request_body(Config) ->
- doc("PUSH_PROMISE frames include the complete set of request headers "
- "and the request can never include a body. (RFC7540 8.2.1)"),
- ConnPid = gun_open(Config),
- Ref = gun:get(ConnPid, "/resp/push/read_body"),
- {push, PushRef, <<"GET">>, _, _} = gun:await(ConnPid, Ref),
- {response, fin, 200, _} = gun:await(ConnPid, Ref),
-
-
- {response, fin, 200, _} = gun:await(ConnPid, PushRef),
- ok.
- status_code_421(Config) ->
- doc("The 421 Misdirected Request status code can be sent. (RFC7540 9.1.2)"),
- ConnPid = gun_open(Config),
- Ref = gun:get(ConnPid, "/resp/reply2/421"),
- {response, fin, 421, _} = gun:await(ConnPid, Ref),
- ok.
|