o èó·i‹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úgC:\Users\psant\Downloads\PAF backend\school\venv\Lib\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'N©Ú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=%dN©rr)r*©r2Z 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*Nr6©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)N)r)r*r<rrrÚ__repr__ŸózPerMessageBzip2Offer.__repr__N)Tr) rrrrÚ classmethodr.r3r8r=rArrrrr=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*rFrrrr3¯s     z#PerMessageBzip2OfferAccept.__init__cCs>|j}|jjdkr|d|jj7}|jdkr|d|j7}|S)r4rr5z; client_max_compress_level=%dN)rr-r*r7rrrr8Ós   z/PerMessageBzip2OfferAccept.get_extension_stringcCs|j|j ¡|j|jdœS)r:)r;r-r*rFN)rr-r=r*rFr<rrrr=ás ýz#PerMessageBzip2OfferAccept.__json__cCsd|j ¡|j|jfS)r@zWPerMessageBzip2Accept(offer = %s, request_max_compress_level = %s, compress_level = %s)N)r-rAr*rFr<rrrrAísz#PerMessageBzip2OfferAccept.__repr__)rN)rrrrr3r8r=rArrrrr ©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"Nr#)r'r(rr!r+r,Úresponserrrr.üs6      ÿzPerMessageBzip2Response.parsecCs||_||_dS©N©rr!)r2rr!rrrr3,s z PerMessageBzip2Response.__init__cCr9)r:)r;rr!N)rrr!r<rrrr=2r>z PerMessageBzip2Response.__json__cCr?)r@zWPerMessageBzip2Response(client_max_compress_level = %s, server_max_compress_level = %s)NrIr<rrrrA=rBz PerMessageBzip2Response.__repr__N) rrrrrCr.r3r=rArrrrr ÷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 responseNrDrzJinvalid value %s for compress_level - server requested lower maximum value)rEr r%r0rGrrrF)r2rGrFrrrr3Ms    z&PerMessageBzip2ResponseAccept.__init__cCs|j|j ¡|jdœS)r:)r;rGrFN)rrGr=rFr<rrrr=esþz&PerMessageBzip2ResponseAccept.__json__cCsd|j ¡|jfS)r@zAPerMessageBzip2ResponseAccept(response = %s, compress_level = %s)N)rGrArFr<rrrrApsz&PerMessageBzip2ResponseAccept.__repr__rH)rrrrr3r=rArrrrr 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ƒ}|SrH)rGr!rFr©r'Ú is_serverÚacceptZpmcerrrÚcreate_from_response_accept€sþÿþz+PerMessageBzip2.create_from_response_acceptcCs&|||jdur |jn|jj|jƒ}|SrH)rFr-r*rJrrrÚ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)r2rKr!rrrrr3Žs zPerMessageBzip2.__init__cCs|j|j|j|jdœS)N)r;ZisServerr!r)rrOr!rr<rrrr=™s ýzPerMessageBzip2.__json__cCsd|j|j|jfS)Nz^PerMessageBzip2(isServer = %s, server_max_compress_level = %s, client_max_compress_level = %s))rOr!rr<rrrrAŸszPerMessageBzip2.__repr__cCsF|jr|jdurt |j¡|_dSdS|jdur!t |j¡|_dSdSrH)rOrPÚbz2Ú BZ2Compressorr!rr<rrrÚstart_compress_message¢s ÿ ÿz&PerMessageBzip2.start_compress_messagecCó |j |¡SrH)rPÚcompress©r2ÚdatarrrÚcompress_message_dataªó z%PerMessageBzip2.compress_message_datacCs|j ¡}d|_|SrH)rPÚflushrXrrrÚend_compress_message­s z$PerMessageBzip2.end_compress_messagecCs|jdur t ¡|_dSdSrH)rQrSÚBZ2Decompressorr<rrrÚstart_decompress_message¶s ÿz(PerMessageBzip2.start_decompress_messagecCrVrH)rQÚ decompressrXrrrÚdecompress_message_dataºr[z'PerMessageBzip2.decompress_message_datacCs d|_dSrH)rQr<rrrÚend_decompress_message½s z&PerMessageBzip2.end_decompress_messageN)rrrrrRrCrMrNr3r=rArUrZr]r_rarbrrrrr zs      r )rSZ autobahn.websocket.compress_baserrrrrÚ__all__Úobjectrrr r r r rrrrÚs lNP3