o £U¤g‹Gã@s–ddlZddlmZmZmZmZmZdZGdd„deƒZ Gdd„dee ƒZ Gdd „d ee ƒZ Gd d „d ee ƒZ Gd d „d ee ƒZ Gdd„dee ƒZdS)éN)ÚPerMessageCompressOfferÚPerMessageCompressOfferAcceptÚPerMessageCompressResponseÚ PerMessageCompressResponseAcceptÚPerMessageCompress)ÚPerMessageBzip2MixinÚPerMessageBzip2OfferÚPerMessageBzip2OfferAcceptÚPerMessageBzip2ResponseÚPerMessageBzip2ResponseAcceptÚPerMessageBzip2c@seZdZdZdZ gd¢ZdS)rz) Mixin class for this extension. zpermessage-bzip2) ééééééééé N)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚEXTENSION_NAMEÚ!COMPRESS_LEVEL_PERMISSIBLE_VALUES©rrúm/var/www/html/Testing_prj/Navya-Bakers/venv/lib/python3.10/site-packages/autobahn/websocket/compress_bzip2.pyr-s rc@sBeZdZdZedd„ƒZ  ddd„Zdd „Zd d „Zd d „Z dS)rzu Set of extension parameters for `permessage-bzip2` WebSocket extension offered by a client to a server. c CsÜd}d}|D]`}t||ƒdkrtd||jfƒ‚||d}|dkr4|dur1td|||jfƒ‚d}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_levelTúKillegal extension parameter value '%s' for parameter '%s' of extension '%s'Úserver_max_compress_levelú3illegal extension parameter '%s' for extension '%s'©ÚlenÚ ExceptionrÚintrr)ÚclsÚparamsÚaccept_max_compress_levelÚrequest_max_compress_levelÚpÚvalÚofferrrrÚparseCs.    ÿ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_levelrúGinvalid value %s for request_max_compress_level - permissible values %sN)ÚtypeÚboolr%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=%d©rr)r*©r2Ú pmce_stringrrrÚget_extension_string†s  z)PerMessageBzip2Offer.get_extension_stringcCó|j|j|jdœS)úŽ Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict )Ú extensionr)r*r6©r2rrrÚ__json__”óþzPerMessageBzip2Offer.__json__cCód|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 dd„Zdd„Zdd „Zd d „ZdS) r zk Set of parameters with which to accept an `permessage-bzip2` offer from a client by a server. rNcCs²t|tƒs 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*rGrrrr3¯s     z#PerMessageBzip2OfferAccept.__init__cCs>|j}|jjdkr|d|jj7}|jdkr|d|j7}|S)r4rr5z; client_max_compress_level=%d)rr-r*r7rrrr9Ós   z/PerMessageBzip2OfferAccept.get_extension_stringcCs|j|j ¡|j|jdœS)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=rrrrBísz#PerMessageBzip2OfferAccept.__repr__)rN)rrrrr3r9r>rBrrrrr ©s ý$ r c@s4eZdZdZedd„ƒZdd„Zdd„Zdd „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||_||_dS©N©rr!)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 dd„Zdd„Zdd„ZdS) r zn Set of parameters with which to accept an `permessage-bzip2` response from a server by a client. NcCsnt|tƒs 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 ¡|jdœS)r;)r<rHrG)rrHr>rGr=rrrr>esþz&PerMessageBzip2ResponseAccept.__json__cCsd|j ¡|jfS)rAzAPerMessageBzip2ResponseAccept(response = %s, compress_level = %s))rHrBrGr=rrrrBpsz&PerMessageBzip2ResponseAccept.__repr__rI)rrrrr3r>rBrrrrr Gs  þ r c@steZdZdZdZedd„ƒZedd„ƒZdd„Zd d „Z d d „Z d d„Z dd„Z dd„Z dd„Zdd„Zdd„ZdS)r z; `permessage-bzip2` WebSocket extension processor. rcCs.|||jj|jdur|jƒ}|S|jjƒ}|SrI)rHr!rGr©r'Ú is_serverÚacceptÚpmcerrrÚcreate_from_response_accept€sþÿþz+PerMessageBzip2.create_from_response_acceptcCs&|||jdur |jn|jj|jƒ}|SrI)rGr-r*rKrrrÚcreate_from_offer_accept‡s þz(PerMessageBzip2.create_from_offer_acceptcCsD||_d|_d|_|dkr|n|j|_|dkr||_dS|j|_dS)Nr)Ú _isServerÚ _compressorÚ _decompressorÚDEFAULT_COMPRESS_LEVELr!r)r2rLr!rrrrr3Žs zPerMessageBzip2.__init__cCs|j|j|j|jdœS)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=rrrrBŸszPerMessageBzip2.__repr__cCsF|jr|jdurt |j¡|_dSdS|jdur!t |j¡|_dSdSrI)rQrRÚbz2Ú BZ2Compressorr!rr=rrrÚstart_compress_message¢s ÿ ÿz&PerMessageBzip2.start_compress_messagecCó |j |¡SrI)rRÚcompress©r2ÚdatarrrÚcompress_message_dataªó z%PerMessageBzip2.compress_message_datacCs|j ¡}d|_|SrI)rRÚflushr[rrrÚend_compress_message­s z$PerMessageBzip2.end_compress_messagecCs|jdur t ¡|_dSdSrI)rSrVÚBZ2Decompressorr=rrrÚstart_decompress_message¶s ÿz(PerMessageBzip2.start_decompress_messagecCrYrI)rSÚ decompressr[rrrÚdecompress_message_dataºr^z'PerMessageBzip2.decompress_message_datacCs d|_dSrI)rSr=rrrÚend_decompress_message½s z&PerMessageBzip2.end_decompress_messageN)rrrrrTrDrOrPr3r>rBrXr]r`rbrdrerrrrr zs      r )rVÚ autobahn.websocket.compress_baserrrrrÚ__all__Úobjectrrr r r r rrrrÚs lNP3