ó
    ûÞ j.5  ã                  ó˜  • S SK Jr  S SKrS SKJr  S SKJrJrJrJ	r	J
r
Jr  S SKJrJrJr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 J!r!  S	SK"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/J0r0J1r1   " S S\\)   5      r2 " S S\\)   5      r3 " S S\\)   5      r4 " S S\\)   5      r5 " S S\\)   5      r6g)é    )Ú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                  ó’   • \ rS rSr          SS jrSS jrSS jrSS jrSS jr        SS jr	SS jr
SS	 jrSS
 jrSrg)ÚResponseStreamé   c               ó„   • Xl         UR                  U l        U R                  5       U l        [        X#S9U l        X@l        g ©N)Útext_formatÚinput_tools©Ú_raw_streamÚresponseÚ	_responseÚ
__stream__Ú	_iteratorÚResponseStreamStateÚ_stateÚ_starting_after©ÚselfÚ
raw_streamr.   r/   Ústarting_afters        Úc/var/www/html/gaurav/venv/lib/python3.13/site-packages/openai/lib/streaming/responses/_responses.pyÚ__init__ÚResponseStream.__init__   ó7   € ð &ÔØ#×,Ñ,ˆŒØŸ™Ó*ˆŒÜ)°kÑ[ˆŒØ-Õó    c                ó6   • U R                   R                  5       $ ©N)r5   Ú__next__©r:   s    r=   rD   ÚResponseStream.__next__-   s   € Ø�~‰~×&Ñ&Ó(Ð(rA   c              #  ó:   #   • U R                    H  nUv •  M	     g 7frC   ©r5   ©r:   Úitems     r=   Ú__iter__ÚResponseStream.__iter__0   s   é € Ø—N”NˆDØŒJò #ùs   ‚c                ó   • U $ rC   © rE   s    r=   Ú	__enter__ÚResponseStream.__enter__4   s   € ØˆrA   c              #  óÔ   #   • U R                    HT  nU R                  R                  U5      nU H0  nU R                  b  UR                  U R                  :”  d  M,  Uv •  M2     MV     g 7frC   ©r1   r7   Úhandle_eventr8   Úsequence_number©r:   Ú	sse_eventÚevents_to_fireÚevents       r=   r4   ÚResponseStream.__stream__7   sW   é € Ø×)Ô)ˆIØ!Ÿ[™[×5Ñ5°iÓ@ˆNÛ'�Ø×'Ñ'Ñ/°5×3HÑ3HÈ4×K_ÑK_Õ3_Ø”Kó (ò *ùs   ‚AA(ÁA(c                ó$   • U R                  5         g rC   ©Úclose©r:   Úexc_typeÚexcÚexc_tbs       r=   Ú__exit__ÚResponseStream.__exit__>   s   € ð 	�
‰
�rA   c                ó8   • U R                   R                  5         g©zr
Close the response and release the connection.

Automatically called if the response body is read to completion.
N)r3   r\   rE   s    r=   r\   ÚResponseStream.closeF   s   € ð 	�‰×ÑÕrA   c                óv   • U R                  5         U R                  R                  nU(       d  [        S5      eU$ )úhWaits until the stream has been read to completion and returns
the accumulated `ParsedResponse` object.
ú,Didn't receive a `response.completed` event.©Ú
until_doner7   Ú_completed_responseÚRuntimeError©r:   r2   s     r=   Úget_final_responseÚ!ResponseStream.get_final_responseN   s1   € ð 	�‰ÔØ—;‘;×2Ñ2ˆÞÜÐMÓNÐNàˆrA   c                ó   • [        U 5        U $ )ú*Blocks until the stream has been consumed.)r   rE   s    r=   rj   ÚResponseStream.until_doneY   s   € ä˜dÔ#ØˆrA   ©r5   r1   r3   r8   r7   N)
r;   zStream[RawResponseStreamEvent]r.   útype[TextFormatT] | Omitr/   úIterable[ToolParam] | Omitr<   ú
int | NoneÚreturnÚNone©rw   z ResponseStreamEvent[TextFormatT])rw   z*Iterator[ResponseStreamEvent[TextFormatT]]©rw   r   ©r^   ztype[BaseException] | Noner_   zBaseException | Noner`   zTracebackType | Nonerw   rx   ©rw   rx   ©rw   zParsedResponse[TextFormatT])Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r>   rD   rK   rO   r4   ra   r\   rn   rj   Ú__static_attributes__rN   rA   r=   r*   r*      s‡   † ð.ð 3ð.ð .ð	.ð
 0ð.ð #ð.ð 
ô.ô)ôôô ðà,ðð "ðð %ð	ð
 
ôôô	÷rA   r*   c                  óV   • \ rS rSr          SS jrSS jr        S	S jrSrg)
ÚResponseStreamManageré_   c               óB   • S U l         Xl        X l        X0l        X@l        g rC   )Ú_ResponseStreamManager__streamÚ#_ResponseStreamManager__api_requestÚ#_ResponseStreamManager__text_formatÚ#_ResponseStreamManager__input_toolsÚ&_ResponseStreamManager__starting_after©r:   Úapi_requestr.   r/   r<   s        r=   r>   ÚResponseStreamManager.__init__`   s$   € ð =AˆŒØ(ÔØ(ÔØ(ÔØ .ÕrA   c                ó˜   • U R                  5       n[        UU R                  U R                  U R                  S9U l        U R
                  $ ©N)r;   r.   r/   r<   )rˆ   r*   r‰   rŠ   r‹   r‡   ©r:   r;   s     r=   rO   ÚResponseStreamManager.__enter__n   sF   € Ø×'Ñ'Ó)ˆ
ä&Ø!Ø×*Ñ*Ø×*Ñ*Ø×0Ñ0ñ	
ˆŒð �}‰}ÐrA   c                óT   • U R                   b  U R                   R                  5         g g rC   )r‡   r\   r]   s       r=   ra   ÚResponseStreamManager.__exit__z   s#   € ð �=‰=Ñ$Ø�M‰M×ÑÕ!ð %rA   ©Ú__api_requestÚ__input_toolsÚ__starting_afterÚ__streamÚ__text_formatN)
r�   z,Callable[[], Stream[RawResponseStreamEvent]]r.   rt   r/   ru   r<   rv   rw   rx   )rw   zResponseStream[TextFormatT]r{   )r~   r   r€   r�   r>   rO   ra   r‚   rN   rA   r=   r„   r„   _   sg   † ð/àAð/ð .ð	/ð
 0ð/ð #ð/ð 
ô/ô
ð"à,ð"ð "ð"ð %ð	"ð
 
÷"rA   r„   c                  ó’   • \ rS rSr          SS jrSS jrSS jrSS jrSS jr        SS jr	SS jr
SS	 jrSS
 jrSrg)ÚAsyncResponseStreamé„   c               ó„   • Xl         UR                  U l        U R                  5       U l        [        X#S9U l        X@l        g r-   r0   r9   s        r=   r>   ÚAsyncResponseStream.__init__…   r@   rA   c              ƒ  óR   #   • U R                   R                  5       I S h  v•N $  N7frC   )r5   Ú	__anext__rE   s    r=   r¡   ÚAsyncResponseStream.__anext__“   s   é € Ø—^‘^×-Ñ-Ó/×/Ð/Ñ/ùs   ‚' %¡'c               óJ   #   • U R                     S h  v•N nU7v •  M   N
 g 7frC   rH   rI   s     r=   Ú	__aiter__ÚAsyncResponseStream.__aiter__–   s   é € ØŸ.š.÷ 	�$Ø�Jñ	™.ùs   ‚#�!“”!—#Ÿ!¡#c               óä   #   • U R                     S h  v•N nU R                  R                  U5      nU H1  nU R                  b  UR                  U R                  :”  d  M,  U7v •  M3     M]   NX
 g 7frC   rR   rU   s       r=   r4   ÚAsyncResponseStream.__stream__š   s_   é € Ø#×/Ò/÷ 	 �)Ø!Ÿ[™[×5Ñ5°iÓ@ˆNÛ'�Ø×'Ñ'Ñ/°5×3HÑ3HÈ4×K_ÑK_Õ3_Ø•Kó (ñ	 Ñ/ùs,   ‚A0�A.“A,”A.—AA0Á!A0Á,A.Á.A0c              ƒ  ó   #   • U $ 7frC   rN   rE   s    r=   Ú
__aenter__ÚAsyncResponseStream.__aenter__¡   s
   é € Øˆùs   ‚c              ƒ  ó@   #   • U R                  5       I S h  v•N   g  N7frC   r[   r]   s       r=   Ú	__aexit__ÚAsyncResponseStream.__aexit__¤   s   é € ð �j‰j‹l×Óùs   ‚–—c              ƒ  óT   #   • U R                   R                  5       I Sh  v•N   g N7frd   )r3   ÚacloserE   s    r=   r\   ÚAsyncResponseStream.close¬   s   é € ð �n‰n×#Ñ#Ó%×%Ó%ùs   ‚( &¡(c              ƒ  ó’   #   • U R                  5       I Sh  v•N   U R                  R                  nU(       d  [        S5      eU$  N.7f)rg   Nrh   ri   rm   s     r=   rn   Ú&AsyncResponseStream.get_final_response´   s?   é € ð �o‰oÓ×ÐØ—;‘;×2Ñ2ˆÞÜÐMÓNÐNàˆñ 	 ùs   ‚A–A—/Ac              ƒ  ó8   #   • [        U 5      I Sh  v•N   U $  N7f)rq   N)r   rE   s    r=   rj   ÚAsyncResponseStream.until_done¿   s   é € ä$ TÓ*×*Ð*Øˆñ 	+ùs   ‚‘’rs   N)
r;   z#AsyncStream[RawResponseStreamEvent]r.   rt   r/   ru   r<   rv   rw   rx   ry   )rw   z/AsyncIterator[ResponseStreamEvent[TextFormatT]]rz   r{   r|   r}   )r~   r   r€   r�   r>   r¡   r¤   r4   r©   r¬   r\   rn   rj   r‚   rN   rA   r=   rœ   rœ   „   s‡   † ð.ð 8ð.ð .ð	.ð
 0ð.ð #ð.ð 
ô.ô0ôô ôðà,ðð "ðð %ð	ð
 
ôô&ô	÷rA   rœ   c                  óV   • \ rS rSr          SS jrSS jr        S	S jrSrg)
ÚAsyncResponseStreamManageréÅ   c               óB   • S U l         Xl        X l        X0l        X@l        g rC   )Ú#_AsyncResponseStreamManager__streamÚ(_AsyncResponseStreamManager__api_requestÚ(_AsyncResponseStreamManager__text_formatÚ(_AsyncResponseStreamManager__input_toolsÚ+_AsyncResponseStreamManager__starting_afterrŒ   s        r=   r>   Ú#AsyncResponseStreamManager.__init__Æ   s%   € ð BFˆŒØ(ÔØ(ÔØ(ÔØ .ÕrA   c              ƒ  ó¬   #   • U R                   I S h  v•N n[        UU R                  U R                  U R                  S9U l        U R
                  $  N?7fr�   )rº   rœ   r»   r¼   r½   r¹   r‘   s     r=   r©   Ú%AsyncResponseStreamManager.__aenter__Ô   sN   é € Ø×-Ñ-×-ˆ
ä+Ø!Ø×*Ñ*Ø×*Ñ*Ø×0Ñ0ñ	
ˆŒð �}‰}Ðñ .ùs   ‚A’A“A Ac              ƒ  óp   #   • U R                   b#  U R                   R                  5       I S h  v•N   g g  N7frC   )r¹   r\   r]   s       r=   r¬   Ú$AsyncResponseStreamManager.__aexit__à   s/   é € ð �=‰=Ñ$Ø—-‘-×%Ñ%Ó'×'Ñ'ð %Ù'ùs   ‚+6­4®6r•   N)
r�   z.Awaitable[AsyncStream[RawResponseStreamEvent]]r.   rt   r/   ru   r<   rv   rw   rx   )rw   z AsyncResponseStream[TextFormatT]r{   )r~   r   r€   r�   r>   r©   r¬   r‚   rN   rA   r=   r¶   r¶   Å   sg   † ð/àCð/ð .ð	/ð
 0ð/ð #ð/ð 
ô/ô
ð(à,ð(ð "ð(ð %ð	(ð
 
÷(rA   r¶   c                  óH   • \ rS rSr      SS jrS	S jrS
S jrS
S jrSrg)r6   éê   c               óà   • S U l         S U l        [        U5      (       a  U Vs/ sH  o3PM     snO/ U l        X l        [
        R                  " U5      (       a  X l        g [        U l        g s  snf rC   )	Ú&_ResponseStreamState__current_snapshotrk   r   Ú_input_toolsÚ_text_formatÚinspectÚisclassr   Ú_rich_text_format)r:   r/   r.   Útools       r=   r>   ÚResponseStreamState.__init__ë   sa   € ð BFˆÔØGKˆÔ Ü>FÀ{×>SÑ>S©kÓ:©k dšT©kÒ:ÐY[ˆÔØ'ÔÜ=D¿_º_È[×=YÑ=Y¨kÕÔ_cˆÕùò ;s   £
A+c                ó�  • U R                  U5      =U l        n/ nUR                  S:X  aÂ  UR                  UR                     nUR                  S:X  d   eUR
                  UR                     nUR                  S:X  d   eUR                  [        [        UR                  UR                  UR                  UR                  UR                  UR                  SUR                  S9	5        U$ UR                  S:X  aÛ  UR                  UR                     nUR                  S:X  d   eUR
                  UR                     nUR                  S:X  d   eUR                  [        [        [            UR                  UR                  UR                  UR                  UR                  SUR                  [#        UR                  U R$                  S9S9	5        U$ UR                  S:X  a�  UR                  UR                     nUR                  S	:X  d   eUR                  [        [&        UR                  UR                  UR                  UR                  SUR(                  S
95        U$ UR                  S:X  a<  U R*                  nUc   eUR                  [        [,        UR                  SUS95        U$ UR                  U5        U$ )Núresponse.output_text.deltaÚmessageÚoutput_text)Úcontent_indexÚdeltaÚitem_idÚoutput_indexrT   ÚlogprobsÚtypeÚsnapshotzresponse.output_text.done)r.   )rÒ   rÔ   rÕ   rT   rÖ   r×   ÚtextÚparsedú&response.function_call_arguments.deltaÚfunction_call)rÓ   rÔ   rÕ   rT   r×   rØ   úresponse.completed)rT   r×   r2   )Úaccumulate_eventrÆ   r×   ÚoutputrÕ   ÚcontentrÒ   Úappendr   r   rÓ   rÔ   rT   rÖ   rÙ   r   r"   r#   rÈ   r   Ú	argumentsrk   r   )r:   rX   rØ   Úeventsrß   rà   r2   s          r=   rS   Ú 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˜%Ô àˆrA   c                ó¤  • U R                   nUc  U R                  U5      $ UR                  S:X  aú  UR                  R                  S:X  aO  UR                  R                  [        [        [        [        5      UR                  R                  5       S95        U$ UR                  R                  S:X  aO  UR                  R                  [        [        [        [        5      UR                  R                  5       S95        U$ UR                  R                  UR                  5         U$ UR                  S:X  ax  UR                  UR                     nUR                  S:X  aM  UR                  R                  [        [        [        [        5      UR                  R                  5       S95        U$ UR                  S:X  au  UR                  UR                     nUR                  S:X  aJ  UR                  UR                      nUR                  S:X  d   eU=R"                  UR$                  -  sl        U$ UR                  S:X  aJ  UR                  UR                     nUR                  S:X  a  U=R&                  UR$                  -  sl        U$ UR                  S	:X  a.  [)        U R*                  UR,                  U R.                  S
9U l        U$ )Nzresponse.output_item.addedrÜ   ©Útype_ÚvaluerÐ   zresponse.content_part.addedrÏ   rÑ   rÛ   rÝ   )r.   r2   r/   )rÆ   Ú_create_initial_responser×   rJ   rß   rá   r   r
   r   r(   Úto_dictr'   rÕ   rà   r&   ÚpartrÒ   rÙ   rÓ   râ   r$   rÈ   r2   rÇ   rk   )r:   rX   rØ   rß   rà   s        r=   rÞ   Ú$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Ô$ð ˆrA   c                ó    • UR                   S:w  a  [        SUR                    S35      e[        [        UR                  R                  5       S9$ )Nzresponse.createdz5Expected to have received `response.created` before `Ú`ræ   )r×   rl   r   r   r2   rê   )r:   rX   s     r=   ré   Ú,ResponseStreamState._create_initial_responsep  sH   € Ø�:‰:Ð+Ó+ÜÐ!VÐW\×WaÑWaÐVbÐbcÐdÓeÐeä'Ô.DÈEÏNÉN×LbÑLbÓLdÑeÐerA   )Ú__current_snapshotrk   rÇ   rË   rÈ   N)r/   ru   r.   rt   rw   rx   )rX   ÚRawResponseStreamEventrw   z&List[ResponseStreamEvent[TextFormatT]])rX   rñ   rw   r   )	r~   r   r€   r�   r>   rS   rÞ   ré   r‚   rN   rA   r=   r6   r6   ê   s<   † ð
dð 0ð
dð .ð	
dð
 
ô
dôLô\)÷VfrA   r6   )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*   r„   rœ   r¶   r6   rN   rA   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rA   