j'* UddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZddlmZmZdejdejejeeejffd Ze jd e jeiZejee jfed <ejejd Z dd edeje jdefdZ ddej!edejeefdeje j"defdZ# ddej!edejej$eefe j%eeffdejejeefdeje j"def dZ&e jdfd ededeje jdej'ejeefeffdZ( dd edeje jdej'ejeefeffdZ) dd edeje jdej'ejeefeffdZ*dejdejfdZ+dej!ed ej$eejfdefdZ,d edejeejffdZ-dejejeefdejfdZ.dS) N) exceptions) AnyCloudEvent) converters marshallertypes) is_binary)v1v03valuereturncZ|dS tj|g|Ri|S#t$r|cYSwxYw)a5 Serializes the given value into a JSON-encoded string. Given a None value returns None as is. Given a non-JSON-serializable value returns the value as is. :param value: The value to be serialized into a JSON string. :returns: JSON string of the given value OR None OR given value. N)jsondumps TypeError)r argskwargss a/DATA/AppData/hermes/projects/honcho/.venv/lib/python3.11/site-packages/cloudevents/conversion.py_best_effort_serialize_to_jsonrsW }tz%1$111&111  s  **c|SN)xs rr/s_default_marshaller_by_format)z1.0z0.3eventdata_marshallerc0t||dS)a Converts given `event` to a JSON string. :param event: A CloudEvent to be converted into a JSON string. :param data_marshaller: Callable function which will cast `event.data` into a JSON string. :returns: A JSON string representing the given event. r) to_structuredrrs rto_jsonr#6s  @ @ @ CCr event_typedatadata_unmarshallerc(ti|||S)ay Parses JSON string `data` into a CloudEvent. :param data: JSON string representation of a CloudEvent. :param data_unmarshaller: Callable function that casts `data` to a Python object. :param event_type: A concrete type of the event into which the data is deserialized. :returns: A CloudEvent parsed from the given JSON representation. )headersr%r&r$) from_http)r$r%r&s r from_jsonr*Es'  +    rr(c||dkrd}t|tttfs$t jdt |d|D}|t}tj }t|r| dd}n tj|}n?#tjj$r(t jd|wxYwt'|dr| d d}n't jd ||t jd t( |d}|'t jd |||||| }|} | dd| dd| jdi|j|j} |jdks |jdkrd} || | S)a Parses CloudEvent `data` and `headers` into an instance of a given `event_type`. The method supports both binary and structured representations. :param headers: The HTTP request headers. :param data: The HTTP request body. If set to None, "" or b'', the returned event's `data` field will be set to None. :param data_unmarshaller: Callable function to map data to a python object e.g. lambda x: x or lambda x: json.loads(x) :param event_type: The actual type of CloudEvent to deserialize the event to. :returns: A CloudEvent instance parsed from the passed HTTP parameters of the specified type. NrzFExpected json of type (str, bytes, bytearray), but instead found type c>i|]\}}||Sr)lower).0keyr s r zfrom_http..|s&DDDjc5syy{{EDDDrzce-specversionzdFailed to read specversion from both headers and data. The following can not be parsed as json: {!r}get specversionznFailed to read specversion from both headers and data. The following deserialized data has no 'get' method: {}z*Failed to find specversion in HTTP requestzFound invalid specversion {})r&r% extensionsr) isinstancestrbytes bytearraycloud_exceptionsInvalidStructuredJSONtypeitems_json_or_stringrNewDefaultHTTPMarshallerrr2rloadsdecoderJSONDecodeErrorMissingRequiredFieldsformathasattr_obj_by_versionInvalidRequiredFields FromRequest Propertiespopupdater4r%create) r$r(r%r&marshallr3raw_ce event_handlerrattrs result_datas rr)r)\s, |ts{{ dS%3 4 4 4 3&*4jj 3 3   EDGMMOODDDG +244Hkk"2D99  Z%%FF|+   "8@@Ft    65 ! !  **]D99KK"8JJP&QW..  4 8   $'' T::M4 * 1 1+ > >      $:K !  E     E IIfd IIlD!!!EL$$5#$$$/4zK zR5:,,   UK 0 00s 2C ToRequest)rrCrrNattribute_names r_to_httprVs7? ]?224 >m(< > >   $E-$89;;MAA.%*?@@@@))M  . 0 0 : :v ;  rc$t||S)a Returns a tuple of HTTP headers/body dicts representing this Cloud Event. If event.data is a byte object, body will have a `data_base64` field instead of `data`. :param event: The event to be converted. :param data_marshaller: Callable function to cast event.data into either a string or bytes :returns: (http_headers: dict, http_body: bytes or str) r")rVr"s rr!r!s % A A AArc:t|tj|S)aI Returns a tuple of HTTP headers/body dicts representing this Cloud Event. Uses Binary conversion format. :param event: The event to be converted. :param data_marshaller: Callable function to cast event.data into either a string or bytes. :returns: (http_headers: dict, http_body: bytes or str) )rrCr)rVr TypeBinaryr"s r to_binaryrZs' $'   rct|tjr|jSt|tjr|S|S)a[ SHOULD convert any value into a JSON serialization friendly format. This function acts in a best-effort manner and MAY not actually encode the value if it does not know how to do that, or the value is already JSON-friendly. :param value: Value which MAY or MAY NOT be JSON serializable. :return: Possibly encoded value. )r5enumEnumr datetime isoformat)r s r"best_effort_encode_attribute_valuer`sJ%##{%*++!   Lrcd|D}|||dS)a/ Constructs an Event object of a given `event_type` from a dict `event` representation. :param event: The event represented as a dict. :param event_type: The type of the event to be constructed from the dict. :returns: The event of the specified type backed by the given dict. c@i|]\}}|dk |t|S)r%)r`)r/ attr_name attr_values rr1zfrom_dict..s< !Iz    5jAA   rr%) attributesr%)r<rKr2)r$rres r from_dictrfsO%*[[]]J    69J9J  K KKrcRfdD}|d<|S)z Converts given `event` to its canonical dictionary representation. :param event: The event to be converted into a dict. :returns: The canonical dict representation of the event. c<i|]}||Sr)r2)r/rUrs rr1zto_dict.."s' T T TNneii77 T T Trr%)rS)rresults` rto_dictrjs7U T T Te T T TF^^%%F6N Mrcontentc||dS tj|S#tjttf$r|cYSwxYw)z Returns a JSON-decoded dictionary or a list of dictionaries if a valid JSON string is provided. Returns the same `content` in case of an error or `None` when no content provided. N)rr?rArUnicodeDecodeError)rks rr=r='sRtz'"""  )-? @s ;;r)/r^r\rtyping cloudeventsrr9cloudevents.abstractrcloudevents.sdkrrrcloudevents.sdk.convertersrcloudevents.sdk.eventr r AnyOptionalUnionr7r6rTypeStructuredrYrDictMarshallerType__annotations__EventrEr#TypeUnmarshallerTyper*MappingSupportsDuplicateItemsr)TuplerVr!rZr`rfrjr=rrrrsy 666666......9999999999000000)))))))) : _V\%fj"89:*{{9Iv{30D+DE (3955 >B D D  D_U%9: D  D D D D$BF M* ,sEz "u'=> :BF Q1Q1 M*Q1 \sCx %">sCx"HHQ1 /&,sEz2 3 Q1 u'=> Q1Q1Q1Q1Q1l+=A  _U%9: \&+c3h'./ B>BBB B_U%9:B \&+c3h'./BBBB&TX +1?5;O+P \&+c3h'./(fjVZ$L M*L >#vz/ *LLLLL( = V[fj%A     _V\#u*5 6 Zr