Ë
    Eêñiö  ã                  ó
  — U d dl 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mZmZ d dlmZ d dlmZ d dlmZ d d	lmZ erd d
lZd dlmZ d dlmZ  e
e«      Zded<   dZded<   dZ ded<   dZ!ded<   dd„Z" G d„ d«      Z#y
)é    )Úannotations)ÚTYPE_CHECKINGÚFinal)Úcli_utilÚconfigÚutil)Ú
get_logger)ÚRuntimeÚRuntimeConfigÚRuntimeState)ÚMemoryMediaFileStorage)ÚMemorySessionStorage)ÚMemoryUploadedFileManager)Ú$create_default_cache_storage_managerN)Ú	Awaitable©ÚUvicornServerr   Ú_LOGGERzunix://ÚUNIX_SOCKET_PREFIXz/mediaÚMEDIA_ENDPOINTz/_stcore/upload_fileÚUPLOAD_FILE_ENDPOINTc                 ób   — t        j                  d«      } | d uxr | j                  t        «      S )Nzserver.address)r   Ú
get_optionÚ
startswithr   )Úaddresss    ú]/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/streamlit/web/server/server.pyÚserver_address_is_unix_socketr   .   s/   € Ü×ÑÐ 0Ó1€GØ˜$ÐÒI 7×#5Ñ#5Ô6HÓ#IÐIó    c                  ót   — e Zd Zd
d„Zdd„Zedd„«       Zdd„Zedd„«       Zedd„«       Z	edd„«       Z
dd„Zy	)ÚServerc                óò   — || _         d| _        d| _        t        t        «      }t        t        «      }t        t        |||t        «       |t        t        j                  d«      ¬«      ¬«      «      | _        y)z+Create the server. It won't be started yet.Nzserver.disconnectedSessionTTL)Úttl_seconds)Úscript_pathÚmedia_file_storageÚuploaded_file_managerÚcache_storage_managerÚis_helloÚsession_storage)Ú_main_script_pathÚ_starlette_serverÚ_bootstrap_taskr   r   r   r   r
   r   r   r   r   r   Ú_runtime)ÚselfÚmain_script_pathr'   r$   Úuploaded_file_mgrs        r   Ú__init__zServer.__init__4   sp   € à!1ˆÔØ7;ˆÔð ;?ˆÔä3´NÓCÐä5Ô6JÓKÐäÜØ,Ø#5Ø&7Ü&JÓ&LØ!Ü 4Ü &× 1Ñ 1Ð2QÓ Rô!ô	ó
ˆ�r   c                ó,   — t        j                  | «      S ©N)r   Úrepr_©r-   s    r   Ú__repr__zServer.__repr__M   s   € Ü�z‰z˜$ÓÐr   c                ó   — | j                   S r2   )r)   r4   s    r   r.   zServer.main_script_pathP   s   € à×%Ñ%Ð%r   c              ƒ  ó¸   K  — t         j                  d«       ddlm}  || j                  «      | _        | j
                  j                  «       ƒ d{  –—†  y7 Œ­w)zaStart the server.

        When this returns, Streamlit is ready to accept new sessions.
        zStarting server...r   r   N)r   ÚdebugÚstreamlit.web.server.starletter   r,   r*   Ústart)r-   r   s     r   r:   zServer.startT   sA   è ø€ ô
 	�‰Ð*Ô+å@á!.¨t¯}©}Ó!=ˆÔØ×$Ñ$×*Ñ*Ó,×,Ò,ús   ‚AAÁAÁAc                ó   ‡ — dˆ fd„} |«       S )z>A Future that completes when the Server's run loop has exited.c               “  óÂ   •K  — ‰ j                   �,‰ j                   j                  j                  «       ƒ d {  –—†  ‰ j                  j                  ƒ d {  –—†  y 7 Œ#7 Œ­wr2   )r*   ÚstoppedÚwaitr,   r4   s   €r   Ú_wait_for_stopz&Server.stopped.<locals>._wait_for_stopd   sQ   øè ø€ Ø×%Ñ%Ð1Ø×,Ñ,×4Ñ4×9Ñ9Ó;×;Ð;ð —-‘-×'Ñ'×'Ñ'ð <øð (ús!   ƒ4A·A¸AÁAÁAÁA©ÚreturnÚNone© )r-   r?   s   ` r   r=   zServer.stopped`   s   ø€ õ	(ñ ÓÐr   c                óP   — | j                   j                  t        j                  k(  S r2   )r,   Ústater   ÚONE_OR_MORE_SESSIONS_CONNECTEDr4   s    r   Úbrowser_is_connectedzServer.browser_is_connectedm   s   € à�}‰}×"Ñ"¤l×&QÑ&QÑQÐQr   c                ó@   — ddl m} | j                  |j                  k(  S )Nr   )Ústreamlit_app)Ústreamlit.hellorI   r)   Ú__file__)r-   rI   s     r   Úis_running_hellozServer.is_running_helloq   s   € å1à×%Ñ%¨×)?Ñ)?Ñ?Ð?r   c                ó´   — t        j                  dd¬«       | j                  �| j                  j                  «        y | j                  j                  «        y )Nz  Stopping...Úblue)Úfg)r   Úprint_to_clir*   Ústopr,   r4   s    r   rQ   zServer.stopw   sB   € Ü×Ñ˜o°&Õ9Ø×!Ñ!Ð-à×"Ñ"×'Ñ'Õ)ð �M‰M×ÑÕ r   N)r.   Ústrr'   ÚboolrA   rB   )rA   rR   r@   )rA   zAwaitable[None]©rA   rS   )Ú__name__Ú
__module__Ú__qualname__r0   r5   Úpropertyr.   r:   r=   rG   rL   rQ   rC   r   r   r    r    3   sj   „ ó
ó2 ð ò&ó ð&ó
-ð ò
 ó ð
 ð òRó ðRð ò@ó ð@ô
!r   r    rT   )$Ú
__future__r   Útypingr   r   Ú	streamlitr   r   r   Ústreamlit.loggerr	   Ústreamlit.runtimer
   r   r   Ú+streamlit.runtime.memory_media_file_storager   Ú(streamlit.runtime.memory_session_storager   Ú.streamlit.runtime.memory_uploaded_file_managerr   Ú*streamlit.web.cache_storage_manager_configr   ÚasyncioÚcollections.abcr   r9   r   rU   r   Ú__annotations__r   r   r   r   r    rC   r   r   ú<module>re      s}   ðö #ç 'ç ,Ñ ,Ý 'ß BÑ BÝ NÝ IÝ Tõñ ÛÝ)å<á˜HÓ%€ˆÓ %ð &Ð �EÓ %ð !€�Ó  Ø4Ð �eÓ 4óJ÷
K!ò K!r   