hBddlZddlmZmZmZmZmZdZGddeZ Gddee Z Gdd ee Z Gd d ee Z Gd d ee Z Gddee Zy)N)PerMessageCompressOfferPerMessageCompressOfferAcceptPerMessageCompressResponse PerMessageCompressResponseAcceptPerMessageCompress)PerMessageSnappyMixinPerMessageSnappyOfferPerMessageSnappyOfferAcceptPerMessageSnappyResponsePerMessageSnappyResponseAcceptPerMessageSnappyceZdZdZdZy)rz) Mixin class for this extension. zpermessage-snappyN)__name__ __module__ __qualname____doc__EXTENSION_NAME^/var/www/Befach/backend/env/lib/python3.12/site-packages/autobahn/websocket/compress_snappy.pyrr-s)Nrrc>eZdZdZedZ ddZdZdZdZ y) r zv Set of extension parameters for `permessage-snappy` WebSocket extension offered by a client to a server. c zd}d}|D]}t||dkDrtd|d|jd||d}|dk(r&|durtd |d |d |jdd}c|d k(r&|durtd |d |d |jdd}td |d|jd|||}|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,multiple occurrence of extension parameter '' for extension ''rclient_no_context_takeoverT#illegal extension parameter value '' for parameter '' of extension 'server_no_context_takeoverillegal extension parameter 'len Exceptionr)clsparamsaccept_no_context_takeoverrequest_no_context_takeoverpvaloffers rparsezPerMessageSnappyOffer.parse>s&+"&+#A6!9~!hiknk}k} ~)A,C00d?#uxz{~A~P~P%QRR15.22d?#uxz{~A~P~P%QRR26/ YZ\_\n\n opp-0./1 rct|tk7rtdt|z||_t|tk7rtdt|z||_y)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)typeboolr%r(r))selfr(r)s r__init__zPerMessageSnappyOffer.__init__js_ * +t 3LtTnOoop p*D' + , 4MPTUpPqqr r+F(rcb|j}|jr|dz }|jr|dz }|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)r2 pmce_strings rget_extension_stringz*PerMessageSnappyOffer.get_extension_string~s=))  * * 9 9K  + + 9 9KrcJ|j|j|jdS) Returns a JSON serializable object representation. :returns: JSON serializable representation. :rtype: dict ) extensionr(r)r8r2s r__json__zPerMessageSnappyOffer.__json__s+"00.2.M.M/3/O/OQ Qrc<d|jd|jdS) Returns Python object representation that can be eval'ed to reconstruct the object. :returns: Python string representation. :rtype: str z3PerMessageSnappyOffer(accept_no_context_takeover = , request_no_context_takeover = ))r(r)r?s r__repr__zPerMessageSnappyOffer.__repr__s8nrnMnMOSOoOop prN)TF) rrrr classmethodr-r3r;r@rErrrr r 8s; ))X-1-2G(  Qprr c.eZdZdZ ddZdZdZdZy)r zl Set of parameters with which to accept an `permessage-snappy` offer from a client by a server. Nct|tstdt|z||_t|t k7rtdt|z|r|j std|z||_|Et|t k7rtdt|z|jr|std|z||_y)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 r%r0r,r1r(r)no_context_takeover)r2r,r)rKs rr3z$PerMessageSnappyOfferAccept.__init__s%!677$u+EF F + , 4MPTUpPqqr r &u/O/OnrMMN N+F(  *'(D0 IDQdLe eff009L eh{ {||#6 rcv|j}|jjr|dz }|jr|dz }|S)r5r7r6)rr,r)r9s rr;z0PerMessageSnappyOfferAccept.get_extension_stringsA)) :: 1 1 9 9K  + + 9 9Krc||j|jj|j|jdS)r=)r>r,r)rK)rr,r@r)rKr?s rr@z$PerMessageSnappyOfferAccept.__json__s;"00,,./3/O/O'+'?'?A Arcrd|jjd|jd|jdS)rBzPerMessageSnappyAccept(offer = rC, no_context_takeover = rD)r,rEr)rKr?s rrEz$PerMessageSnappyOfferAccept.__repr__sZtxs}s}tGtGtIKOKkKkmqmEmEF Fr)FN)rrrrr3r;r@rErrrr r s&.3%)!7F  AFrr c2eZdZdZedZdZdZdZy)r zH Set of parameters for `permessage-snappy` responded by server. c zd}d}|D]}t||dkDrtd|d|jd||d}|dk(r&|durtd |d |d |jdd}c|d k(r&|durtd |d |d |jdd}td |d|jd|||}|S)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 FrrrrrrTrrr r!r"r#)r&r'rr!r*r+responses rr-zPerMessageSnappyResponse.parses &+"%*"A6!9~!hiknk}k} ~)A,C00d?#uxz{~A~P~P%QRR15.22d?#uxz{~A~P~P%QRR15. YZ\_\n\n opp-0113rc ||_||_yNrr!)r2rr!s rr3z!PerMessageSnappyResponse.__init__s+E'*D'rcJ|j|j|jdS)r=)r>rr!)rrr!r?s rr@z!PerMessageSnappyResponse.__json__#s+"00.2.M.M.2.M.MO Orc<d|jd|jdS)rBz6PerMessageSnappyResponse(client_no_context_takeover = , server_no_context_takeover = rDrUr?s rrEz!PerMessageSnappyResponse.__repr__.s8ptpOpOQUQpQpq qrN) rrrrrFr-r3r@rErrrr r s.''RE Oqrr c&eZdZdZ ddZdZdZy)r zo Set of parameters with which to accept an `permessage-snappy` response from a server by a client. Nct|tstdt|z||_|Et|t k7rtdt|z|j r|std|z||_y)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 responseNrIzCinvalid value %s for no_context_takeover - server requested feature)rJr r%r0rRr1rrK)r2rRrKs rr3z'PerMessageSnappyResponseAccept.__init__>s|($<=:T(^KL L   *'(D0 IDQdLe eff22;N eh{ {||#6 rcf|j|jj|jdS)r=)r>rRrK)rrRr@rKr?s rr@z'PerMessageSnappyResponseAccept.__json__Vs2"00 MM224'+'?'?A ArcXd|jjd|jdS)rBz*PerMessageSnappyResponseAccept(response = rOrD)rRrErKr?s rrEz'PerMessageSnappyResponseAccept.__repr__as5]a\i\i\r\r\tvzwOwOP PrrT)rrrrr3r@rErrrr r 8s&*70 APrr cfeZdZdZedZedZdZdZdZ dZ dZ d Z d Z d Zd Zy )r z< `permessage-snappy` WebSocket extension processor. c|||jj|j|j}|S|jj}|SrT)rRr!rKrr& is_serveracceptpmces rcreate_from_response_acceptz,PerMessageSnappy.create_from_response_acceptpsa9??==171K1K1W6--I ^d]l]l^H^HI rc|||j |jn|jj|j}|SrT)rKr,r)r_s rcreate_from_offer_acceptz)PerMessageSnappy.create_from_offer_acceptwsI9171K1K1W6--]c]i]i^F^F557 rcJ||_||_||_d|_d|_yrT) _is_serverr!r _compressor _decompressor)r2r`r!rs rr3zPerMessageSnappy.__init__~s+$*D'*D'!rcJ|j|j|jdS)N)r>r!r)rr!rr?s rr@zPerMessageSnappy.__json__s)!00.2.M.M.2.M.MO OrcVd|jd|jd|jdS)NzPerMessageSnappy(is_server = rXz, client_no_context_takeover = rD)rgr!rr?s rrEzPerMessageSnappy.__repr__sIw{xGxGIMIhIhjnjIjIJ Jrc|jr3|j |jrtj|_yy|j |j rtj|_yyrT)rgrhr!snappyStreamCompressorrr?s rstart_compress_messagez'PerMessageSnappy.start_compress_messagesa ??'4+J+J#)#:#:#< ,K'4+J+J#)#:#:#< ,Krc8|jj|SrT)rh add_chunkr2datas rcompress_message_dataz&PerMessageSnappy.compress_message_datas))$//rcy)Nrrr?s rend_compress_messagez%PerMessageSnappy.end_compress_messagesrc|jr3|j |jrtj|_yy|j |j rtj|_yyrT)rgrirrmStreamDecompressorr!r?s rstart_decompress_messagez)PerMessageSnappy.start_decompress_messagesa ??!!)T-L-L%+%>%>%@".M!!)T-L-L%+%>%>%@".Mrc8|jj|SrT)ri decompressrrs rdecompress_message_dataz(PerMessageSnappy.decompress_message_datas!!,,T22rcyrTrr?s rend_decompress_messagez'PerMessageSnappy.end_decompress_messages rN)rrrrrFrcrer3r@rErortrvryr|r~rrrr r ks_  "O J=0A3 rr )rm autobahn.websocket.compress_baserrrrr__all__objectrr r r r r rrrrs6  Ffp35JfpRJF"?AVJFZGq9;PGqT0P%EG\0Pf@ )+@@ r