ԟjUdZddlmZddlZddlZddlZddlZddlZddlm Z ddl Z ddl m Z ej dZGddZdad ed <dd ZddZdS)zJService to automatically monitor, start, and keep alive Cloudflare Tunnel.) annotationsN)Path) get_settingszdscons.cloudflared_managercReZdZdZddZddZddZdd Zdd Zdd Z dd Z ddZ dS)CloudflaredManagerzO O   Axxzz 1vv  trboolcl tjgdddd}d|jvS#t$rYdSwxYw)zXChecks whether cloudflared is already running as a system service or background process.)tasklistz/FIzIMAGENAME eq cloudflared.exeT)capture_outputtexttimeoutr!F) subprocessrunstdout Exception)rress r_is_system_process_runningz-CloudflaredManager._is_system_process_running.s` .CCC# C % 2 2   55 s "% 33c`KdD]} tjd4d{V}|d|dd{V}|jdkr dddd{VdS dddd{Vn#1d{VswxYwY#t$rYwxYwgd }|D]} tjd d 4d{V}||d{V}|jdkr dddd{VdS dddd{Vn#1d{VswxYwY#t$rYwxYwd S) zCVerifies if the local tunnel daemon and edge connection are active.)iOiOiOg?r0Nzhttp://127.0.0.1:z/readyT)z*https://dinhsonconstruction.com/api/healthz.https://erp.dinhsonconstruction.com/api/healthz&https://dinhsonconstruction.com/healthz*https://erp.dinhsonconstruction.com/health@F)r0verify)httpx AsyncClientr status_coder4)rportclientr5 test_urlsurls ris_tunnel_healthyz$CloudflaredManager.is_tunnel_healthy;s*  D  ,S999$$$$$$$V & +Kt+K+K+K L LLLLLLLC#--#$$$$$$$$$$$$$$$-$$$$$$$$$$$$$$$$$$$$$$$$$$$         C  ,SGGG$$$$$$$6 & 3//////C#--#$$$$$$$$$$$$$$$-$$$$$$$$$$$$$$$$$$$$$$$$$$$    usvB,A6B$B6 B BB B BB!D=(D %D:D D DD D D+*D+c K|}|stddS|js"td|jdStd|j ddl}d}|jdkr d}d }||z}tj |d d t|jd gtj tj tj ||jdkrd nd|_ td|j j d S#t$r&}td|Yd}~dSd}~wwxYw)z&Starts the cloudflared tunnel process.z,cloudflared binary not found on system PATH.Fz'cloudflared config file not found at %sz-Starting Cloudflare Tunnel using config %s...rNwin32itunnelz--configr2T)r3stderrstdin creationflags close_fdsz.Cloudflare Tunnel process started with PID %s.z,Error starting Cloudflare Tunnel process: %s)r)loggererrorrr$infosysplatformr1Popenr%DEVNULLr pidr4)rbinaryrOrJDETACHED_PROCESSCREATE_NEW_PROCESS_GROUPes r start_tunnelzCloudflaredManager.start_tunnelYs""$$  LLG H H H5&&((  LLBDDT U U U5 CTEUVVV  JJJM|w&&#- +5( 03K K &,()) ")!) (+"%,'"9"9$$u   DM KK@$-BS   4    LLG K K K55555 sB D33 E#=EE#cKt|jddsdS|d{V}|s|std|d{V}|rtdD]S}tj dd{V|d{Vrt ddSTtddSt d dSt d dSt d dS) z4Checks if tunnel is healthy, and restarts it if not.cloudflared_enabledTNz:Cloudflare Tunnel is not running. Initiating auto-start... z4Cloudflare Tunnel successfully recovered and online.z;Cloudflare Tunnel process spawned, waiting for edge sync...z"Failed to start Cloudflare Tunnel.z?Cloudflare Tunnel process is running, awaiting edge connection.z(Cloudflare Tunnel is online and healthy.) getattrr rCr6rLwarningrXrangeasynciosleeprNrMdebug)r is_healthystarted_s rcheck_and_recoverz$CloudflaredManager.check_and_recoverst}&;TBB  F1133333333  E2244 P!% 1 1 3 3333333 G"2YY##%mA.........!%!7!7!9!9999999#"KK V#FF # NNULL!EFFFFF U LLC D D D D Drc4K|jr d}t|jdr|jdu}nt|jddd}|rtdt|jdd |jt|jd r|jd n;#t$r. |j n#t$rYnwxYwYnwxYwd|_dSdSdS) z,Stops the managed tunnel process gracefully.FpollN returncodeTz&Stopping Cloudflare Tunnel (PID %s)...rSzN/Awaitr:r8) r hasattrrhr]rLrN terminaterjr4kill)r is_runnings rstopzCloudflaredManager.stopsO = %Jt}f-- "!]//11T9  d;;C!  % <DM5%88M++---t}f558 **3*777  **,,,,$ !% + % % % %s7A C D C76D 7 DD DD  D Nrr )rr)rr)rr*) __name__ __module__ __qualname____doc__rr r)r6rCrXrfrorrrrsFF7777 BBBB        <((((T E E E ED%%%%%%rrzCloudflaredManager | None_global_cf_managerrc:ttatS)z2Returns the singleton CloudflaredManager instance.)rvrrurrget_cloudflared_managerrxs!/11 rr cKt} |d{Vn2#t$r%}td|Yd}~nd}~wwxYwt jdd{Vi)zOBackground monitor loop that runs indefinitely to keep Cloudflare Tunnel alive.TNz+Error in Cloudflare Tunnel monitor loop: %s)rxrfr4rLrMr`ra)managerrWs rstart_cloudflared_monitor_loopr|s%''G  K++-- - - - - - - - - K K K LLF J J J J J J J J KmB  s. AAA)rrrp)rt __future__rr`loggingrr"r1pathlibrr<app.core.settingsr getLoggerrLrrv__annotations__rxr|rurrrsPPP""""""  ******  7 8 8i%i%i%i%i%i%i%i%X154444      r