Function rusense_sensitivity

webapp_modern.py:1459–1527

Get/set the model-free detection sensitivity: the presence floor and the debounce depth the sensing engine uses. These are the RUVIEW_PRESENCE_FLOOR / RUVIEW_DEBOUNCE_FRAMES env vars; POST writes them to a systemd drop-in (ragnar-sensing.service.d/sensitivity.conf) so they survive a RuSe

()

    try:
        min_conf = float(shared_data.config.get('rusense_notify_min_confidence', 0.95))
    except (TypeError, ValueError):
        min_conf = 0.95
    # Confidence only means something with a trained model. Model-less it is
    # uncalibrated (~0.5), so a high bar would silently drop real presence —
    # relax the gate to 0 and lean on the motion-corroborated presence rule +
    # sustain debounce instead. Never miss presence for lack of a model.
    has_model = _rusense_model_active()
    if not has_model:
        min_conf = 0.0
    # Duty gates are model-aware: a loaded model lifts the empty-room baseline
    # (see the constants above), so use the higher gates then.
    pres_on = _RUSENSE_PRES_ON_MODEL if has_model else _RUSENSE_PRES_ON
    pres_off = _RUSENSE_PRES_OFF_MODEL if has_model else _RUSENSE_PRES_OFF
    try:
        sustain = float(shared_data.config.get('rusense_notify_sustain_s', 2))
    except (TypeError, ValueError):
        sustain = 2.0
    try:
        gf_window = int(shared_data.config.get('rusense_geofence_window', 30))
    except (TypeError, ValueError):
        gf_window = 30
    gf_window = max(4, min(600, gf_window))
    gf_enabled = bool(shared_data.config.get('rusense_geofence_enabled', True))
    now = time.time()
    # Surveillance alerts also respect the permitted-times schedule (if enabled);
    # node-offline + inactivity keep plain notify_on (maintenance / health).
    alerts_now = notify_on and _rusense_within_alert_schedule(now)

    # ── Nodes first: the roster feeds BOTH the geofence RSSI windows and the
    #    offline detector, so fetch it once and reuse it. ──
    nodes = _rusense_get('/api/v1/nodes')
    node_list = nodes.get('nodes') if isinstance(nodes, dict) else None
    if not isinstance(node_list, list):
        node_list = None

    # Extend per-node RSSI windows and evaluate the geofence verdict. A "ghost"
    # is a disturbance with real energy that is NOT corroborated/interior — i.e.
    # a walk-by or through-wall neighbour. When detected we suppress the
    # occupied/motion/people RISE alerts (the "empty" alert is never a ghost).
    block_motion = False
    node_people = None
    if node_list is not None:
        # Per-node person_count is the only count the engine exposes (there is no
        # reliable aggregate). It ghosts on individual nodes, so take the MEDIAN
        # across active nodes — a single node spiking (e.g. node 2 → 3) can't move
        # the median, so a count is only believed when a majority of nodes agree.
        counts = sorted(int(n['person_count']) for n in node_list
                        if n.get('status') == 'active'
                        and isinstance(n.get('person_count'), (int, float)))
        if counts:
            node_people = counts[(len(counts) - 1) // 2]   # lower median (conservative)
        with _rusense_notify_lock:
            windows = _rusense_notify_state['rssi_windows']
            seen = set()
            for n in node_list:
                nid, rssi = n.get('node_id'), n.get('rssi_dbm')
                if nid is None or rssi is None: