.i:0ddlZddlZddlZddlmZddlmZddlmZm Z m Z m Z m Z ddl mZeeeeefZedeeeeee efZdZejeZdedejd e ed e e eje e eeefd fffd Zdejd e ed ejfd Zdedejd e ed ejfdZdejde ed e ejfdZ GddeZ!dS)N) OrderedDict)MutableMapping)MappingOptionalSequenceTupleUnion)typesc \t|dt|dt|S)N__name___name)getattrrepr)ts f/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/opentelemetry/attributes/__init__.py _type_namer+s& 1j'!Wd1gg">"> ? ??keyvaluemax_lenreturn.c $|rt|tstd|dSt|trt ||St|t rd}g}|D]}t ||}|||*t|}|tvr4td|j |dtDdS||}n=||kr7td||j t|j dS||t|Stdt|j |dtDdS)akChecks if attribute value is valid and cleans it if required. The function returns the cleaned value or None if the value is not valid. An attribute value is valid if it is either: - A primitive type: string, boolean, double precision floating point (IEEE 754-1985) or integer. - An array of primitive type values. The array MUST be homogeneous, i.e. it MUST NOT contain values of different types. An attribute needs cleansing if: - Its length is greater than the maximum allowed length. - It needs to be encoded/decoded e.g, bytes to strings. +invalid key `%s`. must be non-empty string.NzLInvalid type %s in attribute '%s' value sequence. Expected one of %s or Nonecg|] }|j Sr .0 valid_types r z$_clean_attribute..]s+&#+rz>Attribute %r mixes types %s and %s in attribute value sequencezYInvalid type %s for attribute '%s' value. Expected one of %s or a sequence of those typescg|] }|j Srrrs rr z$_clean_attribute..|sGGG GGGr) isinstancestr_loggerwarning_VALID_ATTR_VALUE_TYPES_clean_attribute_valuerappendtyper tuple)rrrsequence_first_valid_type cleaned_seqelement element_types r_clean_attributer/2s$ JsC((EsKKKt%0116%eW555%""*"$(! # (# (G,Wg>>G""7+++==L#:::! )*A   tt)0,8))!:::T-6MM*  tt   w ' ' ' '[!!! OO " U  GG/FGGG  4rc|t|tr#|t|tr |d|}|St|trfi}|D]M\}}|rt|tst d|8t|||||<N|St|trd}g}|D]}|| ||t|tr |d|}t|}|tvr t||}t|}||}n<||kr6t d|j t|j dS| |t|S t|S#t$r8tdt|j ddt DdwxYw) Nr)rrrrz1Mixed types %s and %s in attribute value sequencez Invalid type z& for attribute value. Expected one of c,g|]}t|Sr)rrs rr z3_clean_extended_attribute_value..s ```: : 6 6```rz or a sequence of those types)r"r&r#ritemsr$r%_clean_extended_attributerr(r)_clean_extended_attribute_valuer r* Exception TypeError_VALID_ANY_VALUE_TYPES)rr cleaned_dictrr-r+r,r.s rr5r5sn } 5*ABB}  :eS#9#9 (7(OE %!!24 !KKMM  LC JsC00 A3 9w!!!L  %""#"$(!,.  ( (G""7+++"z'3'?'?"!(7(+==L#:::9W $G}} )0,8))!:::G-6MM* tt   w ' ' ' '[!!! 5zz     &DKK0 & &``I_``` & & &    s +F::AG<c|rt|tstd|dS t ||S#t $r'}td||Yd}~dSd}~wwxYw)a.Checks if attribute value is valid and cleans it if required. The function returns the cleaned value or None if the value is not valid. An attribute value is valid if it is an AnyValue. An attribute needs cleansing if: - Its length is greater than the maximum allowed length. rNr1zAttribute %s: %s)r"r#r$r%r5r7)rrr exceptions rr4r4s JsC((EsKKKt.ugFFFF *C;;;tttttsA A8A33A8limitc|dSt|trA |}n+#t$rtdYdSwxYw|t|t r |d|}|S)Nz$Byte attribute could not be decoded.)r"bytesdecodeUnicodeDecodeErrorr$r%r#)rr<s rr'r's }t% LLNNEE!    OOB C C C44  Zs33fuf  Ls0$AAc eZdZdZ ddeedeejdedeed ef d Z d e fd Z d e d ej fdZ d e dej d dfdZd e d dfdZdZd efdZded dfdZdZdS)BoundedAttributeszAn ordered dict with a fixed max capacity. Oldest elements are dropped when the dict is full and a new element is added. NTFmaxlen attributes immutable max_value_lenextended_attributesc$|*t|tr|dkrtd||_d|_||_||_i|_tj |_ |r| D] \}}|||< ||_ dS)Nrz.maxlen must be valid int greater or equal to 0) r"int ValueErrorrCdroppedrF_extended_attributes_dict threadingRLock_lockr3 _immutable)selfrCrDrErFrGrrs r__init__zBoundedAttributes.__init__s  fc** fqjj D  *$7!  _&&  "(..00 " " U!S #rrc,t|jSN)dictrMrRs r__repr__zBoundedAttributes.__repr__stz""$$rrc|j|SrU)rMrRrs r __getitem__zBoundedAttributes.__getitem__sz#rrct|ddrt|j5|j)|jdkr|xjdz c_ ddddS|jrt |||j}n&t|||j}| ddddS||j vr |j |=n|j{t|j |jkr^t|j tst|j |_ |j d|xjdz c_||j |<ddddS#1swxYwYdS)NrQFr)last)rr7rPrCrKrLr4rFr/rMlenr"rpopitem)rRrrs r __setitem__zBoundedAttributes.__setitem__!s 4u - - O Z $ ${&4;!+;+; !  $ $ $ $ $ $ $ $ ( 1 2)eT5GHH= $ $ $ $ $ $ $ $dj  JsOO(S__ -K-K!$*k::9!,TZ!8!8DJ """... ! #DJsO- $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s$E7EBEEEct|ddrt|j5|j|=ddddS#1swxYwYdS)NrQF)rr7rPrMrZs r __delitem__zBoundedAttributes.__delitem__<s 4u - - O Z   3                  s 6::c|j5t|jcdddS#1swxYwYdSrU)rPiterrMcopyrWs r__iter__zBoundedAttributes.__iter__Bs Z + + ))** + + + + + + + + + + + + + + + + + +s &;??c*t|jSrU)r_rMrWs r__len__zBoundedAttributes.__len__Fs4:rmemoc t|j|j|j|j}||t |<|j5tj|j ||_ |j |_ dddn #1swxYwY|S)N)rCrErFrG) rBrCrQrFrLidrPrfdeepcopyrMrK)rRrjcopy_s r __deepcopy__zBoundedAttributes.__deepcopy__Is!;o, $ 9     RXX Z ) )- D99EK LEM  ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  s,A99A=A=c4|jSrU)rMrfrWs rrfzBoundedAttributes.copyXsz   r)NNTNF)r __module__ __qualname____doc__rrIr _ExtendedAttributesboolrSr#rXAnyValuer[rarcrgrirVrorfrrrrBrBsp!%:>'+$) $$ $U67$ $  } $ " $$$$:%#%%%%su~$s$5>$d$$$$6 s t    +++  *=    !!!!!rrB)"rfloggingrN collectionsrcollections.abcrtypingrrrrr opentelemetry.utilr rur#r>rIfloatr&r)r8r getLoggerr r$AttributeValuer/rvr5r4r'rBrrrrsD ######******<<<<<<<<<<<<<<$$$$$$ eS%8 DJJ     @@@ ' H % %L L)L4J $,SMJ  ^J J J J Z ^.6sm ^.  (0  e"#$b!b!b!b!b!b!b!b!b!b!r