h< BdZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z m Z mZmZmZddlmZdd lmZmZd Zed d gZed dgZejdrdZnejZejZe ej!"ddZ#eddZ$ee%feffdZ&efdZ'dZ(GddZ)e)Z*e*j+Z+e*j,Z,e*j-Z-e*j.Z.dZ/dZ0dZ1dZ2dZ3dZ4e0e3e1e4e*5d e0e3e1e4e0e1e3e4d!Z6e7Z8e8fd"Z9e8fd#Z:e:ed$D]\Z;Z<e-e;j=ge<Rd&d%Z>dS)'zSerialization utilities.N) namedtuple)contextmanagerBytesIO)ContentDisallowed DecodeError EncodeErrorSerializerNotInstalledreraise) entrypoints) bytes_to_str str_to_bytes)pickleloadsdumpsregister unregisterbinaryz ascii-8bitapplication/datazapplication/textjavacHtj||dS)Nr)codecs getdecoder)tcodings O/var/www/html/Sam_Eipo/venv/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_loadsr3.s 4  rc|r|d|dn|S)Nz ())firstseconds rparenthesize_aliasr93s#$) 5e v v5rcVeZdZdZdZ 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|_dSr0) _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$rutf-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>rDrE)rFnamer%decoderr#r$s rrzSerializerRegistry.registerDs`0  #(.$$DN4   3+2DN< (*.,'".$rc\d|vr |j|}|j|dSN/)rErCdiscardrFrJs renablezSerializerRegistry.enablees5 d??$T*D $,,T22222rc\d|vr |j|}|j|dSrM)rErCaddrPs rdisablezSerializerRegistry.disablejs5 d??$T*D $((.....rc: |j|}|j|d|j|d|j|d|j|ddS#t $rt d|wxYw)zUnregister 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 )rEr>popr=rDKeyErrorr )rFrJr#s rrzSerializerRegistry.unregisteros <,T2L N  |T 2 2 2 N  tT * * *   ! !, 5 5 5   ! !$ - - - - - < < <(:D::<< <   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|tsr`r.r SKIP_DECODErarcr)rFrer#r$acceptforce_trusted_contentdecodes rrzSerializerRegistry.loadss07C0 \222/   #333$F2211, LLLt;;;E;11, KKK,7>>@@  ;^'' 55F ($[11((!6$<<(((((((((((((((({22"4--3$[11;;"4)9::;;;;;;;;;;;;;;;; s$ B66B:=B:3DDDc td|t|j|||S)Nz-Refusing to deserialize {} content of type {})rformatr9rDr`)rFctypewhys rrkz)SerializerRegistry._for_untrusted_contentsJ ; B B"4#4#8#8#F#FNN     r)rHr0)__name__ __module__ __qualname____doc__rGrrQrTrr[rTRUSTED_CONTENTrrkr6rrr;r;7s<<#*////B333 /// <<<(444&=7=7=7=7@,,,,\     rr;cd}|}t|trFd}ttd5||}dddn #1swxYwYnd}|||fS)zSpecial case serializer.rrHr6r^Nr)rarcr.r rd)rer#rgr$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}application/jsonrHr#r$N) kombu.utilsr}registryrrr)_jsons r register_jsonr!sK)))))) fek5;#5'.00000rc 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 rNyamlapplication/x-yamlrHrc 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_available8s )KMM Mr)rrr safe_dump safe_load ImportError)rrs r register_yamlr*sM &$.$.';+2  4 4 4 4 4  M M M M M M &$ 7KLLLLLL Ms-1*AAc:tt|Sr0)r3r)r1s runpicklerCs  Q ( ((rcltjfd}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_dumpsMsvcO4444rrapplication/x-python-serializerrN)rrrrr)rs rregister_picklerGsR "(5555 h h#C'/11111rcdx}} ddl}|jdkrddlmmfd}fd}nd}|x}}n#tt f$r d}|x}}YnwxYwt d ||d d dS) zNRegister msgpack serializer. See Also: https://msgpack.org/. Nr)rr!)packbunpackbc|dS)NT) use_bin_typer6)r1rs rpackzregister_msgpack..packasuQT2222rc|dS)NF)r]r6)r1rs runpackz register_msgpack..unpackdswqe,,,,rc td)Nz(msgpack requires msgpack-python >= 0.4.0rrs rversion_mismatchz*register_msgpack..version_mismatchgs,>@@@rc td)NzKNo decoder installed for msgpack. Please install the msgpack-python libraryrrs rrz'register_msgpack..not_availablels(<== =rmsgpackapplication/x-msgpackrr)rversionrrr ValueErrorrr)rrrrrrrs @@rregister_msgpackrUs D6& ?f $ $ . . . . . . . . 3 3 3 3 3 - - - - - - @ @ @- ,D6  $&&& = = =&%vvv &  4,!s)2A  A r})r}rrrr~rrrc|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)NOTSETrrQrX)choiceschoices renable_insecure_serializersrs07&/@/@++++gG  F ''''       s 2 ??c|turdgn|}tjD]}t|||D]}t|dSdS)aADisable 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++vhhG" " "D OOD ! ! ! ! " "rzkombu.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)rNr6).0nrEs r z)prepare_accept_content..s)NNN1AA|ANNNrrVr)rrErXr r) content_typesrEes ` rprepare_accept_contentrs1=N8((,L  ANNNN NNN N A A A(?AF1I??AA A A s # AA  Ar0)?ryrosrr( collectionsr contextlibrior exceptionsrr r r r utils.compatr utils.encodingrr__all__ frozensetrmrzplatform startswithrrqr2 pickle_loadintenvironr`rr" Exceptionr.r3r9r;rrrrrr_rrrrrr[ _setupfunsobjectrrreprrJrr6rrrs """"""%%%%%%::::::::::::::%%%%%%66666666 @i<011 )/1CDEE<6""////mGk #bjnn%6::;; 7KLL&L3I2K::::% 666R R R R R R R R l         3 3 3000MMM2))) 1 1 1   H   (((  %'&5-    )/"*0""""( /00HB HRWtr