mbi ddlmZddlZddlZddlmZddlmZmZddl m Z ddl m Z ddl mZmZdd lmZmZmZmZdd lmZdd lmZmZd d lmZmZdgZGddejZedddddd%d$Z dS)&) annotationsN)partial)Callablecast)Buffer)QuicConfiguration)NetworkAddressQuicConnection)QuicPacketTypeencode_quic_retryencode_quic_version_negotiationpull_quic_header)QuicRetryTokenHandler)SessionTicketFetcherSessionTicketHandler)QuicConnectionProtocolQuicStreamHandlerservecReZdZedddddd#dZdZd$dZd%dZd&d Zd'd!Z d(d"Z dS)) QuicServerNFcreate_protocolsession_ticket_fetchersession_ticket_handlerretrystream_handler configurationr rrrSessionTicketFetcher | NonerSessionTicketHandler | NonerboolrQuicStreamHandler | NonereturnNonec||_||_tj|_i|_||_||_d|_||_ |rt|_ dSd|_ dSN) _configuration_create_protocolasyncioget_running_loop_loop _protocols_session_ticket_fetcher_session_ticket_handler _transport_stream_handlerr_retry)selfrrrrrrs b/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/qh3/asyncio/server.py__init__zQuicServer.__init__sn, /-// ?A'=$'=$<@-  /11DKKKDKKKct|jD]}||j|jdSr')setr-valuescloseclearr0)r3protocols r4r:zQuicServer.close2shDO224455  H NN      r6 transportasyncio.BaseTransportcDttj||_dSr')rr*DatagramTransportr0)r3r=s r4connection_madezQuicServer.connection_made8sw8)DDr6data bytes | straddrr c @tt|}t|} t||jj}n#t $rYdSwxYw|jT|j|jjvrA|j t|j |j |jj|dS|j|j d}d}d}|t!|dkr|jt$jkr|j|jsqt-jd}|j t1|j||j |j |j||j ||dS |j||j\}}n#t $rYdSwxYw|j }t7|j|||j|j} || |j}| |j tC|j"| |_#tC|j$| |_%tC|j&| |_'||j|j <||j| j(<||)||dSdS) N)rB)host_cid_length) source_ciddestination_cidsupported_versionsi)versionrGrHoriginal_destination_cid retry_token)r"original_destination_connection_idretry_source_connection_idrr)r)r<)*rbytesrrr(connection_id_length ValueErrorrKrIr0sendtorrHrGr-getlen packet_typer INITIALr2tokenosurandomr create_tokenvalidate_tokenr r.r/r)r1rAr_connection_id_issued_connection_id_issued_handler_connection_id_retired_connection_id_retired_handler_connection_terminated_connection_terminated_handlerhost_ciddatagram_received) r3rBrDbufheaderr<rNrOrG connections r4rdzQuicServer.datagram_received;sE4  $ %T%8%MFF    FF  N &d&9&LLL O " "/%5$*$5'+':'M      F?&&v'=tDD;?*37"  D T!!"n&<<<{&|!#AJO**)$*N'1,2,=5;5K(, (@(@ $f&66%6<5K2("13U+E'+'C'+'C J,,4+?-H  $ $T_ 5 5 56=*X666H 27>+h777H 37>+h777H 37?DOF2 33;DOJ/ 0    & &tT 2 2 2 2 2 s#A AA#F$$ F21F2cidrPr<rc||j|<dSr'r-r3rhr<s r4r]z QuicServer._connection_id_issueds'r6c<|j||ksJ|j|=dSr'rjrks r4r_z!QuicServer._connection_id_retireds,s#x//// OC r6czt|jD]\}}||kr|j|=dSr')listr-items)r3r<rhprotos r4raz!QuicServer._connection_terminatedsKt446677 ) )JC  OC( ) )r6)rr rrrr rr!rr"rr#r$r%)r=r>r$r%)rBrCrDr r$r%)rhrPr<r)rhrPr<rr$r%)r<r) __name__ __module__ __qualname__rr5r:rArdr]r_rar6r4rrs %;>B>B372   EEEE\3\3\3\3|((((!!!! ))))))r6rFrhoststrportintrr rrrr rr!rr"rrr$cKtj}|fd||fd{V\} } | S)aQ Start a QUIC server at the given `host` and `port`. :func:`serve` requires a :class:`~qh3.quic.configuration.QuicConfiguration` containing TLS certificate and private key as the ``configuration`` argument. :func:`serve` also accepts the following optional arguments: * ``create_protocol`` allows customizing the :class:`~asyncio.Protocol` that manages the connection. It should be a callable or class accepting the same arguments as :class:`~qh3.asyncio.QuicConnectionProtocol` and returning an instance of :class:`~qh3.asyncio.QuicConnectionProtocol` or a subclass. * ``session_ticket_fetcher`` is a callback which is invoked by the TLS engine when a session ticket is presented by the peer. It should return the session ticket with the specified ID or `None` if it is not found. * ``session_ticket_handler`` is a callback which is invoked by the TLS engine when a new session ticket is issued. It should store the session ticket for future lookup. * ``retry`` specifies whether client addresses should be validated prior to the cryptographic handshake using a retry packet. * ``stream_handler`` is a callback which is invoked whenever a stream is created. It must accept two arguments: a :class:`asyncio.StreamReader` and a :class:`asyncio.StreamWriter`. c.tS)N)rrrrrr)r)rrrrrrsr4zserve..s( '+#9#9)    r6) local_addrN)r*r+create_datagram_endpoint) rurwrrrrrrloop_r<s `````` r4rrsH  # % %D55         $<6        KAx Or6)rurvrwrxrr rrrr rr!rr"rrr$r)! __future__rr*rY functoolsrtypingrr_hazmatrquic.configurationr quic.connectionr r quic.packetr r rr quic.retryrtlsrrr<rr__all__DatagramProtocolrrrtr6r4rs"""""" !!!!!!!!222222<<<<<<<< /.....<<<<<<<<???????? )M)M)M)M)M))M)M)M)j!7:>:>(,11111111r6