Function check_and_handle_network_switch

webapp_modern.py:3940–3980

Check if we've switched networks and clear old data if so

()

        download_name=os.path.basename(target), mimetype='application/x-ndjson')


@app.route('/api/rusense/diagnostics', methods=['GET'])
def rusense_diagnostics():
    """One-shot deep diagnostics bundle for CSI-node debugging. Runs the exact
    server-side commands a human would (tcpdump on the CSI UDP port, journalctl
    for the sensing engine, ss/systemctl, system + wifi state, binary md5s) AND
    the sensing-server API snapshots, so the Nodes-tab 'Download logs' captures
    EVERYTHING in one file. Local route; the webapp runs as root so the shell
    commands work. ?secs=6 controls the tcpdump window (2-20)."""
    import subprocess
    import hashlib
    try:
        secs = int(request.args.get('secs', 6))
    except (TypeError, ValueError):
        secs = 6
    secs = max(2, min(20, secs))

    def run(cmd, timeout=12):
        try:
            r = subprocess.run(cmd, capture_output=True, text=True, timeout=timeout)
            return {'cmd': ' '.join(cmd), 'rc': r.returncode,
                    'stdout': (r.stdout or '')[-24000:], 'stderr': (r.stderr or '')[-4000:]}
        except FileNotFoundError:
            return {'cmd': ' '.join(cmd), 'error': 'command not installed'}
        except subprocess.TimeoutExpired:
            return {'cmd': ' '.join(cmd), 'error': f'timeout after {timeout}s'}
        except Exception as exc:
            return {'cmd': ' '.join(cmd), 'error': str(exc)}

    def md5(path):
        try:
            h = hashlib.md5()
            with open(path, 'rb') as fh:
                for chunk in iter(lambda: fh.read(65536), b''):
                    h.update(chunk)
            return h.hexdigest()
        except Exception as exc:
            return f'err: {exc}'

    # tcpdump the CSI UDP port for `secs` (bounded by packet count too). `-i any`
    # is portable; the raw lines carry source IP + payload length per packet.
    udp = run(['timeout', str(secs), 'tcpdump', '-i', 'any', '-n', '-c', '500',
               'udp', 'port', '5005'], timeout=secs + 8)