o >hG@sddlZddlmZmZmZmZmZdZGdddeZ Gdddee Z Gdd d ee Z Gd d d ee Z Gd d d ee Z Gdddee ZdS)N)PerMessageCompressOfferPerMessageCompressOfferAcceptPerMessageCompressResponse PerMessageCompressResponseAcceptPerMessageCompress)PerMessageBzip2MixinPerMessageBzip2OfferPerMessageBzip2OfferAcceptPerMessageBzip2ResponsePerMessageBzip2ResponseAcceptPerMessageBzip2c@seZdZdZdZ gdZdS)rz) Mixin class for this extension. zpermessage-bzip2)  N)__name__ __module__ __qualname____doc__EXTENSION_NAME!COMPRESS_LEVEL_PERMISSIBLE_VALUESrr/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/websocket/compress_bzip2.pyr-s rc@sBeZdZdZeddZ  dddZdd Zd d Zd d Z dS)rzu 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`. Frr Bmultiple 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_levelpvalofferrrrparseCs.    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__qs  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*r2 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*r6r2rrr__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.r3r9r>rBrrrrr=s .  rc@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 offerrr/zOinvalid 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) isinstancerr%r0r-rr)r*compress_level)r2r-r*rGrrrr3s     z#PerMessageBzip2OfferAccept.__init__cCs>|j}|jjdkr|d|jj7}|jdkr|d|j7}|S)r4rr5z; client_max_compress_level=%d)rr-r*r7rrrr9s   z/PerMessageBzip2OfferAccept.get_extension_stringcCs|j|j|j|jdS)r;)r<r-r*rG)rr-r>r*rGr=rrrr>s z#PerMessageBzip2OfferAccept.__json__cCsd|j|j|jfS)rAzWPerMessageBzip2Accept(offer = %s, request_max_compress_level = %s, compress_level = %s))r-rBr*rGr=rrrrBsz#PerMessageBzip2OfferAccept.__repr__)rN)rrrrr3r9r>rBrrrrr 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 rr rrr r!r"r#)r'r(rr!r+r,responserrrr.s6      zPerMessageBzip2Response.parsecCs||_||_dSNrr!)r2rr!rrrr3,s z PerMessageBzip2Response.__init__cCr:)r;)r<rr!)rrr!r=rrrr>2r?z PerMessageBzip2Response.__json__cCr@)rAzWPerMessageBzip2Response(client_max_compress_level = %s, server_max_compress_level = %s)rJr=rrrrB=rCz PerMessageBzip2Response.__repr__N) rrrrrDr.r3r>rBrrrrr 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 responseNrErzJinvalid value %s for compress_level - server requested lower maximum value)rFr r%r0rHrrrG)r2rHrGrrrr3Ms    z&PerMessageBzip2ResponseAccept.__init__cCs|j|j|jdS)r;)r<rHrG)rrHr>rGr=rrrr>esz&PerMessageBzip2ResponseAccept.__json__cCsd|j|jfS)rAzAPerMessageBzip2ResponseAccept(response = %s, compress_level = %s))rHrBrGr=rrrrBpsz&PerMessageBzip2ResponseAccept.__repr__rI)rrrrr3r>rBrrrrr Gs   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}|SrI)rHr!rGrr' is_serveracceptpmcerrrcreate_from_response_acceptsz+PerMessageBzip2.create_from_response_acceptcCs&|||jdur |jn|jj|j}|SrI)rGr-r*rKrrrcreate_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)r2rLr!rrrrr3s zPerMessageBzip2.__init__cCs|j|j|j|jdS)N)r<isServerr!r)rrQr!rr=rrrr>s zPerMessageBzip2.__json__cCsd|j|j|jfS)Nz^PerMessageBzip2(isServer = %s, server_max_compress_level = %s, client_max_compress_level = %s))rQr!rr=rrrrBszPerMessageBzip2.__repr__cCsF|jr|jdurt|j|_dSdS|jdur!t|j|_dSdSrI)rQrRbz2 BZ2Compressorr!rr=rrrstart_compress_messages  z&PerMessageBzip2.start_compress_messagecC |j|SrI)rRcompressr2datarrrcompress_message_data z%PerMessageBzip2.compress_message_datacCs|j}d|_|SrI)rRflushr[rrrend_compress_messages z$PerMessageBzip2.end_compress_messagecCs|jdur t|_dSdSrI)rSrVBZ2Decompressorr=rrrstart_decompress_messages z(PerMessageBzip2.start_decompress_messagecCrYrI)rS decompressr[rrrdecompress_message_datar^z'PerMessageBzip2.decompress_message_datacCs d|_dSrI)rSr=rrrend_decompress_messages z&PerMessageBzip2.end_decompress_messageN)rrrrrTrDrOrPr3r>rBrXr]r`rbrdrerrrrr zs      r )rV autobahn.websocket.compress_baserrrrr__all__objectrrr r r r rrrrs lNP3