mxiRUdZddlmZddlmZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZdd lmZdd lmZmZmZmZmZmZmZmZmZmZmZmZm Z dd l!m"Z"m#Z#m$Z$dd l%m&Z&dd l'm(Z(erHddl)m*Z*m+Z+m,Z,m-Z-ddlm.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6m7Z7m8Z8m9Z9ddl:m;Z;ddlm?Z?ddl@mAZAdeddeddedfZBdeCd<d"dZDd#dZEd$dZFGddZGdd gZHy!)%z2Starlette application for serving a Streamlit app.) annotations)asynccontextmanager)Path) TYPE_CHECKINGAnyFinal)config)get_cookie_secret)generate_random_hex_string)create_auth_routes) BASE_ROUTE_COMPONENTBASE_ROUTE_COREBASE_ROUTE_MEDIABASE_ROUTE_UPLOAD_FILE create_app_static_serving_routescreate_bidi_component_routescreate_component_routescreate_health_routescreate_host_config_routescreate_media_routescreate_metrics_routescreate_script_health_routescreate_upload_routes)GZIP_COMPRESSLEVELGZIP_MINIMUM_SIZESESSION_COOKIE_NAME)%create_streamlit_static_assets_routes)create_websocket_routes) AsyncIteratorCallableMappingSequence)AbstractAsyncContextManager Starlette Middleware) BaseRoute)ExceptionHandlerReceiveScopeSend)Runtime)MediaFileManagerMemoryMediaFileStorageMemoryUploadedFileManager/zFinal[tuple[str, ...]]_RESERVED_ROUTE_PREFIXESc|j}|j}|j}|j}|j}t j d}tt j d}g}|jt|||jt|||jt||jt|||jt||||jt|||jt|||jt!|||jt#|t j dr(t%|dd} |jt'| |t j dr|jt)|||s|jt+||S)aCreate the Streamlit-internal routes for the application. This function creates all the routes required for Streamlit's core functionality including WebSocket communication, health checks, media serving, file uploads, and static file serving. Parameters ---------- runtime The Streamlit Runtime instance that manages the application state. Returns ------- list[BaseRoute] A list of Starlette route objects for Streamlit's core functionality. zserver.baseUrlPathzglobal.developmentModezserver.enableStaticServing_main_script_pathNzserver.scriptHealthCheckEnabled)base_url)media_file_mgruploaded_file_mgr_storagecomponent_registrybidi_component_registryr get_optionboolextendrrrrrrrrr getattrrrr) runtime media_manager upload_mgr media_storager;bidi_component_managerr7dev_moderoutesmain_script_paths c/home/htdocs/ttos/venv/lib/python3.12/site-packages/streamlit/web/server/starlette/starlette_app.pycreate_streamlit_routesrJLs$'.&<&?@HF MM&w9: MM':; MM+H56 MM%mX>? MM&w HEF MM)*r r=rrr)r'rMrN middlewares rIcreate_streamlit_middlewarer[s0?$&J (*J.H.JF--.BCD.    $*,  rKc ddlm}tdfd }t }t }||||S#t$r}td|d}~wwxYw)aCreate a Starlette application for serving Streamlit. This factory function creates a fully configured Starlette app that provides the full web-server functionality required for Streamlit: - WebSocket endpoint for client-server communication - Health check endpoints - Media file serving with range request support - File upload handling - Custom component serving - Static file serving with SPA fallback - XSRF protection - Session middleware - GZip compression rr$zdStarlette is not installed. Run `pip install streamlit[starlette]` or disable `server.useStarlette`.NclKjd{djy7w)N)startstop)_apprAs rI _lifespanz'create_starlette_app.._lifespans)mmo   s 424)rGrZlifespanr`r%returnzAsyncIterator[None])starlette.applicationsr%ModuleNotFoundError RuntimeErrorrrJr[)rAr%excrarGrZs` rIcreate_starlette_apprism4%W -F,.J FzI NN)  0  s8 A A  AceZdZdZdddddd ddZddZeddZeddZdd Z dd Z dd Z e dd Z dd ZddZy)Appa ASGI-compatible Streamlit application. .. warning:: This feature is experimental and may change or be removed in future versions without warning. Use at your own risk. This class provides a way to configure and run Streamlit applications with custom routes, middleware, lifespan hooks, and exception handlers. Parameters ---------- script_path : str | Path Path to the main Streamlit script. Can be absolute or relative. Relative paths are resolved based on context: when started via ``streamlit run``, they resolve relative to the main script; when started directly via uvicorn or another ASGI server, they resolve relative to the current working directory. lifespan : Callable[[App], AbstractAsyncContextManager[dict[str, Any] | None]] | None Async context manager for startup/shutdown logic. The context manager receives the App instance and can yield a dictionary of state that will be accessible via ``app.state``. routes : Sequence[BaseRoute] | None Additional routes to mount alongside Streamlit. User routes are checked against reserved Streamlit routes and will raise ValueError if they conflict. middleware : Sequence[Middleware] | None Middleware stack to apply to all requests. User middleware runs before Streamlit's internal middleware. exception_handlers : Mapping[Any, ExceptionHandler] | None Custom exception handlers for user routes. debug : bool Enable debug mode for the underlying Starlette application. Examples -------- Basic usage: >>> from streamlit.web.server.starlette import App >>> app = App("main.py") With lifespan hooks: >>> from contextlib import asynccontextmanager >>> from streamlit.web.server.starlette import App >>> >>> @asynccontextmanager ... async def lifespan(app): ... print("Starting up...") ... yield {"model": "loaded"} ... print("Shutting down...") >>> >>> app = App("main.py", lifespan=lifespan) With custom routes: >>> from starlette.routing import Route >>> from starlette.responses import JSONResponse >>> from streamlit.web.server.starlette import App >>> >>> async def health(request): ... return JSONResponse({"status": "ok"}) >>> >>> app = App("main.py", routes=[Route("/health", health)]) NF)rbrGrZexception_handlersdebugct||_||_|r t|ng|_|r t|ng|_|r t |ni|_||_d|_ d|_ i|_ d|_ |jy)NF)r _script_path_user_lifespanlist _user_routes_user_middlewaredict_exception_handlers_debug_runtime_starlette_app_state_external_lifespan_validate_routes)self script_pathrbrGrZrlrms rI__init__z App.__init__#s!-&,2DL4>Z 0B(:D# $   (, 04&( (- rKc |jD]T}t|dd}|stD]9}|j|s||j dk(s)t d|d|dVy)zHValidate that user routes don't conflict with reserved Streamlit routes.pathNr3zRoute 'z2' conflicts with reserved Streamlit route prefix 'z('. Use a different path like '/api/...'.)rrr@r4 startswithrstrip ValueError)r|routerreserveds rIr{zApp._validate_routes@sz&& E5&$/D 8Hx0DHOOC>> from fastapi import FastAPI >>> from streamlit.starlette import App >>> >>> streamlit_app = App("dashboard.py") >>> fastapi_app = FastAPI(lifespan=streamlit_app.lifespan()) >>> fastapi_app.mount("/dashboard", streamlit_app) T)rw_create_runtimerz_combined_lifespanrs rIrbz App.lifespanVs40 ==  002DM#'&&&rKc|jjr |jStjr>t tjj |jz j S|jj S)a6Resolve the script path to an absolute path. Resolution order: 1. If already absolute, return as-is 2. If CLI set main_script_path (via `streamlit run`), resolve relative to it 3. Otherwise, resolve relative to current working directory (e.g. when started via uvicorn) )ro is_absoluter r6rparentresolvers rI_resolve_script_pathzApp._resolve_script_pathvso    ( ( *$$ $  # #11299DRuntime not initialized. Call _create_runtime before lifespan.z asgi-mountedz asgi-server)streamlit.web.bootstraprrwrgrzr _server_moderrr^rpryupdater_)r|r`rrs rIrzApp._combined_lifespans J == P   " "#1F   ("/F  &c$*C*C*E&FGmm!!### !""..t4 **51  MM    $  MM   srB EDE!D)6D7D):#D D)(D) D)3ED)D)D&D D&"D))EEcddlm}ddlm}|jr@|j duxs#|j j |jk(}|r td|j |j|_t|j }|j|z}t}|j|z}|jrdn |j}||j|||j |S)z?Build the Starlette application with all routes and middleware.rr$) RuntimeStateNzCannot use App as standalone ASGI application after calling lifespan(). The lifespan() method should only be used when mounting this App on another ASGI framework like FastAPI.)rmrGrZrlrb)rer%rrrzrwrINITIALrgrrJrrr[rsrrvru) r|r%rruntime_not_startedstreamlit_routes all_routesstreamlit_middlewareall_middleware app_lifespans rI_build_starlette_appzApp._build_starlette_apps42  " " %T)<)< @T@T)T #"P ==  002DM34==A&&)99  ;<..1EE $66tDrdNone)rdr)rdr)rdzdict[str, Any])rdz2Callable[[Any], AbstractAsyncContextManager[None]])rdr-rc)rdr%)rr+rr*rr,rdr)__name__ __module__ __qualname____doc__r~r{propertyr}rrbrrrrrrrKrIrkrks=J -126DH  W  + 0 B    : !!'@+&$ L,!,!\0 d8rKrkriN)rAr-rdzlist[BaseRoute])rdzlist[Middleware])rAr-rdr%)Ir __future__r contextlibrpathlibrtypingrrr streamlitr streamlit.web.server.server_utilr 2streamlit.web.server.starlette.starlette_app_utilsr 4streamlit.web.server.starlette.starlette_auth_routesr /streamlit.web.server.starlette.starlette_routesr rrrrrrrrrrrr6streamlit.web.server.starlette.starlette_server_configrrr6streamlit.web.server.starlette.starlette_static_routesr2streamlit.web.server.starlette.starlette_websocketrcollections.abcrr r!r"r#rer%rVr'starlette.routingr(starlette.typesr)r*r+r,rr-$streamlit.runtime.media_file_managerr.rr0rr2r4__annotations__rJr[rirk__all__rrKrIrs9"*,,>T WJJ60/+FF)ERXQ40<~-`%OPr8r8j ( )rK