Ë
    ²Œj.5  ã                  ó˜  — d dl mZ d dlZd dlmZ d dlmZmZmZm	Z	m
Z
mZ d dl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 d	d
lmZmZ d	dlmZ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' ddl(m)Z)m*Z*m+Z+ d	dl,m-Z- d	dl.m/Z/m0Z0m1Z1  G d„ dee)   «      Z2 G d„ dee)   «      Z3 G d„ dee)   «      Z4 G d„ dee)   «      Z5 G d„ dee)   «      Z6y)é    )ÚannotationsN)ÚTracebackType)ÚAnyÚListÚGenericÚIterableÚ	AwaitableÚcast)ÚSelfÚCallableÚIteratorÚAsyncIteratoré   )ÚParsedResponseSnapshot)ÚResponseStreamEventÚResponseTextDoneEventÚResponseCompletedEventÚResponseTextDeltaEventÚ'ResponseFunctionCallArgumentsDeltaEventé   )ÚOmitÚomit)Úis_givenÚconsume_sync_iteratorÚconsume_async_iterator)ÚbuildÚconstruct_type_unchecked)ÚStreamÚAsyncStream)ÚParsedResponser   é   )ÚTextFormatTÚ
parse_textÚparse_response)Ú	ToolParam)ÚParsedContentÚParsedResponseOutputMessageÚParsedResponseFunctionToolCallc                  óx   — e Zd Z	 	 	 	 	 	 	 	 	 	 dd„Zdd„Zdd„Zdd„Zdd„Z	 	 	 	 	 	 	 	 dd„Zdd„Z	dd„Z
dd	„Zy
)ÚResponseStreamc               ó�   — || _         |j                  | _        | j                  «       | _        t        ||¬«      | _        || _        y ©N)Útext_formatÚinput_tools©Ú_raw_streamÚresponseÚ	_responseÚ
__stream__Ú	_iteratorÚResponseStreamStateÚ_stateÚ_starting_after©ÚselfÚ
raw_streamr-   r.   Ústarting_afters        ús/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/openai/lib/streaming/responses/_responses.pyÚ__init__zResponseStream.__init__   ó=   € ð &ˆÔØ#×,Ñ,ˆŒØŸ™Ó*ˆŒÜ)°kÈ{Ô[ˆŒØ-ˆÕó    c                ó6   — | j                   j                  «       S ©N)r4   Ú__next__©r9   s    r<   rB   zResponseStream.__next__-   s   € Ø�~‰~×&Ñ&Ó(Ð(r?   c              #  ó6   K  — | j                   D ]  }|–— Œ y ­wrA   ©r4   ©r9   Úitems     r<   Ú__iter__zResponseStream.__iter__0   s   è ø€ Ø—N”NˆDØ‹Jñ #ùs   ‚c                ó   — | S rA   © rC   s    r<   Ú	__enter__zResponseStream.__enter__4   s   € Øˆr?   c              #  óÆ   K  — | j                   D ]N  }| j                  j                  |«      }|D ],  }| j                  �|j                  | j                  kD  sŒ)|–— Œ. ŒP y ­wrA   ©r0   r6   Úhandle_eventr7   Úsequence_number©r9   Ú	sse_eventÚevents_to_fireÚevents       r<   r3   zResponseStream.__stream__7   sX   è ø€ Ø×)Ô)ˆIØ!Ÿ[™[×5Ñ5°iÓ@ˆNÛ'�Ø×'Ñ'Ð/°5×3HÑ3HÈ4×K_ÑK_Ó3_Ø“Kñ (ñ *ùs   ‚AA!Á	A!c                ó$   — | j                  «        y rA   ©Úclose©r9   Úexc_typeÚexcÚexc_tbs       r<   Ú__exit__zResponseStream.__exit__>   s   € ð 	�
‰
�r?   c                ó8   — | j                   j                  «        y©zŠ
        Close the response and release the connection.

        Automatically called if the response body is read to completion.
        N)r2   rV   rC   s    r<   rV   zResponseStream.closeF   s   € ð 	�‰×ÑÕr?   c                ól   — | j                  «        | j                  j                  }|st        d«      ‚|S )úxWaits until the stream has been read to completion and returns
        the accumulated `ParsedResponse` object.
        ú,Didn't receive a `response.completed` event.©Ú
until_doner6   Ú_completed_responseÚRuntimeError©r9   r1   s     r<   Úget_final_responsez!ResponseStream.get_final_responseN   s1   € ð 	�‰ÔØ—;‘;×2Ñ2ˆÙÜÐMÓNÐNàˆr?   c                ó   — t        | «       | S )ú*Blocks until the stream has been consumed.)r   rC   s    r<   rb   zResponseStream.until_doneY   s   € ä˜dÔ#Øˆr?   N)
r:   zStream[RawResponseStreamEvent]r-   útype[TextFormatT] | Omitr.   úIterable[ToolParam] | Omitr;   ú
int | NoneÚreturnÚNone©rl   z ResponseStreamEvent[TextFormatT])rl   z*Iterator[ResponseStreamEvent[TextFormatT]]©rl   r   ©rX   ztype[BaseException] | NonerY   zBaseException | NonerZ   zTracebackType | Nonerl   rm   ©rl   rm   ©rl   zParsedResponse[TextFormatT])Ú__name__Ú
__module__Ú__qualname__r=   rB   rH   rK   r3   r[   rV   rf   rb   rJ   r?   r<   r*   r*      s‡   „ ð.ð 3ð.ð .ð	.ð
 0ð.ð #ð.ð 
ó.ó)óóó ðà,ðð "ðð %ð	ð
 
óóó	ôr?   r*   c                  óH   — e Zd Z	 	 	 	 	 	 	 	 	 	 dd„Zdd„Z	 	 	 	 	 	 	 	 dd„Zy)ÚResponseStreamManagerc               óJ   — d | _         || _        || _        || _        || _        y rA   )Ú_ResponseStreamManager__streamÚ#_ResponseStreamManager__api_requestÚ#_ResponseStreamManager__text_formatÚ#_ResponseStreamManager__input_toolsÚ&_ResponseStreamManager__starting_after©r9   Úapi_requestr-   r.   r;   s        r<   r=   zResponseStreamManager.__init__`   s,   € ð =AˆŒØ(ˆÔØ(ˆÔØ(ˆÔØ .ˆÕr?   c                óž   — | j                  «       }t        || j                  | j                  | j                  ¬«      | _        | j
                  S ©N)r:   r-   r.   r;   )rz   r*   r{   r|   r}   ry   ©r9   r:   s     r<   rK   zResponseStreamManager.__enter__n   sF   € Ø×'Ñ'Ó)ˆ
ä&Ø!Ø×*Ñ*Ø×*Ñ*Ø×0Ñ0ô	
ˆŒð �}‰}Ðr?   c                óR   — | j                   �| j                   j                  «        y y rA   )ry   rV   rW   s       r<   r[   zResponseStreamManager.__exit__z   s#   € ð �=‰=Ð$Ø�M‰M×ÑÕ!ð %r?   N)
r   z,Callable[[], Stream[RawResponseStreamEvent]]r-   ri   r.   rj   r;   rk   rl   rm   )rl   zResponseStream[TextFormatT]rp   )rs   rt   ru   r=   rK   r[   rJ   r?   r<   rw   rw   _   sg   „ ð/àAð/ð .ð	/ð
 0ð/ð #ð/ð 
ó/ó
ð"à,ð"ð "ð"ð %ð	"ð
 
ô"r?   rw   c                  óx   — e Zd Z	 	 	 	 	 	 	 	 	 	 dd„Zdd„Zdd„Zdd„Zdd„Z	 	 	 	 	 	 	 	 dd„Zdd„Z	dd„Z
dd	„Zy
)ÚAsyncResponseStreamc               ó�   — || _         |j                  | _        | j                  «       | _        t        ||¬«      | _        || _        y r,   r/   r8   s        r<   r=   zAsyncResponseStream.__init__…   r>   r?   c              ƒ  óR   K  — | j                   j                  «       ƒ d {  –—† S 7 Œ­wrA   )r4   Ú	__anext__rC   s    r<   rˆ   zAsyncResponseStream.__anext__“   s   è ø€ Ø—^‘^×-Ñ-Ó/×/Ð/Ð/ús   ‚' %¡'c               óH   K  — | j                   2 3 d {  –—† }|­–— Œ7 Œ
6 y ­wrA   rE   rF   s     r<   Ú	__aiter__zAsyncResponseStream.__aiter__–   s!   è ø€ ØŸ.š.÷ 	�$ØŒJð	ø™.ùs   ‚"� “” —"ž  "c               óØ   K  — | j                   2 3 d {  –—† }| j                  j                  |«      }|D ]-  }| j                  �|j                  | j                  kD  sŒ)|­–— Œ/ ŒW7 ŒR6 y ­wrA   rM   rP   s       r<   r3   zAsyncResponseStream.__stream__š   sa   è ø€ Ø#×/Ò/÷ 	 �)Ø!Ÿ[™[×5Ñ5°iÓ@ˆNÛ'�Ø×'Ñ'Ð/°5×3HÑ3HÈ4×K_ÑK_Ó3_Ø”Kñ (ð	 øÑ/ùs,   ‚A*�A(“A&”A(—AA*ÁA*Á&A(Á(A*c              ƒ  ó   K  — | S ­wrA   rJ   rC   s    r<   Ú
__aenter__zAsyncResponseStream.__aenter__¡   s   è ø€ Øˆùs   ‚c              ƒ  ó@   K  — | j                  «       ƒ d {  –—†  y 7 Œ­wrA   rU   rW   s       r<   Ú	__aexit__zAsyncResponseStream.__aexit__¤   s   è ø€ ð �j‰j‹l×Òús   ‚–—c              ƒ  óT   K  — | j                   j                  «       ƒ d{  –—†  y7 Œ­wr]   )r2   ÚacloserC   s    r<   rV   zAsyncResponseStream.close¬   s   è ø€ ð �n‰n×#Ñ#Ó%×%Ò%ús   ‚( &¡(c              ƒ  óˆ   K  — | j                  «       ƒ d{  –—†  | j                  j                  }|st        d«      ‚|S 7 Œ)­w)r_   Nr`   ra   re   s     r<   rf   z&AsyncResponseStream.get_final_response´   s@   è ø€ ð �o‰oÓ×ÐØ—;‘;×2Ñ2ˆÙÜÐMÓNÐNàˆð 	 ús   ‚A–A —*Ac              ƒ  ó8   K  — t        | «      ƒ d{  –—†  | S 7 Œ­w)rh   N)r   rC   s    r<   rb   zAsyncResponseStream.until_done¿   s   è ø€ ä$ TÓ*×*Ð*Øˆð 	+ús   ‚‘’N)
r:   z#AsyncStream[RawResponseStreamEvent]r-   ri   r.   rj   r;   rk   rl   rm   rn   )rl   z/AsyncIterator[ResponseStreamEvent[TextFormatT]]ro   rp   rq   rr   )rs   rt   ru   r=   rˆ   rŠ   r3   r�   r�   rV   rf   rb   rJ   r?   r<   r…   r…   „   s‡   „ ð.ð 8ð.ð .ð	.ð
 0ð.ð #ð.ð 
ó.ó0óó óðà,ðð "ðð %ð	ð
 
óó&ó	ôr?   r…   c                  óH   — e Zd Z	 	 	 	 	 	 	 	 	 	 dd„Zdd„Z	 	 	 	 	 	 	 	 dd„Zy)ÚAsyncResponseStreamManagerc               óJ   — d | _         || _        || _        || _        || _        y rA   )Ú#_AsyncResponseStreamManager__streamÚ(_AsyncResponseStreamManager__api_requestÚ(_AsyncResponseStreamManager__text_formatÚ(_AsyncResponseStreamManager__input_toolsÚ+_AsyncResponseStreamManager__starting_afterr~   s        r<   r=   z#AsyncResponseStreamManager.__init__Æ   s-   € ð BFˆŒØ(ˆÔØ(ˆÔØ(ˆÔØ .ˆÕr?   c              ƒ  ó²   K  — | j                   ƒ d {  –—† }t        || j                  | j                  | j                  ¬«      | _        | j
                  S 7 ŒB­wr�   )r˜   r…   r™   rš   r›   r—   r‚   s     r<   r�   z%AsyncResponseStreamManager.__aenter__Ô   sO   è ø€ Ø×-Ñ-×-ˆ
ä+Ø!Ø×*Ñ*Ø×*Ñ*Ø×0Ñ0ô	
ˆŒð �}‰}Ðð .ús   ‚A’A“AAc              ƒ  ón   K  — | j                   �#| j                   j                  «       ƒ d {  –—†  y y 7 Œ­wrA   )r—   rV   rW   s       r<   r�   z$AsyncResponseStreamManager.__aexit__à   s0   è ø€ ð �=‰=Ð$Ø—-‘-×%Ñ%Ó'×'Ñ'ð %Ø'ús   ‚*5¬3­5N)
r   z.Awaitable[AsyncStream[RawResponseStreamEvent]]r-   ri   r.   rj   r;   rk   rl   rm   )rl   z AsyncResponseStream[TextFormatT]rp   )rs   rt   ru   r=   r�   r�   rJ   r?   r<   r•   r•   Å   sg   „ ð/àCð/ð .ð	/ð
 0ð/ð #ð/ð 
ó/ó
ð(à,ð(ð "ð(ð %ð	(ð
 
ô(r?   r•   c                  ó8   — e Zd Z	 	 	 	 	 	 dd„Zdd„Zdd„Zdd„Zy)	r5   c               óÌ   — d | _         d | _        t        |«      r|D �cg c]  }|‘Œ c}ng | _        || _        t        j                  |«      r|| _        y t        | _        y c c}w rA   )	Ú&_ResponseStreamState__current_snapshotrc   r   Ú_input_toolsÚ_text_formatÚinspectÚisclassr   Ú_rich_text_format)r9   r.   r-   Útools       r<   r=   zResponseStreamState.__init__ë   s_   € ð BFˆÔØGKˆÔ Ü>FÀ{Ô>S©kÓ:©k dšT¨kÒ:ÐY[ˆÔØ'ˆÔÜ=D¿_¹_È[Ô=Y¨kˆÕÔ_cˆÕùò ;s   ž	A!c                óš  — | j                  |«      x| _        }g }|j                  dk(  rÃ|j                  |j                     }|j                  dk(  sJ ‚|j
                  |j                     }|j                  dk(  sJ ‚|j                  t        t        |j                  |j                  |j                  |j                  |j                  |j                  d|j                  ¬«	      «       |S |j                  dk(  rß|j                  |j                     }|j                  dk(  sJ ‚|j
                  |j                     }|j                  dk(  sJ ‚|j                  t        t        t            |j                  |j                  |j                  |j                  |j                  d|j                  t#        |j                  | j$                  ¬«      ¬«	      «       |S |j                  dk(  rƒ|j                  |j                     }|j                  d	k(  sJ ‚|j                  t        t&        |j                  |j                  |j                  |j                  d|j(                  ¬
«      «       |S |j                  dk(  r>| j*                  }|€J ‚|j                  t        t,        |j                  d|¬«      «       |S |j                  |«       |S )Núresponse.output_text.deltaÚmessageÚoutput_text)Úcontent_indexÚdeltaÚitem_idÚoutput_indexrO   ÚlogprobsÚtypeÚsnapshotzresponse.output_text.done)r-   )r«   r­   r®   rO   r¯   r°   ÚtextÚparsedú&response.function_call_arguments.deltaÚfunction_call)r¬   r­   r®   rO   r°   r±   úresponse.completed)rO   r°   r1   )Úaccumulate_eventr    r°   Úoutputr®   Úcontentr«   Úappendr   r   r¬   r­   rO   r¯   r²   r   r"   r#   r¢   r   Ú	argumentsrc   r   )r9   rS   r±   Úeventsr¸   r¹   r1   s          r<   rN   z ResponseStreamState.handle_event÷   s}  € Ø-1×-BÑ-BÀ5Ó-IÐIˆÔ (à9;ˆà�:‰:Ð5Ò5Ø—_‘_ U×%7Ñ%7Ñ8ˆFØ—;‘; )Ò+Ð+Ð+à—n‘n U×%8Ñ%8Ñ9ˆGØ—<‘< =Ò0Ð0Ð0à�M‰MÜÜ*Ø"'×"5Ñ"5ØŸ+™+Ø!ŸM™MØ!&×!3Ñ!3Ø$)×$9Ñ$9Ø"Ÿ^™^Ø5Ø$Ÿ\™\ô
ôð@ ˆðg �Z‰ZÐ6Ò6Ø—_‘_ U×%7Ñ%7Ñ8ˆFØ—;‘; )Ò+Ð+Ð+à—n‘n U×%8Ñ%8Ñ9ˆGØ—<‘< =Ò0Ð0Ð0à�M‰MÜÜ)¬+Ñ6Ø"'×"5Ñ"5Ø!ŸM™MØ!&×!3Ñ!3Ø$)×$9Ñ$9Ø"Ÿ^™^Ø4ØŸ™Ü% e§j¡j¸d×>OÑ>OÔPô
ôðX ˆð? �Z‰ZÐCÒCØ—_‘_ U×%7Ñ%7Ñ8ˆFØ—;‘; /Ò1Ð1Ð1à�M‰MÜÜ;ØŸ+™+Ø!ŸM™MØ!&×!3Ñ!3Ø$)×$9Ñ$9ØAØ#×-Ñ-ôô
ð6 ˆð �Z‰ZÐ/Ò/Ø×/Ñ/ˆHØÐ'Ð'Ð'à�M‰MÜÜ*Ø$)×$9Ñ$9Ø-Ø%ô	ôð ˆð �M‰M˜%Ô àˆr?   c                ó¢  — | j                   }|€| j                  |«      S |j                  dk(  rý|j                  j                  dk(  rR|j                  j                  t        t        t        t        «      |j                  j                  «       ¬«      «       |S |j                  j                  dk(  rR|j                  j                  t        t        t        t        «      |j                  j                  «       ¬«      «       |S |j                  j                  |j                  «       |S |j                  dk(  rz|j                  |j                     }|j                  dk(  rP|j                  j                  t        t        t        t        «      |j                  j                  «       ¬«      «       |S |j                  dk(  rs|j                  |j                     }|j                  dk(  rI|j                  |j                      }|j                  dk(  sJ ‚|xj"                  |j$                  z  c_        |S |j                  dk(  rI|j                  |j                     }|j                  dk(  r|xj&                  |j$                  z  c_        |S |j                  d	k(  r1t)        | j*                  |j,                  | j.                  ¬
«      | _        |S )Nzresponse.output_item.addedrµ   ©Útype_Úvaluer©   zresponse.content_part.addedr¨   rª   r´   r¶   )r-   r1   r.   )r    Ú_create_initial_responser°   rG   r¸   rº   r   r
   r   r(   Úto_dictr'   r®   r¹   r&   Úpartr«   r²   r¬   r»   r$   r¢   r1   r¡   rc   )r9   rS   r±   r¸   r¹   s        r<   r·   z$ResponseStreamState.accumulate_eventE  sG  € Ø×*Ñ*ˆØÐØ×0Ñ0°Ó7Ð7à�:‰:Ð5Ò5Ø�z‰z�‰ /Ò1Ø—‘×&Ñ&Ü,Ü"¤3Ô(FÓGÈuÏzÉz×OaÑOaÓOcôôðD ˆð; —‘—‘ IÒ-Ø—‘×&Ñ&Ü,´4¼Ô=XÓ3YÐaf×akÑak×asÑasÓauÔvôð8 ˆð1 —‘×&Ñ& u§z¡zÔ2ð0 ˆð/ �Z‰ZÐ8Ò8Ø—_‘_ U×%7Ñ%7Ñ8ˆFØ�{‰{˜iÒ'Ø—‘×%Ñ%Ü,´4¼¼]Ó3KÐSX×S]ÑS]×SeÑSeÓSgÔhôð( ˆð# �Z‰ZÐ7Ò7Ø—_‘_ U×%7Ñ%7Ñ8ˆFØ�{‰{˜iÒ'Ø Ÿ.™.¨×)<Ñ)<Ñ=�Ø—|‘| }Ò4Ð4Ð4Ø—’ §¡Ñ+•ð ˆð �Z‰ZÐCÒCØ—_‘_ U×%7Ñ%7Ñ8ˆFØ�{‰{˜oÒ-Ø× Ò  E§K¡KÑ/Õ ð ˆð �Z‰ZÐ/Ò/Ü'5Ø ×-Ñ-ØŸ™Ø ×-Ñ-ô(ˆDÔ$ð ˆr?   c                ó¤   — |j                   dk7  rt        d|j                   › d�«      ‚t        t        |j                  j                  «       ¬«      S )Nzresponse.createdz5Expected to have received `response.created` before `Ú`r¾   )r°   rd   r   r   r1   rÂ   )r9   rS   s     r<   rÁ   z,ResponseStreamState._create_initial_responsep  sH   € Ø�:‰:Ð+Ò+ÜÐ!VÐW\×WaÑWaÐVbÐbcÐdÓeÐeä'Ô.DÈEÏNÉN×LbÑLbÓLdÔeÐer?   N)r.   rj   r-   ri   rl   rm   )rS   ÚRawResponseStreamEventrl   z&List[ResponseStreamEvent[TextFormatT]])rS   rÆ   rl   r   )rs   rt   ru   r=   rN   r·   rÁ   rJ   r?   r<   r5   r5   ê   s<   „ ð
dð 0ð
dð .ð	
dð
 
ó
dóLó\)ôVfr?   r5   )7Ú
__future__r   r£   Útypesr   Útypingr   r   r   r   r	   r
   Útyping_extensionsr   r   r   r   Ú_typesr   Ú_eventsr   r   r   r   r   r   r   Ú_utilsr   r   r   Ú_modelsr   r   Ú
_streamingr   r   Útypes.responsesr    rÆ   Ú_parsing._responsesr"   r#   r$   Útypes.responses.tool_paramr%   Útypes.responses.parsed_responser&   r'   r(   r*   rw   r…   r•   r5   rJ   r?   r<   Ú<module>rÔ      s«   ðÝ "ã Ý ß @× @ß EÓ Eå *÷õ ÷ "ß NÑ Nß 7ß .ß ]ß JÑ JÝ 4÷ñ ô>�W˜[Ñ)ô >ôB""˜G KÑ0ô ""ôJ>˜' +Ñ.ô >ôB"( ¨Ñ!5ô "(ôJJf˜' +Ñ.õ Jfr?   