Ë
    @Øïi>  ã                   óœ   — d dl Z d dlZd dl mZ d dl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 eeef   Zeeeeef   ZdZ G d„ d«      Zy)	é    N)ÚQueue)ÚAnyÚDictÚUnion)ÚConfig)ÚLifespanScopeÚLifespanShutdownCompleteEventÚLifespanShutdownEventÚLifespanShutdownFailedEventÚLifespanStartupCompleteEventÚLifespanStartupEventÚLifespanStartupFailedEventz2Got invalid state transition on lifespan protocol.c                   óD   — e Zd Zdeddfd„Zd
d„Zd
d„Zd
d„Zdd„Zdd	„Z	y)Ú
LifespanOnÚconfigÚreturnNc                 óZ  — |j                   s|j                  «        || _        t        j                  d«      | _        t        j                  «       | _        t        j                  «       | _	        t        j                  «       | _        d| _        d| _        d| _        d| _        i | _        y )Nzuvicorn.errorF)ÚloadedÚloadr   ÚloggingÚ	getLoggerÚloggerÚasyncioÚEventÚstartup_eventÚshutdown_eventr   Úreceive_queueÚerror_occuredÚstartup_failedÚshutdown_failedÚshould_exitÚstate)Úselfr   s     úM/var/www/html/aiagents/fe/lib/python3.12/site-packages/uvicorn/lifespan/on.pyÚ__init__zLifespanOn.__init__   s|   € Ø�}Š}Ø�K‰KŒMàˆŒÜ×'Ñ'¨Ó8ˆŒÜ$Ÿ]™]›_ˆÔÜ%Ÿm™m›oˆÔÜ>E¿m¹m»oˆÔØ"ˆÔØ#ˆÔØ$ˆÔØ ˆÔØ%'ˆ�
ó    c              ƒ   ó   K  — | j                   j                  d«       t        j                  «       }|j	                  | j                  «       «      }ddi}| j                  j                  |«      ƒ d {  –—†  | j                  j                  «       ƒ d {  –—†  | j                  s%| j                  r<| j                  j                  dk(  r#| j                   j                  d«       d| _        y | j                   j                  d«       y 7 Œ–7 Œv­w)Nz Waiting for application startup.Útypezlifespan.startupÚonz$Application startup failed. Exiting.TzApplication startup complete.)r   Úinfor   Úget_event_loopÚcreate_taskÚmainr   Úputr   Úwaitr   r   r   ÚlifespanÚerrorr!   )r#   ÚloopÚmain_lifespan_taskr   s       r$   ÚstartupzLifespanOn.startup-   s×   è ø€ Ø�‰×ÑÐ;Ô<ä×%Ñ%Ó'ˆØ!×-Ñ-¨d¯i©i«kÓ:Ðð 06Ð7IÐ.JˆØ× Ñ ×$Ñ$ ]Ó3×3Ð3Ø× Ñ ×%Ñ%Ó'×'Ð'à×Ò 4×#5Ò#5¸$¿+¹+×:NÑ:NÐRVÒ:VØ�K‰K×ÑÐDÔEØ#ˆDÕà�K‰K×ÑÐ<Õ=ð 	4øØ'ús%   ‚A1DÁ3D
Á4!DÂDÂA5DÄDc              ƒ   óÔ  K  — | j                   ry | j                  j                  d«       ddi}| j                  j	                  |«      ƒ d {  –—†  | j
                  j                  «       ƒ d {  –—†  | j                  s%| j                   r<| j                  j                  dk(  r#| j                  j                  d«       d| _        y | j                  j                  d«       y 7 Œ–7 Œv­w)Nz!Waiting for application shutdown.r(   zlifespan.shutdownr)   z%Application shutdown failed. Exiting.TzApplication shutdown complete.)r   r   r*   r   r.   r   r/   r    r   r0   r1   r!   )r#   r   s     r$   ÚshutdownzLifespanOn.shutdown>   s¼   è ø€ Ø×ÒØØ�‰×ÑÐ<Ô=Ø17Ð9LÐ0MˆØ× Ñ ×$Ñ$ ^Ó4×4Ð4Ø×!Ñ!×&Ñ&Ó(×(Ð(à×ÒØ×Ò 4§;¡;×#7Ñ#7¸4Ò#?à�K‰K×ÑÐEÔFØ#ˆDÕà�K‰K×ÑÐ=Õ>ð 	5øØ(ús%   ‚AC(ÁC$Á!C(Á/C&Á0A5C(Ã&C(c              ƒ   óH  K  — 	 | j                   j                  }d| j                   j                  ddœ| j                  dœ} ||| j                  | j
                  «      ƒ d {  –—†  | j                  j                  «        | j                  j                  «        y 7 Œ9# t        $ r¿}d | _        d| _        | j                  s| j                  r9Y d }~| j                  j                  «        | j                  j                  «        y | j                   j                  dk(  rd}| j                  j!                  |«       nd}| j                  j#                  ||¬	«       Y d }~Œúd }~ww xY w# | j                  j                  «        | j                  j                  «        w xY w­w)
Nr0   z2.0)ÚversionÚspec_version)r(   Úasgir"   TÚautoz-ASGI 'lifespan' protocol appears unsupported.z!Exception in 'lifespan' protocol
)Úexc_info)r   Ú
loaded_appÚasgi_versionr"   ÚreceiveÚsendÚBaseExceptionr:   r   r   r    r   Úsetr   r0   r   r*   r1   )r#   ÚappÚscopeÚexcÚmsgs        r$   r-   zLifespanOn.mainN   sK  è ø€ ð	&Ø—+‘+×(Ñ(ˆCà"Ø$(§K¡K×$<Ñ$<ÈeÑTØŸ™ñ$ˆEñ
 �e˜TŸ\™\¨4¯9©9Ó5×5Ð5ð ×Ñ×"Ñ"Ô$Ø×Ñ×#Ñ#Õ%ð 6ùÜò 
	5ØˆDŒIØ!%ˆDÔØ×"Ò" d×&:Ò&:Ûð ×Ñ×"Ñ"Ô$Ø×Ñ×#Ñ#Õ%ð �{‰{×#Ñ# vÒ-ØE�Ø—‘× Ñ  Õ%à:�Ø—‘×!Ñ! #°Ð!Ô4ÿøð
	5ûð ×Ñ×"Ñ"Ô$Ø×Ñ×#Ñ#Õ%üs`   ‚F"„AB Á"BÁ#B Á'5F"ÂB Â	E&Â'&E!ÃE) Ã5F"ÄAE!ÅE) Å!E&Å&E) Å)6FÆF"c              ƒ   ób  K  — |d   dv sJ ‚|d   dk(  re| j                   j                  «       rJ t        «       ‚| j                  j                  «       rJ t        «       ‚| j                   j	                  «        y |d   dk(  rœ| j                   j                  «       rJ t        «       ‚| j                  j                  «       rJ t        «       ‚| j                   j	                  «        d| _        |j                  d«      r| j                  j                  |d   «       y y |d   dk(  re| j                   j                  «       sJ t        «       ‚| j                  j                  «       rJ t        «       ‚| j                  j	                  «        y |d   dk(  rœ| j                   j                  «       sJ t        «       ‚| j                  j                  «       rJ t        «       ‚| j                  j	                  «        d| _	        |j                  d«      r| j                  j                  |d   «       y y y ­w)	Nr(   )úlifespan.startup.completeúlifespan.startup.failedúlifespan.shutdown.completeúlifespan.shutdown.failedrH   rI   TÚmessagerJ   rK   )
r   Úis_setÚSTATE_TRANSITION_ERRORr   rB   r   Úgetr   r1   r    )r#   rL   s     r$   r@   zLifespanOn.sendf   sö  è ø€ Ø�v‰ð #
ñ 
ð 	
ð 
ð �6‰?Ð9Ò9Ø×)Ñ)×0Ñ0Ô2ÐJÔ4JÓJÐ2Ø×*Ñ*×1Ñ1Ô3ÐKÔ5KÓKÐ3Ø×Ñ×"Ñ"Õ$à�V‰_Ð 9Ò9Ø×)Ñ)×0Ñ0Ô2ÐJÔ4JÓJÐ2Ø×*Ñ*×1Ñ1Ô3ÐKÔ5KÓKÐ3Ø×Ñ×"Ñ"Ô$Ø"&ˆDÔØ�{‰{˜9Ô%Ø—‘×!Ñ! '¨)Ñ"4Õ5ð &ð �V‰_Ð <Ò<Ø×%Ñ%×,Ñ,Ô.ÐFÔ0FÓFÐ.Ø×*Ñ*×1Ñ1Ô3ÐKÔ5KÓKÐ3Ø×Ñ×#Ñ#Õ%à�V‰_Ð :Ò:Ø×%Ñ%×,Ñ,Ô.ÐFÔ0FÓFÐ.Ø×*Ñ*×1Ñ1Ô3ÐKÔ5KÓKÐ3Ø×Ñ×#Ñ#Ô%Ø#'ˆDÔ Ø�{‰{˜9Ô%Ø—‘×!Ñ! '¨)Ñ"4Õ5ð &ð ;ùs   ‚H-H/c              ƒ   óR   K  — | j                   j                  «       ƒ d {  –—† S 7 Œ­w)N)r   rO   )r#   s    r$   r?   zLifespanOn.receiveˆ   s!   è ø€ Ø×'Ñ'×+Ñ+Ó-×-Ð-Ð-ús   ‚' %¡')r   N)rL   ÚLifespanSendMessager   N)r   ÚLifespanReceiveMessage)
Ú__name__Ú
__module__Ú__qualname__r   r%   r4   r6   r-   r@   r?   © r&   r$   r   r      s/   „ ð(˜vð (¨$ó (ó>ó"?ó &ó0 6ôD.r&   r   )r   r   r   Útypingr   r   r   Úuvicornr   Úuvicorn._typesr   r	   r
   r   r   r   r   rR   rQ   rN   r   rV   r&   r$   ú<module>rZ      sk   ðÛ Û Ý ß #Ñ #å ÷÷ ñ ð Ð3Ð5JÐJÑKÐ ØØØØ Ø!ð#ñÐ ð NÐ ÷l.ò l.r&   