{jvddlZddlZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z mZddlmZ ddlZd Zn#e$rdZd ZYnwxYwd Zd Zgd ZdeDZdeDZgdZgdZdeDZejdZdedefdZdedefdZ de!de!fdZ"dZ#Gdde Z$dS)N)Callable)Any)Field) BaseSettingsSettingsConfigDict)ResponseSession) __version__TFz [REDACTED]7pylf_v1_us_6zTrqKw3YjJBHfpVPVr55wYcJ9sTV6sd4D3C4hsXLfJC)usernamepassword refresh_token oauth_tokenoauth_token_secret mfa_tokenembedcRg|]$}tj|dtj%S)z=[^&\s]*)recompile IGNORECASE.0keys L/home/lighthouse/health/venv/lib/python3.11/site-packages/garth/telemetry.py r%s? J3   "-00c&g|]}|dtS)=)REDACTEDrs rrr)s3sXr) access_tokenrjti consumer_keyconsumer_secretrrr) AuthorizationCookiez Set-Cookiec6h|]}|S)lower)rhs r r+;s @@@17799@@@rz=[^;]* cookie_valuereturncHtdt|S)z.Sanitize cookie value by redacting all values.r)_COOKIE_PATTERNsubr )r,s rsanitize_cookier1As   ~8~~| < <zTelemetry.us 0" 5r)default_factoryrZ session_id_logfire_configured_logfire_instance_attached_sessionsc,t|_dS)N)setrf)self_Telemetry__contexts rmodel_post_initzTelemetry.model_post_init|s"%%%rrBcLtr|jsdS|jj di|dS)z'Default callback that sends to logfire.N!http {method} {url} {status_code})rm)LOGFIRE_AVAILABLErdreinfo)rirBs r_default_callbackzTelemetry._default_callbacksM  (@  F## /  37     rresponsec @|jsdS |j}|dS|jt|j|j|jttt|j ttt|j d}|j rE|j }t|tr|dd}t||d<t|j|d<|jp|j}||dS#t&$rYdSwxYw)z1Session hook that captures request/response data.N)rc garth_versionmethodurl status_coderequest_headersresponse_headerszutf-8replace)errors request_body response_body)rVrequestrcr rtrurvstrrKr;rEbodyr:bytesdecoderDr2r[rp Exception)rirqargskwargsr}rBrr[s r_response_hookzTelemetry._response_hooks4|  F &G"o!,!.{'3#&$T'/%:%:;;$$%($T(*:%;%;<<%%  D| 6|dE**B;;wy;AAD'/~~^$$,X]$;$;D !}>(>H HTNNNNN    DD s DC7D DDc|||_|||_|||_|||_|jsdS|j|js|dSdSdS)a Configure telemetry. Disabled by default. Args: enabled: Enable/disable telemetry (default: False) send_to_logfire: Send to Logfire Cloud (default: False) token: Logfire write token callback: Custom callback for telemetry data. If provided, logfire will not be configured and data will be passed to this callback instead. N)rVrWrXr[rd_configure_logfire)rirVrWrXr[s r configurezTelemetry.configures$  "DL  D  DJ  $DM|  F = )A  # # % % % % % ! rc tsdStjdd|j|jtjt d|_d|_dS)zConfigure a local logfire instance for garth telemetry. Uses local=True to avoid overwriting logfire configuration in applications that integrate garth. NTgarth)r[F)local service_namerWrX scrubbingconsole) rnlogfirerrWrXScrubbingOptionsrOrerd)ris rrzTelemetry._configure_logfiresa !  F!(!2  0*.8KLLL " " " $(   rsessionct|}||jvrdS|jd|j|j|dS)zAttach telemetry hooks to a session. This method is idempotent - calling it multiple times with the same session will only attach the hook once. Nrq)idrfhooksappendradd)rirrcs rattachzTelemetry.attachs] [[ 0 0 0 F j!(()<=== ##J/////r)NNNN)__name__ __module__ __qualname__r model_configrVbool__annotations__rW DEFAULT_TOKENrXr~rr[rr;rcrdrerrhrfrkrprrrrr rr(rrrQrQjs%%%L GT!OT!!!E3.3eD$.O.O.OHhvt|$t+OOOe55J!&%%%!s!!!!cee###((( d    "x""""L $'+ 26 & & & &Tz & D64<(4/ & & & &D(((& 0g 0 0 0 0 0 0rrQ)%r8rr^collections.abcrtypingrpydanticrpydantic_settingsrrrequestsrr versionr rrn ImportErrorr r_SENSITIVE_QUERY_PARAMSr6r7r<SENSITIVE_HEADERSrIrr/r~r1rDr;rKrOrQr(rrrs2 $$$$$$>>>>>>>>&&&&&&&& NNNG I &#:   >==@@.?@@@"*Y''=#=#==== 33,dt A0A0A0A0A0 A0A0A0A0A0s= A A