1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207 |
- -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() ->
- Tests = ct_helper:all(?MODULE),
- Clear = [T || T <- Tests, lists:sublist(atom_to_list(T), 4) =/= "alpn"] -- [prior_knowledge_reject_tls],
- TLS = [T || T <- Tests, lists:sublist(atom_to_list(T), 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)
- 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)
- 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)
- 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)
- 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.
|