Ë
    Ô~ïi*E  ã                  ó�  — d dl mZ d dlZd dlmZmZmZmZ d dlm	Z	m
Z
 d dlZddlmZ ddlmZ ddlmZmZmZmZ dd	lmZ dd
lmZ ddlmZ ddlmZ ddlmZmZ ddl m!Z!m"Z" ddlm#Z#m$Z$ ddl%m&Z&m'Z'm(Z(m)Z) ddl*m+Z+m,Z,m-Z-m.Z. ddl/m0Z0m1Z1 ddl2m0Z3m1Z4 dZ5dZ6 edeejn                  ejp                  f   ¬«      Z9 edee!e   e"e   f   ¬«      Z: G d„ de«      Z; G d„ de«      Z< G d„ de'e9e:f   «      Z=	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d$d„Z> G d „ d!e=ejn                  e!e   f   e(«      Z? G d"„ d#e=ejp                  e"e   f   e)«      Z@y)%é    )ÚannotationsN)ÚAnyÚUnionÚMappingÚTypeVar)ÚSelfÚoverrideé   )Ú_exceptions©ÚQuerystring)Ú	NOT_GIVENÚOmitÚTimeoutÚNotGiven)Úis_given)Úcached_property)Ú__version__é   )Úget_auth_headers)ÚSyncAPIResourceÚAsyncAPIResource)ÚStreamÚAsyncStream)ÚAnthropicErrorÚAPIStatusError)ÚDEFAULT_MAX_RETRIESÚ
BaseClientÚSyncAPIClientÚAsyncAPIClient)Úresolve_regionÚresolve_api_keyÚresolve_auth_modeÚvalidate_credentials)ÚMessagesÚAsyncMessageszbedrock-mantle)ÚAWS_BEARER_TOKEN_BEDROCKÚANTHROPIC_AWS_API_KEYÚ_HttpxClientT)ÚboundÚ_DefaultStreamTc                  ó   — e Zd Zedd„«       Zy)Ú
MantleBetac                ó,   — t        | j                  «      S ©N)ÚBetaMessagesÚ_client©Úselfs    út/var/www/acinvestment.org/public_html/aci/backend/venv/lib/python3.12/site-packages/anthropic/lib/bedrock/_mantle.pyÚmessageszMantleBeta.messages.   s   € ä˜DŸL™LÓ)Ð)ó    N)Úreturnr0   ©Ú__name__Ú
__module__Ú__qualname__r   r5   © r6   r4   r-   r-   -   s   „ Øò*ó ñ*r6   r-   c                  ó   — e Zd Zedd„«       Zy)ÚAsyncMantleBetac                ó,   — t        | j                  «      S r/   )ÚAsyncBetaMessagesr1   r2   s    r4   r5   zAsyncMantleBeta.messages4   s   € ä  §¡Ó.Ð.r6   N)r7   r@   r8   r<   r6   r4   r>   r>   3   s   „ Øò/ó ñ/r6   r>   c                  ó.   — e Zd Ze	 	 	 	 	 	 	 	 dd„«       Zy)ÚBaseMantleClientc               ó*  — |j                   dk(  rt        j                  |||¬«      S |j                   dk(  rt        j                  |||¬«      S |j                   dk(  rt        j                  |||¬«      S |j                   dk(  rt        j
                  |||¬«      S |j                   dk(  rt        j                  |||¬«      S |j                   dk(  rt        j                  |||¬«      S |j                   dk(  rt        j                  |||¬«      S |j                   d	k(  rt        j                  |||¬«      S |j                   d
k(  rt        j                  |||¬«      S |j                   dk\  rt        j                  |||¬«      S t        |||¬«      S )Ni�  )ÚresponseÚbodyi‘  i“  i”  i™  i�  i¦  i­  i  iô  )Ústatus_coder   ÚBadRequestErrorÚAuthenticationErrorÚPermissionDeniedErrorÚNotFoundErrorÚConflictErrorÚRequestTooLargeErrorÚUnprocessableEntityErrorÚRateLimitErrorÚOverloadedErrorÚInternalServerErrorr   )r3   Úerr_msgrE   rD   s       r4   Ú_make_status_errorz#BaseMantleClient._make_status_error=   sx  € ð ×Ñ 3Ò&Ü×.Ñ.¨wÀÐPTÔUÐUà×Ñ 3Ò&Ü×2Ñ2°7ÀXÐTXÔYÐYà×Ñ 3Ò&Ü×4Ñ4°WÀxÐVZÔ[Ð[à×Ñ 3Ò&Ü×,Ñ,¨W¸xÈdÔSÐSà×Ñ 3Ò&Ü×,Ñ,¨W¸xÈdÔSÐSà×Ñ 3Ò&Ü×3Ñ3°GÀhÐUYÔZÐZà×Ñ 3Ò&Ü×7Ñ7¸È(ÐY]Ô^Ð^à×Ñ 3Ò&Ü×-Ñ-¨gÀÈtÔTÐTà×Ñ 3Ò&Ü×.Ñ.¨wÀÐPTÔUÐUà×Ñ 3Ò&Ü×2Ñ2°7ÀXÐTXÔYÐYÜ˜g°¸tÔDÐDr6   N)rQ   ÚstrrE   ÚobjectrD   zhttpx.Responser7   r   )r9   r:   r;   r	   rR   r<   r6   r4   rB   rB   <   s@   „ Øð$Eàð$Eð ð	$Eð
 !ð$Eð 
ò$Eó ñ$Er6   rB   c                ó.  — |rd}d}	n3t        ||¬«       t        | |||t        ¬«      }t        | |t        ¬«      }	t	        |«      }
|€t
        j                  j                  d«      }|€|
€t        d«      ‚d|
› d	�}i }|r|j                  |«       |	|||fS )
z‰Resolve and validate all Mantle client configuration.

    Returns (resolved_api_key, resolved_base_url, use_sigv4, merged_headers).
    FN)Úaws_access_keyÚaws_secret_key)Úapi_keyrV   rW   Úaws_profileÚapi_key_env_vars)rX   Ú	use_sigv4rZ   Ú!ANTHROPIC_BEDROCK_MANTLE_BASE_URLz×No AWS region or base URL found. Set `aws_region` in the constructor, the `AWS_REGION` / `AWS_DEFAULT_REGION` environment variable, or provide a `base_url` / `ANTHROPIC_BEDROCK_MANTLE_BASE_URL` environment variable.zhttps://bedrock-mantle.z.api.aws/anthropic)
r$   r#   Ú_MANTLE_API_KEY_ENV_VARSr"   r!   ÚosÚenvironÚgetr   Úupdate)rX   rV   rW   Ú
aws_regionrY   Ú	skip_authÚbase_urlÚdefault_headersr[   Úresolved_api_keyÚresolved_regionÚmerged_headerss               r4   Ú_resolve_mantle_configri   h   sÆ   € ñ Øˆ	ØÑä¨NÈ>ÕZä%ØØ)Ø)Ø#Ü5ô
ˆ	ô +ØØÜ5ô
Ðô % ZÓ0€OàÐÜ—:‘:—>‘>Ð"EÓFˆØÐØÐ"Ü ð[óð ð
 -¨_Ð,=Ð=OÐPˆà%'€NÙØ×Ñ˜oÔ.à˜X y°.Ð@Ð@r6   c                  óÄ  ‡ — e Zd ZU ded<   ded<   ded<   ded<   ded<   ded	<   ded
<   ded<   ded<   ddddddddeedddddœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dˆ fd„Zeedd„«       «       Z	eedd„«       «       Z
eedˆ fd„«       «       Zedd„«       Zedd„«       Zddddddddededdddi dœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„ZeZˆ xZS ) ÚAnthropicBedrockMantler%   r5   r-   Úbetaú
str | Nonerb   rV   rW   Úaws_session_tokenrY   Úboolrc   Ú
_use_sigv4NF©rV   rW   rn   rb   rY   rX   rc   rd   ÚtimeoutÚmax_retriesre   Údefault_queryÚhttp_clientÚ_strict_response_validationc          
     ó2  •— t        ||||||||¬«      \  }}}}t        |«      }t        ‰| �  t        ||	|
||||¬«       || _        || _        || _        || _        || _	        || _
        || _        || _        t        | «      | _        t        | «      | _        y ©N)rX   rV   rW   rb   rY   rc   rd   re   )Úversionrd   rr   rs   Úcustom_headersÚcustom_queryru   rv   )ri   r!   ÚsuperÚ__init__r   rX   rb   rV   rW   rn   rY   rc   rp   r%   r5   r-   rl   ©r3   rV   rW   rn   rb   rY   rX   rc   rd   rr   rs   re   rt   ru   rv   rf   Úresolved_base_urlr[   rh   rg   Ú	__class__s                       €r4   r}   zAnthropicBedrockMantle.__init__¯   sÀ   ø€ ô$ J`ØØ)Ø)Ø!Ø#ØØØ+ô	J
ÑFÐÐ+¨Y¸ô )¨Ó4ˆä‰ÑÜØ&ØØ#Ø)Ø&Ø#Ø(Cð 	ô 		
ð (ˆŒØ)ˆŒØ,ˆÔØ,ˆÔØ!2ˆÔØ&ˆÔØ"ˆŒØ#ˆŒä  ›ˆŒÜ˜tÓ$ˆ�	r6   c                ó   — t        d¬«      S ©NÚcomma)Úarray_formatr   r2   s    r4   ÚqszAnthropicBedrockMantle.qså   ó   € ô ¨Ô0Ð0r6   c                ód   — | j                   s| j                  ri S | j                  }|€i S dd|› �iS ©NÚAuthorizationzBearer ©rc   rp   rX   ©r3   rX   s     r4   Úauth_headersz#AnthropicBedrockMantle.auth_headersê   ó;   € ð �>Š>˜TŸ_š_ØˆIØ—,‘,ˆØˆ?ØˆIØ 7¨7¨)Ð!4Ð5Ð5r6   c                ó>   •— i t         ‰| �  ¥dddœ¥| j                  ¥S )NÚfalseú
2023-06-01©zX-Stainless-Asynczanthropic-version©r|   re   Ú_custom_headers©r3   r€   s    €r4   re   z&AnthropicBedrockMantle.default_headersô   s5   ø€ ð
Ü‰gÑ%ð
à!(Ø!-ò
ð ×"Ñ"ð	
ð 	
r6   c                 ó   — y r/   r<   ©r3   Úheadersrz   s      r4   Ú_validate_headersz(AnthropicBedrockMantle._validate_headersþ   ó   € àr6   c                óŒ  — | j                   s| j                  sy |j                  «       j                  «       }t	        |j
                  t        |j                  «      |j                  | j                  | j                  | j                  | j                  | j                  |t        ¬«
      }|j                  j                  |«       y ©N)
ÚmethodÚurlr—   rV   rW   rn   ÚregionÚprofileÚdataÚservice_name©rc   rp   ÚreadÚdecoder   rœ   rS   r�   r—   rV   rW   rn   rb   rY   ÚDEFAULT_SERVICE_NAMEra   ©r3   Úrequestr    r—   s       r4   Ú_prepare_requestz'AnthropicBedrockMantle._prepare_request  s�   € à�>Š> §¢Øà�|‰|‹~×$Ñ$Ó&ˆä"Ø—>‘>Ü�G—K‘KÓ Ø—O‘OØ×.Ñ.Ø×.Ñ.Ø"×4Ñ4Ø—?‘?Ø×$Ñ$ØÜ-ô
ˆð 	�‰×Ñ˜wÕ'r6   ©rX   rV   rW   rn   rb   rY   rc   rd   rr   ru   rs   re   Úset_default_headersrt   Úset_default_queryÚ_extra_kwargsc               ó(  — |�|�t        d«      ‚|�|�t        d«      ‚| j                  }|�i |¥|¥}n|�|}| j                  }|�i |¥|¥}n|�|} | j                  d|xs | j                  |xs | j
                  |xs | j                  |xs | j                  |xs | j                  |xs | j                  |�|n| j                  |xs | j                  t        |	t        «      r| j                  n|	|
t        |«      r|n| j                   ||dœ|¤ŽS ©NzPThe `default_headers` and `set_default_headers` arguments are mutually exclusivezLThe `default_query` and `set_default_query` arguments are mutually exclusive)rX   rV   rW   rn   rb   rY   rc   rd   rr   ru   rs   re   rt   r<   ©Ú
ValueErrorr“   Ú_custom_queryr€   rX   rV   rW   rn   rb   rY   rc   rd   Ú
isinstancer   rr   r   rs   ©r3   rX   rV   rW   rn   rb   rY   rc   rd   rr   ru   rs   re   rª   rt   r«   r¬   r—   Úparamss                      r4   ÚcopyzAnthropicBedrockMantle.copy  óC  € ð( Ð&Ð+>Ð+JÜÐoÓpÐpàÐ$Ð):Ð)FÜÐkÓlÐlà×&Ñ&ˆØÐ&Ø4˜Ð4 OÐ4‰GØ Ð,Ø)ˆGà×#Ñ#ˆØÐ$Ø0˜Ð0 -Ð0‰FØÐ*Ø&ˆFàˆt�~‰~ð 
ØÒ+˜tŸ|™|Ø)Ò@¨T×-@Ñ-@Ø)Ò@¨T×-@Ñ-@Ø/ÒI°4×3IÑ3IØ!Ò4 T§_¡_Ø#Ò7 t×'7Ñ'7Ø#,Ð#8‘i¸d¿n¹nØÒ. §¡Ü$.¨w¼Ô$A�D—L’LÀwØ#Ü'/°Ô'<™À$×BRÑBRØ#Ø ñ
ð ñ
ð 	
r6   )rV   rm   rW   rm   rn   rm   rb   rm   rY   rm   rX   rm   rc   ro   rd   ústr | httpx.URL | Nonerr   ú!float | Timeout | None | NotGivenrs   Úintre   úMapping[str, str] | Nonert   úMapping[str, object] | Noneru   úhttpx.Client | Nonerv   ro   r7   ÚNone©r7   r   ©r7   zdict[str, str]©r7   zdict[str, str | Omit]©r—   r   rz   r   r7   r½   ©r§   zhttpx.Requestr7   r½   )"rX   rm   rV   rm   rW   rm   rn   rm   rb   rm   rY   rm   rc   úbool | Nonerd   r·   rr   r¸   ru   r¼   rs   úint | NotGivenre   rº   rª   rº   rt   r»   r«   r»   r¬   úMapping[str, Any]r7   r   ©r9   r:   r;   Ú__annotations__r   r   r}   Úpropertyr	   r…   rŒ   re   r˜   r¨   rµ   Úwith_optionsÚ__classcell__©r€   s   @r4   rk   rk   ¢   se  ø… ØÓØ
ÓàÓØÓØÓØ!Ó!ØÓØƒOàÓð
 &*Ø%)Ø(,Ø!%Ø"&Ø"ØØ+/Ø5>Ø.Ø48Ø59Ø+/Ø,1ñ!4%ð #ð4%ð #ð	4%ð
 &ð4%ð ð4%ð  ð4%ð ð4%ð ð4%ð )ð4%ð 3ð4%ð ð4%ð 2ð4%ð 3ð4%ð )ð4%ð  &*ð!4%ð" 
õ#4%ðl Øò1ó ó ð1ð Øò6ó ó ð6ð Øô
ó ó ð
ð òó ðð ò(ó ð(ð. #Ø%)Ø%)Ø(,Ø!%Ø"&Ø!%Ø+/Ø5>Ø+/Ø&/Ø48Ø8<Ø59Ø9=Ø+-ñ%5
ð ð5
ð #ð	5
ð
 #ð5
ð &ð5
ð ð5
ð  ð5
ð ð5
ð )ð5
ð 3ð5
ð )ð5
ð $ð5
ð 2ð5
ð 6ð5
ð  3ð!5
ð" 7ð#5
ð$ )ð%5
ð& 
ó'5
ðn „Lr6   rk   c                  óÄ  ‡ — e Zd ZU ded<   ded<   ded<   ded<   ded<   ded	<   ded
<   ded<   ded<   ddddddddeedddddœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dˆ fd„Zeedd„«       «       Z	eedd„«       «       Z
eedˆ fd„«       «       Zedd„«       Zedd„«       Zddddddddededdddi dœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„ZeZˆ xZS ) ÚAsyncAnthropicBedrockMantler&   r5   r>   rl   rm   rb   rV   rW   rn   rY   ro   rc   rp   NFrq   c          
     ó2  •— t        ||||||||¬«      \  }}}}t        |«      }t        ‰| �  t        ||	|
||||¬«       || _        || _        || _        || _        || _	        || _
        || _        || _        t        | «      | _        t        | «      | _        y rx   )ri   r!   r|   r}   r   rX   rb   rV   rW   rn   rY   rc   rp   r&   r5   r>   rl   r~   s                       €r4   r}   z$AsyncAnthropicBedrockMantle.__init__a  sÁ   ø€ ô$ J`ØØ)Ø)Ø!Ø#ØØØ+ô	J
ÑFÐÐ+¨Y¸ô )¨Ó4ˆä‰ÑÜØ&ØØ#Ø)Ø&Ø#Ø(Cð 	ô 		
ð (ˆŒØ)ˆŒØ,ˆÔØ,ˆÔØ!2ˆÔØ&ˆÔØ"ˆŒØ#ˆŒä% dÓ+ˆŒÜ# DÓ)ˆ�	r6   c                ó   — t        d¬«      S r‚   r   r2   s    r4   r…   zAsyncAnthropicBedrockMantle.qs—  r†   r6   c                ód   — | j                   s| j                  ri S | j                  }|€i S dd|› �iS rˆ   rŠ   r‹   s     r4   rŒ   z(AsyncAnthropicBedrockMantle.auth_headersœ  r�   r6   c                ó>   •— i t         ‰| �  ¥dddœ¥| j                  ¥S )Nzasync:asyncior�   r‘   r’   r”   s    €r4   re   z+AsyncAnthropicBedrockMantle.default_headers¦  s5   ø€ ð
Ü‰gÑ%ð
à!0Ø!-ò
ð ×"Ñ"ð	
ð 	
r6   c                 ó   — y r/   r<   r–   s      r4   r˜   z-AsyncAnthropicBedrockMantle._validate_headers°  r™   r6   c              ƒ  ó”  K  — | j                   s| j                  sy |j                  «       j                  «       }t	        |j
                  t        |j                  «      |j                  | j                  | j                  | j                  | j                  | j                  |t        ¬«
      }|j                  j                  |«       y ­wr›   r¢   r¦   s       r4   r¨   z,AsyncAnthropicBedrockMantle._prepare_request´  s“   è ø€ à�>Š> §¢Øà�|‰|‹~×$Ñ$Ó&ˆä"Ø—>‘>Ü�G—K‘KÓ Ø—O‘OØ×.Ñ.Ø×.Ñ.Ø"×4Ñ4Ø—?‘?Ø×$Ñ$ØÜ-ô
ˆð 	�‰×Ñ˜wÕ'ùs   ‚CCr©   c               ó(  — |�|�t        d«      ‚|�|�t        d«      ‚| j                  }|�i |¥|¥}n|�|}| j                  }|�i |¥|¥}n|�|} | j                  d|xs | j                  |xs | j
                  |xs | j                  |xs | j                  |xs | j                  |xs | j                  |�|n| j                  |xs | j                  t        |	t        «      r| j                  n|	|
t        |«      r|n| j                   ||dœ|¤ŽS r®   r¯   r³   s                      r4   rµ   z AsyncAnthropicBedrockMantle.copyÉ  r¶   r6   )rV   rm   rW   rm   rn   rm   rb   rm   rY   rm   rX   rm   rc   ro   rd   r·   rr   r¸   rs   r¹   re   rº   rt   r»   ru   úhttpx.AsyncClient | Nonerv   ro   r7   r½   r¾   r¿   rÀ   rÁ   rÂ   )"rX   rm   rV   rm   rW   rm   rn   rm   rb   rm   rY   rm   rc   rÃ   rd   r·   rr   r¸   ru   rÕ   rs   rÄ   re   rº   rª   rº   rt   r»   r«   r»   r¬   rÅ   r7   r   rÆ   rË   s   @r4   rÍ   rÍ   T  se  ø… ØÓØ
ÓàÓØÓØÓØ!Ó!ØÓØƒOàÓð
 &*Ø%)Ø(,Ø!%Ø"&Ø"ØØ+/Ø5>Ø.Ø48Ø59Ø04Ø,1ñ!4*ð #ð4*ð #ð	4*ð
 &ð4*ð ð4*ð  ð4*ð ð4*ð ð4*ð )ð4*ð 3ð4*ð ð4*ð 2ð4*ð 3ð4*ð .ð4*ð  &*ð!4*ð" 
õ#4*ðl Øò1ó ó ð1ð Øò6ó ó ð6ð Øô
ó ó ð
ð òó ðð ò(ó ð(ð. #Ø%)Ø%)Ø(,Ø!%Ø"&Ø!%Ø+/Ø5>Ø04Ø&/Ø48Ø8<Ø59Ø9=Ø+-ñ%5
ð ð5
ð #ð	5
ð
 #ð5
ð &ð5
ð ð5
ð  ð5
ð ð5
ð )ð5
ð 3ð5
ð .ð5
ð $ð5
ð 2ð5
ð 6ð5
ð  3ð!5
ð" 7ð#5
ð$ )ð%5
ð& 
ó'5
ðn „Lr6   rÍ   )rX   rm   rV   rm   rW   rm   rb   rm   rY   rm   rc   ro   rd   r·   re   rº   r7   z8tuple[str | None, str | httpx.URL, bool, dict[str, str]])AÚ
__future__r   r^   Útypingr   r   r   r   Útyping_extensionsr   r	   ÚhttpxÚ r   Ú_qsr   Ú_typesr   r   r   r   Ú_utilsr   Ú_compatr   Ú_versionr   Ú	aws._authr   Ú	_resourcer   r   Ú
_streamingr   r   r   r   Ú_base_clientr   r   r   r    Úaws._credentialsr!   r"   r#   r$   Úresources.messagesr%   r&   Úresources.beta.messagesr0   r@   r¥   r]   ÚClientÚAsyncClientr)   r+   r-   r>   rB   ri   rk   rÍ   r<   r6   r4   ú<module>ré      s‡  ðÝ "ã 	ß /Ó /ß ,ã å Ý ß 8Ó 8Ý Ý &Ý #Ý (ß :ß -ß 9÷ó ÷ó ÷ :ß cà'Ð àPÐ á˜¨u°U·\±\À5×CTÑCTÐ5TÑ/UÔV€ÙÐ+°5¸À¹ÀkÐRUÑFVÐ9VÑ3WÔX€ô*�ô *ô/Ð&ô /ô&E�z -°Ð"@ÑAô &EðX4Aàð4Að ð4Að ð	4Að
 ð4Að ð4Að ð4Að %ð4Að .ð4Að >ó4AôtlÐ-¨e¯l©l¸FÀ3¹KÐ.GÑHÈ-ô lôdlÐ"2°5×3DÑ3DÀkÐRUÑFVÐ3VÑ"WÐYgõ lr6   