g*ddlZddlZddlmZmZddlmZmZddlm Z m Z m Z m Z ddl mZmZddlmZmZmZmZddlmZdd lmZdd lmZmZeZd Zd Zd Z dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*idedede de"de#de$de$de!d e%d!e&d"e'd#e(d$e*d%e*d&e)d'e)d(e)Z+d)Z, d4d*ed+ed,e-d-e.d.e.d/e.d0e.fd1Z/ d5d2eed+ed-e.d.e.d/e.d0e.f d3Z0y)6N)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 NamedSchemasc |duS)z#Checks that the data value is None.Ndatumkwargss L/var/www/openai/venv/lib/python3.12/site-packages/fastavro/_validation_py.py_validate_nullrs D=c "t|tS)z*Check that the data value is bool instance) isinstanceboolrs r_validate_booleanr!s eT ""rc "t|tS)z#Check that the data value is stringrstrrs r_validate_stringr%s eS !!rc .t|ttfS)z.Check that the data value is python bytes type)rbytes bytearrayrs r_validate_bytesr)s eeY/ 00rc t|ttjfxr+t|cxkxr t kncxrt|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 )rintnumbersIntegralr rr rs r _validate_intr.$sB 53 0 012 ( U 3m 3 (5$' 'rc t|ttjfxr+t|cxkxr t kncxrt|t  S)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 r rs r_validate_longr04sB 53 0 012 ( e 5~ 5 (5$' 'rc rt|tttjfxrt|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,Realr rs r_validate_floatr4Ds, ec5',,7 8 XESWAX=XXrc Ht|txrt||dk(S)zb Check that the data value is fixed width bytes, matching the schema['size'] exactly! size)rr'lenrschemars r_validate_fixedr:Os# eU # DE fVn(DDrc ||dvS)z:Check that the data value matches one of the enum symbols.symbolsrr8s r_validate_enumr=Ws F9% %%rct|ttjfxr+t|t xrt fd|DS)z:Check that the data list values all match schema['items'].c 3FK|]}t|dyw)itemsrr9 named_schemasfield raise_errorsoptionsN _validate).0drBrE parent_nsrDr9s r z"_validate_array..as=   g+)   !)rrarrayr$allrr9rBrJrDrEs `````r_validate_arrayrP\sK 58U[[12 5#& &     rct|txr:td|Dxr&tfd|jDS)zY Check that the data is a Map(k,v) matching values to schema['values'] type. c3<K|]}t|tyw)Nr#)rHks rrKz _validate_map..vs2Eq 1c"Esc 3FK|]}t|dyw)valuesrANrF)rHvrBrErJrDr9s rrKz _validate_map..ws>  $ h'+)   $rL)rrrNrUrOs `````r _validate_maprWosI 5'" 2E2 2   \\^  rct||\}ttxr,dvxrdk7 xrtfd|dDS)ze Check that the data is a Mapping type with all schema defined fields validated as True. z-typec 3K|]G}tj|d|jdt|dd|dIyw)namedefaulttype.rAN)rGgetNoValue)rHfrfullnamerBrErDs rrKz#_validate_record..sf  & ii& 155G+DEy+! !AfI;/)   &sA Afields)rrrrN)rr9rBrJrDrE_ras` ` `` @r_validate_recordrdsc fi0KAx5'" E!@eGn&@ A   H%  rc pt|trL|jds;|\}}|D]0}t|dk(r|d}n|}||k(st ||||||cSyg} |D]} t || ||||} | ry|rt | y#t $r%} | j | jYd} ~ Od} ~ wwxYw)z[ Check that the data is a list type with possible options to validate as True. disable_tuple_notationrecordrZr9rBrCrDrEFTN)rtupler^rrGr extenderrors) rr9rBrJrDrErZ candidaterrksretes r_validate_unionrps % 4L(M uI"9-9'/ ' d" $"/#!-#    F  $+) Cv&&   $ MM!(( # # $s%B B5B00B5nullbooleanstringr+longr2doubler'fixedenumrMmapunion error_unionrgerrorrequestct|}d}|tur|jdrd}n|turd}t|}|r t j|} | r | ||}t j|} | r| ||||||}n$||vrt |||||||}n t||r|durtt||||S)NstrictF)r9rBrJrDrErh) rr_r^rr VALIDATORSrGrr r ) rr9rBrCrDrE record_typeresult logical_typeprepare validators rrGrGs%f-K F GKK1 G E+F3 %)),7Gv.NN;/ +) FM )$[1+) Fk* *%1%GHH Mrrr9rCrDr~rfreturnc Fi}t||}t|||||||dS)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) r~rf)rE)rrG)rr9rCrDr~rfrB parsed_schemas rvalidater s;J#%M 7M   !=ST  rrecordsc  i}t||}g}g}|D]&} |jt| ||d|||d(|r |rt|t |S#t$r%} |j | j Yd} ~ id} ~ wwxYw)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) r)rCrDrEN)rappendrGr rjrkrN) rr9rDr~rfrBrrkresultsrgros r validate_manyr<sD#%M 7M FG $ NN!!!-"(2H  "v&& w<  $ MM!(( # # $s#A BA>>B)rTFF)TFF)1rMr,collections.abcrrtypingrrconstrr r r _validate_commonr r r9rrrrlogical_writersr_schema_commonrtypesrrobjectr_rr!r%r)r.r0r4r:r=rPrWrdrprrGr$r rrrrrrs - OOBXX,'' ( # " 1   YE& &,.*Z N    =   N   _  o _ _ N _ = _?   !"# **`#( . . . . .  . ! . .h#( 9 c]9 99  9 ! 9  9r