o ,&]i1@s$UddlmZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZddlmZddlmZmZddlmZmZmZeeZded <d Zd4ddZd5ddZd6ddZd7ddZ d8ddZ!d4dd Z"d7d!d"Z#d5d#d$Z$d9d&d'Z%d:d*d+Z&d:d,d-Z'd.d/d;d2d3Z(dS)<) annotationsN)AnyFinal)cli_utilconfigenv_util file_utilnet_utilsecrets) get_logger)report_watchdog_availability watch_file)Serverserver_address_is_unix_socket server_utilr_LOGGERi@serverrreturnNonecsbtdd fdd }ttj|ttj|tjd kr(ttj|dSttj|dS) NzSetting up signal handler signal_numberint stack_framerrrcs dSN)stop)rrrU/var/www/html/IGF-ODF-V3/venv/lib/python3.10/site-packages/streamlit/web/bootstrap.pysignal_handler(s z._set_up_signal_handler..signal_handlerwin32)rrrrrr) rdebugsignalSIGTERMSIGINTsysplatformSIGBREAKSIGQUIT)rrrrr_set_up_signal_handler%s  r'main_script_pathstrcCstjdtj|dS)zAdd the script's folder to the sys path. Python normally does this automatically, but since we exec the script ourselves we need to do it instead. rN)r#pathinsertosdirname)r(rrr _fix_sys_path4sr.running_in_event_loopboolcCsp|rdStjr dSzddl}Wn tyYdSwz |tdWdSty7tjdddYdSw)z=Install uvloop as the default event loop policy if available.Nrz.uvloop installed as default event loop policy.z7Failed to install uvloop. Falling back to default loop.T)exc_info) r IS_WINDOWSuvloopModuleNotFoundErrorinstallrr Exceptionwarning)r/r3rrr_maybe_install_uvloop=s"    r8cCsXtjr(z ddlm}m}Wn tyYdSwtt|ur*t|dSdSdS)a/Set default asyncio policy to be compatible with Tornado 6. Tornado 6 (at least) is not compatible with the default asyncio implementation on Windows. So here we pick the older SelectorEventLoopPolicy when the OS is Windows if the known-incompatible default policy is in use. This has to happen as early as possible to make it a low priority and overridable See: https://github.com/tornadoweb/tornado/issues/2608 FIXME: if/when tornado supports the defaults in asyncio, remove and bump tornado requirement for py38 rWindowsProactorEventLoopPolicyWindowsSelectorEventLoopPolicyN) rr2asyncior:r; ImportErrortypeget_event_loop_policyset_event_loop_policyr9rrr_fix_tornado_crashTs  rAargs list[str]cCsddl}|gt||_dS)ztsys.argv needs to exclude streamlit arguments and parameters and be set to what a user's script may expect. rN)r#listargv)r(rBr#rrr _fix_sys_argvtsrFcCs`t|jt|jtztWnty!t dYnwddd}t |dS)Nz Failed to load secrets.toml filerrcSs\tdrdStdrtd}ntdr"trdStd}nd}tt|dS)Nserver.headlessbrowser.serverAddressserver.address localhost)r get_optionis_manually_setrr open_browserrget_url)addrrrrmaybe_open_browsers     z,_on_server_start..maybe_open_browserrr) "_maybe_print_static_folder_warningr( _print_urlis_running_hellor r load_if_toml_existsr6r exceptionr<get_running_loop call_soon)rrPrrr_on_server_start}s     rYcCs"dtjvrtdtjd<dSdS)ziSets MAPBOX_API_KEY environment variable needed for PyDeck otherwise it will throw an exception. MAPBOX_API_KEYz mapbox.tokenN)r,environrrKrrrr_fix_pydeck_mapbox_api_warnings r\cCsrtdr5t|}tj|stjd|ddddSt |}|t kr7t ddtjddddSdSdS) z7Prints a warning if the static folder is misconfigured.zserver.enableStaticServingzGWARNING: Static file serving is enabled, but no static folder found at zJ. To disable static file serving, set server.enableStaticServing to false.yellow)fgFzVWARNING: Static folder size is larger than 1GB. Static file serving has been disabled.N) rrKrget_app_static_dirr,r*isdirr print_to_cliget_directory_sizeMAX_APP_STATIC_FOLDER_SIZE set_option)r(static_folder_pathstatic_folder_sizerrrrRs$       rRrTcCs|rd}nd}g}tdrdttdfg}nMtdr.ts.dttdfg}n9tr:dtdfg}n-dtdfg}t}|rR|d t|ftd rgt }|rg|d t|ft d t j d |dddt d |D]\}}t j d |ddddt j |ddq~t d |rt dt j dddt j dddt d t dt d t d dSdS)Nz9Welcome to Streamlit. Check out our demo in your browser.z4You can now view your Streamlit app in your browser.rHURLrIz Unix Socketz Local URLrJz Network URLrGz External URLz blueT)r^boldz: F)nlr^)rjz5 Ready to create your own Python apps super quickly?z Head over to )rkzhttps://docs.streamlit.ioz May you create awesome apps!) rrLrrNrKrr get_internal_ipappendget_external_iprra)rT title_message named_urls internal_ip external_ipurl_nameurlrrrrSsR            rS flag_optionsdict[str, Any]cCs$dd|D}tjd|ddS)a;Load config options from config.toml files, then overlay the ones set by flag_options. The "streamlit run" command supports passing Streamlit's config options as flags. This function reads through the config options set via flag, massages them, and passes them to get_config_options() so that they overwrite config option defaults and those loaded from config.toml files. Parameters ---------- flag_options : dict[str, Any] A dict of config options where the keys are the CLI flag version of the config option names. cSs.i|]\}}|dur|dkr|dd|qS)Nr_.)replace).0namevalrrr s  z'load_config_options..T) force_reparseoptions_from_flagsN)itemsrget_config_options)rurrrrload_config_optionssrcs8dfdd }tdD] }tj|rt||q dS) N_pathr)rrcs tdSr)r)rrurron_config_changeds z3_install_config_watchers..on_config_changedz config.toml)rr)rr)rget_config_filesr,r*existsr )rurfilenamerrr_install_config_watcherss   rF)stop_immediately_for_testingis_hellorcst|tt||tt|t||dfdd dfdd }d}ztd}Wn ty:Ynw|rOt d tj |d d }|_ d St |t d t|d S)zuRun a script in a separate thread and start a server for the app. This starts a blocking asyncio eventloop. rrcsFIdHttrtdjIdHdS)Nz'Stopping server immediately for testing)startrYr'rrrstoppedr)rrrr run_server8s zrun..run_servercsIdHdSrrr)rrrmainKszrun..mainFTz&Running server in existing event loop.zbootstrap.run_server)r{z"Starting new event loop for serverNrQ)r.rArFr\rrr<rW RuntimeErrorrr create_task_bootstrap_taskr8run)r(rrBrurrr/taskr)rrrrr"s,       r)rrrr)r(r)rr)r/r0rrrQ)r(r)rBrCrr)rTr0rr)rurvrr) r(r)rr0rBrCrurvrr0rr)) __future__rr<r,r r#typingrr streamlitrrrrr r streamlit.loggerr streamlit.watcherr r streamlit.web.serverrrr__name__r__annotations__rcr'r.r8rArFrYr\rRrSrrrrrrrs2      "  ;