Add RxMER Echo Detection 1 Postman endpoint and sync visualizer script

mgarcia01752 · mgarcia01752 · commit 0e82fd82be87 · 2026-03-08T16:02:21.000-06:00
- add new PyPNM request yaml for Ofdm RxMER Analysis Echo Detection 1
- add global variable rxmer_analysis_echo_detection_1 for analysis type selection
- sync Postman visualizer script from visual html to keep 1 to 1 mapping
- keep request body and operation id pattern consistent with existing MultiCapture RxMER analysis endpoints - 2026-03-08 16:02:21
diff --git a/postman/collections/PyPNM/MultiCapture/RxMER/Ofdm-RxMER-Analysis-Echo-Detection-1.request.yaml b/postman/collections/PyPNM/MultiCapture/RxMER/Ofdm-RxMER-Analysis-Echo-Detection-1.request.yaml
@@ -0,0 +1,318 @@
+$kind: http-request
+url: '{{pypnm_url}}/advance/multi/ds/rxMer/analysis'
+method: POST
+body:
+  type: json
+  content: "{\r\n  \"analysis\": {\r\n    \"type\": \"{{rxmer_analysis_echo_detection_1}}\",\r\n    \"output\": {\r\n      \"type\": \"json\"\r\n    },\r\n    \"plot\": {\r\n      \"ui\": {\r\n        \"theme\": \"dark\"\r\n      }\r\n    }\r\n  },\r\n  \"operation_id\": \"{{rxmer_multi_operation_id}}\"\r\n}"
+scripts:
+- type: afterResponse
+  code: |-
+    // Postman Visualizer: MultiCapture/RxMER/Ofdm-RxMER-Analysis-Echo-Detection-1
+    // Last Update: 2026-03-08 14:10:00 MST
+
+    const template = `
+    <style>
+      body { background:#0b0b0b; color:#e8e8e8; font-family:Arial,sans-serif; margin:0; padding:16px; }
+      .container { max-width:1600px; margin:0 auto; }
+      .header-row { display:grid; grid-template-columns:1fr auto 1fr; align-items:center; gap:8px; margin-bottom:12px; }
+      .page-title { grid-column:2; margin:0; text-align:center; color:#f2f2f2; font-size:22px; font-weight:700; }
+      .status-chip { grid-column:3; justify-self:end; font-size:12px; color:#d7deec; background:rgba(255,255,255,0.03); border:1px solid rgba(255,255,255,0.08); border-radius:999px; padding:6px 10px; white-space:nowrap; }
+
+      .device-info { background:#151515; padding:14px; margin-bottom:14px; border-radius:10px; border:1px solid #2a2a2a; }
+      .table-wrap { overflow-x:auto; border:1px solid rgba(255,255,255,0.08); border-radius:10px; }
+      .table-title { font-size:11px; text-transform:uppercase; letter-spacing:0.7px; padding:10px 12px; background:rgba(255,255,255,0.03); border-bottom:1px solid rgba(255,255,255,0.08); color:#dbe3ff; }
+      .table { width:100%; min-width:720px; border-collapse:collapse; }
+      .table th { text-align:left; white-space:nowrap; padding:9px 12px; font-size:11px; text-transform:uppercase; letter-spacing:0.45px; color:#dbe3ff; background:rgba(255,255,255,0.03); }
+      .table td { padding:10px 12px; font-size:12px; color:#fff; white-space:nowrap; border-top:1px solid rgba(255,255,255,0.08); }
+      .mono { font-family:Consolas,"Liberation Mono",Menlo,monospace; }
+
+      .panel { background:#202020; border:1px solid #303030; border-radius:10px; padding:14px; margin-bottom:14px; }
+      .panel-title { margin:0 0 10px 0; color:#5a6fd8; text-align:center; font-size:14px; font-weight:700; }
+      .channel-grid { display:grid; grid-template-columns:repeat(2,minmax(0,1fr)); gap:14px; }
+      @media (max-width:1100px) { .channel-grid { grid-template-columns:1fr; } }
+
+      .channel-meta { display:flex; gap:10px; justify-content:center; flex-wrap:wrap; color:#cfd8ea; font-size:12px; margin-bottom:8px; }
+      .echo-state { text-align:center; font-size:12px; margin-bottom:8px; }
+      .echo-state.ok { color:#39c28e; }
+      .echo-state.warn { color:#c62828; }
+      .echo-state.maybe { color:#f1c40f; }
+
+      .chart-wrap { position:relative; height:260px; margin-bottom:10px; }
+      .chart-wrap.tall { height:360px; }
+      .chart-canvas { display:block; width:100% !important; height:100% !important; box-sizing:border-box; background:#1a1a1a; border:1px solid #4d4d4d; border-radius:6px; }
+    </style>
+
+    <div class="container">
+      <div class="header-row">
+        <div class="page-title">RxMER Analysis Echo Detection 1</div>
+        <div class="status-chip">Status: {{status}} · Channels: {{channelCount}}</div>
+      </div>
+
+      <div class="device-info">
+        <div class="table-wrap">
+          <div class="table-title">Device Info</div>
+          <table class="table">
+            <thead>
+              <tr>
+                <th>MacAddress</th><th>Model</th><th>Vendor</th><th>SW Version</th><th>HW Version</th><th>Boot ROM</th>
+              </tr>
+            </thead>
+            <tbody>
+              <tr>
+                <td class="mono">{{deviceInfo.macAddress}}</td>
+                <td>{{deviceInfo.MODEL}}</td>
+                <td>{{deviceInfo.VENDOR}}</td>
+                <td class="mono">{{deviceInfo.SW_REV}}</td>
+                <td class="mono">{{deviceInfo.HW_REV}}</td>
+                <td class="mono">{{deviceInfo.BOOTR}}</td>
+              </tr>
+            </tbody>
+          </table>
+        </div>
+      </div>
+
+      <div class="panel">
+        <div class="panel-title">All Channels ({{channelCount}}) · RxMER Avg Aligned by Frequency</div>
+        <div class="chart-wrap tall"><canvas id="rxmerAllChart" class="chart-canvas"></canvas></div>
+      </div>
+
+      <div id="perChannelCharts" class="channel-grid"></div>
+    </div>
+
+    <script src="https://cdn.jsdelivr.net/npm/chart.js@3.7.1/dist/chart.min.js"></script>
+    <script>
+    pm.getData(function (err, value) {
+      if (err) return;
+      const channels = Array.isArray(value.channelData) ? value.channelData : [];
+      const root = document.getElementById('perChannelCharts');
+      if (!root) return;
+
+      const textColor = '#e0e0e0';
+      const gridColor = 'rgba(255,255,255,0.10)';
+      const palette = ['#5a6fd8','#39c28e','#c62828','#f1c40f','#00bcd4','#9b59b6','#ff9800'];
+
+      function toLinePointsXHzToMHz(freq, vals) {
+        const n = Math.min(Array.isArray(freq) ? freq.length : 0, Array.isArray(vals) ? vals.length : 0);
+        const out = [];
+        for (let i = 0; i < n; i++) {
+          const x = Number(freq[i]);
+          const y = Number(vals[i]);
+          if (Number.isFinite(x) && Number.isFinite(y)) out.push({ x: x / 1e6, y: y });
+        }
+        return out;
+      }
+
+      function makeOptions(xTitle, yTitle) {
+        return {
+          responsive: true,
+          maintainAspectRatio: false,
+          parsing: false,
+          normalized: true,
+          plugins: { legend: { labels: { color: textColor } } },
+          elements: { point: { radius: 0, hoverRadius: 0 } },
+          scales: {
+            x: {
+              type: 'linear',
+              title: { display: true, text: xTitle, color: textColor },
+              ticks: { color: textColor, callback: function(v){ return String(Math.round(v)); } },
+              grid: { color: gridColor }
+            },
+            y: {
+              title: { display: true, text: yTitle, color: textColor },
+              ticks: { color: textColor },
+              grid: { color: gridColor }
+            }
+          }
+        };
+      }
+
+      const allCanvas = document.getElementById('rxmerAllChart');
+      if (allCanvas) {
+        const ds = channels.map((ch, idx) => ({
+          label: 'Channel ' + ch.channelId,
+          data: toLinePointsXHzToMHz(ch.frequency, ch.avg),
+          borderColor: palette[idx % palette.length],
+          borderWidth: 1.2,
+          spanGaps: true
+        }));
+        new Chart(allCanvas, {
+          type: 'line',
+          data: { datasets: ds },
+          options: makeOptions('MHz', 'RxMER (dB)')
+        });
+      }
+
+      channels.forEach(function(ch, idx) {
+        const echoCount = Number(ch.echoCount || 0);
+        const stateText = echoCount > 0 ? 'Echo Detected' : (ch.standingWaveLikely ? 'Standing Wave Likely' : 'No Echo Detected');
+        const stateClass = echoCount > 0 ? 'warn' : (ch.standingWaveLikely ? 'maybe' : 'ok');
+
+        const card = document.createElement('div');
+        card.className = 'panel';
+        card.innerHTML = '' +
+          '<div class="panel-title">Channel ' + ch.channelId + '</div>' +
+          '<div class="echo-state ' + stateClass + '">' + stateText + '</div>' +
+          '<div class="channel-meta">' +
+          '<span>Subcarriers: ' + ch.subcarriers + '</span>' +
+          '<span>Captures: ' + ch.captures + '</span>' +
+          '<span>Sample Rate: ' + ch.sampleRateMHz + ' MHz</span>' +
+          '<span>VF: ' + ch.velocityFactor + '</span>' +
+          '<span>Ripple P2P: ' + ch.rippleP2PDb + ' dB</span>' +
+          '<span>Notches: ' + ch.notchCount + '</span>' +
+          '</div>' +
+          '<div class="chart-wrap"><canvas id="rx_raw_' + idx + '" class="chart-canvas"></canvas></div>' +
+          '<div class="table-wrap" style="margin-top:10px">' +
+          '<div class="table-title">Echo Table</div>' +
+          '<table class="table" style="min-width:0">' +
+          '<thead><tr><th>Type</th><th>Rank</th><th>Delay (us)</th><th>Distance (m)</th><th>Distance (ft)</th><th>Amplitude</th></tr></thead>' +
+          '<tbody>' + ch.echoTableRows + '</tbody>' +
+          '</table>' +
+          '</div>';
+
+        root.appendChild(card);
+
+        const c1 = document.getElementById('rx_raw_' + idx);
+        if (c1) {
+          new Chart(c1, {
+            type: 'line',
+            data: {
+              datasets: [
+                { label: 'RxMER Avg', data: toLinePointsXHzToMHz(ch.frequency, ch.avg), borderColor: '#5a6fd8', borderWidth: 1.2, spanGaps: true }
+              ]
+            },
+            options: makeOptions('MHz', 'RxMER (dB)')
+          });
+        }
+      });
+    });
+    </script>
+    `;
+
+    (function () {
+      const response = pm.response.json();
+
+      function safeText(v) {
+        if (v === undefined || v === null) return 'N/A';
+        const s = String(v).trim();
+        return s ? s : 'N/A';
+      }
+
+      function analyzeStandingWave(freq, values) {
+        const n = Math.min(Array.isArray(freq) ? freq.length : 0, Array.isArray(values) ? values.length : 0);
+        const y = [];
+        for (let i = 0; i < n; i++) {
+          const v = Number(values[i]);
+          if (Number.isFinite(v)) y.push(v);
+        }
+        if (y.length < 128) return { likely: false, p2pDb: 0, notchCount: 0 };
+
+        const start = y[0];
+        const end = y[y.length - 1];
+        let minR = Infinity;
+        let maxR = -Infinity;
+        let meanR = 0;
+        const residual = new Array(y.length);
+
+        for (let i = 0; i < y.length; i++) {
+          const t = y.length > 1 ? i / (y.length - 1) : 0;
+          const trend = start + ((end - start) * t);
+          const r = y[i] - trend;
+          residual[i] = r;
+          meanR += r;
+          if (r < minR) minR = r;
+          if (r > maxR) maxR = r;
+        }
+        meanR /= residual.length;
+
+        const p2pDb = maxR - minR;
+        const notchThreshold = meanR - 0.9;
+        let notchCount = 0;
+        for (let i = 1; i < residual.length - 1; i++) {
+          const cur = residual[i];
+          if (cur < notchThreshold && cur < residual[i - 1] && cur < residual[i + 1]) notchCount++;
+        }
+
+        return { likely: p2pDb >= 1.4 && notchCount >= 4, p2pDb: p2pDb, notchCount: notchCount };
+      }
+
+      function fmt(num, digits, fallback) {
+        const n = Number(num);
+        if (!Number.isFinite(n)) return fallback;
+        return n.toFixed(digits);
+      }
+
+      const device = response && typeof response.device === 'object' ? response.device : {};
+      const sys = device && typeof device.system_description === 'object' ? device.system_description : {};
+      const data = response && typeof response.data === 'object' ? response.data : {};
+      const channelKeys = Object.keys(data).sort(function(a, b){ return Number(a) - Number(b); });
+
+      const channelData = channelKeys.map(function(key) {
+        const ch = data[key] || {};
+        const rx = ch.rxmer && typeof ch.rxmer === 'object' ? ch.rxmer : {};
+        const report = ch.echo_report && typeof ch.echo_report === 'object' ? ch.echo_report : {};
+        const info = report.dataset_info && typeof report.dataset_info === 'object' ? report.dataset_info : {};
+        const direct = report.direct_path && typeof report.direct_path === 'object' ? report.direct_path : {};
+        const echoes = Array.isArray(report.echoes) ? report.echoes : [];
+
+        const frequency = Array.isArray(rx.frequency) ? rx.frequency : [];
+        const avg = Array.isArray(rx.avg) ? rx.avg : [];
+        const standing = analyzeStandingWave(frequency, avg);
+
+        let rows = '';
+        rows += '<tr>' +
+          '<td>Direct</td>' +
+          '<td>0</td>' +
+          '<td>' + fmt(Number(direct.time_s) * 1e6, 3, '0.000') + '</td>' +
+          '<td>' + fmt(direct.distance_m, 2, '0.00') + '</td>' +
+          '<td>' + fmt(direct.distance_ft, 2, '0.00') + '</td>' +
+          '<td>' + fmt(direct.amplitude, 3, '0.000') + '</td>' +
+          '</tr>';
+
+        if (echoes.length) {
+          for (let i = 0; i < echoes.length; i++) {
+            const e = echoes[i] || {};
+            rows += '<tr>' +
+              '<td>Echo</td>' +
+              '<td>' + (i + 1) + '</td>' +
+              '<td>' + fmt(Number(e.time_s) * 1e6, 3, '0.000') + '</td>' +
+              '<td>' + fmt(e.distance_m, 2, '0.00') + '</td>' +
+              '<td>' + fmt(e.distance_ft, 2, '0.00') + '</td>' +
+              '<td>' + fmt(e.amplitude, 3, '0.000') + '</td>' +
+              '</tr>';
+          }
+        } else {
+          rows += '<tr><td>Echo</td><td>-</td><td colspan="4">No secondary echoes in report</td></tr>';
+        }
+
+        return {
+          channelId: ch.channel_id !== undefined && ch.channel_id !== null ? ch.channel_id : key,
+          frequency: frequency,
+          avg: avg,
+          subcarriers: Number(info.subcarriers) || 0,
+          captures: Number(info.captures) || 0,
+          sampleRateMHz: Number(report.sample_rate_hz) ? (Number(report.sample_rate_hz) / 1e6).toFixed(0) : 'N/A',
+          velocityFactor: Number(report.velocity_factor) ? Number(report.velocity_factor).toFixed(2) : 'N/A',
+          echoCount: echoes.length,
+          standingWaveLikely: standing.likely,
+          rippleP2PDb: standing.p2pDb.toFixed(2),
+          notchCount: standing.notchCount,
+          echoTableRows: rows
+        };
+      });
+
+      pm.visualizer.set(template, {
+        status: response.status !== undefined ? response.status : 'N/A',
+        channelCount: channelData.length,
+        deviceInfo: {
+          macAddress: safeText(device.mac_address).toLowerCase(),
+          MODEL: safeText(sys.MODEL),
+          VENDOR: safeText(sys.VENDOR),
+          SW_REV: safeText(sys.SW_REV),
+          HW_REV: safeText(sys.HW_REV),
+          BOOTR: safeText(sys.BOOTR)
+        },
+        channelData: channelData
+      });
+    })();
+  language: text/javascript
+order: 8000
diff --git a/postman/globals/workspace.globals.yaml b/postman/globals/workspace.globals.yaml
@@ -105,6 +105,11 @@ values:
     enabled: true
     type: default
     description: ''
+  - key: rxmer_analysis_echo_detection_1
+    value: ''
+    enabled: true
+    type: default
+    description: ''
   - key: chan_est_group_delay
     value: ''
     enabled: true
