o Df@sFUdZddlmZddlZddlZddlZddlmZmZmZddl m Z ddl m Z m Z mZdZz ddlmZeef7ZWn eyGYnwGd d d ejZd0ddZejedfddZd1ddZejdefddZe e ge fZZedZedZddfd2d%d&ZiZd'ed(<d)dd*dd+Zd,ed-<d.d/Z e dS)3zJSON Serialization Utilities.) annotationsN)datedatetimetime)Decimal)AnyCallableTypeVar)Promisecs eZdZdZfddZZS) JSONEncoderzKombu custom json encoder.cst|dd}|dur |St|trt|StD]\}\}}t||r8|dur/||St|||Sqt|tr\z td|dWSt y[tdt |dYSwt |S)N__json__bytesutf-8base64)getattr isinstance textual_typesstr _encodersitems_asrdecodeUnicodeDecodeErrorr b64encodesuperdefault)selforeducertmarkerencoder __class__r I/home/ubuntu/webapp/venv/lib/python3.10/site-packages/kombu/utils/json.pyrs&       zJSONEncoder.default)__name__ __module__ __qualname____doc__r __classcell__r r r#r%r sr r rvrcCs ||dS)N)__type__ __value__r )r r+r r r%r2s rcKs(|pi}||fd|it|fi|S)z Serialize object to json string.cls)dict)s_dumpsr.default_kwargskwargsr r r%dumps6s r4rr/cCs>|ddhkrt|d}|r||dStdt||S)z0Hook function to perform custom deserialization.r,r-zUnsupported type)keys _decodersget ValueErrortype)rdecoderr r r% object_hookBs   r;TcCsTt|tr |d}nt|tr|d}n |r$t|tr$|d}|||dS)zDeserialize json from string.r)r;)r memoryviewtobytesr bytearrayr)r0_loads decode_bytesr;r r r%loadsNs     rATEncodedTcCs|SNr )dr r r%isrFtype[T]r! str | Noner"Callable[[T], EncodedT]r:Callable[[EncodedT], T]cCs$||ft|<|dur|t|<dSdS)a Add support for serializing/deserializing native python type. If marker is `None`, the encoding is a pure transformation and the result is not placed in an envelope, so `decoder` is unnecessary. Decoding must instead be handled outside this library. N)rr6)r r!r"r:r r r% register_typees  rKz'dict[type, tuple[str | None, EncoderT]]rcCs |dSNr)encoderr r r%rFx cCst|dSrL)r b64decoderMrNr r r%rFy)rrzdict[str, DecoderT]r6cCsfttdtjtjttdddddttdddtjttdttttj d d dd ddS) NrrcS|SrD isoformatrNr r r%rFz)_register_default_types..cSst|SrD)r fromisoformatrrNr r r%rFsrcSrRrDrSrNr r r%rFrUdecimaluuidcSs d|jiS)Nhex)rYrNr r r%rFrOcSstjdi|S)Nr )rXUUIDrNr r r%rFrQ) rKrrTrVrrrrrXrZr r r r%_register_default_types}s" r[)r rr+r)rr/)r rGr!rHr"rIr:rJ)!r) __future__rrjsonrXrrrrWrtypingrrr rdjango.utils.functionalr ImportErrorr rr4r;rADecoderTEncoderTrBrCrKr__annotations__r6r[r r r r%sD