QjV<(dZddlmZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZdd lmZdd lmZmZd Zed d gZeddgZej8j;drdZn ej>Zej@Z!e"ejFjIddZ%eddZ&e e'feffdZ(e!fdZ)dZ*GddZ+e+Z,e,jZZ-e,j\Z.e,j^Z/e,j`Z0dZ1dZ2dZ3dZ4dZ5d Z6e2e5e3e6e,jod!e8Z9e9fd"Z:e9fd#Z;e;ed$D]\Ztj||dS)Nr)codecs getdecoder)tcodings O/var/www/html/truck-me/venv/lib/python3.12/site-packages/kombu/serialization.py_decoders(v  (+A..PICKLE_PROTOCOLcodec) content_typecontent_encodingencoderc#K dy#|$r|$r2}t|||tjdYd}~yd}~wwxYww)N)r sysexc_info)wrapperincludeexcludeexcs r_reraise_errorsr/%sF:  :s||~a'899:s)A A A(AAAAc$|t|SNr)sloads r pickle_loadsr40s  r c|r|d|dS|S)Nz ())firstseconds rparenthesize_aliasr:5s$)eWBvha 5v5r cTeZdZdZdZ d dZdZdZdZdZ dd Z dd e fd Z d Z y)SerializerRegistryz2The registry keeps track of serialization methods.ci|_i|_d|_d|_d|_t |_i|_i|_yr1) _encoders _decoders_default_encode_default_content_type_default_content_encodingset_disabled_content_types type_to_name name_to_type)selfs r__init__zSerializerRegistry.__init__<sB#%)")-&'*u$r c|rt||||j|<|r||j|<||j|<||j|<y)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.registerFsU2 #(.$DNN4  +2DNN< (*.,'".$r c`d|vr|j|}|jj|yN/)rFrDdiscardrGrJs renablezSerializerRegistry.enablehs- d?$$T*D $$,,T2r c`d|vr|j|}|jj|yrM)rFrDaddrPs rdisablezSerializerRegistry.disablems- d?$$T*D $$((.r c: |j|}|jj|d|jj|d|jj|d|jj|dy#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 )rGrJr$s rrzSerializerRegistry.unregisterrs <,,T2L NN  |T 2 NN  tT *    ! !, 5    ! !$ - <(3D6:< < rArBr@rXr rPs r_set_default_serializerz*SerializerRegistry._set_default_serializersN 4%)^^D%9 #T ')G  ! 4(+D624 4 4s"%=Nc|dk(r t|S|r)|jj|std||st |t rdd|fS|s@t |t r0ttd5|jd}dddd dfS|r|j|\}}}n$|j}|j}|j}tt5||}ddd||fS#1swYmxYw#1swYxYw) 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. rawrZrrr7r-utf-8Nz text/plain) raw_encoder>getr isinstancebytesstrr/r encoder@rArB)rGdata serializerpayloadr$r%r&s rrzSerializerRegistry.dumpssD  d# # dnn00<(+J<8: : ju5&x5 5js3 b9 /++g. /'1 1 z* 4L*G**G55L#==  [ ) $dmG $-w66 / / $ $s6C4 D4C=D Fc|r t|nd}|||vr8||vr4|j|d||jvr|s|j|d|xsdj}|r{|jj |}|r!t t5||cdddS|tvr5t|ts%t t5t||cdddS|S#1swYHxYw#1swY|SxYw)aDecode serialized data. Deserialize a data stream as serialized using `dumps` based on `content_type`. Arguments: --------- data (bytes, buffer, str): The message data to deserialize. content_type (str): The content-type of the data. (e.g., `application/json`). content_encoding (str): The content-encoding of the data. (e.g., `utf-8`, `binary`, or `us-ascii`). accept (Set): List of content-types to accept. Raises ------ ContentDisallowed: If the content-type is not accepted. Returns ------- Any: The unserialized data. rN untrusteddisabledr_) r_for_untrusted_contentrDlowerr?rar/r SKIP_DECODErbrdr)rGrfr$r%acceptforce_trusted_contentdecodes rrzSerializerRegistry.loadss67C \2/   #33$F211, LLt;;;E11, KK,7>>@ ^^'' 5F$[1(!$<(({2"4-$[1;"4)9:;; ((; sC! C-!C*-C7c tdj|t|jj |||S)Nz-Refusing to deserialize {} content of type {})r formatr:rEra)rGctypewhys rrlz)SerializerRegistry._for_untrusted_contents= ; B B"4#4#4#8#8#FN   r )r_r1)__name__ __module__ __qualname____doc__rHrrQrTrr[rTRUSTED_CONTENTrrlr7r rr<r<9sD<#* /D3 / <,4*@7F/b r r<cd}|}t|tr.d}ttd5|j |}dddnd}|||fS#1swYxYw)zSpecial case serializer.rr_r7r^Nr)rbrdr/r re)rfr$rhr%s rr`r`!se%LG'3" [" 5 7nn%56G 7 7$ )7 22  7 7s A  Aclddlm}tjd|j|j ddy)z2Register a encoder/decoder for JSON serialization.r)jsonr~zapplication/jsonr_r$r%N) kombu.utilsr~registryrrr)_jsons r register_jsonr.s,) fekk5;;#5'.0r c ddl}tjd|j|jddy#t $rd}tjdd|dYywxYw)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-yamlr_rctd)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 )KM Mr )rrr safe_dump safe_load ImportError)rrs r register_yamlr7sbM&$..$..';+2  4  M M &$ 7KL Ms25$AAc*tt|Sr1)r4r)r2s runpicklerPs  Q ((r cftjfd}tjd|tddy)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_dumpsZscO44r rzapplication/x-python-serializerrN)rrrrr)rs rregister_picklerTs1 "(5 h h#C'/1r cdx}} ddl}|jdk\rddlmmfd}fd}nd}|x}}t jd ||d d y#tt f$r d}|x}}Y3wxYw) zZRegister msgpack serializer. See Also -------- https://msgpack.org/. Nr)rr")packbunpackbc|dS)NT) use_bin_typer7)r2rs rpackzregister_msgpack..packosQT22r c|dS)NF)r]r7)r2rs runpackz register_msgpack..unpackrsqe,,r ctd)Nz(msgpack requires msgpack-python >= 0.4.0rrs rversion_mismatchz*register_msgpack..version_mismatchus,>@@r ctd)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 - @- ,D6 4,!  $& =&%v &s-AA)(A)r~c~|turgdn|}||D]} tj|yy#t$rY(wxYw)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)NOTSETrrQrX)choiceschoices renable_insecure_serializersrsR07&/@+gG F '   s 0 <<c|turdgn|}tjD]}tj|||D]}tj |yy)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?rTrQ)allowedrJs rdisable_insecure_serializersrs]"V+vhG"" "D OOD ! "r zkombu.serializersc|stjn|}| |Dchc] }d|vr|n||c}S|Scc}w#t$r }td|jdd}~wwxYw)zReplace aliases of content_types with full names from registry. Raises ------ SerializerNotInstalled: If the serialization method requested is not available. NrNrVr)rrFrXr r) content_typesrFnes rprepare_accept_contentrs1=8((,L  A@MN1A|A6N N  O A(3AFF1I;?A A As!8388 A!AA!r1)@rz __future__rrosrr) collectionsr contextlibrior exceptionsr r r r r utils.compatrutils.encodingrr__all__ frozensetrnr{platform startswithrrrr3 pickle_loadintenvironrarr# Exceptionr/r4r:r<rrrrrr`rrrrrr[objectrrreprrJrr7r rrs" "%::%6 @<01 /1CDE<<6"/mmGkk bjjnn%6:;7KL&L3I2K::% 6] ] B        30M2) 1!J  ( )/$*0"*/0HB RWWtr