o ¼>hBã@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)ÚPerMessageSnappyMixinÚPerMessageSnappyOfferÚPerMessageSnappyOfferAcceptÚPerMessageSnappyResponseÚPerMessageSnappyResponseAcceptÚPerMessageSnappyc@seZdZdZdZdS)rz) Mixin class for this extension. zpermessage-snappyN)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚEXTENSION_NAME©rrú‚/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/websocket/compress_snappy.pyr-src@sBeZdZdZedd„ƒZ  ddd„Zdd „Zd d „Zd d „Z dS)rzv Set of extension parameters for `permessage-snappy` WebSocket extension offered by a client to a server. cCó²d}d}|D]K}t||ƒdkrtd||jfƒ‚||d}|dkr4|dur1td|||jfƒ‚d}q|dkrI|durFtd|||jfƒ‚d}qtd ||jfƒ‚|||ƒ}|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éúBmultiple occurrence of extension parameter '%s' for extension '%s'rÚclient_no_context_takeoverTúKillegal extension parameter value '%s' for parameter '%s' of extension '%s'Úserver_no_context_takeoverú3illegal extension parameter '%s' for extension '%s'©ÚlenÚ Exceptionr)ÚclsÚparamsÚaccept_no_context_takeoverÚrequest_no_context_takeoverÚpÚvalÚofferrrrÚparse>s&  ÿzPerMessageSnappyOffer.parseTFcCsHt|ƒtkrtdt|ƒƒ‚||_t|ƒtkrtdt|ƒƒ‚||_dS)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)ÚtypeÚboolrr r!)Úselfr r!rrrÚ__init__js   zPerMessageSnappyOffer.__init__cCs&|j}|jr |d7}|jr|d7}|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_takeover©rr r!©r)Ú pmce_stringrrrÚget_extension_string~s z*PerMessageSnappyOffer.get_extension_stringcCó|j|j|jdœS)úŽ Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict )Ú extensionr r!r.©r)rrrÚ__json__ŒóþzPerMessageSnappyOffer.__json__cCód|j|jfS)úª Returns Python object representation that can be eval'ed to reconstruct the object. :returns: Python string representation. :rtype: str zXPerMessageSnappyOffer(accept_no_context_takeover = %s, request_no_context_takeover = %s))r r!r5rrrÚ__repr__—ózPerMessageSnappyOffer.__repr__N)TF) r rrrÚ classmethodr%r*r1r6r:rrrrr8s , þ rc@s6eZdZdZ  d dd„Zdd„Zdd „Zd d „ZdS) r zl Set of parameters with which to accept an `permessage-snappy` offer from a client by a server. FNcCsœt|tƒs tdt|ƒƒ‚||_t|ƒtkrtdt|ƒƒ‚|r)|js)td|ƒ‚||_|durIt|ƒtkr>tdt|ƒƒ‚|jrI|sItd|ƒ‚||_dS)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 offerr&zPinvalid 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) Ú isinstancerrr'r$r(r r!Úno_context_takeover)r)r$r!r?rrrr*§s        z$PerMessageSnappyOfferAccept.__init__cCs(|j}|jjr |d7}|jr|d7}|S)r+r-r,)rr$r!r/rrrr1Ês z0PerMessageSnappyOfferAccept.get_extension_stringcCs|j|j ¡|j|jdœS)r3)r4r$r!r?)rr$r6r!r?r5rrrr6Øs ýz$PerMessageSnappyOfferAccept.__json__cCsd|j ¡|j|jfS)r9z^PerMessageSnappyAccept(offer = %s, request_no_context_takeover = %s, no_context_takeover = %s))r$r:r!r?r5rrrr:äsz$PerMessageSnappyOfferAccept.__repr__)FN)r rrrr*r1r6r:rrrrr ¡s ý# r c@s4eZdZdZedd„ƒZdd„Zdd„Zdd „Zd S) r zH Set of parameters for `permessage-snappy` responded by server. cCr) 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 FrrrrTrrrr)rrrrr"r#Úresponserrrr%ós&  ÿzPerMessageSnappyResponse.parsecCs||_||_dS©N©rr)r)rrrrrr*s z!PerMessageSnappyResponse.__init__cCr2)r3)r4rr)rrrr5rrrr6#r7z!PerMessageSnappyResponse.__json__cCr8)r9zZPerMessageSnappyResponse(client_no_context_takeover = %s, server_no_context_takeover = %s)rBr5rrrr:.r;z!PerMessageSnappyResponse.__repr__N) r rrrr<r%r*r6r:rrrrr îs ) r c@s,eZdZdZ d dd„Zdd„Zdd„ZdS) r zo Set of parameters with which to accept an `permessage-snappy` response from a server by a client. NcCsdt|tƒs tdt|ƒƒ‚||_|dur-t|ƒtkr"tdt|ƒƒ‚|jr-|s-td|ƒ‚||_dS)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 responseNr=zCinvalid value %s for no_context_takeover - server requested feature)r>r rr'r@r(rr?)r)r@r?rrrr*>s     z'PerMessageSnappyResponseAccept.__init__cCs|j|j ¡|jdœS)r3)r4r@r?)rr@r6r?r5rrrr6Vsþz'PerMessageSnappyResponseAccept.__json__cCsd|j ¡|jfS)r9zGPerMessageSnappyResponseAccept(response = %s, no_context_takeover = %s))r@r:r?r5rrrr:asz'PerMessageSnappyResponseAccept.__repr__rA)r rrrr*r6r:rrrrr 8s  þ r c@speZdZdZedd„ƒZedd„ƒZdd„Zdd „Zd d „Z d d „Z dd„Z dd„Z dd„Z dd„Zdd„ZdS)r z< `permessage-snappy` WebSocket extension processor. cCs.|||jj|jdur|jƒ}|S|jjƒ}|SrA)r@rr?r©rÚ is_serverÚacceptÚpmcerrrÚcreate_from_response_acceptpsþÿþz,PerMessageSnappy.create_from_response_acceptcCs&|||jdur |jn|jj|jƒ}|SrA)r?r$r!rCrrrÚcreate_from_offer_acceptws þz)PerMessageSnappy.create_from_offer_acceptcCs"||_||_||_d|_d|_dSrA)Ú _is_serverrrÚ _compressorÚ _decompressor)r)rDrrrrrr*~s  zPerMessageSnappy.__init__cCr2)N)r4rr)rrrr5rrrr6‰sþzPerMessageSnappy.__json__cCsd|j|j|jfS)NzbPerMessageSnappy(is_server = %s, server_no_context_takeover = %s, client_no_context_takeover = %s))rIrrr5rrrr:ŽszPerMessageSnappy.__repr__cCóJ|jr|jdus |jrt ¡|_dSdS|jdus|jr#t ¡|_dSdSrA)rIrJrÚsnappyÚStreamCompressorrr5rrrÚstart_compress_message‘óÿÿz'PerMessageSnappy.start_compress_messagecCó |j |¡SrA)rJÚ add_chunk©r)ÚdatarrrÚcompress_message_data™ó z&PerMessageSnappy.compress_message_datacCsdS)Nórr5rrrÚend_compress_messageœóz%PerMessageSnappy.end_compress_messagecCrLrA)rIrKrrMÚStreamDecompressorrr5rrrÚstart_decompress_messageŸrPz)PerMessageSnappy.start_decompress_messagecCrQrA)rKÚ decompressrSrrrÚdecompress_message_data§rVz(PerMessageSnappy.decompress_message_datacCsdSrArr5rrrÚend_decompress_messageªrYz'PerMessageSnappy.end_decompress_messageN)r rrrr<rGrHr*r6r:rOrUrXr[r]r^rrrrr ks    r )rMÚ autobahn.websocket.compress_baserrrrrÚ__all__Úobjectrrr r r r rrrrÚs  iMJ3