Ë
    sPêj06  ã                  ó²  — U d dl mZ d dl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mZmZmZmZ ddlmZ ddlmZmZmZmZmZmZmZmZmZ dd	lmZm Z 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-m.Z. ddl/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZC ddlDmEZEmFZFmGZG ddlHmIZJ ddlKmLZL ddlMmNZNmOZO g d¢ZPej¢                  sddlRmSZS ddlTmUZVmWZXmYZY ddlZm[Z[ ddl\m]Z]m^Z^ ddl_m`Z`maZa ddlb­ ddlcmdZdmeZe  eJ«         ef«       ZgePD ]  ZhehjÓ                  d«      rŒ	 degeh   _j        Œ! d dlZd dlZmd dlnZoddlDm,Z,m-Z- dapdeqd<   dardeqd <   dasdeqd!<   datdeqd"<   daudeqd#<   dZvd$eqd%<   e,awd&eqd'<   e-axd(eqd)<   dayd*eqd+<   dazd,eqd-<   da{d.eqd/<   emjø                  d0   Z} ejü                  e}ejþ                  �j                  d1«      «      a�d2eqd3<   ejþ                  �j                  d4«      a‚deqd5<   ejþ                  �j                  d6«      aƒdeqd7<   ejþ                  �j                  d8«      a„deqd9<   dZ…d:eqd;<   da†deqd<<   dZ‡d=eqd><    G d?„ d@e«      Zˆ G dA„ dBeˆe]«      Z‰ G dC„ dDeˆe`«      ZŠ G dE„ dFe2«      Z‹dOdG„ZŒdOdH„Z�dOdI„ZŽdadJeqdK<   dPdL„Z�dQdM„Z�ddNl‘m’Z’m“Z“m”Z”m•Z•m–Z–m—Z—m˜Z˜m™Z™mšZšm›Z›mœZœm�Z�mžZžmŸZŸm Z m¡Z¡m¢Z¢m£Z£m¤Z¤m¥Z¥m¦Z¦m§Z§m¨Z¨ y# ekelf$ r Y �ŒÂw xY w)Ré    )ÚannotationsN)Úoverrideé   )Útypes)Ú	NOT_GIVENÚOmitÚNoneTypeÚNotGivenÚ	TransportÚProxiesTypesÚomitÚ	not_given)Úfile_from_path)	ÚClientÚOpenAIÚStreamÚTimeoutr   ÚAsyncClientÚAsyncOpenAIÚAsyncStreamÚRequestOptions)ÚDefaultHttpx2ClientÚDefaultAsyncHttpx2ClientÚnormalize_httpx_url)Ú	BaseModel)Ú	__title__Ú__version__)ÚAPIResponseÚAsyncAPIResponse)ÚDEFAULT_TIMEOUTÚDEFAULT_MAX_RETRIESÚDEFAULT_CONNECTION_LIMITS)ÚAPIErrorÚ
OAuthErrorÚOpenAIErrorÚConflictErrorÚNotFoundErrorÚAPIStatusErrorÚRateLimitErrorÚAPITimeoutErrorÚBadRequestErrorÚAPIConnectionErrorÚAuthenticationErrorÚInternalServerErrorÚPermissionDeniedErrorÚLengthFinishReasonErrorÚWebSocketQueueFullErrorÚUnprocessableEntityErrorÚAPIResponseValidationErrorÚInvalidWebhookSignatureErrorÚContentFilterFinishReasonErrorÚWebSocketConnectionClosedError)ÚDefaultHttpxClientÚDefaultAioHttpClientÚDefaultAsyncHttpxClient)Úsetup_logging)ÚHttpxBinaryResponseContent)ÚReconnectingEventÚReconnectingOverrides)5r   r   r   r	   r   r   r
   r   r   r   r   r%   r#   r(   r*   r,   r3   r+   r-   r$   r/   r'   r&   r2   r)   r.   r0   r5   r4   r   r   r   r   r   r   r   r   ÚBedrockOpenAIÚAsyncBedrockOpenAIr   r   r    r!   r"   r7   r9   r8   r   r   r<   r=   r1   r6   )Ú	resources)ÚazureÚbedrockÚpydantic_function_tool)ÚVERSION)ÚAzureOpenAIÚAsyncAzureOpenAI)r>   r?   )Ú*)ÚAssistantEventHandlerÚAsyncAssistantEventHandlerÚ__Úopenai)r    r!   ú
str | NoneÚapi_keyÚadmin_api_keyÚorganizationÚprojectÚwebhook_secretzstr | _httpx.URL | NoneÚbase_urlúfloat | Timeout | NoneÚtimeoutÚintÚmax_retriesú_t.Mapping[str, str] | NoneÚdefault_headersú_t.Mapping[str, object] | NoneÚdefault_queryz_httpx.Client | NoneÚhttp_client)rK   rA   úamazon-bedrockÚOPENAI_API_TYPEz_ApiType | NoneÚapi_typeÚOPENAI_API_VERSIONÚapi_versionÚAZURE_OPENAI_ENDPOINTÚazure_endpointÚAZURE_OPENAI_AD_TOKENÚazure_ad_tokenz"_azure.AzureADTokenProvider | NoneÚazure_ad_token_providerÚ_bedrock_api_keyz$_bedrock.BedrockTokenProvider | NoneÚbedrock_token_providerc                  óö  ‡ — e Zd Zeedd„«       «       Zej                  dd„«       Zeedd„«       «       Zej                  dd„«       Zeedd„«       «       Zej                  dd„«       Zeedd„«       «       Z	e	j                  dd„«       Z	eedd	„«       «       Z
e
j                  dd
„«       Z
eedˆ fd„«       «       Zej                  dˆ fd„«       Zeedd„«       «       Zej                  dd„«       Zeedd„«       «       Zej                  dd„«       Zeedd„«       «       Zej                  d d„«       Zeed!d„«       «       Zej                  d"d„«       Zeed#ˆ fd„«       «       Zej                  d$d„«       Zˆ xZS )%Ú_ModuleClientc                ó   — t         S ©N©rM   ©Úselfs    úT/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/openai/__init__.pyrM   z_ModuleClient.api_key´   ó	   € ô ˆó    c                ó   — |a y rk   rl   ©rn   Úvalues     ro   rM   z_ModuleClient.api_key¹   ó	   € ð ‰rq   c                ó   — t         S rk   ©rN   rm   s    ro   rN   z_ModuleClient.admin_api_key¿   ó
   € ô Ðrq   c                ó   — |a y rk   rw   rs   s     ro   rN   z_ModuleClient.admin_api_keyÄ   ó	   € ð ‰rq   c                ó   — t         S rk   ©rO   rm   s    ro   rO   z_ModuleClient.organizationÊ   s
   € ô Ðrq   c                ó   — |a y rk   r|   rs   s     ro   rO   z_ModuleClient.organizationÏ   s	   € ð ‰rq   c                ó   — t         S rk   ©rP   rm   s    ro   rP   z_ModuleClient.projectÕ   rp   rq   c                ó   — |a y rk   r   rs   s     ro   rP   z_ModuleClient.projectÚ   ru   rq   c                ó   — t         S rk   ©rQ   rm   s    ro   rQ   z_ModuleClient.webhook_secretà   s
   € ô Ðrq   c                ó   — |a y rk   r‚   rs   s     ro   rQ   z_ModuleClient.webhook_secretå   s	   € ð ‰rq   c                óB   •— t         �t        t         «      S t        ‰| �   S rk   )rR   Ú_normalize_httpx_urlÚsuper©rn   Ú	__class__s    €ro   rR   z_ModuleClient.base_urlë   s!   ø€ ô ÐÜ'¬Ó1Ð1ä‰wÑÐrq   c                ó$   •— |t        «       _        y rk   )r†   rR   )rn   Úurlrˆ   s     €ro   rR   z_ModuleClient.base_urló   s   ø€ àŒ‹Õrq   c                ó   — t         S rk   ©rT   rm   s    ro   rT   z_ModuleClient.timeout÷   rp   rq   c                ó   — |a y rk   rŒ   rs   s     ro   rT   z_ModuleClient.timeoutü   ru   rq   c                ó   — t         S rk   ©rV   rm   s    ro   rV   z_ModuleClient.max_retries  s
   € ô Ðrq   c                ó   — |a y rk   r�   rs   s     ro   rV   z_ModuleClient.max_retries  ó	   € ð ‰rq   c                ó   — t         S rk   ©rX   rm   s    ro   Ú_custom_headersz_ModuleClient._custom_headers  s
   € ô Ðrq   c                ó   — |a y rk   r“   rs   s     ro   r”   z_ModuleClient._custom_headers  s	   € ð  ‰rq   c                ó   — t         S rk   ©rZ   rm   s    ro   Ú_custom_queryz_ModuleClient._custom_query  rx   rq   c                ó   — |a y rk   r—   rs   s     ro   r˜   z_ModuleClient._custom_query  rz   rq   c                ó(   •— t         xs
 t        ‰| �  S rk   )r[   r†   Ú_clientr‡   s    €ro   r›   z_ModuleClient._client#  s   ø€ ô Ò-œe™g™oÐ-rq   c                ó   — |a y rk   )r[   rs   s     ro   r›   z_ModuleClient._client(  r‘   rq   ©ÚreturnrL   ©rt   rL   rž   ÚNone)rž   z
_httpx.URL)rŠ   z_httpx.URL | strrž   r    )rž   rS   )rt   rS   rž   r    )rž   rU   )rt   rU   rž   r    )rž   rW   )rt   rW   rž   r    )rž   rY   )rt   rY   rž   r    )rž   ú_httpx.Client)rt   r¡   rž   r    )Ú__name__Ú
__module__Ú__qualname__Úpropertyr   rM   ÚsetterrN   rO   rP   rQ   rR   rT   rV   r”   r˜   r›   Ú__classcell__©rˆ   s   @ro   ri   ri   °   sK  ø„ ð Øòó ó ðð ‡^�^òó ðð
 Øòó ó ðð ×Ñòó ðð
 Øòó ó ðð ×Ñòó ðð
 Øòó ó ðð ‡^�^òó ðð
 Øòó ó ðð ×Ñòó ðð
 Øô ó ó ð ð ‡_�_ôó ðð Øòó ó ðð ‡^�^òó ðð
 Øòó ó ðð ×Ñòó ðð
 Øòó ó ðð ×Ñò ó ð ð
 Øòó ó ðð ×Ñòó ðð
 Øô.ó ó ð.ð ‡^�^òó ôrq   ri   c                  ó   — e Zd Zy)Ú_AzureModuleClientN)r¢   r£   r¤   © rq   ro   rª   rª   /  s   „ Ørq   rª   c                  ó‚   ‡ — e Zd Zeedd„«       «       Zej                  dd„«       Zedˆ fd„«       Zedˆ fd„«       Zˆ xZ	S )	Ú_BedrockModuleClientc                ó&   — t         �t         S t        S rk   )rM   rf   rm   s    ro   rM   z_BedrockModuleClient.api_key4  s   € ô "Ð-ŒwÐCÔ3CÐCrq   c                ó   — |a y rk   )rf   rs   s     ro   rM   z_BedrockModuleClient.api_key9  s
   € ð !Ñrq   c                ó8   •— t         �t         S t        ‰| �	  «       S rk   )rM   r†   Ú_refresh_api_keyr‡   s    €ro   r±   z%_BedrockModuleClient._refresh_api_key?  s   ø€ äÐÜˆNä‰wÑ'Ó)Ð)rq   c                ó<   •— t         �dt         fS t        ‰| �	  «       S )NÚbearer)rM   r†   Ú_legacy_auth_configurationr‡   s    €ro   r´   z/_BedrockModuleClient._legacy_auth_configurationF  s"   ø€ äÐØœgÐ&Ð&Ü‰wÑ1Ó3Ð3rq   r�   rŸ   )rž   Ústr)rž   z!_bedrock._LegacyAuthConfiguration)
r¢   r£   r¤   r¥   r   rM   r¦   r±   r´   r§   r¨   s   @ro   r­   r­   3  s_   ø„ ØØòDó ó ðDð ‡^�^ò!ó ð!ð
 ô*ó ð*ð ô4ó ô4rq   r­   c                  ó    ‡ — e Zd Zdˆ fd„Zˆ xZS )Ú _AmbiguousModuleClientUsageErrorc                ó$   •— t         ‰| �  d«       y )Nz”Ambiguous use of module client; please set `openai.api_type` or the `OPENAI_API_TYPE` environment variable to `openai`, `azure`, or `amazon-bedrock`)r†   Ú__init__r‡   s    €ro   r¹   z)_AmbiguousModuleClientUsageError.__init__N  s   ø€ Ü‰Ñð cõ	
rq   ©rž   r    )r¢   r£   r¤   r¹   r§   r¨   s   @ro   r·   r·   M  s   ø„ ÷
ñ 
rq   r·   c                 óD   — t         j                  j                  d«      d uS )NÚOPENAI_API_KEY)Ú_osÚenvironÚgetr«   rq   ro   Ú_has_openai_credentialsrÀ   T  s   € Ü�;‰;�?‰?Ð+Ó,°DÐ8Ð8rq   c                 óX   — t         d uxs! t        j                  j                  d«      d uS )NÚAZURE_OPENAI_API_KEY)rb   r½   r¾   r¿   r«   rq   ro   Ú_has_azure_credentialsrÃ   X  s&   € Ü Ð%Ò\¬¯©¯©Ð9OÓ)PÐX\Ð)\Ð\rq   c                 ól   — t         j                  j                  d«      d uxs t        d uxs t        d uS )Nrc   )r½   r¾   r¿   rd   re   r«   rq   ro   Ú_has_azure_ad_credentialsrÅ   \  s7   € ä�‰�‰Ð/Ó0¸Ð<ò 	/Ü Ð%ò	/ä"¨$Ð.ðrq   zOpenAI | Noner›   c                 óÀ  — t         �€Òt        €t        j                  j	                  d«      at
        €t        j                  j	                  d«      at        €t        j                  j	                  d«      at        €mt        «       } t        «       }t        «       }| r|s|r
t        «       ‚t
        €t        �*t        j                  j	                  d«      	 �
t        «       ‚|s|rdandat        dk(  rMt        t        t        t        t
        t        t        t         t"        t$        t&        t(        t*        ¬«      a t         S t        dk(  rHt-        t        t.        t        t0        t2        t         t"        t$        t&        t(        t*        ¬	«      a t         S t5        t        t6        t        t0        t2        t         t"        t$        t&        t(        t*        d
¬«      a t         S t         S )Nra   rc   r_   rÂ   rA   rK   )r`   rb   rM   rd   re   rO   rR   rT   rV   rX   rZ   r[   r\   )rM   rg   rO   rP   rQ   rR   rT   rV   rX   rZ   r[   F)rM   rN   rO   rP   rQ   rR   rT   rV   rX   rZ   r[   Ú_enforce_credentials)r›   rb   r½   r¾   r¿   rd   r`   r^   rÀ   rÃ   rÅ   r·   re   rª   rM   rO   rR   rT   rV   rX   rZ   r[   r­   rg   rP   rQ   ri   rN   )Ú
has_openaiÚ	has_azureÚhas_azure_ads      ro   Ú_load_clientrË   g  s}  € ô �ô Ð!Ü Ÿ[™[Ÿ_™_Ð-DÓEˆNäÐ!Ü Ÿ[™[Ÿ_™_Ð-DÓEˆNäÐÜŸ+™+Ÿ/™/Ð*>Ó?ˆKäÐÜ0Ó2ˆJÜ.Ó0ˆIÜ4Ó6ˆLá™y©LÜ6Ó8Ð8äÐ*Ô.EÐ.QÔWZ×WbÑWb×WfÑWfØ&óXàðXô 7Ó8Ð8á™LØ"‘à#�ä�wÒÜ(Ü'Ü-ÜÜ-Ü(?Ü)Ü!ÜÜ'Ü /Ü+Ü'ôˆGô ˆNäÐ'Ò'Ü*ÜÜ'=Ü)ÜÜ-Ü!ÜÜ'Ü /Ü+Ü'ôˆGô ˆNäÜÜ'Ü%ÜÜ)ÜÜÜ#Ü+Ü'Ü#Ø!&ô
ˆô ˆä€Nrq   c                 ó   — d a y rk   )r›   r«   rq   ro   Ú_reset_clientrÍ   ¼  s	   € ð �Grq   )ÚbetaÚchatÚadminÚaudioÚevalsÚfilesÚimagesÚmodelsÚskillsÚvideosÚbatchesÚuploadsÚrealtimeÚwebhooksÚ	responsesÚ
containersÚ
embeddingsÚcompletionsÚfine_tuningÚmoderationsÚconversationsÚvector_storesÚcontent_provenance_checks)rž   Úbool)rž   r   rº   )©Ú
__future__r   Úosr½   ÚtypingÚ_tÚtyping_extensionsr   Ú r   Ú_typesr   r   r	   r
   r   r   r   r   Ú_utilsr   r›   r   r   r   r   r   r   r   r   Ú_httpx2r   r   r   r…   Ú_modelsr   Ú_versionr   r   Ú	_responser   r   Ú
_constantsr    r!   r"   Ú_exceptionsr#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   r6   Ú_base_clientr7   r8   r9   Ú_utils._logsr:   Ú_setup_loggingÚ_legacy_responser;   Útypes.websocket_reconnectionr<   r=   Ú__all__ÚTYPE_CHECKINGÚ_utils._resources_proxyr@   ÚlibrA   Ú_azurerB   Ú_bedrockrC   ÚversionrD   Ú	lib.azurerE   rF   Úlib.bedrockr>   r?   Úlib._old_apiÚlib.streamingrH   rI   ÚlocalsÚ__localsÚ__nameÚ
startswithr£   Ú	TypeErrorÚAttributeErrorÚ_teÚhttpxÚ_httpxrM   Ú__annotations__rN   rO   rP   rQ   rR   rT   rV   rX   rZ   r[   ÚLiteralÚ_ApiTypeÚcastr¾   r¿   r^   r`   rb   rd   re   rf   rg   ri   rª   r­   r·   rÀ   rÃ   rÅ   rË   rÍ   Ú_module_clientrÎ   rÏ   rÐ   rÑ   rÒ   rÓ   rÔ   rÕ   rÖ   r×   rØ   rÙ   rÚ   rÛ   rÜ   rÝ   rÞ   rß   rà   rá   râ   rã   rä   r«   rq   ro   ú<module>r     s™  ðö #ã Û Ý &å ß a× aÓ aÝ "ß v× vÕ vß oÑ oÝ ß ,ß Wß WÑ W÷÷ ÷ ÷ ÷ ó ÷, \Ñ [Ý 9Ý Vß Rò6€ðp 
×ÒÝ?ç gÑ gÝ 'ß Wß aÜ ÷ñ
 Ô ñ ‹8€Øò €FØ×Ñ˜TÕ"ð	Ø*2ˆH�VÑÕ'ðó Û ã ç >à€ˆÓ à €ˆzÓ  à€ˆjÓ à€ˆÓ à!€�
Ó !à$(€Ð
!Ó (à"1€Ð	Ó 1à&€ˆSÓ &à/3€Ð,Ó 3à04€Ð-Ó 4à$(€Ð!Ó (à�;‰;Ð:Ñ;€à#˜BŸG™G H¨c¯k©k¯oªoÐ>OÓ.PÓQ€ˆ/Ó QàŸ+™+Ÿ/š/Ð*>Ó?€ˆZÓ ?à Ÿ[™[Ÿ_š_Ð-DÓE€�
Ó Eà Ÿ[™[Ÿ_š_Ð-DÓE€�
Ó Eà>BÐ Ð;Ó Bà#Ð �*Ó #à?CÐ Ð<Ó Cô|�Fô |ô~˜¨ô ô4˜=¨-ô 4ô4
 {ô 
ó9ó]óð €ˆÓ óRój÷÷ ÷ ÷ ÷ ÷ ò øðK
 ˜>Ð*ò 	âð	ús   Ä)
KËKËK