o @BiG@sddlmZddlZddlmZmZmZmZmZdZ Gddde Z Gdddee Z Gd d d ee Z Gd d d ee ZGd ddee ZGdddee ZdS))absolute_importN)PerMessageCompressOfferPerMessageCompressOfferAcceptPerMessageCompressResponse PerMessageCompressResponseAcceptPerMessageCompress)PerMessageBzip2MixinPerMessageBzip2OfferPerMessageBzip2OfferAcceptPerMessageBzip2ResponsePerMessageBzip2ResponseAcceptPerMessageBzip2c@seZdZdZdZ gdZdS)rz) Mixin class for this extension. zpermessage-bzip2)  N)__name__ __module__ __qualname____doc__EXTENSION_NAME!COMPRESS_LEVEL_PERMISSIBLE_VALUESrra/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/websocket/compress_bzip2.pyr/s rc@sBeZdZdZeddZ  dddZdd Zd d Zd d Z dS)r zu Set of extension parameters for `permessage-bzip2` WebSocket extension offered by a client to a server. c Csd}d}|D]`}t||dkrtd||jf||d}|dkr4|dur1td|||jfd}q|dkr^zt|}Wn td|||jf|tjvr[td|||jf|}qtd ||jf|||}|S) aQ Parses a WebSocket extension offer for `permessage-bzip2` provided by a client to a server. :param params: Output from :func:`autobahn.websocket.WebSocketProtocol._parseExtensionsHeader`. :type params: list :returns: object -- A new instance of :class:`autobahn.compress.PerMessageBzip2Offer`. FrrBmultiple occurrence of extension parameter '%s' for extension '%s'client_max_compress_levelTKillegal extension parameter value '%s' for parameter '%s' of extension '%s'server_max_compress_level3illegal extension parameter '%s' for extension '%s'len Exceptionrintrr)clsparamsaccept_max_compress_levelrequest_max_compress_levelpvalofferrrrparseEs.    zPerMessageBzip2Offer.parseTrcCsPt|tkrtdt|||_|dkr#||jvr#td||jf||_dS)a_ Constructor. :param accept_max_compress_level: Iff true, client accepts "maximum compression level" parameter. :type accept_max_compress_level: bool :param request_max_compress_level: Iff non-zero, client requests given "maximum compression level" - must be 1-9. :type request_max_compress_level: int z-invalid type %s for accept_max_compress_levelrGinvalid value %s for request_max_compress_level - permissible values %sN)typeboolr&r*rr+)selfr*r+rrr__init__ss  zPerMessageBzip2Offer.__init__cCs0|j}|jr |d7}|jdkr|d|j7}|S) Returns the WebSocket extension configuration string as sent to the server. :returns: PMCE configuration string. :rtype: str z; client_max_compress_levelr; server_max_compress_level=%drr*r+r3 pmce_stringrrrget_extension_strings  z)PerMessageBzip2Offer.get_extension_stringcC|j|j|jdS) Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict ) extensionr*r+r7r3rrr__json__zPerMessageBzip2Offer.__json__cCd|j|jfS) Returns Python object representation that can be eval'ed to reconstruct the object. :returns: Python string representation. :rtype: str zUPerMessageBzip2Offer(accept_max_compress_level = %s, request_max_compress_level = %s))r*r+r>rrr__repr__zPerMessageBzip2Offer.__repr__N)Tr) rrrr classmethodr/r4r:r?rCrrrrr ?s .  r c@s6eZdZdZ  d ddZddZdd Zd d ZdS) r zk Set of parameters with which to accept an `permessage-bzip2` offer from a client by a server. rNcCst|ts tdt|||_|dkr"||jvr"td||jf|dkr/|js/td|||_|durT||jvrDtd||jf|jdkrT||jkrTtd|||_dS)a Constructor. :param offer: The offer being accepted. :type offer: Instance of :class:`autobahn.compress.PerMessageBzip2Offer`. :param request_max_compress_level: Iff non-zero, server requests given "maximum compression level" - must be 1-9. :type request_max_compress_level: int :param compress_level: Override server ("server-to-client direction") compress level (this must be compatible with offer). :type compress_level: int zinvalid type %s for offerrr0zOinvalid value %s for request_max_compress_level - feature unsupported by clientN;invalid value %s for compress_level - permissible values %szJinvalid value %s for compress_level - client requested lower maximum value) isinstancer r&r1r.rr*r+compress_level)r3r.r+rHrrrr4s     z#PerMessageBzip2OfferAccept.__init__cCs>|j}|jjdkr|d|jj7}|jdkr|d|j7}|S)r5rr6z; client_max_compress_level=%d)rr.r+r8rrrr:s   z/PerMessageBzip2OfferAccept.get_extension_stringcCs|j|j|j|jdS)r<)r=r.r+rH)rr.r?r+rHr>rrrr?s z#PerMessageBzip2OfferAccept.__json__cCsd|j|j|jfS)rBzWPerMessageBzip2Accept(offer = %s, request_max_compress_level = %s, compress_level = %s))r.rCr+rHr>rrrrCsz#PerMessageBzip2OfferAccept.__repr__)rN)rrrrr4r:r?rCrrrrr s $ r c@s4eZdZdZeddZddZddZdd Zd S) r zG Set of parameters for `permessage-bzip2` responded by server. c Csd}d}|D]u}t||dkrtd||jf||d}|dkrIzt|}Wn td|||jf|tjvrFtd|||jf|}q|dkrszt|}Wn td|||jf|tjvrptd|||jf|}qtd||jf|||}|S)aa Parses a WebSocket extension response for `permessage-bzip2` 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.PerMessageBzip2Response`. :rtype: obj rrrr r!r"r#r$)r(r)r r"r,r-responserrrr/s6      zPerMessageBzip2Response.parsecCs||_||_dSNr r")r3r r"rrrr4.s z PerMessageBzip2Response.__init__cCr;)r<)r=r r")rr r"r>rrrr?4r@z PerMessageBzip2Response.__json__cCrA)rBzWPerMessageBzip2Response(client_max_compress_level = %s, server_max_compress_level = %s)rKr>rrrrC?rDz PerMessageBzip2Response.__repr__N) rrrrrEr/r4r?rCrrrrr s / r c@s,eZdZdZ d ddZddZddZdS) r zn Set of parameters with which to accept an `permessage-bzip2` response from a server by a client. NcCsnt|ts tdt|||_|dur2||jvr"td||jf|jdkr2||jkr2td|||_dS)a@ :param response: The response being accepted. :type response: Instance of :class:`autobahn.compress.PerMessageBzip2Response`. :param compress_level: Override client ("client-to-server direction") compress level (this must be compatible with response). :type compress_level: int zinvalid type %s for responseNrFrzJinvalid value %s for compress_level - server requested lower maximum value)rGr r&r1rIrr rH)r3rIrHrrrr4Os    z&PerMessageBzip2ResponseAccept.__init__cCs|j|j|jdS)r<)r=rIrH)rrIr?rHr>rrrr?gsz&PerMessageBzip2ResponseAccept.__json__cCsd|j|jfS)rBzAPerMessageBzip2ResponseAccept(response = %s, compress_level = %s))rIrCrHr>rrrrCrsz&PerMessageBzip2ResponseAccept.__repr__rJ)rrrrr4r?rCrrrrr Is   r c@steZdZdZdZeddZeddZddZd d Z d d Z d dZ ddZ ddZ ddZddZddZdS)r z; `permessage-bzip2` WebSocket extension processor. rcCs.|||jj|jdur|j}|S|jj}|SrJ)rIr"rHr r( is_serveracceptpmcerrrcreate_from_response_acceptsz+PerMessageBzip2.create_from_response_acceptcCs&|||jdur |jn|jj|j}|SrJ)rHr.r+rLrrrcreate_from_offer_accepts z(PerMessageBzip2.create_from_offer_acceptcCsD||_d|_d|_|dkr|n|j|_|dkr||_dS|j|_dS)Nr) _isServer _compressor _decompressorDEFAULT_COMPRESS_LEVELr"r )r3rMr"r rrrr4s zPerMessageBzip2.__init__cCs|j|j|j|jdS)N)r=isServerr"r )rrRr"r r>rrrr?s zPerMessageBzip2.__json__cCsd|j|j|jfS)Nz^PerMessageBzip2(isServer = %s, server_max_compress_level = %s, client_max_compress_level = %s))rRr"r r>rrrrCszPerMessageBzip2.__repr__cCsF|jr|jdurt|j|_dSdS|jdur!t|j|_dSdSrJ)rRrSbz2 BZ2Compressorr"r r>rrrstart_compress_messages  z&PerMessageBzip2.start_compress_messagecC |j|SrJ)rScompressr3datarrrcompress_message_data z%PerMessageBzip2.compress_message_datacCs|j}d|_|SrJ)rSflushr\rrrend_compress_messages z$PerMessageBzip2.end_compress_messagecCs|jdur t|_dSdSrJ)rTrWBZ2Decompressorr>rrrstart_decompress_messages z(PerMessageBzip2.start_decompress_messagecCrZrJ)rT decompressr\rrrdecompress_message_datar_z'PerMessageBzip2.decompress_message_datacCs d|_dSrJ)rTr>rrrend_decompress_messages z&PerMessageBzip2.end_decompress_messageN)rrrrrUrErPrQr4r?rCrYr^rarcrerfrrrrr |s      r ) __future__rrW autobahn.websocket.compress_baserrrrr__all__objectrr r r r r rrrrs  lNP3