8'hSBddlmZddlZddlmZmZmZmZmZdZ Gdde Z Gddee Z Gd d ee Z Gd d ee ZGd dee ZGddee Zy))absolute_importN)PerMessageCompressOfferPerMessageCompressOfferAcceptPerMessageCompressResponse PerMessageCompressResponseAcceptPerMessageCompress)PerMessageSnappyMixinPerMessageSnappyOfferPerMessageSnappyOfferAcceptPerMessageSnappyResponsePerMessageSnappyResponseAcceptPerMessageSnappyceZdZdZdZy)r z) Mixin class for this extension. zpermessage-snappyN)__name__ __module__ __qualname____doc__EXTENSION_NAME^/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/websocket/compress_snappy.pyr r /s)Nrr c>eZdZdZedZ ddZdZdZdZ y) r zv Set of extension parameters for `permessage-snappy` WebSocket extension offered by a client to a server. c zd}d}|D]}t||dkDrtd|d|jd||d}|dk(r&|durtd |d |d |jdd}c|d k(r&|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&+"&+# qA6!9~!hiknk}k} ~)A,C00d?#uxz{~A~P~P%QRR15.22d?#uxz{~A~P~P%QRR26/ YZ\_\n\n opp- q0./1 rct|tk7rtdt|z||_t|tk7rtdt|z||_y)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__ls_ * +t 3LtTnOoop p*D' + , 4MPTUpPqqr r+F(rcb|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*r3 pmce_strings rget_extension_stringz*PerMessageSnappyOffer.get_extension_strings=))  * * 9 9K  + + 9 9KrcJ|j|j|jdS) Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict ) extensionr)r*r9r3s r__json__zPerMessageSnappyOffer.__json__s+"00.2.M.M/3/O/OQ 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__s8nrnMnMOSOoOop prN)TF) rrrr classmethodr.r4r<rArFrrrr r :s; ))X-1-2G(  Qprr c.eZdZdZ ddZdZdZdZy)r zl Set of parameters with which to accept an `permessage-snappy` offer from a client by a server. Nct|tstdt|z||_t|t k7rtdt|z|r|j std|z||_|Et|t k7rtdt|z|jr|std|z||_y)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 offerr0zPinvalid 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&r1r-r2r)r*no_context_takeover)r3r-r*rLs rr4z$PerMessageSnappyOfferAccept.__init__s%!677$u+EF F + , 4MPTUpPqqr r &u/O/OnrMMN N+F(  *'(D0 IDQdLe eff009L eh{ {||#6 rcv|j}|jjr|dz }|jr|dz }|S)r6r8r7)rr-r*r:s rr<z0PerMessageSnappyOfferAccept.get_extension_stringsA)) :: 1 1 9 9K  + + 9 9Krc||j|jj|j|jdS)r>)r?r-r*rL)rr-rAr*rLr@s rrAz$PerMessageSnappyOfferAccept.__json__s;"00,,./3/O/O'+'?'?A Arcrd|jjd|jd|jdS)rCzPerMessageSnappyAccept(offer = rD, no_context_takeover = rE)r-rFr*rLr@s rrFz$PerMessageSnappyOfferAccept.__repr__sZtxs}s}tGtGtIKOKkKkmqmEmEF Fr)FN)rrrrr4r<rArFrrrr r s&.3%)!7F  AFrr c2eZdZdZedZdZdZdZy)r zH Set of parameters for `permessage-snappy` responded by server. c zd}d}|D]}t||dkDrtd|d|jd||d}|dk(r&|durtd |d |d |jdd}c|d k(r&|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 FrrrrrrTrr r!r"r#r$)r'r(rr"r+r,responses rr.zPerMessageSnappyResponse.parses&+"%*" qA6!9~!hiknk}k} ~)A,C00d?#uxz{~A~P~P%QRR15.22d?#uxz{~A~P~P%QRR15. YZ\_\n\n opp- q0113rc ||_||_yNrr")r3rr"s rr4z!PerMessageSnappyResponse.__init__s+E'*D'rcJ|j|j|jdS)r>)r?rr")rrr"r@s rrAz!PerMessageSnappyResponse.__json__%s+"00.2.M.M.2.M.MO Orc<d|jd|jdS)rCz6PerMessageSnappyResponse(client_no_context_takeover = , server_no_context_takeover = rErVr@s rrFz!PerMessageSnappyResponse.__repr__0s8ptpOpOQUQpQpq qrN) rrrrrGr.r4rArFrrrr r s.''RE Oqrr c&eZdZdZ ddZdZdZy)r zo Set of parameters with which to accept an `permessage-snappy` response from a server by a client. Nct|tstdt|z||_|Et|t k7rtdt|z|j r|std|z||_y)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 responseNrJzCinvalid value %s for no_context_takeover - server requested feature)rKr r&r1rSr2rrL)r3rSrLs rr4z'PerMessageSnappyResponseAccept.__init__@s|($<=:T(^KL L   *'(D0 IDQdLe eff22;N eh{ {||#6 rcf|j|jj|jdS)r>)r?rSrL)rrSrArLr@s rrAz'PerMessageSnappyResponseAccept.__json__Xs2"00 MM224'+'?'?A ArcXd|jjd|jdS)rCz*PerMessageSnappyResponseAccept(response = rPrE)rSrFrLr@s rrFz'PerMessageSnappyResponseAccept.__repr__cs5]a\i\i\r\r\tvzwOwOP PrrU)rrrrr4rArFrrrr r :s&*70 APrr cfeZdZdZedZedZdZdZdZ dZ dZ d Z d Z d Zd Zy )rz< `permessage-snappy` WebSocket extension processor. c|||jj|j|j}|S|jj}|SrU)rSr"rLrr' is_serveracceptpmces rcreate_from_response_acceptz,PerMessageSnappy.create_from_response_acceptrsa9??==171K1K1W6--I ^d]l]l^H^HI rc|||j |jn|jj|j}|SrU)rLr-r*r`s rcreate_from_offer_acceptz)PerMessageSnappy.create_from_offer_acceptysI9171K1K1W6--]c]i]i^F^F557 rcJ||_||_||_d|_d|_yrU) _is_serverr"r _compressor _decompressor)r3rar"rs rr4zPerMessageSnappy.__init__s+$*D'*D'!rcJ|j|j|jdS)N)r?r"r)rr"rr@s rrAzPerMessageSnappy.__json__s)!00.2.M.M.2.M.MO OrcVd|jd|jd|jdS)NzPerMessageSnappy(is_server = rYz, client_no_context_takeover = rE)rhr"rr@s rrFzPerMessageSnappy.__repr__sIw{xGxGIMIhIhjnjIjIJ Jrc|jr3|j |jrtj|_yy|j |j rtj|_yyrU)rhrir"snappyStreamCompressorrr@s rstart_compress_messagez'PerMessageSnappy.start_compress_messagesa ??'4+J+J#)#:#:#< ,K'4+J+J#)#:#:#< ,Krc8|jj|SrU)ri add_chunkr3datas rcompress_message_dataz&PerMessageSnappy.compress_message_datas))$//rcy)Nrrr@s rend_compress_messagez%PerMessageSnappy.end_compress_messagesrc|jr3|j |jrtj|_yy|j |j rtj|_yyrU)rhrjrrnStreamDecompressorr"r@s rstart_decompress_messagez)PerMessageSnappy.start_decompress_messagesa ??!!)T-L-L%+%>%>%@".M!!)T-L-L%+%>%>%@".Mrc8|jj|SrU)rj decompressrss rdecompress_message_dataz(PerMessageSnappy.decompress_message_datas!!,,T22rcyrUrr@s rend_decompress_messagez'PerMessageSnappy.end_decompress_messages rN)rrrrrGrdrfr4rArFrprurwrzr}rrrrrrms_  "O J=0A3 rr) __future__rrn autobahn.websocket.compress_baserrrrr__all__objectr r r r r rrrrrs6'   Ffp35JfpRJF"?AVJFZGq9;PGqT0P%EG\0Pf@ )+@@ r