Function _rusense_pushover

webapp_modern.py:847–858

Return the shared PushoverService, creating it once if needed.

()

        tmp = f"{path}.tmp"
        with open(tmp, 'w') as fh:
            json.dump(lst, fh)
        os.replace(tmp, path)
    except OSError as exc:
        logger.error(f"[rusense] failed to persist vitals history: {exc}")


def _rusense_vitals_record(now, vs, present):
    """Fold one ~1 Hz notify pass into the current 5-min bucket; when the
    bucket rolls over, compact the finished one into the persisted history.
    Every pass contributes to the activity duty; HR/BR contribute only at
    display-grade confidence (>= 0.3 — below that the engine is guessing).
    A restart loses at most the one in-progress bucket."""
    bucket_t = int(now - (now % _RUSENSE_VITALS_BUCKET_S))
    with _rusense_vitals_lock:
        cur = _rusense_notify_state.get('vitals_bucket')