7j dZddlmZddlmZmZddlmZddlmZm Z ddl m Z ddl m Z ddlmZmZmZdd lmZed Zddd Zddd Zy )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). ) annotations)datetimetimezone)Any) ApiClientApiError)Config)system)load_agent_token save_statussave_last_error) get_logger heartbeatc 2|j||jtjt j t jjtjtjtjddS)zAssemble the heartbeat payload. The frozen heartbeat contract requires `agent_version` and `status`; the agent is identified by its X-Agent-Token header, not the body. Light metrics are sent as additional informational fields. ) load_average disk_usagememory) agent_versionstatus server_idhostname timestampmetrics) rrr rrnowrutc isoformatrr memory_usage)configrs C/var/www/downloads.wolfpanel.net/public_html/agent/src/heartbeat.py build_payloadr so --%%OO%\\(,,/99;"//1 ++-))+  c|jdk(rtjdyt||} |j |t |tj d|t|dy#t$rf}t|t||jdk(r"t|dtjdntjd |Yd}~yd}~wwxYw) 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)NTiz3Heartbeat rejected by Central; marked agent revokedz.heartbeat failed, will retry next interval: %s) rlogwarningr rr infor rstr status_coder )r api_clientrpayloadexcs r send_oncer,+s }} ! :;FF+G W&6v&>? +V4% C) ??c !  * KKM N KKH# Ns=A11 C :ACC N)online)rr rr'returnzdict[str, Any])rr r)rrr'r.bool)__doc__ __future__rrrtypingrr)rrrr discoveryr identityr r r loggerrr$r r,r!rr7s;#'*CC*r!