mbiLddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z mZmZmZmZmZmZmZddlmZmZddlmZmZmZdd lmZd d lmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&d d l'm(Z(ej)d Z*dgZ+dZ,ej-dZ.GddeZ/GddeZ0GddeZ1GddeZ2GddeZ3Gdde4Z5Gdde5Z6Gdd e5Z7Gd!d"e5Z8Gd#d$e5Z9Gd%d&e5Z:Gd'd(e5Z;Gd)d*e5Z<Gd+d,e5Z=Gd-d.e5Z>dMd4Z?dNd7Z@dOd9ZAdPd:ZB dQdRdBZCdSdDZDdSdEZEdTdGZFdSdHZGGdIdJZHGdKdLZIdS)U) annotationsN)EnumIntEnum)UINT_VAR_MAX_SIZE) BufferBufferReadErrorDecoderStreamErrorDecompressionFailedEncoderStreamError QpackDecoder QpackEncoder StreamBlockedencode_uint_var)QuicConnectionstream_is_unidirectional)DatagramFrameReceived QuicEventStreamDataReceived)QuicLoggerTrace)DatagramReceived DataReceivedH3EventHeadersHeadersReceivedInformationalHeadersReceivedPushPromiseReceivedWebTransportStreamDataReceived)NoAvailablePushIDErrorhttp3h3)rrs[A-Z]c^eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdS) ErrorCodeiiiiiiiii i i i i iiiiiiN)__name__ __module__ __qualname__ H3_NO_ERRORH3_GENERAL_PROTOCOL_ERRORH3_INTERNAL_ERRORH3_STREAM_CREATION_ERRORH3_CLOSED_CRITICAL_STREAMH3_FRAME_UNEXPECTEDH3_FRAME_ERRORH3_EXCESSIVE_LOAD H3_ID_ERRORH3_SETTINGS_ERRORH3_MISSING_SETTINGSH3_REQUEST_REJECTEDH3_REQUEST_CANCELLEDH3_REQUEST_INCOMPLETEH3_MESSAGE_ERRORH3_CONNECT_ERRORH3_VERSION_FALLBACKQPACK_DECOMPRESSION_FAILEDQPACK_ENCODER_STREAM_ERRORQPACK_DECODER_STREAM_ERRORa/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/qh3/h3/connection.pyr'r'+sK %$ %NK !!&!&!&rAr'c6eZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) FrameTyperrrr#r$r% AN) r)r*r+DATAHEADERSPRIORITY CANCEL_PUSHSETTINGS PUSH_PROMISEGOAWAY MAX_PUSH_IDDUPLICATE_PUSHWEBTRANSPORT_STREAMr@rArBrDrDBsC DGHKHL FKNrArDceZdZdZdZdZdS) HeadersStaterrrN)r)r*r+INITIAL AFTER_HEADERSAFTER_TRAILERSr@rArBrTrTOsGMNNNrArTc*eZdZdZdZdZdZdZdZdZ dS) SettingrrEiwiB7`+!N) r)r*r+QPACK_MAX_TABLE_CAPACITYMAX_FIELD_SECTION_SIZEQPACK_BLOCKED_STREAMSENABLE_CONNECT_PROTOCOL H3_DATAGRAMENABLE_WEBTRANSPORTDUMMYr@rArBrYrYUs:" "K$ EEErArYc"eZdZdZdZdZdZdZdS) StreamTyperrrr#TN)r)r*r+CONTROLPUSH QPACK_ENCODER QPACK_DECODER WEBTRANSPORTr@rArBrerefs'G DMMLLLrArec*eZdZdZejZdddZdS) ProtocolErrorz Base class for protocol errors. These errors are not exposed to the API user, they are handled in :meth:`H3Connection.handle_event`. reason_phrasestrc||_dSN)ro)selfros rB__init__zProtocolError.__init__xs*rAN)rn)rorp)r)r*r+__doc__r'r- error_codertr@rArBrmrmnsA4J+++++++rArmceZdZejZdS)QpackDecompressionFailedN)r)r*r+r'r=rvr@rArBrxrx|5JJJrArxceZdZejZdS)QpackDecoderStreamErrorN)r)r*r+r'r?rvr@rArBr{r{ryrAr{ceZdZejZdS)QpackEncoderStreamErrorN)r)r*r+r'r>rvr@rArBr}r}ryrAr}ceZdZejZdS)ClosedCriticalStreamN)r)r*r+r'r0rvr@rArBrrs4JJJrArceZdZejZdS)FrameUnexpectedN)r)r*r+r'r1rvr@rArBrr.JJJrArceZdZejZdS) MessageErrorN)r)r*r+r'r:rvr@rArBrrs+JJJrArceZdZejZdS)MissingSettingsErrorN)r)r*r+r'r6rvr@rArBrrrrArceZdZejZdS) SettingsErrorN)r)r*r+r'r5rvr@rArBrrs,JJJrArceZdZejZdS)StreamCreationErrorN)r)r*r+r'r/rvr@rArBrrs3JJJrAr frame_typeint frame_databytesreturnct|}t|dtzz}|||||||jS)Nrcapacity)lenrr push_uint_var push_bytesdata)rr frame_lengthbufs rB encode_framersiz??L ,->)>> ? ? ?Cj!!!l###NN: 8OrAsettingsdict[int, int]ctd}|D]/\}}||||0|jS)Nir)ritemsrr)rrsettingvalues rBencode_settingsrsa $   C"..**!! '""" %    8OrArczt|}|}|sJ|S)Nr)r pull_uint_vareof)rr max_push_ids rBparse_max_push_idrs= d   C##%%K 7799 rAcXt|}i}|sv|}|}|tvrt d|dd||vrt d|dd|||<|vt |S)NrzSetting identifier 0xxz is reserved is included twice)rrrRESERVED_SETTINGSrdict)rrrrrs rBparse_settingsrs d   C!Hggii"##%%!!## ' ' ' O O O O OPP P h   U U U U UVV V!ggii" >>rAheadersrallowed_pseudo_headersfrozenset[bytes]required_pseudo_headersextract_header bytes | Noneczd}d}d}d}t}d} |D]\} } t| rtd| d|| | } | drs|rtd| d| |vrtd| d| |vrtd| d|| | d kr| }| d kr| }| d kr| }d }||} | r td t| d|dvr"|std|std| S)NFzHeader z contains uppercase letters:zPseudo-header z% is not allowed after regular headersz is not validr :authority:path:schemeTzPseudo-headers z are missing)shttpshttpsz+Pseudo-header b':authority' cannot be emptyz&Pseudo-header b':path' cannot be empty)set UPPERCASEsearchr startswithadd differencesorted) rrrrafter_pseudo_headers authoritypathschemeseen_pseudo_headersextracted_header_valuekeyrmissings rBvalidate_headersrs !"IDF&)ee+/(( U   C  MKKKKLL L  %*@*H%* " >>$   (# "QSQQQ000"#HC#H#H#HIII)))"#MC#M#M#MNNN  # #C ( ( (m##!  ""$( &001DEEGLJVG__JJJKKK $$$ NLMM M IGHH H !!rANonec^t|tdtddS)N):methodrrrrrr frozensetrs rBvalidate_push_promise_headersrsH( =  !* =! ! rAc^t|tdtddS)N)rrrrs :protocol)rrrrrs rBvalidate_request_headersr sG( L  !**E F FrA int | Nonect|tdtdd}|dS t|S#t$rYdSwxYw)N):statusr)rrr)rrr ValueError)r status_codes rBvalidate_response_headersrst 0(77 )- 8 8! !!!Kt; ttsA AAcZt|ttdS)Nrrrs rBvalidate_trailersr)s4({{ ) rAc&eZdZd dZd dZd dZd S) H3Stream stream_idrrrcd|_d|_d|_d|_d|_d|_t j|_t j|_ d|_ d|_ ||_ d|_ d|_d|_dS)NFrA)blockedblocked_frame_sizebufferended frame_sizerrTrUheaders_recv_stateheaders_send_statepush_id session_idr stream_typereceiving_ended sending_ended)rsrs rBrtzH3Stream.__init__2sv .2  &*&*0<0D0<0D#' &*"'+$"rAboolc.|jo|jo|j Srr)rrrrss rBis_endedzH3Stream.is_endedBs!Od&:O4!"<== =!rAN)rrrr)rrrr)r)r*r+rtrrr@rArBrr1sT#### PPPP""""""rArceZdZdZdd Zd?dZd@dZdAdZdBdZ d>!*--.    rAeventr list[H3Event]cR|js t|tr||St|tr||jSnD#t$r7}d|_|j |j |j Yd}~nd}~wwxYwgS)zx Handle a QUIC event and return a list of HTTP events. :param event: The QUIC event to handle. T)rvroN) r isinstancer_receive_stream_datar_receive_datagramrrmrcloservro)rsrexcs rB handle_eventzH3Connection.handle_events}  e%788>44U;;;'<==>11%*===>     $    "~S=N!   s)A#.A## B$--BB$flow_idrrcZ|jt||zdS)z Send a datagram for the specified flow. :param flow_id: The flow ID. :param data: The HTTP/3 datagram payload. N)rsend_datagram_framer)rsr%rs rB send_datagramzH3Connection.send_datagrams- &&w'?'?$'FGGGGGrArrrc |jr Jd|j|j|jkrt|j}|xjdz c_|j|t tjt|| ||z| tj |}|j|t||S)a Send a push promise related to the specified stream. Returns the stream ID on which headers and data can be sent. :param stream_id: The stream ID on which to send the data. :param headers: The HTTP request headers for this push. z%Only servers may send a push promise.Nr)r)rrr r rrrrDrNr_encode_headersrrerh)rsrrrpush_stream_ids rBsend_push_promisezH3Connection.send_push_promises?KK$KKKK   $(:d>O(O(O( ($ a ##  &((4+?+? 7+S+SS     00'0RR ##NOG4L4LMMMrA end_streamc ||5}|jtjkrt d|r|dddn #1swxYwY|jD|jdd|jt|||j |ttj||dS)a Send data on the given stream. To retrieve datagram which need to be sent over the network call the QUIC connection's :meth:`~qh3.connection.QuicConnection.datagrams_to_send` method. :param stream_id: The stream ID on which to send the data. :param data: The data to send. :param end_stream: Whether to end the stream. 'DATA frame is not allowed in this stateNhttp frame_createdlengthrcategoryrr)_get_or_create_streamrrTrVrrr log_eventencode_http3_data_framerrrrrDrI)rsrrr-streams rB send_datazH3Connection.send_datas4 ' ' 2 2 (f(L,FFF%&OPPP (%%'''  ( ( ( ( ( ( ( ( ( ( ( ( ( ( (   (   ' '%&>>t99 ? (    ## |IND99:     s;AA!$A!c ||5}|jtjkrt d|r||||}|jE|jdd|j t||||jtj kr\d}|j s?|s=|D]:\}}|dkrt|d krd }n#|d sn;|stj|_ntj|_|j|t%t&j||ddddS#1swxYwYdS) a Send headers on the given stream. To retrieve datagram which need to be sent over the network call the QUIC connection's :meth:`~qh3.connection.QuicConnection.datagrams_to_send` method. :param stream_id: The stream ID on which to send the headers. :param headers: The HTTP headers to send. :param end_stream: Whether to end the stream. *HEADERS frame is not allowed in this stateNr0r1r3rrr4FrTr)r6rrTrWrrr*rr7encode_http3_headers_framerrUrrrrVrrrrDrJ) rsrrr-r9ris_informational_headerskvs rB send_headerszH3Connection.send_headerss ' ' 2 2' f(L,GGG%&RSSS (%%'''--iAAJ ,!++#)*EE":9F,(L,@@@+0("z" '""1 ??"1vv||;? 8 % ,"#d!3!3"!E"0K0<0JF-,8,G) J ' '< (9:FF    K' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' sEE66E:=E:dict[int, int] | Nonec|jS)z> Return the received SETTINGS frame, or None. )rrs rBreceived_settingszH3Connection.received_settings%s &&rAc|jS)z: Return the sent SETTINGS frame, or None. )rrs rB sent_settingszH3Connection.sent_settings,s ""rANrrrc|jd}|||||j|t ||S)zD Create an unidirectional stream of the given type. T)rrrr)rrrrr)rsrrrs rBrzH3Connection._create_uni_stream3shJ;;d;SS  yk     ##I{/K/KLLLrArrcl |#|j|j\}}|j|`n.|st|j||\}}|xjt |z c_|j|j |n!#t$r}t|d}~wwxYw|S)z Decode a HEADERS block and send decoder updates on the decoder stream. This is called with frame_data=None when a stream becomes unblocked. N) r_pendingr r feed_headerrrrrr rx)rsrrdecoderrr#s rB_decode_headerszH3Connection._decode_headers>s 6!#'#;I#F#O ,Y7@@"0-///#'=#<#)rr)rrrr_z"Clients must not send PUSH_PROMISEr)r3rrr)rrrz$Invalid frame type on request streamz!Invalid frame type on push stream)&rDrIrrTrVrappendrrrrJrWrOrUrrrrrr7r?rrrrrNrrtellrencode_http3_push_promise_framerrKrLrMrOrPrQ) rsrrr9r_ http_eventsrr frame_bufrs rB_handle_request_or_push_framez*H3Connection._handle_request_or_push_frames &(  ' '(L,FFF%&OPPP z "" ' &%1"("2 9, , ,(L,GGG%&RSSS**6+;ZHHG&*K(L,@@@?6";G"D"DKK,W5555!'*** ,!++#(*EE *1#55!$Z '"("2F,   (L,@@@&+*<*< *<0<0JF-,8,G))\-AAA+#%%""0 '"("2""# ' &"("2%1 91 1 1fn6L? L%&JKKKJ///I--//G** *Y^^-=-=-?-?"@G *' 2 2 2 ,!++#(*JJ": ' '"("2 K,      ##W@P         !    "    !  $   ">)768  rAc T|tj|_||_|j|jttj t|j|j rQ|j J|j|jttjt|j |tj|_|tj|_dSrr)rrergr rVrrrrrDrMrrrrPrrir rjr rs rBrzH3Connection._init_connection)s(,(?(? @R(S(S%"6688 ##  ) +_T=P-Q-Q R R    ? t0< J ' '-Y2ODDU4V4VWW    )-(?(?  $) ) %)-(?(?  $) ) %%%rAc|jGdddddd|d}||d}|||d <|jd d | dSdS) Ncontrolpush qpack_encoder qpack_decoder webtransport)rrrr#rfunknown)newrassociated_push_idr0stream_type_setr4)rr]r7)rsrrr type_namers rBrzH3Connection._log_stream_type?s   (""$  c+y)) %9==D"-4)*   ' '' (      ) (rAct|} |}n#t$rtdwxYwt ||d|gS)z$ Handle a datagram. rzCould not parse flow IDN)rr%)rrr rmrrc)rsrrr%s rBr!zH3Connection._receive_datagramUs}$ ;''))GG ; ; ; 9:: : ; d388::<<&8'JJJKKs 'Arc(|j}||5}t|r-|||j|jcdddS|||j|jcdddS#1swxYwYdSrr)rr6r_receive_stream_data_unirr-_receive_request_or_push_data)rsrrr9s rBr z!H3Connection._receive_stream_data`sO  ' ' 2 2 f' 22 44EJ(8         99EJ(8                   s0B BB B c ,g}|xj|z c_|rd|_|jr|S|jtjkrE|j>|t|j|j|j |d|_|S|jtj kr|j }t|j|j kr`|t|j|j|j d|xj t|jzc_ d|_|S|r9|js2|td|j|j d|St|j}d}|s|j P ||_||_ n#t$$rYn8wxYw|}|jtjkr|j |_d|_ |j|d}d|_||j t*j |s|r0|t||j|j ||S|jV|jtj krA|jd d |j|j |j  t5|j |j|z }|jtj kr ||j krn||}|j} |}|xj |zc_ |j sd|_ d|_ ||| |||jo|n:#t>$r-d|_t||_ ||j!|j <YnwxYw||j|d|_|S)zC Handle data received on a request or push stream. TN)rrrr_rAF)rrrr_rrrr0rar2r4rrr9r_)"rrrrrDrRrrbrrrIrrrrrrrr rcrrerkrr7r8minr pull_bytesextendrgrrr) rsr9rr_rerconsumedr chunk_sizers rBrwz*H3Connection._receive_request_or_push_datams &(    *%)F " >    !> > >!-   .%0$.!-     FM    / /!-FM""V%666   "N$.!&       V]!3!3 3  FM       "N$.!%     &-(((''))K  ((+(9(9(;(;F%(+(9(9(;(;F%%&E88::$ (EEE(.(9F%(,F%!'xyy!9J$'FM))"("2 @W*"\#**:%/+1+<*0*:-9 '&%1)Y^;;%//!',!.FF#)#4@PG0V. x0GHHJ IN22zFDU7U7U 33J*JxxzzH    +  $ )$(!$(! ""66#-#-%%+%;%I 7!   !%,/ OO)=C()9:  O''))K \ hii0 s%2F;; G G +AN114O('O(c 4 g}|xj|z c_|rd|_t|j}d}t}|jt jt jt jfvs| sc|j | |_n#t$rYn3wxYw| }|jt jkr#|j td|j|_ no|jt jkr#|jtd|j|_n7|jt jkr"|jtd|j|_|jt jkr!||j|j|jt jkr|rt+d | }| } || } n#t$rYnwxYw| }||| n\|jt jkr|jg | |_n#t$rYnXwxYw| }||j|j|j |j|d|_||d |S|jt jkr|j@ | |_n#t$rYnwxYw| }|j|d} d |_| s|r5|t9| |j|j|j |S|jt jkr||j| z }| } |j|n!#t@$r} tC| d} ~ wwxYw|xj"tG|z c_"nM|jt jkr ||j| z }| } |j$%|n!#tL$r} tO| d} ~ wwxYw|j()D]Q\} } |j$*| \}}||f| _+|,| B#tZ$rYNwxYw|xj.tG|z c_.n.|/|j| }|jt jt jt jfvN| c|j|d|_|D]}|j0|}|1|2tfj4d||jo|j d |_5d|_6|j(|=|jr/|1||d |j|S)NTrrz"Only one control stream is allowedz(Only one QPACK decoder stream is allowedz(Only one QPACK encoder stream is allowedrz%Closing control stream is not allowedrJrA)rrr_rryF)7rrrrrrerhrgrkrrr rcr rrrjrrirrrr{r^rrwrrbrrr feed_decoderr r{rrr feed_encoderr r}rr resume_headerrLrrrseekrr|rgrDrJrr)rsr9rr_rerr}unblocked_streamsrrrr# blocked_idblocked_stream stream_datarrs rBrvz%H3Connection._receive_stream_data_unis&(    *%)F "&-(((&)ee  !3Z5LM N N7799 N !)),):):)<))),):):)<)<*"xxzzH)) &"("2$*$6*!' hii 8 99&#|TTT#z'>>>$,,/,=,=,?,?))*"xxzzH#]8995 # &&6!+'-'8)/)?&,&6 #"#z'???~~clSXXZZ&?@@88::=M..t4444)===133<=,,D 9,,,#z'???~~clSXXZZ&?@@88::=M..t4444)===133<=372J2P2P2R2R ! !.J!/3}/J/J:/V/V, W'#3/*--j9999(!!! !,,D 9,,,&&&88::y  !3Z5LM N N7799 N~ hii0 +  I\),F   22(0#!!'!7!M > J  J L,, L:9L:;P P4 P//P40S S)S$$S) ;U UUrctjtjtjfD]'}||vr!||dvrt |jd(|tjdkr|jjt d|tjdkr2|tjdkrt ddSdS)N)rrz setting must be 0 or 1rz@H3_DATAGRAM requires max_datagram_frame_size transport parameterz(ENABLE_WEBTRANSPORT requires H3_DATAGRAM) rYr`rbrarnamer]r_remote_max_datagram_frame_size)rsrrs rBr[zH3Connection._validate_settingss  +  '    N NG (""x'8'F'F#w|$L$L$LMMM LL, - - 2 2 :BR  LL4 5 5 : : W011Q66 JKK K ; :66rA)F)rrrrrr)rrrrrr)rrrr)r%rrrrr)rrrrrr)rrrrr-rrr)rrrrr-rrr)rrDrr)rrrrrr)rrrrrr)rrrrrr)rrrrS)rr)rrrrrr) rrrrr9rr_rrrr)rrrrrrrr)rrrr)rrrr)r9rrrr_rrr)rrrr)r)r*r+rurtrr$r(r,r:rCpropertyrFrHrrOr* contextlibcontextmanagerr6rVr^rgrrr!r rwrvr[r@rArBrrLsc " " " " " J:?0*HHHH<     FDI66666p'''X' ###X#     .     , , , ,    JJJJ@HHHHT    .GK, L L L L    OOOObjjjjXLLLLLLrAr)rrrrrr)rrrr)rrrr)rrrrrr) rrrrrrrrrr)rrrr)rrrr)J __future__rrloggingretypingenumrr_compatr_hazmatrr r r r r rrrquic.connectionrr quic.eventsrrr quic.loggerreventsrrrrrrrr exceptionsr getLoggerloggerH3_ALPNrcompilerr'rDrTrYre Exceptionrmrxr{r}rrrrrrrrrrrrrrrrrr@rArBrsl"""""" ''''''                      GFFFFFFFNNNNNNNNNN))))))                    /.....  7 # # &- BJx ''''''''.        4 g" + + + + +I + + +66666}66666666m66666666m66655555=555/////m///,,,,,=,,,/////=///-----M---44444-444    $$( 7"7"7"7"7"t        """""""""6s Ls Ls Ls Ls Ls Ls Ls Ls Ls LrA