o i*@sddlZddlZddlmZmZddlmZmZddlm Z m Z m Z m Z ddl mZmZddlmZmZmZmZddlmZdd lmZdd lmZmZeZd d Zd dZddZ ddZ!ddZ"ddZ#ddZ$ddZ%ddZ&ddZ'dd Z(d!d"Z)d#d$Z*id%ed&ed'e d(e"d)e#d*e$d+e$d,e!d-e%d.e&d/e'd0e(d1e*d2e*d3e)d4e)d5e)Z+d6d7Z, 8 9 : :dGd;ede.d?e.d@e.dAe.fdBdCZ/ 9 : :dHdDeede.d?e.d@e.dAe.f dEdFZ0dS)IN)MappingSequence)AnyIterable) INT_MAX_VALUE INT_MIN_VALUELONG_MAX_VALUELONG_MIN_VALUE)ValidationErrorValidationErrorData)extract_record_typeextract_logical_type schema_name parse_schema)LOGICAL_WRITERS) UnknownType)Schema NamedSchemascKs|duS)z#Checks that the data value is None.Ndatumkwargsrr]/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/fastavro/_validation_py.py_validate_nullsrcK t|tS)z*Check that the data value is bool instance) isinstanceboolrrrr_validate_boolean rcKr)z#Check that the data value is stringrstrrrrr_validate_stringrr"cKst|ttfS)z.Check that the data value is python bytes type)rbytes bytearrayrrrr_validate_bytessr%cK4t|ttjfot|kotknot|t S)z Check that the data value is a non floating point number with size less that Int32. Int32 = -2147483648<=datum<=2147483647 conditional python types: int, numbers.Integral )rintnumbersIntegralrrrrrrr _validate_int$   r*cKr&)z Check that the data value is a non floating point number with size less that long64. Int64 = -9223372036854775808 <= datum <= 9223372036854775807 conditional python types: int, numbers.Integral )rr'r(r)r r rrrrr_validate_long4r+r,cKst|tttjfot|t S)z Check that the data value is a floating point number or double precision. conditional python types (int, float, numbers.Real) )rr'floatr(Realrrrrr_validate_floatDsr/cKst|to t||dkS)zb Check that the data value is fixed width bytes, matching the schema['size'] exactly! size)rr#lenrschemarrrr_validate_fixedOsr4cKs ||dvS)z:Check that the data value matches one of the enum symbols.symbolsrr2rrr_validate_enumWs r6cs:t|ttjfot|t otfdd|DS)z:Check that the data list values all match schema['items'].c 3(|]}t|ddVqdS)itemsrr3 named_schemasfield raise_errorsoptionsN _validate).0dr:r= parent_nsr<r3rr a  z"_validate_array..)rrarrayr!allrr3r:rCr<r=rrBr_validate_array\s  rIcs>t|totdd|Dotfdd|DS)zY Check that the data is a Map(k,v) matching values to schema['values'] type. css|]}t|tVqdS)Nr )r@krrrrDvsz _validate_map..c 3r7)valuesr9Nr>)r@vrBrrrDwrE)rrrGrKrHrrBr _validate_mapos  rMcsPt||\}tto'dvodk o'tfdd|dDS)ze Check that the data is a Mapping type with all schema defined fields validated as True. z-typec 3sJ|] }t|d|dt|dd|ddVqdS)namedefaulttype.r9N)r?getNoValue)r@frfullnamer:r=r<rrrDs  z#_validate_record..fields)rrrrG)rr3r:rCr<r=_rrUr_validate_records  rYc Cst|tr2|ds2|\}}|D]}t|dkr|d}n|}||kr/t||||||dSqdSg} |D],} zt|| ||||d} | rIWdSWq6tyb} z | | jWYd} ~ q6d} ~ ww|rit| dS)z[ Check that the data is a list type with possible options to validate as True. disable_tuple_notationrecordrNr3r:r;r<r=FTN)rtuplerRr r?r extenderrors) rr3r:rCr<r=rN candidaterr_sreterrr_validate_unionsL    rdnullbooleanstringr'longr-doubler#fixedenumrFmapunion error_unionr[errorrequestc Cst|}d}|tur|drd}n?|turd}t|}|r*t|} | r*| ||}t|} | r<| ||||||d}n||vrMt|||||||d}nt||r_|dur_tt ||||S)NstrictF)r3r:rCr<r=r\) r rSrRrr VALIDATORSr?rr r ) rr3r:r;r<r= record_typeresult logical_typeprepare validatorrrrr?sD    r?TFrr3r;r<rqrZreturnc Cs(i}t||}t|||||||ddS)a Determine if a python datum is an instance of a schema. Parameters ---------- datum Data being validated schema Schema field Record field being validated raise_errors If true, errors are raised for invalid data. If false, a simple True (valid) or False (invalid) result is returned strict If true, fields without values will raise errors rather than implicitly defaulting to None disable_tuple_notation If set to True, tuples will not be treated as a special case. Therefore, using a tuple to indicate the type of a record will not work Example:: from fastavro.validation import validate schema = {...} record = {...} validate(record, schema) rqrZ)r=)rr?)rr3r;r<rqrZr: parsed_schemarrrvalidate s% r|recordsc Csi}t||}g}g}|D],} z|t| ||d|||ddWq ty9} z || jWYd} ~ q d} ~ ww|rB|rBt|t|S)a Validate a list of data! Parameters ---------- records List of records to validate schema Schema raise_errors If true, errors are raised for invalid data. If false, a simple True (valid) or False (invalid) result is returned strict If true, fields without values will raise errors rather than implicitly defaulting to None disable_tuple_notation If set to True, tuples will not be treated as a special case. Therefore, using a tuple to indicate the type of a record will not work Example:: from fastavro.validation import validate_many schema = {...} records = [{...}, {...}, ...] validate_many(records, schema) rxrz)r;r<r=N)rappendr?r r^r_rG) r}r3r<rqrZr:r{r_resultsr[rcrrr validate_many<s2"  r)rxTFF)TFF)1rFr(collections.abcrrtypingrrconstrrr r _validate_commonr r r3r rrrlogical_writersr_schema_commonrtypesrrobjectrSrrr"r%r*r,r/r4r6rIrMrYrdrrr?r!rr|rrrrrs   -     0 4