o @BiSB@sddlmZddlZddlmZmZmZmZmZdZ Gddde Z Gdddee Z Gd d d ee Z Gd d d ee ZGd ddee ZGdddee ZdS))absolute_importN)PerMessageCompressOfferPerMessageCompressOfferAcceptPerMessageCompressResponse PerMessageCompressResponseAcceptPerMessageCompress)PerMessageSnappyMixinPerMessageSnappyOfferPerMessageSnappyOfferAcceptPerMessageSnappyResponsePerMessageSnappyResponseAcceptPerMessageSnappyc@seZdZdZdZdS)rz) Mixin class for this extension. zpermessage-snappyN)__name__ __module__ __qualname____doc__EXTENSION_NAMErrb/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/websocket/compress_snappy.pyr/src@sBeZdZdZeddZ  dddZdd Zd d Zd d Z dS)r zv Set of extension parameters for `permessage-snappy` WebSocket extension offered by a client to a server. cCd}d}|D]K}t||dkrtd||jf||d}|dkr4|dur1td|||jfd}q|dkrI|durFtd|||jfd}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 FBmultiple occurrence of extension parameter '%s' for extension '%s'rclient_no_context_takeoverTKillegal extension parameter value '%s' for parameter '%s' of extension '%s'server_no_context_takeover3illegal extension parameter '%s' for extension '%s'len Exceptionr)clsparamsaccept_no_context_takeoverrequest_no_context_takeoverpvalofferrrrparse@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)typeboolrr!r")selfr!r"rrr__init__ls   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_takeoverrr!r"r* pmce_stringrrrget_extension_strings z*PerMessageSnappyOffer.get_extension_stringcC|j|j|jdS) Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict ) extensionr!r"r/r*rrr__json__zPerMessageSnappyOffer.__json__cCd|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"r6rrr__repr__zPerMessageSnappyOffer.__repr__N)TF) rrrr classmethodr&r+r2r7r;rrrrr :s ,  r c@s6eZdZdZ  d ddZddZdd Zd d ZdS) r zl Set of parameters with which to accept an `permessage-snappy` offer from a client by a server. FNcCst|ts 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) isinstancer rr(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"r0rrrr2s z0PerMessageSnappyOfferAccept.get_extension_stringcCs|j|j|j|jdS)r4)r5r%r"r@)rr%r7r"r@r6rrrr7s z$PerMessageSnappyOfferAccept.__json__cCsd|j|j|jfS)r:z^PerMessageSnappyAccept(offer = %s, request_no_context_takeover = %s, no_context_takeover = %s))r%r;r"r@r6rrrr;sz$PerMessageSnappyOfferAccept.__repr__)FN)rrrrr+r2r7r;rrrrr s # r c@s4eZdZdZeddZddZddZdd 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)rr rrr#r$responserrrr&s&  zPerMessageSnappyResponse.parsecCs||_||_dSNrr)r*rrrrrr+s z!PerMessageSnappyResponse.__init__cCr3)r4)r5rr)rrrr6rrrr7%r8z!PerMessageSnappyResponse.__json__cCr9)r:zZPerMessageSnappyResponse(client_no_context_takeover = %s, server_no_context_takeover = %s)rCr6rrrr;0r<z!PerMessageSnappyResponse.__repr__N) rrrrr=r&r+r7r;rrrrr s ) r c@s,eZdZdZ d ddZddZddZdS) r zo Set of parameters with which to accept an `permessage-snappy` response from a server by a client. NcCsdt|ts 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(rAr)rr@)r*rAr@rrrr+@s     z'PerMessageSnappyResponseAccept.__init__cCs|j|j|jdS)r4)r5rAr@)rrAr7r@r6rrrr7Xsz'PerMessageSnappyResponseAccept.__json__cCsd|j|jfS)r:zGPerMessageSnappyResponseAccept(response = %s, no_context_takeover = %s))rAr;r@r6rrrr;csz'PerMessageSnappyResponseAccept.__repr__rB)rrrrr+r7r;rrrrr :s   r c@speZdZdZeddZeddZddZdd Zd d Z d d Z ddZ ddZ ddZ ddZddZdS)r z< `permessage-snappy` WebSocket extension processor. cCs.|||jj|jdur|j}|S|jj}|SrB)rArr@rr is_serveracceptpmcerrrcreate_from_response_acceptrsz,PerMessageSnappy.create_from_response_acceptcCs&|||jdur |jn|jj|j}|SrB)r@r%r"rDrrrcreate_from_offer_acceptys z)PerMessageSnappy.create_from_offer_acceptcCs"||_||_||_d|_d|_dSrB) _is_serverrr _compressor _decompressor)r*rErrrrrr+s  zPerMessageSnappy.__init__cCr3)N)r5rr)rrrr6rrrr7szPerMessageSnappy.__json__cCsd|j|j|jfS)NzbPerMessageSnappy(is_server = %s, server_no_context_takeover = %s, client_no_context_takeover = %s))rJrrr6rrrr;szPerMessageSnappy.__repr__cCJ|jr|jdus |jrt|_dSdS|jdus|jr#t|_dSdSrB)rJrKrsnappyStreamCompressorrr6rrrstart_compress_messagez'PerMessageSnappy.start_compress_messagecC |j|SrB)rK add_chunkr*datarrrcompress_message_data z&PerMessageSnappy.compress_message_datacCsdS)Nrr6rrrend_compress_messagez%PerMessageSnappy.end_compress_messagecCrMrB)rJrLrrNStreamDecompressorrr6rrrstart_decompress_messagerQz)PerMessageSnappy.start_decompress_messagecCrRrB)rL decompressrTrrrdecompress_message_datarWz(PerMessageSnappy.decompress_message_datacCsdSrBrr6rrrend_decompress_messagerZz'PerMessageSnappy.end_decompress_messageN)rrrrr=rHrIr+r7r;rPrVrYr\r^r_rrrrr ms    r ) __future__rrN autobahn.websocket.compress_baserrrrr__all__objectrr r r r r rrrrs   iMJ3