^fV<8dZddlmZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZdd lmZdd lmZmZd Zed d gZeddgZejdrdZnejZej Z!e"ej#$ddZ%eddZ&e e'feffdZ(e!fdZ)dZ*GddZ+e+Z,e,j-Z-e,j.Z.e,j/Z/e,j0Z0dZ1dZ2dZ3dZ4dZ5d Z6e2e5e3e6e,7d!e8Z9e9fd"Z:e9fd#Z;e;ed$D]\Zge=Rd&d%Z?dS)'zSerialization utilities.) annotationsN) namedtuple)contextmanagerBytesIO)ContentDisallowed DecodeError EncodeErrorSerializerNotInstalledreraise) entrypoints) bytes_to_str str_to_bytes)pickleloadsdumpsregister unregisterbinaryz ascii-8bitapplication/datazapplication/textjavacHtj||dS)Nr)codecs getdecoder)tcodings E/var/www/html/env/lib/python3.11/site-packages/kombu/serialization.py_decoders"(v ((++A..PICKLE_PROTOCOLcodec) content_typecontent_encodingencoderc#K dVdS#|$r|$r<}t|||tjdYd}~dSd}~wwxYw)N)r sysexc_info)wrapperincludeexcludeexcs r_reraise_errorsr/%s:   :::s|~~a'8999999999:s A1A  Ac2|t|SNr)sloads r pickle_loadsr40s 4  r c|r|d|dn|S)Nz ())firstseconds rparenthesize_aliasr:5s#$) 5e v v5r cVeZdZdZdZ ddZdZdZdZdZ dd Z d d e fd Z d Z d S)SerializerRegistryz2The registry keeps track of serialization methods.ci|_i|_d|_d|_d|_t |_i|_i|_dSr1) _encoders _decoders_default_encode_default_content_type_default_content_encodingset_disabled_content_types type_to_name name_to_type)selfs r__init__zSerializerRegistry.__init__<sJ#%)")-&'*uu$r utf-8c||rt||||j|<|r ||j|<||j|<||j|<dS)aRegister a new encoder/decoder. Arguments: --------- name (str): A convenience name for the serialization method. encoder (callable): A method that will be passed a python data structure and should return a string representing the serialized data. If :const:`None`, then only a decoder will be registered. Encoding will not be possible. decoder (Callable): A method that will be passed a string representing serialized data and should return a python data structure. If :const:`None`, then only an encoder will be registered. Decoding will not be possible. content_type (str): The mime-type describing the serialized structure. content_encoding (str): The content encoding (character set) that the `decoder` method will be returning. Will usually be `utf-8`, `us-ascii`, or `binary`. N)r#r>r?rErF)rGnamer&decoderr$r%s rrzSerializerRegistry.registerFs`2  #(.$$DN4   3+2DN< (*.,'".$r c\d|vr |j|}|j|dSN/)rFrDdiscardrGrKs renablezSerializerRegistry.enablehs5 d??$T*D $,,T22222r c\d|vr |j|}|j|dSrN)rFrDaddrQs rdisablezSerializerRegistry.disablems5 d??$T*D $((.....r c: |j|}|j|d|j|d|j|d|j|ddS#t $rt d|wxYw)aUnregister registered encoder/decoder. Arguments: --------- name (str): Registered serialization method name. Raises ------ SerializerNotInstalled: If a serializer by that name cannot be found. N!No encoder/decoder installed for )rFr?popr>rEKeyErrorr )rGrKr$s rrzSerializerRegistry.unregisterrs <,T2L N  |T 2 2 2 N  tT * * *   ! !, 5 5 5   ! !$ - - - - - < < <(:D::<< < rArBr@rYr rQs r_set_default_serializerz*SerializerRegistry._set_default_serializersd 4%)^D%9 #T ')G  ! ! ! 4 4 4(2D2244 4 4s $ANcH|dkrt|S|r,|j|std||st |t rdd|fS|s]t |t rHttd5| d}dddn #1swxYwYd d|fS|r|j|\}}}n|j }|j }|j }tt5||}dddn #1swxYwY|||fS) aEncode data. Serialize a data structure into a string suitable for sending as an AMQP message body. Arguments: --------- data (List, Dict, str): The message data to send. serializer (str): An optional string representing the serialization method you want the data marshalled into. (For example, `json`, `raw`, or `pickle`). If :const:`None` (default), then json will be used, unless `data` is a :class:`str` or :class:`unicode` object. In this latter case, no serialization occurs as it would be unnecessary. Note that if `serializer` is specified, then that serialization method will be used even if a :class:`str` or :class:`unicode` object is passed in. Returns ------- Tuple[str, str, str]: A three-item tuple containing the content type (e.g., `application/json`), content encoding, (e.g., `utf-8`) and a string containing the serialized data. Raises ------ SerializerNotInstalled: If the serialization method requested is not available. rawr[rrr7r-rINz text/plain) raw_encoder>getr isinstancebytesstrr/r encoder@rArB)rGdata serializerpayloadr$r%r&s rrzSerializerRegistry.dumpssD   d## #  :dn00<< :(8J88:: :  6ju55 6&x5 5 2js33 2 b999 / /++g.. / / / / / / / / / / / / / / /'1 1  >z* 4L*GG*G5L#=  [ ) ) $ $gdmmG $ $ $ $ $ $ $ $ $ $ $ $ $ $ $-w66s$ B//B36B3< DDDFc:|rt|nd}|||vr||vr||dn!||jvr|s||d|pd}|r|j|}|r7t t5||cdddS#1swxYwY|tvrQt|ts>@@  ;^'' 55F ($[11((!6$<<(((((((((((((((({22"4--3$[11;;"4)9::;;;;;;;;;;;;;;;; s$ B66B:=B:3DDDc td|t|j|||S)Nz-Refusing to deserialize {} content of type {})r formatr:rEra)rGctypewhys rrlz)SerializerRegistry._for_untrusted_contentsJ ; B B"4#4#8#8#F#FNN     r )rIr1)__name__ __module__ __qualname____doc__rHrrRrUrr\rTRUSTED_CONTENTrrlr7r rr<r<9s<<#* / / / /D333 /// <<<,444*@7@7@7@7F////b     r r<cd}|}t|trFd}ttd5||}dddn #1swxYwYnd}|||fS)zSpecial case serializer.rrIr7r_Nr)rbrdr/r re)rfr$rhr%s rr`r`!s%LG'3$" [" 5 5 5 7 7nn%566G 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7$ )7 22sAAAcdddlm}td|j|jdddS)z2Register a encoder/decoder for JSON serialization.r)jsonr~zapplication/jsonrIr$r%N) kombu.utilsr~registryrrr)_jsons r register_jsonr.sK)))))) fek5;#5'.00000r c ddl}td|j|jdddS#t $r$d}tdd|dYdSwxYw)zRegister a encoder/decoder for YAML serialization. It is slower than JSON, but allows for more data types to be serialized. Useful if you need to send data such as dates rNyamlzapplication/x-yamlrIrc td)zRaise SerializerNotInstalled. Used in case a client receives a yaml message, but yaml isn't installed. z9No decoder installed for YAML. Install the PyYAML libraryr argskwargss r not_availablez$register_yaml..not_availableEs )KMM Mr )rrr safe_dump safe_load ImportError)rrs r register_yamlr7sM &$.$.';+2  4 4 4 4 4  M M M M M M &$ 7KLLLLLL Ms-1*AAc:tt|Sr1)r4r)r2s runpicklerPs  Q ( ((r cltjfd}td|tdddS)zpRegister pickle serializer. The fastest serialization method, but restricts you to python clients. c&||tS)N)protocol)pickle_protocol)objdumpers r pickle_dumpsz%register_pickle..pickle_dumpsZsvcO4444r rzapplication/x-python-serializerrN)rrrrr)rs rregister_picklerTsR "(5555 h h#C'/11111r cdx}} ddl}|jdkrddlmmfd}fd}nd}|x}}n#tt f$r d}|x}}YnwxYwt d ||d d dS) zZRegister msgpack serializer. See Also -------- https://msgpack.org/. Nr)rr")packbunpackbc|dS)NT) use_bin_typer7)r2rs rpackzregister_msgpack..packosuQT2222r c|dS)NF)r^r7)r2rs runpackz register_msgpack..unpackrswqe,,,,r c td)Nz(msgpack requires msgpack-python >= 0.4.0rrs rversion_mismatchz*register_msgpack..version_mismatchus,>@@@r c td)NzKNo decoder installed for msgpack. Please install the msgpack-python libraryrrs rrz'register_msgpack..not_availablezs(<== =r msgpackzapplication/x-msgpackrr)rversionrrr ValueErrorrr)rrrrrrrs @@rregister_msgpackrbsD6& ?f $ $ . . . . . . . . 3 3 3 3 3 - - - - - - @ @ @- ,D6  $&&& = = =&%vvv &  4,!s)2A  A r~c|turgdn|}|0|D]/} t|#t$rY*wxYwdSdS)zEnable serializers that are considered to be unsafe. Note: ---- Will enable ``pickle``, ``yaml`` and ``msgpack`` by default, but you can also specify a list of serializers (by name or content type) to enable. )rrrN)NOTSETrrRrY)choiceschoices renable_insecure_serializersrs07&/@/@++++gG  F ''''       s 2 ??c|turdgn|}tjD]}t|||D]}t|dSdS)aJDisable untrusted serializers. Will disable all serializers except ``json`` or you can specify a list of deserializers to allow. Note: ---- Producers will still be able to serialize data in these formats, but consumers will not accept incoming data using the untrusted content types. r~N)rrr?rUrR)allowedrKs rdisable_insecure_serializersrs~"V++vhhG" " "D OOD ! ! ! ! " "r zkombu.serializerscs tjn|> fd|DS#t$r"}td|jdd}~wwxYw|S)zReplace aliases of content_types with full names from registry. Raises ------ SerializerNotInstalled: If the serialization method requested is not available. Nc,h|]}d|vr|n|S)rOr7).0nrFs r z)prepare_accept_content..s)NNN1AA|ANNNr rWr)rrFrYr r) content_typesrFes ` rprepare_accept_contentrs1=N8((,L  ANNNN NNN N A A A(?AF1I??AA A A s # AA  Ar1)@rz __future__rrosrr) collectionsr contextlibrior exceptionsr r r r r utils.compatrutils.encodingrr__all__ frozensetrnr{platform startswithrrrr3 pickle_loadintenvironrarr# Exceptionr/r4r:r<rrrrrr`rrrrrr\objectrrreprrKrr7r rrs"""""" """"""%%%%%%::::::::::::::%%%%%%66666666 @i<011 )/1CDEE<6""////mGk #bjnn%6::;; 7KLL&L3I2K::::% 666] ] ] ] ] ] ] ] B         3 3 3000MMM2))) 1 1 1!!!J   ((( )/$*0""""* /00HB HRWtr