ó
    Ú2‰iO  ã                   ó.  • S SK Jr  S SKJr  S SKJrJrJrJrJ	r	  S SK
JrJr  S SKJrJrJr  S SKJr  S SKJr  S SKJr  S S	KJr  \" \5      r " S
 S\R6                  5      rS\\\4   S\4S jrS\\\R@                        S\\R@                     4S jr!g)é    )Ú	getLogger)Úsplit)ÚIterableÚListÚMappingÚOptionalÚSet)Ú
quote_plusÚunquote_plus)Ú_is_valid_pairÚget_allÚset_baggage)Úget_current)ÚContext)Útextmap)Ú_DELIMITER_PATTERNc            	       óB  • \ rS rSrSrSrSrSrSrS\	R                  4S\	R                  S	\\   S
\	R                  \	R                     S\4S jjrS\	R                   4S\	R                  S	\\   S\	R"                  \	R                     SS4S jjr\S\\   4S j5       rSrg)ÚW3CBaggagePropagatoré   zAExtracts and injects Baggage which is used to annotate telemetry.i    i   é´   ÚbaggageNÚcarrierÚcontextÚgetterÚreturnc                 óV  • Uc
  [        5       n[        UR                  XR                  5      5      nU(       d  U$ [	        U5      U R
                  :”  a  [        R                  SU5        U$ [        [        U5      nU R                  n[	        U5      U R                  :”  a  [        R                  SU5        U HÅ  n[	        U5      U R                  :”  a  [        R                  SU5        M4  U(       d  M=   UR                  SS5      u  p‰[        X‰5      (       d  [        R                  SU5        Mz  [        U5      R                  5       n[        U	5      R                  5       n	[!        UU	US9nUS-  nUS	:X  d  MÄ    U$    U$ ! [         a    [        R                  SU5         Mî  f = f)
zeExtract Baggage from the carrier.

See
`opentelemetry.propagators.textmap.TextMapPropagator.extract`
zKBaggage header `%s` exceeded the maximum number of bytes per baggage-stringz?Baggage header `%s` exceeded the maximum number of list-memberszGBaggage entry `%s` exceeded the maximum number of bytes per list-memberÚ=é   z1Baggage list-member `%s` doesn't match the formatzInvalid baggage entry: `%s`©r   r   )r   Ú_extract_first_elementÚgetÚ_BAGGAGE_HEADER_NAMEÚlenÚ_MAX_HEADER_LENGTHÚ_loggerÚwarningr   r   Ú
_MAX_PAIRSÚ_MAX_PAIR_LENGTHÚ	Exceptionr   r   Ústripr   )
Úselfr   r   r   ÚheaderÚbaggage_entriesÚtotal_baggage_entriesÚentryÚnameÚvalues
             Úg/home/mande/repo/quber/.venv/lib/python3.13/site-packages/opentelemetry/baggage/propagation/__init__.pyÚextractÚW3CBaggagePropagator.extract%   s’  € ð ‰?Ü!“mˆGä'Ø�J‰J�w× 9Ñ 9Ó:ó
ˆö ØˆNäˆv‹;˜×0Ñ0Ó0Ü�O‰OØ]Øôð ˆNä%*Ô+=¸vÓ%FˆØ $§¡ÐäˆÓ $§/¡/Ó1Ü�O‰OØQØôó
 %ˆEÜ�5‹z˜D×1Ñ1Ó1Ü—‘Ø]Øôñ ÞÙðØ#Ÿk™k¨#¨qÓ1‘�ô " $×.Ñ.Ü—‘Ð =¸uÔEÙä Ó%×+Ñ+Ó-ˆDÜ  Ó'×-Ñ-Ó/ˆEä!ØØØñˆGð
 " QÑ&Ð!Ø$¨Õ)ØàˆñC %ðB ˆøô- ó Ü—‘ØGÈôò ð	ús   Ã7FÆ F(Æ'F(Úsetterc                 ót   • [        US9nU(       d  g[        U5      nUR                  XR                  U5        g)zdInjects Baggage into the carrier.

See
`opentelemetry.propagators.textmap.TextMapPropagator.inject`
r   N)r   Ú_format_baggageÚsetr"   )r+   r   r   r5   r-   Úbaggage_strings         r2   ÚinjectÚW3CBaggagePropagator.injectn   s2   € ô "¨'Ñ2ˆÞØä(¨Ó9ˆØ�
‰
�7×5Ñ5°~ÕFó    c                 ó   • U R                   1$ )z.Returns a set with the fields set in `inject`.)r"   )r+   s    r2   ÚfieldsÚW3CBaggagePropagator.fields€   s   € ð ×)Ñ)Ð*Ð*r<   © )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r$   r(   r'   r"   r   Údefault_getterÚCarrierTr   r   ÚGetterr3   Údefault_setterÚSetterr:   Úpropertyr	   Ústrr>   Ú__static_attributes__r@   r<   r2   r   r      sì   † ÙKàÐØÐØ€JØ$Ðð
 &*Ø3:×3IÑ3Iñ	Gà×!Ñ!ðGð ˜'Ñ"ðGð —‘˜w×/Ñ/Ñ0ð	Gð
 
õGðX &*Ø3:×3IÑ3Iñ	Gà×!Ñ!ðGð ˜'Ñ"ðGð —‘˜w×/Ñ/Ñ0ð	Gð
 
õGð$ ð+˜˜C™ó +ó ó+r<   r   r-   r   c                 óN   • SR                  S U R                  5        5       5      $ )NÚ,c              3   ó~   #   • U  H3  u  p[        [        U5      5      S -   [        [        U5      5      -   v •  M5     g7f)r   N)r
   rL   )Ú.0Úkeyr1   s      r2   Ú	<genexpr>Ú"_format_baggage.<locals>.<genexpr>‡   s5   é € ð â1‰JˆCô 	”3�s“8Ó˜sÑ"¤Z´°E³
Ó%;Ö;Ú1ùs   ‚;=)ÚjoinÚitems)r-   s    r2   r7   r7   †   s)   € Ø�8‰8ñ à)×/Ñ/Ô1óó ð r<   rV   c                 ó4   • U c  g [        [        U 5      S 5      $ )N)ÚnextÚiter)rV   s    r2   r    r    �   s   € ð �}ØÜ”�U“˜TÓ"Ð"r<   N)"Úloggingr   Úrer   Útypingr   r   r   r   r	   Úurllib.parser
   r   Úopentelemetry.baggager   r   r   Úopentelemetry.contextr   Úopentelemetry.context.contextr   Úopentelemetry.propagatorsr   Úopentelemetry.util.rer   rA   r%   ÚTextMapPropagatorr   rL   Úobjectr7   rG   r    r@   r<   r2   Ú<module>re      s“   ðõ Ý ß 9Õ 9ß 1ç FÑ FÝ -Ý 1Ý -Ý 4á
�HÓ
€ôf+˜7×4Ñ4ô f+ðR W¨S°&¨[Ñ%9ð ¸cô ð#Ø�H˜W×-Ñ-Ñ.Ñ/ð#àˆg×ÑÑõ#r<   