tfBddlZddlmZmZmZmZmZdZGddeZ Gddee Z Gdd ee Z Gd d ee Z Gd d ee Z Gddee ZdS)N)PerMessageCompressOfferPerMessageCompressOfferAcceptPerMessageCompressResponse PerMessageCompressResponseAcceptPerMessageCompress)PerMessageSnappyMixinPerMessageSnappyOfferPerMessageSnappyOfferAcceptPerMessageSnappyResponsePerMessageSnappyResponseAcceptPerMessageSnappyceZdZdZdZdS)rz) Mixin class for this extension. zpermessage-snappyN)__name__ __module__ __qualname____doc__EXTENSION_NAMEa/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/websocket/compress_snappy.pyrr-s%)NrrcFeZdZdZedZ d dZdZdZdZ d S) r zv Set of extension parameters for `permessage-snappy` WebSocket extension offered by a client to a server. c d}d}|D]}t||dkrtd|d|jd||d}|dkr%|durtd |d |d |jdd}o|d kr%|durtd |d |d |jdd}td |d|jd|||}|S)a] Parses a WebSocket extension offer for `permessage-snappy` provided by a client to a server. :param params: Output from :func:`autobahn.websocket.WebSocketProtocol._parseExtensionsHeader`. :type params: list :returns: A new instance of :class:`autobahn.compress.PerMessageSnappyOffer`. :rtype: obj F,multiple occurrence of extension parameter '' for extension ''rclient_no_context_takeoverT#illegal extension parameter value '' for parameter '' of extension 'server_no_context_takeoverillegal extension parameter 'len Exceptionr)clsparamsaccept_no_context_takeoverrequest_no_context_takeoverpvaloffers rparsezPerMessageSnappyOffer.parse>s&+"&+# q qA6!9~~!!ihihihiknk}k}k} ~)A,C000d??#)uxuxuxz{z{z{~A~P~P~P%QRRR15..222d??#)uxuxuxz{z{z{~A~P~P~P%QRRR26// iYZYZYZ\_\n\n\n oppp./11 rTFct|tkrtdt|z||_t|tkrtdt|z||_dS)a0 :param accept_no_context_takeover: Iff true, client accepts "no context takeover" feature. :type accept_no_context_takeover: bool :param request_no_context_takeover: Iff true, client request "no context takeover" feature. :type request_no_context_takeover: bool z.invalid type %s for accept_no_context_takeover/invalid type %s for request_no_context_takeoverN)typeboolr%r(r))selfr(r)s r__init__zPerMessageSnappyOffer.__init__js} * + +t 3 3LtTnOoOoopp p*D' + , , 4 4MPTUpPqPqqrr r+F(((rcD|j}|jr|dz }|jr|dz }|S) Returns the WebSocket extension configuration string as sent to the server. :returns: PMCE configuration string. :rtype: str ; client_no_context_takeover; server_no_context_takeoverrr(r)r2 pmce_strings rget_extension_stringz*PerMessageSnappyOffer.get_extension_string~s>)  * : 9 9K  + : 9 9Krc,|j|j|jdS) Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict ) extensionr(r)r8r2s r__json__zPerMessageSnappyOffer.__json__s("0.2.M/3/OQQ Qrc(d|jd|jdS) Returns Python object representation that can be eval'ed to reconstruct the object. :returns: Python string representation. :rtype: str z3PerMessageSnappyOffer(accept_no_context_takeover = , request_no_context_takeover = ))r(r)r?s r__repr__zPerMessageSnappyOffer.__repr__sHnrnMnMnMOSOoOoOop prN)TF) rrrr classmethodr-r3r;r@rErrrr r 8s ))[)X-1-2GGGG(    Q Q Qppppprr c0eZdZdZ ddZdZdZdZdS) r zl Set of parameters with which to accept an `permessage-snappy` offer from a client by a server. FNct|tstdt|z||_t|t krtdt|z|r|jstd|z||_|Rt|t krtdt|z|jr|std|z||_dS)a :param offer: The offer being accepted. :type offer: Instance of :class:`autobahn.compress.PerMessageSnappyOffer`. :param request_no_context_takeover: Iff true, server request "no context takeover" feature. :type request_no_context_takeover: bool :param no_context_takeover: Override server ("server-to-client direction") context takeover (this must be compatible with offer). :type no_context_takeover: bool zinvalid type %s for offerr/zPinvalid value %s for request_no_context_takeover - feature unsupported by clientN'invalid type %s for no_context_takeoverzCinvalid value %s for no_context_takeover - client requested feature) isinstancer r%r0r,r1r(r)no_context_takeover)r2r,r)rKs rr3z$PerMessageSnappyOfferAccept.__init__s%!677 G7$u++EFF F + , , 4 4MPTUpPqPqqrr r & Nu/O NnrMMNN N+F(  *'((D00 IDQdLeLe efff0 }9L } eh{ {|||#6   rcN|j}|jjr|dz }|jr|dz }|S)r5r7r6)rr,r)r9s rr;z0PerMessageSnappyOfferAccept.get_extension_strings@) : 1 : 9 9K  + : 9 9Krc\|j|j|j|jdS)r=)r>r,r)rK)rr,r@r)rKr?s rr@z$PerMessageSnappyOfferAccept.__json__s9"0,,../3/O'+'?AA Arc\d|jd|jd|jdS)rBzPerMessageSnappyAccept(offer = rC, no_context_takeover = rD)r,rEr)rKr?s rrEz$PerMessageSnappyOfferAccept.__repr__s|txs}tGtGtItItItIKOKkKkKkmqmEmEmEF Fr)FN)rrrrr3r;r@rErrrr r sp.3%)!7!7!7!7F    A A AFFFFFrr c:eZdZdZedZdZdZdZdS)r zH Set of parameters for `permessage-snappy` responded by server. c d}d}|D]}t||dkrtd|d|jd||d}|dkr%|durtd |d |d |jdd}o|d kr%|durtd |d |d |jdd}td |d|jd|||}|S)ac Parses a WebSocket extension response for `permessage-snappy` provided by a server to a client. :param params: Output from :func:`autobahn.websocket.WebSocketProtocol._parseExtensionsHeader`. :type params: list :returns: A new instance of :class:`autobahn.compress.PerMessageSnappyResponse`. :rtype: obj FrrrrrrTrrr r!r"r#)r&r'rr!r*r+responses rr-zPerMessageSnappyResponse.parses&+"%*" q qA6!9~~!!ihihihiknk}k}k} ~)A,C000d??#)uxuxuxz{z{z{~A~P~P~P%QRRR15..222d??#)uxuxuxz{z{z{~A~P~P~P%QRRR15.. iYZYZYZ\_\n\n\n oppp31133rc"||_||_dSNrr!)r2rr!s rr3z!PerMessageSnappyResponse.__init__s+E'*D'''rc,|j|j|jdS)r=)r>rr!)rrr!r?s rr@z!PerMessageSnappyResponse.__json__#s("0.2.M.2.MOO Orc(d|jd|jdS)rBz6PerMessageSnappyResponse(client_no_context_takeover = , server_no_context_takeover = rDrUr?s rrEz!PerMessageSnappyResponse.__repr__.sHptpOpOpOQUQpQpQpq qrN) rrrrrFr-r3r@rErrrr r sr''['REEE O O Oqqqqqrr c(eZdZdZ ddZdZdZdS)r zo Set of parameters with which to accept an `permessage-snappy` response from a server by a client. Nc2t|tstdt|z||_|Rt|t krtdt|z|jr|std|z||_dS)aN :param response: The response being accepted. :type response: Instance of :class:`autobahn.compress.PerMessageSnappyResponse`. :param no_context_takeover: Override client ("client-to-server direction") context takeover (this must be compatible with response). :type no_context_takeover: bool zinvalid type %s for responseNrIzCinvalid value %s for no_context_takeover - server requested feature)rJr r%r0rRr1rrK)r2rRrKs rr3z'PerMessageSnappyResponseAccept.__init__>s($<== M:T(^^KLL L   *'((D00 IDQdLeLe efff2 };N } eh{ {|||#6   rcP|j|j|jdS)r=)r>rRrK)rrRr@rKr?s rr@z'PerMessageSnappyResponseAccept.__json__Vs3"0 M2244'+'?AA ArcLd|jd|jdS)rBz*PerMessageSnappyResponseAccept(response = rOrD)rRrErKr?s rrEz'PerMessageSnappyResponseAccept.__repr__asD]a\i\r\r\t\t\t\tvzwOwOwOP PrrT)rrrrr3r@rErrrr r 8s]&*77770 A A APPPPPrr cteZdZdZedZedZdZdZdZ dZ dZ d Z d Z d Zd Zd S)r z< `permessage-snappy` WebSocket extension processor. cd|||jj|j|jn |jj}|SrT)rRr!rKrr& is_serveracceptpmces rcreate_from_response_acceptz,PerMessageSnappy.create_from_response_acceptpsDs9?=171K1W6--]c]l^HII rcZ|||j|jn |jj|j}|SrT)rKr,r)r_s rcreate_from_offer_acceptz)PerMessageSnappy.create_from_offer_acceptws@s9171K1W6--]c]i^F577 rcL||_||_||_d|_d|_dSrT) _is_serverr!r _compressor _decompressor)r2r`r!rs rr3zPerMessageSnappy.__init__~s1$*D'*D'!rc,|j|j|jdS)N)r>r!r)rr!rr?s rr@zPerMessageSnappy.__json__s&!0.2.M.2.MOO Orc8d|jd|jd|jdS)NzPerMessageSnappy(is_server = rXz, client_no_context_takeover = rD)rgr!rr?s rrEzPerMessageSnappy.__repr__s`w{xGxGxGIMIhIhIhjnjIjIjIJ Jrc|jr*|j|jrtj|_dSdS|j|jrtj|_dSdSrT)rgrhr!snappyStreamCompressorrr?s rstart_compress_messagez'PerMessageSnappy.start_compress_messagesn ? ='4+J'#)#:#<#<   (''4+J'#)#:#<#<   ('rc6|j|SrT)rh add_chunkr2datas rcompress_message_dataz&PerMessageSnappy.compress_message_datas))$///rcdS)Nrrr?s rend_compress_messagez%PerMessageSnappy.end_compress_messagessrc|jr*|j|jrtj|_dSdS|j|jrtj|_dSdSrT)rgrirrmStreamDecompressorr!r?s rstart_decompress_messagez)PerMessageSnappy.start_decompress_messageso ? A!)T-L)%+%>%@%@"""*)!)T-L)%+%>%@%@"""*)rc6|j|SrT)ri decompressrrs rdecompress_message_dataz(PerMessageSnappy.decompress_message_datas!,,T222rcdSrTrr?s rend_decompress_messagez'PerMessageSnappy.end_decompress_messages rN)rrrrrFrcrer3r@rErortrvryr|r~rrrr r ks[ [ " " "OOO JJJ===000AAA333     rr )rm autobahn.websocket.compress_baserrrrr__all__objectrr r r r r rrrrs6   Ffpfpfpfpfp35JfpfpfpRJFJFJFJFJF"?AVJFJFJFZGqGqGqGqGq9;PGqGqGqT0P0P0P0P0P%EG\0P0P0Pf@ @ @ @ @ )+@@ @ @ @ @ r