#JjJSrSSKJr SSKrSSKJrJr SSKJr SSKJ r J r SSK J r SSK Jr SS KJrJrJr SS KJr \"S 5rS qSqS qSSjrSSSjjrSSSjjrg)a+Heartbeat: periodic liveness + light metrics to the Central API. The heartbeat must be resilient: if the API is unavailable the agent logs the failure and keeps running, retrying on the next interval. It never crashes the service and never blocks indefinitely (the API client has its own timeout). ) annotationsN)datetimetimezone)Any) ApiClientApiError)Config)system)load_agent_token save_statussave_last_error) get_logger heartbeatgFcz[R"5n[USS5n[bU[- U:a [[4$SSKJn U"X5nUbURqURqUq[cURS4$[[4$![a n[RSU5 SnANFSnAff=f)Nheartbeat_interval<r)checkz0Silent ignore of update manifest fetch error: %sF) timegetattr_cached_latest_version_last_fetch_time_cached_update_availableupdaterlatestupdate_available Exceptionlogwarning agent_version)config api_clientnowinterval check_updateinfoexcs 3D:\Programs\laragon\www\wolf\agent\src\heartbeat.pyget_update_statusr(s ))+Cv3R8H)s5E/E/P%'???M0F/  %)[[ "'+'<'< $" %##U** !#; ;; M FLLMs+B B:B55B:c [X5up4SSKnURURS9 UR 5nURUUUUR[R"5[R"[R5R!5US.$![ a"n[ RSU5 0nSnANSnAff=f)aAssemble the heartbeat payload. The heartbeat contract requires `agent_version`, `update_available`, `latest_version`, and `status`; the agent is identified by its X-Agent-Token header, not the body. Light metrics are sent as additional informational fields. rN)r#zFailed to collect telemetry: %s)rrlatest_versionstatus server_idhostname timestampmetrics)r(r/ start_updaterr get_metricsrrrrr,r r-rr"rutc isoformat)r r!r+r*rr/collected_metricsr&s r' build_payloadr54s(9'L$Nv'@'@A#//1  --,(%%OO%\\(,,/99;$    5s;s-B C (CC c@URS:Xa[RS5 g[XU5nUR U[ U55 [R SU5 [US5 SSKnURS- nUR5(Ga[US5nURU5nSSS5 WRS 5nU(aE[R S U5 URUS S S UR3S.S.[ U55 URS5n U (aNSSKJn SSKn U "U 5n U R'5(a'U R)U 5 [R SU 5 UR+5 [R S5 SSKnUR2RS5nU(a=[US5nUR5S5 SSS5 [R SU5 UR2RS5nU(aRSSKn[9US5(a;UR;[=U5UR>5 [R SU5 g g !,(df  GN=f![,a!n [R/SU 5 Sn A GNSn A ff=f!,(df  N=f![,a n [R/SU 5 Sn A NSn A ff=f![,a n [R/SU 5 Sn A g Sn A ff=f![@agn[U[CU55 URDS:Xa"[GUS5 [RS5 O[RS U5 SnAgSnAff=f)!uSend a single heartbeat. Returns True on success, False on failure. Never raises — transport errors are caught and reported so the caller's loop continues. revokedz$Heartbeat skipped: Agent is revoked.Fzheartbeat ok (status=%s)Nrzupdate_state.jsonrjob_idz>Reporting self-update command success to backend for job_id=%s succeededTzSuccessfully updated to )successmessage)r+result backup_dir)PathzCleaned up backup directory %szDeleted update state filez2Failed to complete update reporting or cleanup: %sWOLFPANEL_UPDATE_FLAG_FILEwOKz"Wrote update success flag file: %sz$Failed to write update flag file: %sWOLFPANEL_UPDATE_PARENT_PIDSIGUSR1zSent SIGUSR1 to parent PID: %szFailed to signal parent: %siz3Heartbeat rejected by Central; marked agent revokedz.heartbeat failed, will retry next interval: %s)$r+rrr5rr r%r jsonvar_diris_fileopenloadgetpost_command_resultrpathlibr?shutilexistsrmtreeunlinkrerrorosenvironwritesignalhasattrkillintrDrstr status_coder )r r!r+payloadrE state_filef update_stater9backup_dir_pathr?rMbderR flag_file parent_pidrUr&s r' send_oncerdRs }} ! :;F7GAW&6v&>? +V4% ^^&99      S*c*a#'99QJ93L,9J>>L, K K K<K72L,7K<<L,? L) L$L,$L))L,, N6ANN)r r r!rreturnztuple[str, bool])online)r r r!rr+rYrezdict[str, Any])r r r!rr+rYrebool)__doc__ __future__rrrrtypingrr!rrr r discoveryr identityr r r loggerrrrrrr(r5rdr'rpsV# '*CC <2