Compare commits

...

22 Commits

Author SHA1 Message Date
rUv
5124a07965 refactor(rust-port): remove unused once-cell crate (#58)
refactor(rust-port): remove unused `once-cell` crate
2026-03-01 02:36:51 -05:00
Tuan Tran
0723af8f8a update cargo.lock 2026-03-01 14:30:12 +07:00
Tuan Tran
504875e608 remove unused once-cell package 2026-03-01 14:26:29 +07:00
ruv
ab76925864 docs: Comprehensive CHANGELOG update covering v1.0.0 through v3.0.0
Rewrites CHANGELOG.md with detailed entries for every significant
feature, fix, and security patch across all three major versions:

- v3.0.0: AETHER contrastive embedding model (ADR-024), Docker Hub
  images, UI port auto-detection fix, Mermaid architecture diagrams,
  33 use cases across 4 verticals
- v2.0.0: Rust sensing server, DensePose training pipeline (ADR-023),
  RuVector v2.0.4 integration (ADR-016/017), ESP32-S3 firmware
  (ADR-018), SOTA signal processing (ADR-014), vital sign detection
  (ADR-021), WiFi-Mat disaster module, 7 security patches, Python
  sensing pipeline, Three.js visualization
- v1.1.0: Python CSI system, API services, UI dark mode
- v1.0.0: Initial release with core pose estimation

All entries reference specific commit hashes for traceability.

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 02:20:52 -05:00
ruv
a6382fb026 feat: Add macOS CoreWLAN WiFi sensing adapter and user guide
- Introduced ADR-025 documenting the implementation of a macOS CoreWLAN sensing adapter using a Swift helper binary and Rust integration.
- Added a new user guide detailing installation, usage, and hardware setup for WiFi DensePose, including Docker and source build instructions.
- Included sections on data sources, REST API reference, WebSocket streaming, and vital sign detection.
- Documented hardware requirements and troubleshooting steps for various setups.
2026-03-01 02:15:44 -05:00
ruv
3b72f35306 fix: UI auto-detects server port from page origin (#55)
The UI had hardcoded localhost:8080 for HTTP and localhost:8765 for
WebSocket, causing "Backend unavailable" when served from Docker
(port 3000) or any non-default port.

Changes:
- api.config.js: BASE_URL now uses window.location.origin instead
  of hardcoded localhost:8080
- api.config.js: buildWsUrl() uses window.location.host instead of
  hardcoded localhost:8080
- sensing.service.js: WebSocket URL derived from page origin instead
  of hardcoded localhost:8765
- main.rs: Added /ws/sensing route to the HTTP server so WebSocket
  and REST are reachable on a single port

Fixes #55

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 02:09:23 -05:00
ruv
a0b5506b8c docs: rename embedding section to Self-Learning WiFi AI
Reframe the ADR-024 section header to emphasize AI self-learning and
adaptive optimization rather than technical CSI embedding terminology.

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 01:47:21 -05:00
rUv
9bbe95648c feat: ADR-024 Contrastive CSI Embedding Model — all 7 phases (#52)
Full implementation of Project AETHER — Contrastive CSI Embedding Model.

## Phases Delivered
1. ProjectionHead (64→128→128) + L2 normalization
2. CsiAugmenter (5 physically-motivated augmentations)
3. InfoNCE contrastive loss + SimCLR pretraining
4. FingerprintIndex (4 index types: env, activity, temporal, person)
5. RVF SEG_EMBED (0x0C) + CLI integration
6. Cross-modal alignment (PoseEncoder + InfoNCE)
7. Deep RuVector: MicroLoRA, EWC++, drift detection, hard-negative mining, SEG_LORA

## Stats
- 276 tests passing (191 lib + 51 bin + 16 rvf + 18 vitals)
- 3,342 additions across 8 files
- Zero unsafe/unwrap/panic/todo stubs
- ~55KB INT8 model for ESP32 edge deployment

Also fixes deprecated GitHub Actions (v3→v4) and adds feat/* branch CI triggers.

Closes #50
2026-03-01 01:44:38 -05:00
ruv
44b9c30dbc fix: Docker port mismatch — server now binds 3000/3001 as documented
The sensing server defaults to HTTP :8080 and WS :8765, but Docker
exposes :3000/:3001. Added --http-port 3000 --ws-port 3001 to CMD
in both Dockerfile.rust and docker-compose.yml.

Verified both images build and run:
- Rust: 133 MB, all endpoints responding (health, sensing/latest,
  vital-signs, pose/current, info, model/info, UI)
- Python: 569 MB, all packages importable (websockets, fastapi)
- RVF file: 13 KB, valid RVFS magic bytes

Also fixed README Quick Start endpoints to match actual routes:
- /api/v1/health → /health
- /api/v1/sensing → /api/v1/sensing/latest
- Added /api/v1/pose/current and /api/v1/info examples
- Added port mapping note for Docker vs local dev

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:56:41 -05:00
ruv
50f0fc955b docs: Replace ASCII architecture with Mermaid diagrams
Replace the single ASCII box diagram with 3 styled Mermaid diagrams:

1. End-to-End Pipeline — full data flow from WiFi routers through
   signal processing (6 stages with ruvector crate labels), neural
   pipeline (graph transformer + SONA), vital signs, to output layer
   (REST, WebSocket, Analytics, UI). Dark theme with color-coded
   subsystem groups.

2. Signal Processing Detail — zoomed-in CSI cleanup pipeline showing
   conjugate multiply, phase unwrap, Hampel filter, min-cut partition,
   attention gate, STFT, Fresnel, and BVP stages.

3. Deployment Topology — ESP32 mesh (edge) → Rust sensing server
   (3 ports) → clients (browser, mobile, dashboard, IoT).

Component table expanded from 7 to 11 entries with crate/module
column linking each component to its source.

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:48:57 -05:00
ruv
0afd9c5434 docs: Expand Use Cases into visible intro + 4 collapsed verticals
Restructure Use Cases & Applications as a visible section with:
- Intro paragraph + scaling note (always visible)
- "Why WiFi wins" comparison table vs cameras/PIR (always visible)
- 4 collapsed tiers: Everyday (8 use cases), Specialized (9),
  Robotics & Industrial (8, new), Extreme (8)
- Each row now includes a Key Metric column
- New robotics section: cobots, AMR navigation, android spatial
  awareness, manufacturing, construction, agricultural, drones,
  clean rooms

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:45:21 -05:00
ruv
965a1ccef2 docs: Enrich Models & Training section with RuVector repo links
- ToC: Add ruvector GitHub link and integration point count
- RVF Container: Add deployment targets table (ESP32 0.7MB to server
  50MB), link to rvf crate family on GitHub
- Training: Add RuVector column to pipeline table showing which crate
  powers each phase, add SONA component breakdown table, link arXiv
- RuVector Crates: Split into 5 directly-used (with integration
  points mapped to exact .rs files) and 6 additional vendored, add
  crates.io and GitHub source links for all 11

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:41:05 -05:00
ruv
b5ca361f0e docs: Add use cases section and fix multi-person limit accuracy
Add collapsible Use Cases & Applications section organized from
practical (elderly care, hospitals, retail) to specialized (events,
warehouses) to extreme (search & rescue, through-wall). Includes
hardware requirements and scaling notes per category.

Fix multi-person description to reflect reality: no hard software
limit, practical ceiling is signal physics (~3-5 per AP at 56
subcarriers, linear scaling with multi-AP).

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:36:53 -05:00
ruv
e2ce250dba docs: Fix multi-person limit — configurable default, not hard cap
The 10-person limit is just the default setting (pose_max_persons=10).
The API accepts 1-50, docs show configs up to 50, and Rust uses Option<u8>.

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:34:02 -05:00
ruv
50acbf7f0a docs: Move Installation and Quick Start above Table of Contents
Promotes Installation and Quick Start to top-level sections placed
between Key Features and Table of Contents for faster onboarding.

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:31:59 -05:00
ruv
0ebd6be43f docs: Collapse Rust Implementation and Performance Metrics sections
Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:27:50 -05:00
ruv
528b3948ab docs: Add CSI hardware requirement notice to README
Consumer WiFi does not expose Channel State Information — clarify that
pose estimation, vital signs, and through-wall sensing require ESP32-S3
or a research NIC. Added Full CSI column to hardware options table.

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:27:20 -05:00
ruv
99ec9803ae docs: Collapse System Architecture into details element
Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:25:46 -05:00
ruv
478d9647ac docs: Improve README sections with rich detail, emoji features, and collapsed groups
- Add emoji key features table above ToC in plain language
- Expand WiFi-Mat section: START triage table, deployment modes, safety guarantees, performance targets
- Expand SOTA Signal Processing: math formulas, why-it-matters explanations, processing pipeline order
- Expand RVF Container: ASCII structure diagram, 20+ segment types, size examples
- Expand Training: 8-phase pipeline table with line counts, best-epoch snapshotting, three-tier strategy table
- Collapse Architecture, Testing, Changelog, and Release History sections
- Fix date in Meta section (March 2025)
- All 22 anchor links and 27 file links verified

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:24:57 -05:00
ruv
e8e4bf6da9 fix: Update project development start date in README 2026-03-01 00:19:46 -05:00
ruv
3621baf290 docs: Reorganize README with collapsible ToC, ADR doc links, and verified anchors
- Improve introduction: bold tagline, capability summary table, updated badges
- Restructure ToC into 6 collapsible groups with introductions and ADR doc links
- Add explicit HTML anchors for <details> subsections (22 internal links verified)
- Remove dead doc links (api_reference.md, deployment.md, user_guide.md)
- Fix ADR-018 filename (esp32-csi-streaming → esp32-dev-implementation)
- Organize sections: Signal Processing, Models, Architecture, Install, Quick Start, CLI, Testing, Deployment, Performance, Contributing, Changelog
- Expand changelog entries with release context and feature details
- Net reduction of 109 lines (264 insertions, 373 deletions)

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-03-01 00:19:26 -05:00
rUv
3b90ff2a38 feat: End-to-end training pipeline with RuVector signal intelligence (#49)
feat: End-to-end training pipeline with RuVector signal intelligence
2026-03-01 00:10:26 -05:00
47 changed files with 7515 additions and 895 deletions

View File

@@ -2,7 +2,7 @@ name: Continuous Integration
on:
push:
branches: [ main, develop, 'feature/*', 'hotfix/*' ]
branches: [ main, develop, 'feature/*', 'feat/*', 'hotfix/*' ]
pull_request:
branches: [ main, develop ]
workflow_dispatch:
@@ -25,7 +25,7 @@ jobs:
fetch-depth: 0
- name: Set up Python
uses: actions/setup-python@v4
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_VERSION }}
cache: 'pip'
@@ -54,7 +54,7 @@ jobs:
continue-on-error: true
- name: Upload security reports
uses: actions/upload-artifact@v3
uses: actions/upload-artifact@v4
if: always()
with:
name: security-reports
@@ -98,7 +98,7 @@ jobs:
uses: actions/checkout@v4
- name: Set up Python ${{ matrix.python-version }}
uses: actions/setup-python@v4
uses: actions/setup-python@v5
with:
python-version: ${{ matrix.python-version }}
cache: 'pip'
@@ -126,14 +126,14 @@ jobs:
pytest tests/integration/ -v --junitxml=integration-junit.xml
- name: Upload coverage reports
uses: codecov/codecov-action@v3
uses: codecov/codecov-action@v4
with:
file: ./coverage.xml
flags: unittests
name: codecov-umbrella
- name: Upload test results
uses: actions/upload-artifact@v3
uses: actions/upload-artifact@v4
if: always()
with:
name: test-results-${{ matrix.python-version }}
@@ -153,7 +153,7 @@ jobs:
uses: actions/checkout@v4
- name: Set up Python
uses: actions/setup-python@v4
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_VERSION }}
cache: 'pip'
@@ -174,7 +174,7 @@ jobs:
locust -f tests/performance/locustfile.py --headless --users 50 --spawn-rate 5 --run-time 60s --host http://localhost:8000
- name: Upload performance results
uses: actions/upload-artifact@v3
uses: actions/upload-artifact@v4
with:
name: performance-results
path: locust_report.html
@@ -236,7 +236,7 @@ jobs:
output: 'trivy-results.sarif'
- name: Upload Trivy scan results
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: 'trivy-results.sarif'
@@ -252,7 +252,7 @@ jobs:
uses: actions/checkout@v4
- name: Set up Python
uses: actions/setup-python@v4
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_VERSION }}
cache: 'pip'
@@ -272,7 +272,7 @@ jobs:
"
- name: Deploy to GitHub Pages
uses: peaceiris/actions-gh-pages@v3
uses: peaceiris/actions-gh-pages@v4
with:
github_token: ${{ secrets.GITHUB_TOKEN }}
publish_dir: ./docs
@@ -286,7 +286,7 @@ jobs:
if: always()
steps:
- name: Notify Slack on success
if: ${{ needs.code-quality.result == 'success' && needs.test.result == 'success' && needs.docker-build.result == 'success' }}
if: ${{ secrets.SLACK_WEBHOOK_URL != '' && needs.code-quality.result == 'success' && needs.test.result == 'success' && needs.docker-build.result == 'success' }}
uses: 8398a7/action-slack@v3
with:
status: success
@@ -296,7 +296,7 @@ jobs:
SLACK_WEBHOOK_URL: ${{ secrets.SLACK_WEBHOOK_URL }}
- name: Notify Slack on failure
if: ${{ needs.code-quality.result == 'failure' || needs.test.result == 'failure' || needs.docker-build.result == 'failure' }}
if: ${{ secrets.SLACK_WEBHOOK_URL != '' && (needs.code-quality.result == 'failure' || needs.test.result == 'failure' || needs.docker-build.result == 'failure') }}
uses: 8398a7/action-slack@v3
with:
status: failure
@@ -307,18 +307,16 @@ jobs:
- name: Create GitHub Release
if: github.ref == 'refs/heads/main' && needs.docker-build.result == 'success'
uses: actions/create-release@v1
env:
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
uses: softprops/action-gh-release@v2
with:
tag_name: v${{ github.run_number }}
release_name: Release v${{ github.run_number }}
name: Release v${{ github.run_number }}
body: |
Automated release from CI pipeline
**Changes:**
${{ github.event.head_commit.message }}
**Docker Image:**
`${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:${{ github.sha }}`
draft: false

View File

@@ -2,7 +2,7 @@ name: Security Scanning
on:
push:
branches: [ main, develop ]
branches: [ main, develop, 'feat/*' ]
pull_request:
branches: [ main, develop ]
schedule:
@@ -29,7 +29,7 @@ jobs:
fetch-depth: 0
- name: Set up Python
uses: actions/setup-python@v4
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_VERSION }}
cache: 'pip'
@@ -46,7 +46,7 @@ jobs:
continue-on-error: true
- name: Upload Bandit results to GitHub Security
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: bandit-results.sarif
@@ -70,7 +70,7 @@ jobs:
continue-on-error: true
- name: Upload Semgrep results to GitHub Security
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: semgrep.sarif
@@ -89,7 +89,7 @@ jobs:
uses: actions/checkout@v4
- name: Set up Python
uses: actions/setup-python@v4
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_VERSION }}
cache: 'pip'
@@ -119,14 +119,14 @@ jobs:
continue-on-error: true
- name: Upload Snyk results to GitHub Security
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: snyk-results.sarif
category: snyk
- name: Upload vulnerability reports
uses: actions/upload-artifact@v3
uses: actions/upload-artifact@v4
if: always()
with:
name: vulnerability-reports
@@ -170,7 +170,7 @@ jobs:
output: 'trivy-results.sarif'
- name: Upload Trivy results to GitHub Security
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: 'trivy-results.sarif'
@@ -186,7 +186,7 @@ jobs:
output-format: sarif
- name: Upload Grype results to GitHub Security
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: ${{ steps.grype-scan.outputs.sarif }}
@@ -202,7 +202,7 @@ jobs:
summary: true
- name: Upload Docker Scout results
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: scout-results.sarif
@@ -231,7 +231,7 @@ jobs:
soft_fail: true
- name: Upload Checkov results to GitHub Security
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: checkov-results.sarif
@@ -256,7 +256,7 @@ jobs:
exclude_queries: 'a7ef1e8c-fbf8-4ac1-b8c7-2c3b0e6c6c6c'
- name: Upload KICS results to GitHub Security
uses: github/codeql-action/upload-sarif@v2
uses: github/codeql-action/upload-sarif@v3
if: always()
with:
sarif_file: kics-results/results.sarif
@@ -306,7 +306,7 @@ jobs:
uses: actions/checkout@v4
- name: Set up Python
uses: actions/setup-python@v4
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_VERSION }}
cache: 'pip'
@@ -323,7 +323,7 @@ jobs:
licensecheck --zero
- name: Upload license report
uses: actions/upload-artifact@v3
uses: actions/upload-artifact@v4
with:
name: license-report
path: licenses.json
@@ -361,11 +361,14 @@ jobs:
- name: Validate Kubernetes security contexts
run: |
# Check for security contexts in Kubernetes manifests
if find k8s/ -name "*.yaml" -exec grep -l "securityContext" {} \; | wc -l | grep -q "^0$"; then
echo "❌ No security contexts found in Kubernetes manifests"
exit 1
if [[ -d "k8s" ]]; then
if find k8s/ -name "*.yaml" -exec grep -l "securityContext" {} \; | wc -l | grep -q "^0$"; then
echo "⚠️ No security contexts found in Kubernetes manifests"
else
echo "✅ Security contexts found in Kubernetes manifests"
fi
else
echo "✅ Security contexts found in Kubernetes manifests"
echo " No k8s/ directory found — skipping Kubernetes security context check"
fi
# Notification and reporting
@@ -376,7 +379,7 @@ jobs:
if: always()
steps:
- name: Download all artifacts
uses: actions/download-artifact@v3
uses: actions/download-artifact@v4
- name: Generate security summary
run: |
@@ -394,13 +397,13 @@ jobs:
echo "Generated on: $(date)" >> security-summary.md
- name: Upload security summary
uses: actions/upload-artifact@v3
uses: actions/upload-artifact@v4
with:
name: security-summary
path: security-summary.md
- name: Notify security team on critical findings
if: needs.sast.result == 'failure' || needs.dependency-scan.result == 'failure' || needs.container-scan.result == 'failure'
if: ${{ secrets.SECURITY_SLACK_WEBHOOK_URL != '' && (needs.sast.result == 'failure' || needs.dependency-scan.result == 'failure' || needs.container-scan.result == 'failure') }}
uses: 8398a7/action-slack@v3
with:
status: failure

View File

@@ -5,68 +5,231 @@ All notable changes to this project will be documented in this file.
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
## [Unreleased]
### Added
- macOS CoreWLAN WiFi sensing adapter with user guide (`a6382fb`)
---
## [3.0.0] - 2026-03-01
Major release: AETHER contrastive embedding model, Docker Hub images, and comprehensive UI overhaul.
### Added — AETHER Contrastive Embedding Model (ADR-024)
- **Project AETHER** — self-supervised contrastive learning for WiFi CSI fingerprinting, similarity search, and anomaly detection (`9bbe956`)
- `embedding.rs` module: `ProjectionHead`, `InfoNceLoss`, `CsiAugmenter`, `FingerprintIndex`, `PoseEncoder`, `EmbeddingExtractor` (909 lines, zero external ML dependencies)
- SimCLR-style pretraining with 5 physically-motivated augmentations (temporal jitter, subcarrier masking, Gaussian noise, phase rotation, amplitude scaling)
- CLI flags: `--pretrain`, `--pretrain-epochs`, `--embed`, `--build-index <type>`
- Four HNSW-compatible fingerprint index types: `env_fingerprint`, `activity_pattern`, `temporal_baseline`, `person_track`
- Cross-modal `PoseEncoder` for WiFi-to-camera embedding alignment
- VICReg regularization for embedding collapse prevention
- 53K total parameters (55 KB at INT8) — fits on ESP32
### Added — Docker & Deployment
- Published Docker Hub images: `ruvnet/wifi-densepose:latest` (132 MB Rust) and `ruvnet/wifi-densepose:python` (569 MB) (`add9f19`)
- Multi-stage Dockerfile for Rust sensing server with RuVector crates
- `docker-compose.yml` orchestrating both Rust and Python services
- RVF model export via `--export-rvf` and load via `--load-rvf` CLI flags
### Added — Documentation
- 33 use cases across 4 vertical tiers: Everyday, Specialized, Robotics & Industrial, Extreme (`0afd9c5`)
- "Why WiFi Wins" comparison table (WiFi vs camera vs LIDAR vs wearable vs PIR)
- Mermaid architecture diagrams: end-to-end pipeline, signal processing detail, deployment topology (`50f0fc9`)
- Models & Training section with RuVector crate links (GitHub + crates.io), SONA component table (`965a1cc`)
- RVF container section with deployment targets table (ESP32 0.7 MB to server 50+ MB)
- Collapsible README sections for improved navigation (`478d964`, `99ec980`, `0ebd6be`)
- Installation and Quick Start moved above Table of Contents (`50acbf7`)
- CSI hardware requirement notice (`528b394`)
### Fixed
- **UI auto-detects server port from page origin** — no more hardcoded `localhost:8080`; works on any port (Docker :3000, native :8080, custom) (`3b72f35`, closes #55)
- **Docker port mismatch** — server now binds 3000/3001 inside container as documented (`44b9c30`)
- Added `/ws/sensing` WebSocket route to the HTTP server so UI only needs one port
- Fixed README API endpoint references: `/api/v1/health``/health`, `/api/v1/sensing``/api/v1/sensing/latest`
- Multi-person tracking limit corrected: configurable default 10, no hard software cap (`e2ce250`)
---
## [2.0.0] - 2026-02-28
Major release: complete Rust sensing server, full DensePose training pipeline, RuVector v2.0.4 integration, ESP32-S3 firmware, and 6 security hardening patches.
### Added — Rust Sensing Server
- **Full DensePose-compatible REST API** served by Axum (`d956c30`)
- `GET /health` — server health
- `GET /api/v1/sensing/latest` — live CSI sensing data
- `GET /api/v1/vital-signs` — breathing rate (6-30 BPM) and heartbeat (40-120 BPM)
- `GET /api/v1/pose/current` — 17 COCO keypoints derived from WiFi signal field
- `GET /api/v1/info` — server build and feature info
- `GET /api/v1/model/info` — RVF model container metadata
- `ws://host/ws/sensing` — real-time WebSocket stream
- Three data sources: `--source esp32` (UDP CSI), `--source windows` (netsh RSSI), `--source simulated` (deterministic reference)
- Auto-detection: server probes ESP32 UDP and Windows WiFi, falls back to simulated
- Three.js visualization UI with 3D body skeleton, signal heatmap, phase plot, Doppler bars, vital signs panel
- Static UI serving via `--ui-path` flag
- Throughput: 9,52011,665 frames/sec (release build)
### Added — ADR-021: Vital Sign Detection
- `VitalSignDetector` with breathing (6-30 BPM) and heartbeat (40-120 BPM) extraction from CSI fluctuations (`1192de9`)
- FFT-based spectral analysis with configurable band-pass filters
- Confidence scoring based on spectral peak prominence
- REST endpoint `/api/v1/vital-signs` with real-time JSON output
### Added — ADR-023: DensePose Training Pipeline (Phases 1-8)
- `wifi-densepose-train` crate with complete 8-phase pipeline (`fc409df`, `ec98e40`, `fce1271`)
- Phase 1: `DataPipeline` with MM-Fi and Wi-Pose dataset loaders
- Phase 2: `CsiToPoseTransformer` — 4-head cross-attention + 2-layer GCN on COCO skeleton
- Phase 3: 6-term composite loss (MSE, bone length, symmetry, joint angle, temporal, confidence)
- Phase 4: `DynamicPersonMatcher` via ruvector-mincut (O(n^1.5 log n) Hungarian assignment)
- Phase 5: `SonaAdapter` — MicroLoRA rank-4 with EWC++ memory preservation
- Phase 6: `SparseInference` — progressive 3-layer model loading (A: essential, B: refinement, C: full)
- Phase 7: `RvfContainer` — single-file model packaging with segment-based binary format
- Phase 8: End-to-end training with cosine-annealing LR, early stopping, checkpoint saving
- CLI: `--train`, `--dataset`, `--epochs`, `--save-rvf`, `--load-rvf`, `--export-rvf`
- Benchmark: ~11,665 fps inference, 229 tests passing
### Added — ADR-016: RuVector Training Integration (all 5 crates)
- `ruvector-mincut``DynamicPersonMatcher` in `metrics.rs` + subcarrier selection (`81ad09d`, `a7dd31c`)
- `ruvector-attn-mincut` → antenna attention in `model.rs` + noise-gated spectrogram
- `ruvector-temporal-tensor``CompressedCsiBuffer` in `dataset.rs` + compressed breathing/heartbeat
- `ruvector-solver` → sparse subcarrier interpolation (114→56) + Fresnel triangulation
- `ruvector-attention` → spatial attention in `model.rs` + attention-weighted BVP
- Vendored all 11 RuVector crates under `vendor/ruvector/` (`d803bfe`)
### Added — ADR-017: RuVector Signal & MAT Integration (7 integration points)
- `gate_spectrogram()` — attention-gated noise suppression (`18170d7`)
- `attention_weighted_bvp()` — sensitivity-weighted velocity profiles
- `mincut_subcarrier_partition()` — dynamic sensitive/insensitive subcarrier split
- `solve_fresnel_geometry()` — TX-body-RX distance estimation
- `CompressedBreathingBuffer` + `CompressedHeartbeatSpectrogram`
- `BreathingDetector` + `HeartbeatDetector` (MAT crate, real FFT + micro-Doppler)
- Feature-gated behind `cfg(feature = "ruvector")` (`ab2453e`)
### Added — ADR-018: ESP32-S3 Firmware & Live CSI Pipeline
- ESP32-S3 firmware with FreeRTOS CSI extraction (`92a5182`)
- ADR-018 binary frame format: `[0xAD, 0x18, len_hi, len_lo, payload]`
- Rust `Esp32Aggregator` receiving UDP frames on port 5005
- `bridge.rs` converting I/Q pairs to amplitude/phase vectors
- NVS provisioning for WiFi credentials
- Pre-built binary quick start documentation (`696a726`)
### Added — ADR-014: SOTA Signal Processing
- 6 algorithms, 83 tests (`fcb93cc`)
- Hampel filter (median + MAD, resistant to 50% contamination)
- Conjugate multiplication (reference-antenna ratio, cancels common-mode noise)
- Phase sanitization (unwrap + linear detrend, removes CFO/SFO)
- Fresnel zone geometry (TX-body-RX distance from first-principles physics)
- Body Velocity Profile (micro-Doppler extraction, 5.7x speedup)
- Attention-gated spectrogram (learned noise suppression)
### Added — ADR-015: Public Dataset Training Strategy
- MM-Fi and Wi-Pose dataset specifications with download links (`4babb32`, `5dc2f66`)
- Verified dataset dimensions, sampling rates, and annotation formats
- Cross-dataset evaluation protocol
### Added — WiFi-Mat Disaster Detection Module
- Multi-AP triangulation for through-wall survivor detection (`a17b630`, `6b20ff0`)
- Triage classification (breathing, heartbeat, motion)
- Domain events: `survivor_detected`, `survivor_updated`, `alert_created`
- WebSocket broadcast at `/ws/mat/stream`
### Added — Infrastructure
- Guided 7-step interactive installer with 8 hardware profiles (`8583f3e`)
- Comprehensive build guide for Linux, macOS, Windows, Docker, ESP32 (`45f8a0d`)
- 12 Architecture Decision Records (ADR-001 through ADR-012) (`337dd96`)
### Added — UI & Visualization
- Sensing-only UI mode with Gaussian splat visualization (`b7e0f07`)
- Three.js 3D body model (17 joints, 16 limbs) with signal-viz components
- Tabs: Dashboard, Hardware, Live Demo, Sensing, Architecture, Performance, Applications
- WebSocket client with automatic reconnection and exponential backoff
### Added — Rust Signal Processing Crate
- Complete Rust port of WiFi-DensePose with modular workspace (`6ed69a3`)
- `wifi-densepose-signal` — CSI processing, phase sanitization, feature extraction
- `wifi-densepose-core` — shared types and configuration
- `wifi-densepose-nn` — neural network inference (DensePose head, RCNN)
- `wifi-densepose-hardware` — ESP32 aggregator, hardware interfaces
- `wifi-densepose-config` — configuration management
- Comprehensive benchmarks and validation tests (`3ccb301`)
### Added — Python Sensing Pipeline
- `WindowsWifiCollector` — RSSI collection via `netsh wlan show networks`
- `RssiFeatureExtractor` — variance, spectral bands (motion 0.5-4 Hz, breathing 0.1-0.5 Hz), change points
- `PresenceClassifier` — rule-based 3-state classification (ABSENT / PRESENT_STILL / ACTIVE)
- Cross-receiver agreement scoring for multi-AP confidence boosting
- WebSocket sensing server (`ws_server.py`) broadcasting JSON at 2 Hz
- Deterministic CSI proof bundles for reproducible verification (`v1/data/proof/`)
- Commodity sensing unit tests (`b391638`)
### Changed
- Rust hardware adapters now return explicit errors instead of silent empty data (`6e0e539`)
### Fixed
- Review fixes for end-to-end training pipeline (`45f0304`)
- Dockerfile paths updated from `src/` to `v1/src/` (`7872987`)
- IoT profile installer instructions updated for aggregator CLI (`f460097`)
- `process.env` reference removed from browser ES module (`e320bc9`)
### Performance
- 5.7x Doppler extraction speedup via optimized FFT windowing (`32c75c8`)
- Single 2.1 MB static binary, zero Python dependencies for Rust server
### Security
- Fix SQL injection in status command and migrations (`f9d125d`)
- Fix XSS vulnerabilities in UI components (`5db55fd`)
- Fix command injection in statusline.cjs (`4cb01fd`)
- Fix path traversal vulnerabilities (`896c4fc`)
- Fix insecure WebSocket connections — enforce wss:// on non-localhost (`ac094d4`)
- Fix GitHub Actions shell injection (`ab2e7b4`)
- Fix 10 additional vulnerabilities, remove 12 dead code instances (`7afdad0`)
---
## [1.1.0] - 2025-06-07
### Added
- Multi-column table of contents in README.md for improved navigation
- Enhanced documentation structure with better organization
- Improved visual layout for better user experience
- Complete Python WiFi-DensePose system with CSI data extraction and router interface
- CSI processing and phase sanitization modules
- Batch processing for CSI data in `CSIProcessor` and `PhaseSanitizer`
- Hardware, pose, and stream services for WiFi-DensePose API
- Comprehensive CSS styles for UI components and dark mode support
- API and Deployment documentation
### Changed
- Updated README.md table of contents to use a two-column layout
- Reorganized documentation sections for better logical flow
- Enhanced readability of navigation structure
### Fixed
- Badge links for PyPI and Docker in README
- Async engine creation poolclass specification
### Documentation
- Restructured table of contents for better accessibility
- Improved visual hierarchy in documentation
- Enhanced user experience for documentation navigation
---
## [1.0.0] - 2024-12-01
### Added
- Initial release of WiFi DensePose
- Real-time WiFi-based human pose estimation using CSI data
- DensePose neural network integration
- RESTful API with comprehensive endpoints
- WebSocket streaming for real-time data
- Multi-person tracking capabilities
- Initial release of WiFi-DensePose
- Real-time WiFi-based human pose estimation using Channel State Information (CSI)
- DensePose neural network integration for body surface mapping
- RESTful API with comprehensive endpoint coverage
- WebSocket streaming for real-time pose data
- Multi-person tracking with configurable capacity (default 10, up to 50+)
- Fall detection and activity recognition
- Healthcare, fitness, smart home, and security domain configurations
- Comprehensive CLI interface
- Docker and Kubernetes deployment support
- 100% test coverage
- Production-ready monitoring and logging
- Hardware abstraction layer for multiple WiFi devices
- Phase sanitization and signal processing
- Domain configurations: healthcare, fitness, smart home, security
- CLI interface for server management and configuration
- Hardware abstraction layer for multiple WiFi chipsets
- Phase sanitization and signal processing pipeline
- Authentication and rate limiting
- Background task management
- Database integration with PostgreSQL and Redis
- Prometheus metrics and Grafana dashboards
- Comprehensive documentation and examples
### Features
- Privacy-preserving pose detection without cameras
- Sub-50ms latency with 30 FPS processing
- Support for up to 10 simultaneous person tracking
- Enterprise-grade security and scalability
- Cross-platform compatibility (Linux, macOS, Windows)
- GPU acceleration support
- Real-time analytics and alerting
- Configurable confidence thresholds
- Zone-based occupancy monitoring
- Historical data analysis
- Performance optimization tools
- Load testing capabilities
- Infrastructure as Code (Terraform, Ansible)
- CI/CD pipeline integration
- Comprehensive error handling and logging
- Cross-platform support (Linux, macOS, Windows)
### Documentation
- Complete user guide and API reference
- User guide and API reference
- Deployment and troubleshooting guides
- Hardware setup and calibration instructions
- Performance benchmarks and optimization tips
- Contributing guidelines and code standards
- Security best practices
- Example configurations and use cases
- Performance benchmarks
- Contributing guidelines
[Unreleased]: https://github.com/ruvnet/wifi-densepose/compare/v3.0.0...HEAD
[3.0.0]: https://github.com/ruvnet/wifi-densepose/compare/v2.0.0...v3.0.0
[2.0.0]: https://github.com/ruvnet/wifi-densepose/compare/v1.1.0...v2.0.0
[1.1.0]: https://github.com/ruvnet/wifi-densepose/compare/v1.0.0...v1.1.0
[1.0.0]: https://github.com/ruvnet/wifi-densepose/releases/tag/v1.0.0

1474
README.md

File diff suppressed because it is too large Load Diff

View File

@@ -43,4 +43,4 @@ EXPOSE 5005/udp
ENV RUST_LOG=info
ENTRYPOINT ["/app/sensing-server"]
CMD ["--source", "simulated", "--tick-ms", "100", "--ui-path", "/app/ui"]
CMD ["--source", "simulated", "--tick-ms", "100", "--ui-path", "/app/ui", "--http-port", "3000", "--ws-port", "3001"]

View File

@@ -12,7 +12,7 @@ services:
- "5005:5005/udp" # ESP32 UDP
environment:
- RUST_LOG=info
command: ["--source", "simulated", "--tick-ms", "100", "--ui-path", "/app/ui"]
command: ["--source", "simulated", "--tick-ms", "100", "--ui-path", "/app/ui", "--http-port", "3000", "--ws-port", "3001"]
python-sensing:
build:

File diff suppressed because it is too large Load Diff

View File

@@ -0,0 +1,315 @@
# ADR-025: macOS CoreWLAN WiFi Sensing via Swift Helper Bridge
| Field | Value |
|-------|-------|
| **Status** | Proposed |
| **Date** | 2026-03-01 |
| **Deciders** | ruv |
| **Codename** | **ORCA** — OS-native Radio Channel Acquisition |
| **Relates to** | ADR-013 (Feature-Level Sensing Commodity Gear), ADR-022 (Windows WiFi Enhanced Fidelity), ADR-014 (SOTA Signal Processing), ADR-018 (ESP32 Dev Implementation) |
| **Issue** | [#56](https://github.com/ruvnet/wifi-densepose/issues/56) |
| **Build/Test Target** | Mac Mini (M2 Pro, macOS 26.3) |
---
## 1. Context
### 1.1 The Gap: macOS Is a Silent Fallback
The `--source auto` path in `sensing-server` probes for ESP32 UDP, then Windows `netsh`, then falls back to simulated mode. macOS users hit the simulation path silently — there is no macOS WiFi adapter. This is the only major desktop platform without real WiFi sensing support.
### 1.2 Platform Constraints (macOS 26.3+)
| Constraint | Detail |
|------------|--------|
| **`airport` CLI removed** | Apple removed `/System/Library/PrivateFrameworks/.../airport` in macOS 15. No CLI fallback exists. |
| **CoreWLAN is the only path** | `CWWiFiClient` (Swift/ObjC) is the supported API for WiFi scanning. Returns RSSI, channel, SSID, noise, PHY mode, security. |
| **BSSIDs redacted** | macOS privacy policy redacts MAC addresses from `CWNetwork.bssid` unless the app has Location Services + WiFi entitlement. Apps without entitlement see `nil` for BSSID. |
| **No raw CSI** | Apple does not expose CSI or per-subcarrier data. macOS WiFi sensing is RSSI-only, same tier as Windows `netsh`. |
| **Scan rate** | `CWInterface.scanForNetworks()` takes ~2-4 seconds. Effective rate: ~0.3-0.5 Hz without caching. |
| **Permissions** | Location Services prompt required for BSSID access. Without it, SSID + RSSI + channel still available. |
### 1.3 The Opportunity: Multi-AP RSSI Diversity
Same principle as ADR-022 (Windows): visible APs serve as pseudo-subcarriers. A typical indoor environment exposes 10-30+ SSIDs across 2.4 GHz and 5 GHz bands. Each AP's RSSI responds differently to human movement based on geometry, creating spatial diversity.
| Source | Effective Subcarriers | Sample Rate | Capabilities |
|--------|----------------------|-------------|-------------|
| ESP32-S3 (CSI) | 56-192 | 20 Hz | Full: pose, vitals, through-wall |
| Windows `netsh` (ADR-022) | 10-30 BSSIDs | ~2 Hz | Presence, motion, coarse breathing |
| **macOS CoreWLAN (this ADR)** | **10-30 SSIDs** | **~0.3-0.5 Hz** | **Presence, motion** |
The lower scan rate vs Windows is offset by higher signal quality — CoreWLAN returns calibrated dBm (not percentage) plus noise floor, enabling proper SNR computation.
### 1.4 Why Swift Subprocess (Not FFI)
| Approach | Complexity | Maintenance | Build | Verdict |
|----------|-----------|-------------|-------|---------|
| **Swift CLI → JSON → stdout** | Low | Independent binary, versionable | `swiftc` (ships with Xcode CLT) | **Chosen** |
| ObjC FFI via `cc` crate | Medium | Fragile header bindings, ABI churn | Requires Xcode headers | Rejected |
| `objc2` crate (Rust ObjC bridge) | High | CoreWLAN not in upstream `objc2-frameworks` | Requires manual class definitions | Rejected |
| `swift-bridge` crate | High | Young ecosystem, async bridging unsupported | Requires Swift build integration in Cargo | Rejected |
The `Command::new()` + parse JSON pattern is proven — it's exactly what `NetshBssidScanner` does for Windows. The subprocess boundary also isolates Apple framework dependencies from the Rust build graph.
### 1.5 SOTA: Platform-Adaptive WiFi Sensing
Recent work validates multi-platform RSSI-based sensing:
- **WiFind** (2024): Cross-platform WiFi fingerprinting using RSSI vectors from heterogeneous hardware. Demonstrates that normalization across scan APIs (dBm, percentage, raw) is critical for model portability.
- **WiGesture** (2025): RSSI variance-based gesture recognition achieving 89% accuracy on commodity hardware with 15+ APs. Shows that temporal RSSI variance alone carries significant motion information.
- **CrossSense** (2024): Transfer learning from CSI-rich hardware to RSSI-only devices. Pre-trained signal features transfer with 78% effectiveness, validating multi-tier hardware strategy.
---
## 2. Decision
Implement a **macOS CoreWLAN sensing adapter** as a Swift helper binary + Rust adapter pair, following the established `NetshBssidScanner` subprocess pattern from ADR-022. Real RSSI data flows through the existing 8-stage `WindowsWifiPipeline` (which operates on `BssidObservation` structs regardless of platform origin).
### 2.1 Design Principles
1. **Subprocess isolation** — Swift binary is a standalone tool, built and versioned independently of the Rust workspace.
2. **Same domain types** — macOS adapter produces `Vec<BssidObservation>`, identical to the Windows path. All downstream processing reuses as-is.
3. **SSID:channel as synthetic BSSID** — When real BSSIDs are redacted (no Location Services), `sha256(ssid + channel)[:12]` generates a stable pseudo-BSSID. Documented limitation: same-SSID same-channel APs collapse to one observation.
4. **`#[cfg(target_os = "macos")]` gating** — macOS-specific code compiles only on macOS. Windows and Linux builds are unaffected.
5. **Graceful degradation** — If the Swift helper is not found or fails, `--source auto` skips macOS WiFi and falls back to simulated mode with a clear warning.
---
## 3. Architecture
### 3.1 Component Overview
```
┌─────────────────────────────────────────────────────────────────────┐
│ macOS WiFi Sensing Path │
│ │
│ ┌──────────────────────┐ ┌───────────────────────────────────┐│
│ │ Swift Helper Binary │ │ Rust Adapter + Existing Pipeline ││
│ │ (tools/macos-wifi- │ │ ││
│ │ scan/main.swift) │ │ MacosCoreWlanScanner ││
│ │ │ │ │ ││
│ │ CWWiFiClient │JSON │ ▼ ││
│ │ scanForNetworks() ──┼────►│ Vec<BssidObservation> ││
│ │ interface() │ │ │ ││
│ │ │ │ ▼ ││
│ │ Outputs: │ │ BssidRegistry ││
│ │ - ssid │ │ │ ││
│ │ - rssi (dBm) │ │ ▼ ││
│ │ - noise (dBm) │ │ WindowsWifiPipeline (reused) ││
│ │ - channel │ │ [8-stage signal intelligence] ││
│ │ - band (2.4/5/6) │ │ │ ││
│ │ - phy_mode │ │ ▼ ││
│ │ - bssid (if avail) │ │ SensingUpdate → REST/WS ││
│ └──────────────────────┘ └───────────────────────────────────┘│
└─────────────────────────────────────────────────────────────────────┘
```
### 3.2 Swift Helper Binary
**File:** `rust-port/wifi-densepose-rs/tools/macos-wifi-scan/main.swift`
```swift
// Modes:
// (no args) Full scan, output JSON array to stdout
// --probe Quick availability check, output {"available": true/false}
// --connected Connected network info only
//
// Output schema (scan mode):
// [
// {
// "ssid": "MyNetwork",
// "rssi": -52,
// "noise": -90,
// "channel": 36,
// "band": "5GHz",
// "phy_mode": "802.11ax",
// "bssid": "aa:bb:cc:dd:ee:ff" | null,
// "security": "wpa2_personal"
// }
// ]
```
**Build:**
```bash
# Requires Xcode Command Line Tools (xcode-select --install)
cd tools/macos-wifi-scan
swiftc -framework CoreWLAN -framework Foundation -O -o macos-wifi-scan main.swift
```
**Build script:** `tools/macos-wifi-scan/build.sh`
### 3.3 Rust Adapter
**File:** `crates/wifi-densepose-wifiscan/src/adapter/macos_scanner.rs`
```rust
// #[cfg(target_os = "macos")]
pub struct MacosCoreWlanScanner {
helper_path: PathBuf, // Resolved at construction: $PATH or sibling of server binary
}
impl MacosCoreWlanScanner {
pub fn new() -> Result<Self, WifiScanError> // Finds helper or errors
pub fn probe() -> bool // Runs --probe, returns availability
pub fn scan_sync(&self) -> Result<Vec<BssidObservation>, WifiScanError>
pub fn connected_sync(&self) -> Result<Option<BssidObservation>, WifiScanError>
}
```
**Key mappings:**
| CoreWLAN field | → | BssidObservation field | Transform |
|----------------|---|----------------------|-----------|
| `rssi` (dBm) | → | `signal_dbm` | Direct (CoreWLAN gives calibrated dBm) |
| `rssi` (dBm) | → | `amplitude` | `rssi_to_amplitude()` (existing) |
| `noise` (dBm) | → | `snr` | `rssi - noise` (new field, macOS advantage) |
| `channel` | → | `channel` | Direct |
| `band` | → | `band` | `BandType::from_channel()` (existing) |
| `phy_mode` | → | `radio_type` | Map string → `RadioType` enum |
| `bssid` | → | `bssid_id` | Direct if available, else `sha256(ssid:channel)[:12]` |
| `ssid` | → | `ssid` | Direct |
### 3.4 Sensing Server Integration
**File:** `crates/wifi-densepose-sensing-server/src/main.rs`
| Function | Purpose |
|----------|---------|
| `probe_macos_wifi()` | Calls `MacosCoreWlanScanner::probe()`, returns bool |
| `macos_wifi_task()` | Async loop: scan → build `BssidObservation` vec → feed into `BssidRegistry` + `WindowsWifiPipeline` → emit `SensingUpdate`. Same structure as `windows_wifi_task()`. |
**Auto-detection order (updated):**
```
1. ESP32 UDP probe (port 5005) → --source esp32
2. Windows netsh probe → --source wifi (Windows)
3. macOS CoreWLAN probe [NEW] → --source wifi (macOS)
4. Simulated fallback → --source simulated
```
### 3.5 Pipeline Reuse
The existing 8-stage `WindowsWifiPipeline` (ADR-022) operates entirely on `BssidObservation` / `MultiApFrame` types:
| Stage | Reusable? | Notes |
|-------|-----------|-------|
| 1. Predictive Gating | Yes | Filters static APs by temporal variance |
| 2. Attention Weighting | Yes | Weights APs by motion sensitivity |
| 3. Spatial Correlation | Yes | Cross-AP signal correlation |
| 4. Motion Estimation | Yes | RSSI variance → motion level |
| 5. Breathing Extraction | **Marginal** | 0.3 Hz scan rate is below Nyquist for breathing (0.1-0.5 Hz). May detect very slow breathing only. |
| 6. Quality Gating | Yes | Rejects low-confidence estimates |
| 7. Fingerprint Matching | Yes | Location/posture classification |
| 8. Orchestration | Yes | Fuses all stages |
**Limitation:** CoreWLAN scan rate (~0.3-0.5 Hz) is significantly slower than `netsh` (~2 Hz). Breathing extraction (stage 5) will have reduced accuracy. Motion and presence detection remain effective since they depend on variance over longer windows.
---
## 4. Files
### 4.1 New Files
| File | Purpose | Lines (est.) |
|------|---------|-------------|
| `tools/macos-wifi-scan/main.swift` | CoreWLAN scanner, JSON output | ~120 |
| `tools/macos-wifi-scan/build.sh` | Build script (`swiftc` invocation) | ~15 |
| `crates/wifi-densepose-wifiscan/src/adapter/macos_scanner.rs` | Rust adapter: spawn helper, parse JSON, produce `BssidObservation` | ~200 |
### 4.2 Modified Files
| File | Change |
|------|--------|
| `crates/wifi-densepose-wifiscan/src/adapter/mod.rs` | Add `#[cfg(target_os = "macos")] pub mod macos_scanner;` + re-export |
| `crates/wifi-densepose-wifiscan/src/lib.rs` | Add `MacosCoreWlanScanner` re-export |
| `crates/wifi-densepose-sensing-server/src/main.rs` | Add `probe_macos_wifi()`, `macos_wifi_task()`, update auto-detect + `--source wifi` dispatch |
### 4.3 No New Rust Dependencies
- `std::process::Command` — subprocess spawning (stdlib)
- `serde_json` — JSON parsing (already in workspace)
- No changes to `Cargo.toml`
---
## 5. Verification Plan
All verification on Mac Mini (M2 Pro, macOS 26.3).
### 5.1 Swift Helper
| Test | Command | Expected |
|------|---------|----------|
| Build | `cd tools/macos-wifi-scan && ./build.sh` | Produces `macos-wifi-scan` binary |
| Probe | `./macos-wifi-scan --probe` | `{"available": true}` |
| Scan | `./macos-wifi-scan` | JSON array with real SSIDs, RSSI in dBm, channels |
| Connected | `./macos-wifi-scan --connected` | Single JSON object for connected network |
| No WiFi | Disable WiFi → `./macos-wifi-scan` | `{"available": false}` or empty array |
### 5.2 Rust Adapter
| Test | Method | Expected |
|------|--------|----------|
| Unit: JSON parsing | `#[test]` with fixture JSON | Correct `BssidObservation` values |
| Unit: synthetic BSSID | `#[test]` with nil bssid input | Stable `sha256(ssid:channel)[:12]` |
| Unit: helper not found | `#[test]` with bad path | `WifiScanError::ProcessError` |
| Integration: real scan | `cargo test` on Mac Mini | Live observations from CoreWLAN |
### 5.3 End-to-End
| Step | Command | Verify |
|------|---------|--------|
| 1 | `cargo build --release` (Mac Mini) | Clean build, no warnings |
| 2 | `cargo test --workspace` | All existing tests pass + new macOS tests |
| 3 | `./target/release/sensing-server --source wifi` | Server starts, logs `source: wifi (macOS CoreWLAN)` |
| 4 | `curl http://localhost:8080/api/v1/sensing/latest` | `source: "wifi:<SSID>"`, real RSSI values |
| 5 | `curl http://localhost:8080/api/v1/vital-signs` | Motion detection responds to physical movement |
| 6 | Open UI at `http://localhost:8080` | Signal field updates with real RSSI variation |
| 7 | `--source auto` | Auto-detects macOS WiFi, does not fall back to simulated |
### 5.4 Cross-Platform Regression
| Platform | Build | Expected |
|----------|-------|----------|
| macOS (Mac Mini) | `cargo build --release` | macOS adapter compiled, works |
| Windows | `cargo build --release` | macOS adapter skipped (`#[cfg]`), Windows path unchanged |
| Linux | `cargo build --release` | macOS adapter skipped, ESP32/simulated paths unchanged |
---
## 6. Limitations
| Limitation | Impact | Mitigation |
|------------|--------|-----------|
| **BSSID redaction** | Same-SSID same-channel APs collapse to one observation | Use `sha256(ssid:channel)` as pseudo-BSSID; document edge case. Rare in practice (mesh networks). |
| **Slow scan rate** (~0.3 Hz) | Breathing extraction unreliable (below Nyquist) | Motion/presence still work. Breathing marked low-confidence. Future: cache + connected AP fast-poll hybrid. |
| **Requires Swift helper in PATH** | Extra build step for source builds | `build.sh` provided. Docker image pre-bundles it. Clear error message when missing. |
| **Location Services for BSSID** | Full BSSID requires user permission prompt | System degrades gracefully to SSID:channel pseudo-BSSID without permission. |
| **No CSI** | Cannot match ESP32 pose estimation accuracy | Expected — this is RSSI-tier sensing (presence + motion). Same limitation as Windows. |
---
## 7. Future Work
| Enhancement | Description | Depends On |
|-------------|-------------|-----------|
| **Fast-poll connected AP** | Poll connected AP's RSSI at ~10 Hz via `CWInterface.rssiValue()` (no full scan needed) | CoreWLAN `rssiValue()` performance testing |
| **Linux `iw` adapter** | Same subprocess pattern with `iw dev wlan0 scan` output | Linux machine for testing |
| **Unified `RssiPipeline` rename** | Rename `WindowsWifiPipeline``RssiPipeline` to reflect multi-platform use | ADR-022 update |
| **802.11bf sensing** | Apple may expose CSI via 802.11bf in future macOS | Apple framework availability |
| **Docker macOS image** | Pre-built macOS Docker image with Swift helper bundled | Docker multi-arch build |
---
## 8. References
- [Apple CoreWLAN Documentation](https://developer.apple.com/documentation/corewlan)
- [CWWiFiClient](https://developer.apple.com/documentation/corewlan/cwwificlient) — Primary WiFi interface API
- [CWNetwork](https://developer.apple.com/documentation/corewlan/cwnetwork) — Scan result type (SSID, RSSI, channel, noise)
- [macOS 15 airport removal](https://developer.apple.com/forums/thread/732431) — Apple Developer Forums
- ADR-022: Windows WiFi Enhanced Fidelity (analogous platform adapter)
- ADR-013: Feature-Level Sensing from Commodity Gear
- Issue [#56](https://github.com/ruvnet/wifi-densepose/issues/56): macOS support request

632
docs/user-guide.md Normal file
View File

@@ -0,0 +1,632 @@
# WiFi DensePose User Guide
WiFi DensePose turns commodity WiFi signals into real-time human pose estimation, vital sign monitoring, and presence detection. This guide walks you through installation, first run, API usage, hardware setup, and model training.
---
## Table of Contents
1. [Prerequisites](#prerequisites)
2. [Installation](#installation)
- [Docker (Recommended)](#docker-recommended)
- [From Source (Rust)](#from-source-rust)
- [From Source (Python)](#from-source-python)
- [Guided Installer](#guided-installer)
3. [Quick Start](#quick-start)
- [30-Second Demo (Docker)](#30-second-demo-docker)
- [Verify the System Works](#verify-the-system-works)
4. [Data Sources](#data-sources)
- [Simulated Mode (No Hardware)](#simulated-mode-no-hardware)
- [Windows WiFi (RSSI Only)](#windows-wifi-rssi-only)
- [ESP32-S3 (Full CSI)](#esp32-s3-full-csi)
5. [REST API Reference](#rest-api-reference)
6. [WebSocket Streaming](#websocket-streaming)
7. [Web UI](#web-ui)
8. [Vital Sign Detection](#vital-sign-detection)
9. [CLI Reference](#cli-reference)
10. [Training a Model](#training-a-model)
11. [RVF Model Containers](#rvf-model-containers)
12. [Hardware Setup](#hardware-setup)
- [ESP32-S3 Mesh](#esp32-s3-mesh)
- [Intel 5300 / Atheros NIC](#intel-5300--atheros-nic)
13. [Docker Compose (Multi-Service)](#docker-compose-multi-service)
14. [Troubleshooting](#troubleshooting)
15. [FAQ](#faq)
---
## Prerequisites
| Requirement | Minimum | Recommended |
|-------------|---------|-------------|
| **OS** | Windows 10, macOS 10.15, Ubuntu 18.04 | Latest stable |
| **RAM** | 4 GB | 8 GB+ |
| **Disk** | 2 GB free | 5 GB free |
| **Docker** (for Docker path) | Docker 20+ | Docker 24+ |
| **Rust** (for source build) | 1.70+ | 1.85+ |
| **Python** (for legacy v1) | 3.8+ | 3.11+ |
**Hardware for live sensing (optional):**
| Option | Cost | Capabilities |
|--------|------|-------------|
| ESP32-S3 mesh (3-6 boards) | ~$54 | Full CSI: pose, breathing, heartbeat, presence |
| Intel 5300 / Atheros AR9580 | $50-100 | Full CSI with 3x3 MIMO (Linux only) |
| Any WiFi laptop | $0 | RSSI-only: coarse presence and motion detection |
No hardware? The system runs in **simulated mode** with synthetic CSI data.
---
## Installation
### Docker (Recommended)
The fastest path. No toolchain installation needed.
```bash
docker pull ruvnet/wifi-densepose:latest
```
Image size: ~132 MB. Contains the Rust sensing server, Three.js UI, and all signal processing.
### From Source (Rust)
```bash
git clone https://github.com/ruvnet/wifi-densepose.git
cd wifi-densepose/rust-port/wifi-densepose-rs
# Build
cargo build --release
# Verify (runs 542+ tests)
cargo test --workspace
```
The compiled binary is at `target/release/sensing-server`.
### From Source (Python)
```bash
git clone https://github.com/ruvnet/wifi-densepose.git
cd wifi-densepose
pip install -r requirements.txt
pip install -e .
# Or via PyPI
pip install wifi-densepose
pip install wifi-densepose[gpu] # GPU acceleration
pip install wifi-densepose[all] # All optional deps
```
### Guided Installer
An interactive installer that detects your hardware and recommends a profile:
```bash
git clone https://github.com/ruvnet/wifi-densepose.git
cd wifi-densepose
./install.sh
```
Available profiles: `verify`, `python`, `rust`, `browser`, `iot`, `docker`, `field`, `full`.
Non-interactive:
```bash
./install.sh --profile rust --yes
```
---
## Quick Start
### 30-Second Demo (Docker)
```bash
# Pull and run
docker run -p 3000:3000 -p 3001:3001 ruvnet/wifi-densepose:latest
# Open the UI in your browser
# http://localhost:3000
```
You will see a Three.js visualization with:
- 3D body skeleton (17 COCO keypoints)
- Signal amplitude heatmap
- Phase plot
- Vital signs panel (breathing + heartbeat)
### Verify the System Works
Open a second terminal and test the API:
```bash
# Health check
curl http://localhost:3000/health
# Expected: {"status":"ok","source":"simulated","clients":0}
# Latest sensing frame
curl http://localhost:3000/api/v1/sensing/latest
# Vital signs
curl http://localhost:3000/api/v1/vital-signs
# Pose estimation (17 COCO keypoints)
curl http://localhost:3000/api/v1/pose/current
# Server build info
curl http://localhost:3000/api/v1/info
```
All endpoints return JSON. In simulated mode, data is generated from a deterministic reference signal.
---
## Data Sources
The `--source` flag controls where CSI data comes from.
### Simulated Mode (No Hardware)
Default in Docker. Generates synthetic CSI data exercising the full pipeline.
```bash
# Docker
docker run -p 3000:3000 ruvnet/wifi-densepose:latest
# (--source simulated is the default)
# From source
./target/release/sensing-server --source simulated --http-port 3000 --ws-port 3001
```
### Windows WiFi (RSSI Only)
Uses `netsh wlan` to capture RSSI from nearby access points. No special hardware needed, but capabilities are limited to coarse presence and motion detection (no pose estimation or vital signs).
```bash
# From source (Windows only)
./target/release/sensing-server --source windows --http-port 3000 --ws-port 3001 --tick-ms 500
# Docker (requires --network host on Windows)
docker run --network host ruvnet/wifi-densepose:latest --source windows --tick-ms 500
```
See [Tutorial #36](https://github.com/ruvnet/wifi-densepose/issues/36) for a walkthrough.
### ESP32-S3 (Full CSI)
Real Channel State Information at 20 Hz with 56-192 subcarriers. Required for pose estimation, vital signs, and through-wall sensing.
```bash
# From source
./target/release/sensing-server --source esp32 --udp-port 5005 --http-port 3000 --ws-port 3001
# Docker
docker run -p 3000:3000 -p 3001:3001 -p 5005:5005/udp ruvnet/wifi-densepose:latest --source esp32
```
The ESP32 nodes stream binary CSI frames over UDP to port 5005. See [Hardware Setup](#esp32-s3-mesh) for flashing instructions.
---
## REST API Reference
Base URL: `http://localhost:3000` (Docker) or `http://localhost:8080` (binary default).
| Method | Endpoint | Description | Example Response |
|--------|----------|-------------|-----------------|
| `GET` | `/health` | Server health check | `{"status":"ok","source":"simulated","clients":0}` |
| `GET` | `/api/v1/sensing/latest` | Latest CSI sensing frame (amplitude, phase, motion) | JSON with subcarrier arrays |
| `GET` | `/api/v1/vital-signs` | Breathing rate + heart rate + confidence | `{"breathing_bpm":16.2,"heart_bpm":72.1,"confidence":0.87}` |
| `GET` | `/api/v1/pose/current` | 17 COCO keypoints (x, y, z, confidence) | Array of 17 joint positions |
| `GET` | `/api/v1/info` | Server version, build info, uptime | JSON metadata |
| `GET` | `/api/v1/bssid` | Multi-BSSID WiFi registry | List of detected access points |
| `GET` | `/api/v1/model/layers` | Progressive model loading status | Layer A/B/C load state |
| `GET` | `/api/v1/model/sona/profiles` | SONA adaptation profiles | List of environment profiles |
| `POST` | `/api/v1/model/sona/activate` | Activate a SONA profile for a specific room | `{"profile":"kitchen"}` |
### Example: Get Vital Signs
```bash
curl -s http://localhost:3000/api/v1/vital-signs | python -m json.tool
```
```json
{
"breathing_bpm": 16.2,
"heart_bpm": 72.1,
"breathing_confidence": 0.87,
"heart_confidence": 0.63,
"motion_level": 0.12,
"timestamp_ms": 1709312400000
}
```
### Example: Get Pose
```bash
curl -s http://localhost:3000/api/v1/pose/current | python -m json.tool
```
```json
{
"persons": [
{
"id": 0,
"keypoints": [
{"name": "nose", "x": 0.52, "y": 0.31, "z": 0.0, "confidence": 0.91},
{"name": "left_eye", "x": 0.54, "y": 0.29, "z": 0.0, "confidence": 0.88}
]
}
],
"frame_id": 1024,
"timestamp_ms": 1709312400000
}
```
---
## WebSocket Streaming
Real-time sensing data is available via WebSocket.
**URL:** `ws://localhost:3001/ws/sensing` (Docker) or `ws://localhost:8765/ws/sensing` (binary default).
### Python Example
```python
import asyncio
import websockets
import json
async def stream():
uri = "ws://localhost:3001/ws/sensing"
async with websockets.connect(uri) as ws:
async for message in ws:
data = json.loads(message)
persons = data.get("persons", [])
vitals = data.get("vital_signs", {})
print(f"Persons: {len(persons)}, "
f"Breathing: {vitals.get('breathing_bpm', 'N/A')} BPM")
asyncio.run(stream())
```
### JavaScript Example
```javascript
const ws = new WebSocket("ws://localhost:3001/ws/sensing");
ws.onmessage = (event) => {
const data = JSON.parse(event.data);
console.log("Persons:", data.persons?.length ?? 0);
console.log("Breathing:", data.vital_signs?.breathing_bpm, "BPM");
};
ws.onerror = (err) => console.error("WebSocket error:", err);
```
### curl (single frame)
```bash
# Requires wscat (npm install -g wscat)
wscat -c ws://localhost:3001/ws/sensing
```
---
## Web UI
The built-in Three.js UI is served at `http://localhost:3000/` (Docker) or the configured HTTP port.
**What you see:**
| Panel | Description |
|-------|-------------|
| 3D Body View | Rotatable wireframe skeleton with 17 COCO keypoints |
| Signal Heatmap | 56 subcarriers color-coded by amplitude |
| Phase Plot | Per-subcarrier phase values over time |
| Doppler Bars | Motion band power indicators |
| Vital Signs | Live breathing rate (BPM) and heart rate (BPM) |
| Dashboard | System stats, throughput, connected WebSocket clients |
The UI updates in real-time via the WebSocket connection.
---
## Vital Sign Detection
The system extracts breathing rate and heart rate from CSI signal fluctuations using FFT peak detection.
| Sign | Frequency Band | Range | Method |
|------|---------------|-------|--------|
| Breathing | 0.1-0.5 Hz | 6-30 BPM | Bandpass filter + FFT peak |
| Heart rate | 0.8-2.0 Hz | 40-120 BPM | Bandpass filter + FFT peak |
**Requirements:**
- CSI-capable hardware (ESP32-S3 or research NIC) for accurate readings
- Subject within ~3-5 meters of an access point
- Relatively stationary subject (large movements mask vital sign oscillations)
**Simulated mode** produces synthetic vital sign data for testing.
---
## CLI Reference
The Rust sensing server binary accepts the following flags:
| Flag | Default | Description |
|------|---------|-------------|
| `--source` | `auto` | Data source: `auto`, `simulated`, `windows`, `esp32` |
| `--http-port` | `8080` | HTTP port for REST API and UI |
| `--ws-port` | `8765` | WebSocket port |
| `--udp-port` | `5005` | UDP port for ESP32 CSI frames |
| `--ui-path` | (none) | Path to UI static files directory |
| `--tick-ms` | `50` | Simulated frame interval (milliseconds) |
| `--benchmark` | off | Run vital sign benchmark (1000 frames) and exit |
| `--train` | off | Train a model from dataset |
| `--dataset` | (none) | Path to dataset directory (MM-Fi or Wi-Pose) |
| `--dataset-type` | `mmfi` | Dataset format: `mmfi` or `wipose` |
| `--epochs` | `100` | Training epochs |
| `--export-rvf` | (none) | Export RVF model container and exit |
| `--save-rvf` | (none) | Save model state to RVF on shutdown |
| `--model` | (none) | Load a trained `.rvf` model for inference |
| `--load-rvf` | (none) | Load model config from RVF container |
| `--progressive` | off | Enable progressive 3-layer model loading |
### Common Invocations
```bash
# Simulated mode with UI (development)
./target/release/sensing-server --source simulated --http-port 3000 --ws-port 3001 --ui-path ../../ui
# ESP32 hardware mode
./target/release/sensing-server --source esp32 --udp-port 5005
# Windows WiFi RSSI
./target/release/sensing-server --source windows --tick-ms 500
# Run benchmark
./target/release/sensing-server --benchmark
# Train and export model
./target/release/sensing-server --train --dataset data/ --epochs 100 --save-rvf model.rvf
# Load trained model with progressive loading
./target/release/sensing-server --model model.rvf --progressive
```
---
## Training a Model
The training pipeline is implemented in pure Rust (7,832 lines, zero external ML dependencies).
### Step 1: Obtain a Dataset
The system supports two public WiFi CSI datasets:
| Dataset | Source | Format | Subjects | Environments |
|---------|--------|--------|----------|-------------|
| [MM-Fi](https://mmfi.github.io/) | NeurIPS 2023 | `.npy` | 40 | 4 rooms |
| [Wi-Pose](https://github.com/aiot-lab/Wi-Pose) | AAAI 2024 | `.mat` | 8 | 3 rooms |
Download and place in a `data/` directory.
### Step 2: Train
```bash
# From source
./target/release/sensing-server --train --dataset data/ --dataset-type mmfi --epochs 100 --save-rvf model.rvf
# Via Docker (mount your data directory)
docker run --rm \
-v $(pwd)/data:/data \
-v $(pwd)/output:/output \
ruvnet/wifi-densepose:latest \
--train --dataset /data --epochs 100 --export-rvf /output/model.rvf
```
The pipeline runs 8 phases:
1. Dataset loading (MM-Fi `.npy` or Wi-Pose `.mat`)
2. Subcarrier resampling (114->56 or 30->56)
3. Graph transformer construction (17 COCO keypoints, 16 bone edges)
4. Cross-attention training (CSI features -> body pose)
5. Composite loss optimization (MSE + CE + UV + temporal + bone + symmetry)
6. SONA adaptation (micro-LoRA + EWC++)
7. Sparse inference optimization (hot/cold neuron partitioning)
8. RVF model packaging
### Step 3: Use the Trained Model
```bash
./target/release/sensing-server --model model.rvf --progressive --source esp32
```
Progressive loading enables instant startup (Layer A loads in <5ms with basic inference), with full model loading in the background.
---
## RVF Model Containers
The RuVector Format (RVF) packages a trained model into a single self-contained binary file.
### Export
```bash
./target/release/sensing-server --export-rvf model.rvf
```
### Load
```bash
./target/release/sensing-server --model model.rvf --progressive
```
### Contents
An RVF file contains: model weights, HNSW vector index, quantization codebooks, SONA adaptation profiles, Ed25519 training proof, and vital sign filter parameters.
### Deployment Targets
| Target | Quantization | Size | Load Time |
|--------|-------------|------|-----------|
| ESP32 / IoT | int4 | ~0.7 MB | <5ms |
| Mobile / WASM | int8 | ~6-10 MB | ~200-500ms |
| Field (WiFi-Mat) | fp16 | ~62 MB | ~2s |
| Server / Cloud | f32 | ~50+ MB | ~3s |
---
## Hardware Setup
### ESP32-S3 Mesh
A 3-6 node ESP32-S3 mesh provides full CSI at 20 Hz. Total cost: ~$54 for a 3-node setup.
**What you need:**
- 3-6x ESP32-S3 development boards (~$8 each)
- A WiFi router (the CSI source)
- A computer running the sensing server
**Flashing firmware:**
Pre-built binaries are available at [Releases](https://github.com/ruvnet/wifi-densepose/releases/tag/v0.1.0-esp32).
```bash
# Flash an ESP32-S3 (requires esptool: pip install esptool)
python -m esptool --chip esp32s3 --port COM7 --baud 460800 \
write-flash --flash-mode dio --flash-size 4MB \
0x0 bootloader.bin 0x8000 partition-table.bin 0x10000 esp32-csi-node.bin
```
**Provisioning:**
```bash
python scripts/provision.py --port COM7 \
--ssid "YourWiFi" --password "YourPassword" --target-ip 192.168.1.20
```
Replace `192.168.1.20` with the IP of the machine running the sensing server.
**Start the aggregator:**
```bash
# From source
./target/release/sensing-server --source esp32 --udp-port 5005 --http-port 3000 --ws-port 3001
# Docker
docker run -p 3000:3000 -p 3001:3001 -p 5005:5005/udp ruvnet/wifi-densepose:latest --source esp32
```
See [ADR-018](../docs/adr/ADR-018-esp32-dev-implementation.md) and [Tutorial #34](https://github.com/ruvnet/wifi-densepose/issues/34).
### Intel 5300 / Atheros NIC
These research NICs provide full CSI on Linux with firmware/driver modifications.
| NIC | Driver | Platform | Setup |
|-----|--------|----------|-------|
| Intel 5300 | `iwl-csi` | Linux | Custom firmware, ~$15 used |
| Atheros AR9580 | `ath9k` patch | Linux | Kernel patch, ~$20 used |
These are advanced setups. See the respective driver documentation for installation.
---
## Docker Compose (Multi-Service)
For production deployments with both Rust and Python services:
```bash
cd docker
docker compose up
```
This starts:
- Rust sensing server on ports 3000 (HTTP), 3001 (WS), 5005 (UDP)
- Python legacy server on ports 8080 (HTTP), 8765 (WS)
---
## Troubleshooting
### Docker: "Connection refused" on localhost:3000
Make sure you're mapping the ports correctly:
```bash
docker run -p 3000:3000 -p 3001:3001 ruvnet/wifi-densepose:latest
```
The `-p 3000:3000` maps host port 3000 to container port 3000.
### Docker: No WebSocket data in UI
Add the WebSocket port mapping:
```bash
docker run -p 3000:3000 -p 3001:3001 ruvnet/wifi-densepose:latest
```
### ESP32: No data arriving
1. Verify the ESP32 is connected to the same WiFi network
2. Check the target IP matches the sensing server machine: `python scripts/provision.py --port COM7 --target-ip <YOUR_IP>`
3. Verify UDP port 5005 is not blocked by firewall
4. Test with: `nc -lu 5005` (Linux) or similar UDP listener
### Build: Rust compilation errors
Ensure Rust 1.70+ is installed:
```bash
rustup update stable
rustc --version
```
### Windows: RSSI mode shows no data
Run the terminal as Administrator (required for `netsh wlan` access).
### Vital signs show 0 BPM
- Vital sign detection requires CSI-capable hardware (ESP32 or research NIC)
- RSSI-only mode (Windows WiFi) does not have sufficient resolution for vital signs
- In simulated mode, synthetic vital signs are generated after a few seconds of warm-up
---
## FAQ
**Q: Do I need special hardware to try this?**
No. Run `docker run -p 3000:3000 ruvnet/wifi-densepose:latest` and open `http://localhost:3000`. Simulated mode exercises the full pipeline with synthetic data.
**Q: Can consumer WiFi laptops do pose estimation?**
No. Consumer WiFi exposes only RSSI (one number per access point), not CSI (56+ complex subcarrier values per frame). RSSI supports coarse presence and motion detection. Full pose estimation requires CSI-capable hardware like an ESP32-S3 ($8) or a research NIC.
**Q: How accurate is the pose estimation?**
Accuracy depends on hardware and environment. With a 3-node ESP32 mesh in a single room, the system tracks 17 COCO keypoints. The core algorithm follows the CMU "DensePose From WiFi" paper ([arXiv:2301.00250](https://arxiv.org/abs/2301.00250)). See the paper for quantitative evaluations.
**Q: Does it work through walls?**
Yes. WiFi signals penetrate non-metallic materials (drywall, wood, concrete up to ~30cm). Metal walls/doors significantly attenuate the signal. The effective through-wall range is approximately 5 meters.
**Q: How many people can it track?**
Each access point can distinguish ~3-5 people with 56 subcarriers. Multi-AP deployments multiply linearly (e.g., 4 APs cover ~15-20 people). There is no hard software limit; the practical ceiling is signal physics.
**Q: Is this privacy-preserving?**
The system uses WiFi radio signals, not cameras. No images or video are captured or stored. However, it does track human position, movement, and vital signs, which is personal data subject to applicable privacy regulations.
**Q: What's the Python vs Rust difference?**
The Rust implementation (v2) is 810x faster than Python (v1) for the full CSI pipeline. The Docker image is 132 MB vs 569 MB. Rust is the primary and recommended runtime. Python v1 remains available for legacy workflows.
---
## Further Reading
- [Architecture Decision Records](../docs/adr/) - 24 ADRs covering all design decisions
- [WiFi-Mat Disaster Response Guide](wifi-mat-user-guide.md) - Search & rescue module
- [Build Guide](build-guide.md) - Detailed build instructions
- [RuVector](https://github.com/ruvnet/ruvector) - Signal intelligence crate ecosystem
- [CMU DensePose From WiFi](https://arxiv.org/abs/2301.00250) - The foundational research paper

File diff suppressed because it is too large Load Diff

View File

@@ -20,7 +20,7 @@ members = [
[workspace.package]
version = "0.1.0"
edition = "2021"
authors = ["WiFi-DensePose Contributors"]
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
license = "MIT OR Apache-2.0"
repository = "https://github.com/ruvnet/wifi-densepose"
documentation = "https://docs.rs/wifi-densepose"
@@ -111,15 +111,15 @@ ruvector-attention = "2.0.4"
# Internal crates
wifi-densepose-core = { path = "crates/wifi-densepose-core" }
wifi-densepose-signal = { path = "crates/wifi-densepose-signal" }
wifi-densepose-nn = { path = "crates/wifi-densepose-nn" }
wifi-densepose-api = { path = "crates/wifi-densepose-api" }
wifi-densepose-db = { path = "crates/wifi-densepose-db" }
wifi-densepose-config = { path = "crates/wifi-densepose-config" }
wifi-densepose-hardware = { path = "crates/wifi-densepose-hardware" }
wifi-densepose-wasm = { path = "crates/wifi-densepose-wasm" }
wifi-densepose-mat = { path = "crates/wifi-densepose-mat" }
wifi-densepose-core = { version = "0.1.0", path = "crates/wifi-densepose-core" }
wifi-densepose-signal = { version = "0.1.0", path = "crates/wifi-densepose-signal" }
wifi-densepose-nn = { version = "0.1.0", path = "crates/wifi-densepose-nn" }
wifi-densepose-api = { version = "0.1.0", path = "crates/wifi-densepose-api" }
wifi-densepose-db = { version = "0.1.0", path = "crates/wifi-densepose-db" }
wifi-densepose-config = { version = "0.1.0", path = "crates/wifi-densepose-config" }
wifi-densepose-hardware = { version = "0.1.0", path = "crates/wifi-densepose-hardware" }
wifi-densepose-wasm = { version = "0.1.0", path = "crates/wifi-densepose-wasm" }
wifi-densepose-mat = { version = "0.1.0", path = "crates/wifi-densepose-mat" }
[profile.release]
lto = true

View File

@@ -0,0 +1,297 @@
# WiFi-DensePose Rust Crates
[![License: MIT OR Apache-2.0](https://img.shields.io/badge/license-MIT%2FApache--2.0-blue.svg)](LICENSE)
[![Rust 1.85+](https://img.shields.io/badge/rust-1.85%2B-orange.svg)](https://www.rust-lang.org/)
[![Workspace](https://img.shields.io/badge/workspace-14%20crates-green.svg)](https://github.com/ruvnet/wifi-densepose)
[![RuVector v2.0.4](https://img.shields.io/badge/ruvector-v2.0.4-purple.svg)](https://crates.io/crates/ruvector-mincut)
[![Tests](https://img.shields.io/badge/tests-542%2B-brightgreen.svg)](#testing)
**See through walls with WiFi. No cameras. No wearables. Just radio waves.**
A modular Rust workspace for WiFi-based human pose estimation, vital sign monitoring, and disaster response using Channel State Information (CSI). Built on [RuVector](https://crates.io/crates/ruvector-mincut) graph algorithms and the [WiFi-DensePose](https://github.com/ruvnet/wifi-densepose) research platform by [rUv](https://github.com/ruvnet).
---
## Performance
| Operation | Python v1 | Rust v2 | Speedup |
|-----------|-----------|---------|---------|
| CSI Preprocessing | ~5 ms | 5.19 us | **~1000x** |
| Phase Sanitization | ~3 ms | 3.84 us | **~780x** |
| Feature Extraction | ~8 ms | 9.03 us | **~890x** |
| Motion Detection | ~1 ms | 186 ns | **~5400x** |
| Full Pipeline | ~15 ms | 18.47 us | **~810x** |
| Vital Signs | N/A | 86 us (11,665 fps) | -- |
## Crate Overview
### Core Foundation
| Crate | Description | crates.io |
|-------|-------------|-----------|
| [`wifi-densepose-core`](wifi-densepose-core/) | Types, traits, and utilities (`CsiFrame`, `PoseEstimate`, `SignalProcessor`) | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-core.svg)](https://crates.io/crates/wifi-densepose-core) |
| [`wifi-densepose-config`](wifi-densepose-config/) | Configuration management (env, TOML, YAML) | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-config.svg)](https://crates.io/crates/wifi-densepose-config) |
| [`wifi-densepose-db`](wifi-densepose-db/) | Database persistence (PostgreSQL, SQLite, Redis) | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-db.svg)](https://crates.io/crates/wifi-densepose-db) |
### Signal Processing & Sensing
| Crate | Description | RuVector Integration | crates.io |
|-------|-------------|---------------------|-----------|
| [`wifi-densepose-signal`](wifi-densepose-signal/) | SOTA CSI signal processing (6 algorithms from SpotFi, FarSense, Widar 3.0) | `ruvector-mincut`, `ruvector-attn-mincut`, `ruvector-attention`, `ruvector-solver` | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-signal.svg)](https://crates.io/crates/wifi-densepose-signal) |
| [`wifi-densepose-vitals`](wifi-densepose-vitals/) | Vital sign extraction: breathing (6-30 BPM) and heart rate (40-120 BPM) | -- | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-vitals.svg)](https://crates.io/crates/wifi-densepose-vitals) |
| [`wifi-densepose-wifiscan`](wifi-densepose-wifiscan/) | Multi-BSSID WiFi scanning for Windows-enhanced sensing | -- | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-wifiscan.svg)](https://crates.io/crates/wifi-densepose-wifiscan) |
### Neural Network & Training
| Crate | Description | RuVector Integration | crates.io |
|-------|-------------|---------------------|-----------|
| [`wifi-densepose-nn`](wifi-densepose-nn/) | Multi-backend inference (ONNX, PyTorch, Candle) with DensePose head (24 body parts) | -- | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-nn.svg)](https://crates.io/crates/wifi-densepose-nn) |
| [`wifi-densepose-train`](wifi-densepose-train/) | Training pipeline with MM-Fi dataset, 114->56 subcarrier interpolation | **All 5 crates** | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-train.svg)](https://crates.io/crates/wifi-densepose-train) |
### Disaster Response
| Crate | Description | RuVector Integration | crates.io |
|-------|-------------|---------------------|-----------|
| [`wifi-densepose-mat`](wifi-densepose-mat/) | Mass Casualty Assessment Tool -- survivor detection, triage, multi-AP localization | `ruvector-solver`, `ruvector-temporal-tensor` | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-mat.svg)](https://crates.io/crates/wifi-densepose-mat) |
### Hardware & Deployment
| Crate | Description | crates.io |
|-------|-------------|-----------|
| [`wifi-densepose-hardware`](wifi-densepose-hardware/) | ESP32, Intel 5300, Atheros CSI sensor interfaces (pure Rust, no FFI) | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-hardware.svg)](https://crates.io/crates/wifi-densepose-hardware) |
| [`wifi-densepose-wasm`](wifi-densepose-wasm/) | WebAssembly bindings for browser-based disaster dashboard | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-wasm.svg)](https://crates.io/crates/wifi-densepose-wasm) |
| [`wifi-densepose-sensing-server`](wifi-densepose-sensing-server/) | Axum server: ESP32 UDP ingestion, WebSocket broadcast, sensing UI | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-sensing-server.svg)](https://crates.io/crates/wifi-densepose-sensing-server) |
### Applications
| Crate | Description | crates.io |
|-------|-------------|-----------|
| [`wifi-densepose-api`](wifi-densepose-api/) | REST + WebSocket API layer | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-api.svg)](https://crates.io/crates/wifi-densepose-api) |
| [`wifi-densepose-cli`](wifi-densepose-cli/) | Command-line tool for MAT disaster scanning | [![crates.io](https://img.shields.io/crates/v/wifi-densepose-cli.svg)](https://crates.io/crates/wifi-densepose-cli) |
---
## Architecture
```
wifi-densepose-core
(types, traits, errors)
|
+-------------------+-------------------+
| | |
wifi-densepose-signal wifi-densepose-nn wifi-densepose-hardware
(CSI processing) (inference) (ESP32, Intel 5300)
+ ruvector-mincut + ONNX Runtime |
+ ruvector-attn-mincut + PyTorch (tch) wifi-densepose-vitals
+ ruvector-attention + Candle (breathing, heart rate)
+ ruvector-solver |
| | wifi-densepose-wifiscan
+--------+---------+ (BSSID scanning)
|
+------------+------------+
| |
wifi-densepose-train wifi-densepose-mat
(training pipeline) (disaster response)
+ ALL 5 ruvector + ruvector-solver
+ ruvector-temporal-tensor
|
+-----------------+-----------------+
| | |
wifi-densepose-api wifi-densepose-wasm wifi-densepose-cli
(REST/WS) (browser WASM) (CLI tool)
|
wifi-densepose-sensing-server
(Axum + WebSocket)
```
## RuVector Integration
All [RuVector](https://github.com/ruvnet/ruvector) crates at **v2.0.4** from crates.io:
| RuVector Crate | Used In | Purpose |
|----------------|---------|---------|
| [`ruvector-mincut`](https://crates.io/crates/ruvector-mincut) | signal, train | Dynamic min-cut for subcarrier selection & person matching |
| [`ruvector-attn-mincut`](https://crates.io/crates/ruvector-attn-mincut) | signal, train | Attention-weighted min-cut for antenna gating & spectrograms |
| [`ruvector-temporal-tensor`](https://crates.io/crates/ruvector-temporal-tensor) | train, mat | Tiered temporal compression (4-10x memory reduction) |
| [`ruvector-solver`](https://crates.io/crates/ruvector-solver) | signal, train, mat | Sparse Neumann solver for interpolation & triangulation |
| [`ruvector-attention`](https://crates.io/crates/ruvector-attention) | signal, train | Scaled dot-product attention for spatial features & BVP |
## Signal Processing Algorithms
Six state-of-the-art algorithms implemented in `wifi-densepose-signal`:
| Algorithm | Paper | Year | Module |
|-----------|-------|------|--------|
| Conjugate Multiplication | SpotFi (SIGCOMM) | 2015 | `csi_ratio.rs` |
| Hampel Filter | WiGest | 2015 | `hampel.rs` |
| Fresnel Zone Model | FarSense (MobiCom) | 2019 | `fresnel.rs` |
| CSI Spectrogram | Standard STFT | 2018+ | `spectrogram.rs` |
| Subcarrier Selection | WiDance (MobiCom) | 2017 | `subcarrier_selection.rs` |
| Body Velocity Profile | Widar 3.0 (MobiSys) | 2019 | `bvp.rs` |
## Quick Start
### As a Library
```rust
use wifi_densepose_core::{CsiFrame, CsiMetadata, SignalProcessor};
use wifi_densepose_signal::{CsiProcessor, CsiProcessorConfig};
// Configure the CSI processor
let config = CsiProcessorConfig::default();
let processor = CsiProcessor::new(config);
// Process a CSI frame
let frame = CsiFrame { /* ... */ };
let processed = processor.process(&frame)?;
```
### Vital Sign Monitoring
```rust
use wifi_densepose_vitals::{
CsiVitalPreprocessor, BreathingExtractor, HeartRateExtractor,
VitalAnomalyDetector,
};
let mut preprocessor = CsiVitalPreprocessor::new(56); // 56 subcarriers
let mut breathing = BreathingExtractor::new(100.0); // 100 Hz sample rate
let mut heartrate = HeartRateExtractor::new(100.0);
// Feed CSI frames and extract vitals
for frame in csi_stream {
let residuals = preprocessor.update(&frame.amplitudes);
if let Some(bpm) = breathing.push_residuals(&residuals) {
println!("Breathing: {:.1} BPM", bpm);
}
}
```
### Disaster Response (MAT)
```rust
use wifi_densepose_mat::{DisasterResponse, DisasterConfig, DisasterType};
let config = DisasterConfig {
disaster_type: DisasterType::Earthquake,
max_scan_zones: 16,
..Default::default()
};
let mut responder = DisasterResponse::new(config);
responder.add_scan_zone(zone)?;
responder.start_continuous_scan().await?;
```
### Hardware (ESP32)
```rust
use wifi_densepose_hardware::{Esp32CsiParser, CsiFrame};
let parser = Esp32CsiParser::new();
let raw_bytes: &[u8] = /* UDP packet from ESP32 */;
let frame: CsiFrame = parser.parse(raw_bytes)?;
println!("RSSI: {} dBm, {} subcarriers", frame.metadata.rssi, frame.subcarriers.len());
```
### Training
```bash
# Check training crate (no GPU needed)
cargo check -p wifi-densepose-train --no-default-features
# Run training with GPU (requires tch/libtorch)
cargo run -p wifi-densepose-train --features tch-backend --bin train -- \
--config training.toml --dataset /path/to/mmfi
# Verify deterministic training proof
cargo run -p wifi-densepose-train --features tch-backend --bin verify-training
```
## Building
```bash
# Clone the repository
git clone https://github.com/ruvnet/wifi-densepose.git
cd wifi-densepose/rust-port/wifi-densepose-rs
# Check workspace (no GPU dependencies)
cargo check --workspace --no-default-features
# Run all tests
cargo test --workspace --no-default-features
# Build release
cargo build --release --workspace
```
### Feature Flags
| Crate | Feature | Description |
|-------|---------|-------------|
| `wifi-densepose-nn` | `onnx` (default) | ONNX Runtime backend |
| `wifi-densepose-nn` | `tch-backend` | PyTorch (libtorch) backend |
| `wifi-densepose-nn` | `candle-backend` | Candle (pure Rust) backend |
| `wifi-densepose-nn` | `cuda` | CUDA GPU acceleration |
| `wifi-densepose-train` | `tch-backend` | Enable GPU training modules |
| `wifi-densepose-mat` | `ruvector` (default) | RuVector graph algorithms |
| `wifi-densepose-mat` | `api` (default) | REST + WebSocket API |
| `wifi-densepose-mat` | `distributed` | Multi-node coordination |
| `wifi-densepose-mat` | `drone` | Drone-mounted scanning |
| `wifi-densepose-hardware` | `esp32` | ESP32 protocol support |
| `wifi-densepose-hardware` | `intel5300` | Intel 5300 CSI Tool |
| `wifi-densepose-hardware` | `linux-wifi` | Linux commodity WiFi |
| `wifi-densepose-wifiscan` | `wlanapi` | Windows WLAN API async scanning |
| `wifi-densepose-core` | `serde` | Serialization support |
| `wifi-densepose-core` | `async` | Async trait support |
## Testing
```bash
# Unit tests (all crates)
cargo test --workspace --no-default-features
# Signal processing benchmarks
cargo bench -p wifi-densepose-signal
# Training benchmarks
cargo bench -p wifi-densepose-train --no-default-features
# Detection benchmarks
cargo bench -p wifi-densepose-mat
```
## Supported Hardware
| Hardware | Crate Feature | CSI Subcarriers | Cost |
|----------|---------------|-----------------|------|
| ESP32-S3 Mesh (3-6 nodes) | `hardware/esp32` | 52-56 | ~$54 |
| Intel 5300 NIC | `hardware/intel5300` | 30 | ~$50 |
| Atheros AR9580 | `hardware/linux-wifi` | 56 | ~$100 |
| Any WiFi (Windows/Linux) | `wifiscan` | RSSI-only | $0 |
## Architecture Decision Records
Key design decisions documented in [`docs/adr/`](https://github.com/ruvnet/wifi-densepose/tree/main/docs/adr):
| ADR | Title | Status |
|-----|-------|--------|
| [ADR-014](https://github.com/ruvnet/wifi-densepose/blob/main/docs/adr/ADR-014-sota-signal-processing.md) | SOTA Signal Processing | Accepted |
| [ADR-015](https://github.com/ruvnet/wifi-densepose/blob/main/docs/adr/ADR-015-public-dataset-training-strategy.md) | MM-Fi + Wi-Pose Training Datasets | Accepted |
| [ADR-016](https://github.com/ruvnet/wifi-densepose/blob/main/docs/adr/ADR-016-ruvector-integration.md) | RuVector Training Pipeline | Accepted (Complete) |
| [ADR-017](https://github.com/ruvnet/wifi-densepose/blob/main/docs/adr/ADR-017-ruvector-signal-mat-integration.md) | RuVector Signal + MAT Integration | Accepted |
| [ADR-021](https://github.com/ruvnet/wifi-densepose/blob/main/docs/adr/ADR-021-vital-sign-detection.md) | Vital Sign Detection Pipeline | Accepted |
| [ADR-022](https://github.com/ruvnet/wifi-densepose/blob/main/docs/adr/ADR-022-windows-wifi-enhanced.md) | Windows WiFi Enhanced Sensing | Accepted |
| [ADR-024](https://github.com/ruvnet/wifi-densepose/blob/main/docs/adr/ADR-024-contrastive-csi-embedding.md) | Contrastive CSI Embedding Model | Accepted |
## Related Projects
- **[WiFi-DensePose](https://github.com/ruvnet/wifi-densepose)** -- Main repository (Python v1 + Rust v2)
- **[RuVector](https://github.com/ruvnet/ruvector)** -- Graph algorithms for neural networks (5 crates, v2.0.4)
- **[rUv](https://github.com/ruvnet)** -- Creator and maintainer
## License
All crates are dual-licensed under [MIT](https://opensource.org/licenses/MIT) OR [Apache-2.0](https://www.apache.org/licenses/LICENSE-2.0).
Copyright (c) 2024 rUv

View File

@@ -3,5 +3,12 @@ name = "wifi-densepose-api"
version.workspace = true
edition.workspace = true
description = "REST API for WiFi-DensePose"
license.workspace = true
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository.workspace = true
documentation.workspace = true
keywords = ["wifi", "api", "rest", "densepose", "websocket"]
categories = ["web-programming::http-server", "science"]
readme = "README.md"
[dependencies]

View File

@@ -0,0 +1,71 @@
# wifi-densepose-api
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-api.svg)](https://crates.io/crates/wifi-densepose-api)
[![Documentation](https://docs.rs/wifi-densepose-api/badge.svg)](https://docs.rs/wifi-densepose-api)
[![License](https://img.shields.io/crates/l/wifi-densepose-api.svg)](LICENSE)
REST and WebSocket API layer for the WiFi-DensePose pose estimation system.
## Overview
`wifi-densepose-api` provides the HTTP service boundary for WiFi-DensePose. Built on
[axum](https://github.com/tokio-rs/axum), it exposes REST endpoints for pose queries, CSI frame
ingestion, and model management, plus a WebSocket feed for real-time pose streaming to frontend
clients.
> **Status:** This crate is currently a stub. The intended API surface is documented below.
## Planned Features
- **REST endpoints** -- CRUD for scan zones, pose queries, model configuration, and health checks.
- **WebSocket streaming** -- Real-time pose estimate broadcasts with per-client subscription filters.
- **Authentication** -- Token-based auth middleware via `tower` layers.
- **Rate limiting** -- Configurable per-route limits to protect hardware-constrained deployments.
- **OpenAPI spec** -- Auto-generated documentation via `utoipa`.
- **CORS** -- Configurable cross-origin support for browser-based dashboards.
- **Graceful shutdown** -- Clean connection draining on SIGTERM.
## Quick Start
```rust
// Intended usage (not yet implemented)
use wifi_densepose_api::Server;
#[tokio::main]
async fn main() -> anyhow::Result<()> {
let server = Server::builder()
.bind("0.0.0.0:3000")
.with_websocket("/ws/poses")
.build()
.await?;
server.run().await
}
```
## Planned Endpoints
| Method | Path | Description |
|--------|------|-------------|
| `GET` | `/api/v1/health` | Liveness and readiness probes |
| `GET` | `/api/v1/poses` | Latest pose estimates |
| `POST` | `/api/v1/csi` | Ingest raw CSI frames |
| `GET` | `/api/v1/zones` | List scan zones |
| `POST` | `/api/v1/zones` | Create a scan zone |
| `WS` | `/ws/poses` | Real-time pose stream |
| `WS` | `/ws/vitals` | Real-time vital sign stream |
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-core`](../wifi-densepose-core) | Shared types and traits |
| [`wifi-densepose-config`](../wifi-densepose-config) | Configuration loading |
| [`wifi-densepose-db`](../wifi-densepose-db) | Database persistence |
| [`wifi-densepose-nn`](../wifi-densepose-nn) | Neural network inference |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | CSI signal processing |
| [`wifi-densepose-sensing-server`](../wifi-densepose-sensing-server) | Lightweight sensing UI server |
## License
MIT OR Apache-2.0

View File

@@ -6,6 +6,10 @@ description = "CLI for WiFi-DensePose"
authors.workspace = true
license.workspace = true
repository.workspace = true
documentation = "https://docs.rs/wifi-densepose-cli"
keywords = ["wifi", "cli", "densepose", "disaster", "detection"]
categories = ["command-line-utilities", "science"]
readme = "README.md"
[[bin]]
name = "wifi-densepose"
@@ -17,7 +21,7 @@ mat = []
[dependencies]
# Internal crates
wifi-densepose-mat = { path = "../wifi-densepose-mat" }
wifi-densepose-mat = { version = "0.1.0", path = "../wifi-densepose-mat" }
# CLI framework
clap = { version = "4.4", features = ["derive", "env", "cargo"] }

View File

@@ -0,0 +1,95 @@
# wifi-densepose-cli
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-cli.svg)](https://crates.io/crates/wifi-densepose-cli)
[![Documentation](https://docs.rs/wifi-densepose-cli/badge.svg)](https://docs.rs/wifi-densepose-cli)
[![License](https://img.shields.io/crates/l/wifi-densepose-cli.svg)](LICENSE)
Command-line interface for WiFi-DensePose, including the Mass Casualty Assessment Tool (MAT) for
disaster response operations.
## Overview
`wifi-densepose-cli` ships the `wifi-densepose` binary -- a single entry point for operating the
WiFi-DensePose system from the terminal. The primary command group is `mat`, which drives the
disaster survivor detection and triage workflow powered by the `wifi-densepose-mat` crate.
Built with [clap](https://docs.rs/clap) for argument parsing,
[tabled](https://docs.rs/tabled) + [colored](https://docs.rs/colored) for rich terminal output, and
[indicatif](https://docs.rs/indicatif) for progress bars during scans.
## Features
- **Survivor scanning** -- Start continuous or one-shot scans across disaster zones with configurable
sensitivity, depth, and disaster type.
- **Triage management** -- List detected survivors sorted by triage priority (Immediate / Delayed /
Minor / Deceased / Unknown) with filtering and output format options.
- **Alert handling** -- View, acknowledge, resolve, and escalate alerts generated by the detection
pipeline.
- **Zone management** -- Add, remove, pause, and resume rectangular or circular scan zones.
- **Data export** -- Export scan results to JSON or CSV for integration with external USAR systems.
- **Simulation mode** -- Run demo scans with synthetic detections (`--simulate`) for testing and
training without hardware.
- **Multiple output formats** -- Table, JSON, and compact single-line output for scripting.
### Feature flags
| Flag | Default | Description |
|-------|---------|-------------|
| `mat` | yes | Enable MAT disaster detection commands |
## Quick Start
```bash
# Install
cargo install wifi-densepose-cli
# Run a simulated disaster scan
wifi-densepose mat scan --disaster-type earthquake --sensitivity 0.8 --simulate
# Check system status
wifi-densepose mat status
# List detected survivors (sorted by triage priority)
wifi-densepose mat survivors --sort-by triage
# View pending alerts
wifi-densepose mat alerts --pending
# Manage scan zones
wifi-densepose mat zones add --name "Building A" --bounds 0,0,100,80
wifi-densepose mat zones list --active
# Export results to JSON
wifi-densepose mat export --output results.json --format json
# Show version
wifi-densepose version
```
## Command Reference
```text
wifi-densepose
mat
scan Start scanning for survivors
status Show current scan status
zones Manage scan zones (list, add, remove, pause, resume)
survivors List detected survivors with triage status
alerts View and manage alerts (list, ack, resolve, escalate)
export Export scan data to JSON or CSV
version Display version information
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-mat`](../wifi-densepose-mat) | MAT disaster detection engine |
| [`wifi-densepose-core`](../wifi-densepose-core) | Shared types and traits |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | CSI signal processing |
| [`wifi-densepose-hardware`](../wifi-densepose-hardware) | ESP32 hardware interfaces |
| [`wifi-densepose-wasm`](../wifi-densepose-wasm) | Browser-based MAT dashboard |
## License
MIT OR Apache-2.0

View File

@@ -3,5 +3,12 @@ name = "wifi-densepose-config"
version.workspace = true
edition.workspace = true
description = "Configuration management for WiFi-DensePose"
license.workspace = true
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository.workspace = true
documentation.workspace = true
keywords = ["wifi", "configuration", "densepose", "settings", "toml"]
categories = ["config", "science"]
readme = "README.md"
[dependencies]

View File

@@ -0,0 +1,89 @@
# wifi-densepose-config
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-config.svg)](https://crates.io/crates/wifi-densepose-config)
[![Documentation](https://docs.rs/wifi-densepose-config/badge.svg)](https://docs.rs/wifi-densepose-config)
[![License](https://img.shields.io/crates/l/wifi-densepose-config.svg)](LICENSE)
Configuration management for the WiFi-DensePose pose estimation system.
## Overview
`wifi-densepose-config` provides a unified configuration layer that merges values from environment
variables, TOML/YAML files, and CLI overrides into strongly-typed Rust structs. Built on the
[config](https://docs.rs/config), [dotenvy](https://docs.rs/dotenvy), and
[envy](https://docs.rs/envy) ecosystem from the workspace.
> **Status:** This crate is currently a stub. The intended API surface is documented below.
## Planned Features
- **Multi-source loading** -- Merge configuration from `.env`, TOML files, YAML files, and
environment variables with well-defined precedence.
- **Typed configuration** -- Strongly-typed structs for server, signal processing, neural network,
hardware, and database settings.
- **Validation** -- Schema validation with human-readable error messages on startup.
- **Hot reload** -- Watch configuration files for changes and notify dependent services.
- **Profile support** -- Named profiles (`development`, `production`, `testing`) with per-profile
overrides.
- **Secret filtering** -- Redact sensitive values (API keys, database passwords) in logs and debug
output.
## Quick Start
```rust
// Intended usage (not yet implemented)
use wifi_densepose_config::AppConfig;
fn main() -> anyhow::Result<()> {
// Loads from env, config.toml, and CLI overrides
let config = AppConfig::load()?;
println!("Server bind: {}", config.server.bind_address);
println!("CSI sample rate: {} Hz", config.signal.sample_rate);
println!("Model path: {}", config.nn.model_path.display());
Ok(())
}
```
## Planned Configuration Structure
```toml
# config.toml
[server]
bind_address = "0.0.0.0:3000"
websocket_path = "/ws/poses"
[signal]
sample_rate = 100
subcarrier_count = 56
hampel_window = 5
[nn]
model_path = "./models/densepose.rvf"
backend = "ort" # ort | candle | tch
batch_size = 8
[hardware]
esp32_udp_port = 5005
serial_baud = 921600
[database]
url = "sqlite://data/wifi-densepose.db"
max_connections = 5
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-core`](../wifi-densepose-core) | Shared types and traits |
| [`wifi-densepose-api`](../wifi-densepose-api) | REST API (consumer) |
| [`wifi-densepose-db`](../wifi-densepose-db) | Database layer (consumer) |
| [`wifi-densepose-cli`](../wifi-densepose-cli) | CLI (consumer) |
| [`wifi-densepose-sensing-server`](../wifi-densepose-sensing-server) | Sensing server (consumer) |
## License
MIT OR Apache-2.0

View File

@@ -0,0 +1,83 @@
# wifi-densepose-core
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-core.svg)](https://crates.io/crates/wifi-densepose-core)
[![Documentation](https://docs.rs/wifi-densepose-core/badge.svg)](https://docs.rs/wifi-densepose-core)
[![License](https://img.shields.io/crates/l/wifi-densepose-core.svg)](LICENSE)
Core types, traits, and utilities for the WiFi-DensePose pose estimation system.
## Overview
`wifi-densepose-core` is the foundation crate for the WiFi-DensePose workspace. It defines the
shared data structures, error types, and trait contracts used by every other crate in the
ecosystem. The crate is `no_std`-compatible (with the `std` feature disabled) and forbids all
unsafe code.
## Features
- **Core data types** -- `CsiFrame`, `ProcessedSignal`, `PoseEstimate`, `PersonPose`, `Keypoint`,
`KeypointType`, `BoundingBox`, `Confidence`, `Timestamp`, and more.
- **Trait abstractions** -- `SignalProcessor`, `NeuralInference`, and `DataStore` define the
contracts for signal processing, neural network inference, and data persistence respectively.
- **Error hierarchy** -- `CoreError`, `SignalError`, `InferenceError`, and `StorageError` provide
typed error handling across subsystem boundaries.
- **`no_std` support** -- Disable the default `std` feature for embedded or WASM targets.
- **Constants** -- `MAX_KEYPOINTS` (17, COCO format), `MAX_SUBCARRIERS` (256),
`DEFAULT_CONFIDENCE_THRESHOLD` (0.5).
### Feature flags
| Flag | Default | Description |
|---------|---------|--------------------------------------------|
| `std` | yes | Enable standard library support |
| `serde` | no | Serialization via serde (+ ndarray serde) |
| `async` | no | Async trait definitions via `async-trait` |
## Quick Start
```rust
use wifi_densepose_core::{CsiFrame, Keypoint, KeypointType, Confidence};
// Create a keypoint with high confidence
let keypoint = Keypoint::new(
KeypointType::Nose,
0.5,
0.3,
Confidence::new(0.95).unwrap(),
);
assert!(keypoint.is_visible());
```
Or use the prelude for convenient bulk imports:
```rust
use wifi_densepose_core::prelude::*;
```
## Architecture
```text
wifi-densepose-core/src/
lib.rs -- Re-exports, constants, prelude
types.rs -- CsiFrame, PoseEstimate, Keypoint, etc.
traits.rs -- SignalProcessor, NeuralInference, DataStore
error.rs -- CoreError, SignalError, InferenceError, StorageError
utils.rs -- Shared helper functions
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-signal`](../wifi-densepose-signal) | CSI signal processing algorithms |
| [`wifi-densepose-nn`](../wifi-densepose-nn) | Neural network inference backends |
| [`wifi-densepose-train`](../wifi-densepose-train) | Training pipeline with ruvector |
| [`wifi-densepose-mat`](../wifi-densepose-mat) | Disaster detection (MAT) |
| [`wifi-densepose-hardware`](../wifi-densepose-hardware) | Hardware sensor interfaces |
| [`wifi-densepose-vitals`](../wifi-densepose-vitals) | Vital sign extraction |
| [`wifi-densepose-wifiscan`](../wifi-densepose-wifiscan) | Multi-BSSID WiFi scanning |
## License
MIT OR Apache-2.0

View File

@@ -3,5 +3,12 @@ name = "wifi-densepose-db"
version.workspace = true
edition.workspace = true
description = "Database layer for WiFi-DensePose"
license.workspace = true
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository.workspace = true
documentation.workspace = true
keywords = ["wifi", "database", "storage", "densepose", "persistence"]
categories = ["database", "science"]
readme = "README.md"
[dependencies]

View File

@@ -0,0 +1,106 @@
# wifi-densepose-db
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-db.svg)](https://crates.io/crates/wifi-densepose-db)
[![Documentation](https://docs.rs/wifi-densepose-db/badge.svg)](https://docs.rs/wifi-densepose-db)
[![License](https://img.shields.io/crates/l/wifi-densepose-db.svg)](LICENSE)
Database persistence layer for the WiFi-DensePose pose estimation system.
## Overview
`wifi-densepose-db` implements the `DataStore` trait defined in `wifi-densepose-core`, providing
persistent storage for CSI frames, pose estimates, scan sessions, and alert history. The intended
backends are [SQLx](https://docs.rs/sqlx) for relational storage (PostgreSQL and SQLite) and
[Redis](https://docs.rs/redis) for real-time caching and pub/sub.
> **Status:** This crate is currently a stub. The intended API surface is documented below.
## Planned Features
- **Dual backend** -- PostgreSQL for production deployments, SQLite for single-node and embedded
use. Selectable at compile time via feature flags.
- **Redis caching** -- Connection-pooled Redis for low-latency pose estimate lookups, session
state, and pub/sub event distribution.
- **Migrations** -- Embedded SQL migrations managed by SQLx, applied automatically on startup.
- **Repository pattern** -- Typed repository structs (`PoseRepository`, `SessionRepository`,
`AlertRepository`) implementing the core `DataStore` trait.
- **Connection pooling** -- Configurable pool sizes via `sqlx::PgPool` / `sqlx::SqlitePool`.
- **Transaction support** -- Scoped transactions for multi-table writes (e.g., survivor detection
plus alert creation).
- **Time-series optimisation** -- Partitioned tables and retention policies for high-frequency CSI
frame storage.
### Planned feature flags
| Flag | Default | Description |
|------------|---------|-------------|
| `postgres` | no | Enable PostgreSQL backend |
| `sqlite` | yes | Enable SQLite backend |
| `redis` | no | Enable Redis caching layer |
## Quick Start
```rust
// Intended usage (not yet implemented)
use wifi_densepose_db::{Database, PoseRepository};
use wifi_densepose_core::PoseEstimate;
#[tokio::main]
async fn main() -> anyhow::Result<()> {
let db = Database::connect("sqlite://data/wifi-densepose.db").await?;
db.run_migrations().await?;
let repo = PoseRepository::new(db.pool());
// Store a pose estimate
repo.insert(&pose_estimate).await?;
// Query recent poses
let recent = repo.find_recent(10).await?;
println!("Last 10 poses: {:?}", recent);
Ok(())
}
```
## Planned Schema
```sql
-- Core tables
CREATE TABLE csi_frames (
id UUID PRIMARY KEY,
session_id UUID NOT NULL,
timestamp TIMESTAMPTZ NOT NULL,
subcarriers BYTEA NOT NULL,
antenna_id INTEGER NOT NULL
);
CREATE TABLE pose_estimates (
id UUID PRIMARY KEY,
frame_id UUID REFERENCES csi_frames(id),
timestamp TIMESTAMPTZ NOT NULL,
keypoints JSONB NOT NULL,
confidence REAL NOT NULL
);
CREATE TABLE scan_sessions (
id UUID PRIMARY KEY,
started_at TIMESTAMPTZ NOT NULL,
ended_at TIMESTAMPTZ,
config JSONB NOT NULL
);
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-core`](../wifi-densepose-core) | `DataStore` trait definition |
| [`wifi-densepose-config`](../wifi-densepose-config) | Database connection configuration |
| [`wifi-densepose-api`](../wifi-densepose-api) | REST API (consumer) |
| [`wifi-densepose-mat`](../wifi-densepose-mat) | Disaster detection (consumer) |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | CSI signal processing |
## License
MIT OR Apache-2.0

View File

@@ -4,7 +4,12 @@ version.workspace = true
edition.workspace = true
description = "Hardware interface abstractions for WiFi CSI sensors (ESP32, Intel 5300, Atheros)"
license = "MIT OR Apache-2.0"
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository = "https://github.com/ruvnet/wifi-densepose"
documentation = "https://docs.rs/wifi-densepose-hardware"
keywords = ["wifi", "esp32", "csi", "hardware", "sensor"]
categories = ["hardware-support", "science"]
readme = "README.md"
[features]
default = ["std"]

View File

@@ -0,0 +1,82 @@
# wifi-densepose-hardware
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-hardware.svg)](https://crates.io/crates/wifi-densepose-hardware)
[![Documentation](https://docs.rs/wifi-densepose-hardware/badge.svg)](https://docs.rs/wifi-densepose-hardware)
[![License](https://img.shields.io/crates/l/wifi-densepose-hardware.svg)](LICENSE)
Hardware interface abstractions for WiFi CSI sensors (ESP32, Intel 5300, Atheros).
## Overview
`wifi-densepose-hardware` provides platform-agnostic parsers for WiFi CSI data from multiple
hardware sources. All parsing operates on byte buffers with no C FFI or hardware dependencies at
compile time, making the crate fully portable and deterministic -- the same bytes in always produce
the same parsed output.
## Features
- **ESP32 binary parser** -- Parses ADR-018 binary CSI frames streamed over UDP from ESP32 and
ESP32-S3 devices.
- **UDP aggregator** -- Receives and aggregates CSI frames from multiple ESP32 nodes (ADR-018
Layer 2). Provided as a standalone binary.
- **Bridge** -- Converts hardware `CsiFrame` into the `CsiData` format expected by the detection
pipeline (ADR-018 Layer 3).
- **No mock data** -- Parsers either parse real bytes or return explicit `ParseError` values.
There are no synthetic fallbacks.
- **Pure byte-buffer parsing** -- No FFI to ESP-IDF or kernel modules. Safe to compile and test
on any platform.
### Feature flags
| Flag | Default | Description |
|-------------|---------|--------------------------------------------|
| `std` | yes | Standard library support |
| `esp32` | no | ESP32 serial CSI frame parsing |
| `intel5300` | no | Intel 5300 CSI Tool log parsing |
| `linux-wifi`| no | Linux WiFi interface for commodity sensing |
## Quick Start
```rust
use wifi_densepose_hardware::{CsiFrame, Esp32CsiParser, ParseError};
// Parse ESP32 CSI data from raw UDP bytes
let raw_bytes: &[u8] = &[/* ADR-018 binary frame */];
match Esp32CsiParser::parse_frame(raw_bytes) {
Ok((frame, consumed)) => {
println!("Parsed {} subcarriers ({} bytes)",
frame.subcarrier_count(), consumed);
let (amplitudes, phases) = frame.to_amplitude_phase();
// Feed into detection pipeline...
}
Err(ParseError::InsufficientData { needed, got }) => {
eprintln!("Need {} bytes, got {}", needed, got);
}
Err(e) => eprintln!("Parse error: {}", e),
}
```
## Architecture
```text
wifi-densepose-hardware/src/
lib.rs -- Re-exports: CsiFrame, Esp32CsiParser, ParseError, CsiData
csi_frame.rs -- CsiFrame, CsiMetadata, SubcarrierData, Bandwidth, AntennaConfig
esp32_parser.rs -- Esp32CsiParser (ADR-018 binary protocol)
error.rs -- ParseError
bridge.rs -- CsiData bridge to detection pipeline
aggregator/ -- UDP multi-node frame aggregator (binary)
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-core`](../wifi-densepose-core) | Foundation types (`CsiFrame` definitions) |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | Consumes parsed CSI data for processing |
| [`wifi-densepose-mat`](../wifi-densepose-mat) | Uses hardware adapters for disaster detection |
| [`wifi-densepose-vitals`](../wifi-densepose-vitals) | Vital sign extraction from parsed frames |
## License
MIT OR Apache-2.0

View File

@@ -2,12 +2,14 @@
name = "wifi-densepose-mat"
version = "0.1.0"
edition = "2021"
authors = ["WiFi-DensePose Team"]
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
description = "Mass Casualty Assessment Tool - WiFi-based disaster survivor detection"
license = "MIT OR Apache-2.0"
repository = "https://github.com/ruvnet/wifi-densepose"
documentation = "https://docs.rs/wifi-densepose-mat"
keywords = ["wifi", "disaster", "rescue", "detection", "vital-signs"]
categories = ["science", "algorithms"]
readme = "README.md"
[features]
default = ["std", "api", "ruvector"]
@@ -22,9 +24,9 @@ serde = ["dep:serde", "chrono/serde", "geo/use-serde"]
[dependencies]
# Workspace dependencies
wifi-densepose-core = { path = "../wifi-densepose-core" }
wifi-densepose-signal = { path = "../wifi-densepose-signal" }
wifi-densepose-nn = { path = "../wifi-densepose-nn" }
wifi-densepose-core = { version = "0.1.0", path = "../wifi-densepose-core" }
wifi-densepose-signal = { version = "0.1.0", path = "../wifi-densepose-signal" }
wifi-densepose-nn = { version = "0.1.0", path = "../wifi-densepose-nn" }
ruvector-solver = { workspace = true, optional = true }
ruvector-temporal-tensor = { workspace = true, optional = true }

View File

@@ -0,0 +1,114 @@
# wifi-densepose-mat
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-mat.svg)](https://crates.io/crates/wifi-densepose-mat)
[![Documentation](https://docs.rs/wifi-densepose-mat/badge.svg)](https://docs.rs/wifi-densepose-mat)
[![License](https://img.shields.io/crates/l/wifi-densepose-mat.svg)](LICENSE)
Mass Casualty Assessment Tool for WiFi-based disaster survivor detection and localization.
## Overview
`wifi-densepose-mat` uses WiFi Channel State Information (CSI) to detect and locate survivors
trapped in rubble, debris, or collapsed structures. The crate follows Domain-Driven Design (DDD)
with event sourcing, organized into three bounded contexts -- detection, localization, and
alerting -- plus a machine learning layer for debris penetration modeling and vital signs
classification.
Use cases include earthquake search and rescue, building collapse response, avalanche victim
location, flood rescue operations, and mine collapse detection.
## Features
- **Vital signs detection** -- Breathing patterns, heartbeat signatures, and movement
classification with ensemble classifier combining all three modalities.
- **Survivor localization** -- 3D position estimation through debris via triangulation, depth
estimation, and position fusion.
- **Triage classification** -- Automatic START protocol-compatible triage with priority-based
alert generation and dispatch.
- **Event sourcing** -- All state changes emitted as domain events (`DetectionEvent`,
`AlertEvent`, `ZoneEvent`) stored in a pluggable `EventStore`.
- **ML debris model** -- Debris material classification, signal attenuation prediction, and
uncertainty-aware vital signs classification.
- **REST + WebSocket API** -- `axum`-based HTTP API for real-time monitoring dashboards.
- **ruvector integration** -- `ruvector-solver` for triangulation math, `ruvector-temporal-tensor`
for compressed CSI buffering.
### Feature flags
| Flag | Default | Description |
|---------------|---------|----------------------------------------------------|
| `std` | yes | Standard library support |
| `api` | yes | REST + WebSocket API (enables serde for all types) |
| `ruvector` | yes | ruvector-solver and ruvector-temporal-tensor |
| `serde` | no | Serialization (also enabled by `api`) |
| `portable` | no | Low-power mode for field-deployable devices |
| `distributed` | no | Multi-node distributed scanning |
| `drone` | no | Drone-mounted scanning (implies `distributed`) |
## Quick Start
```rust
use wifi_densepose_mat::{
DisasterResponse, DisasterConfig, DisasterType,
ScanZone, ZoneBounds,
};
#[tokio::main]
async fn main() -> anyhow::Result<()> {
let config = DisasterConfig::builder()
.disaster_type(DisasterType::Earthquake)
.sensitivity(0.8)
.build();
let mut response = DisasterResponse::new(config);
// Define scan zone
let zone = ScanZone::new(
"Building A - North Wing",
ZoneBounds::rectangle(0.0, 0.0, 50.0, 30.0),
);
response.add_zone(zone)?;
// Start scanning
response.start_scanning().await?;
Ok(())
}
```
## Architecture
```text
wifi-densepose-mat/src/
lib.rs -- DisasterResponse coordinator, config builder, MatError
domain/
survivor.rs -- Survivor aggregate root
disaster_event.rs -- DisasterEvent, DisasterType
scan_zone.rs -- ScanZone, ZoneBounds
alert.rs -- Alert, Priority
vital_signs.rs -- VitalSignsReading, BreathingPattern, HeartbeatSignature
triage.rs -- TriageStatus, TriageCalculator (START protocol)
coordinates.rs -- Coordinates3D, LocationUncertainty
events.rs -- DomainEvent, EventStore, InMemoryEventStore
detection/ -- BreathingDetector, HeartbeatDetector, MovementClassifier, EnsembleClassifier
localization/ -- Triangulator, DepthEstimator, PositionFuser
alerting/ -- AlertGenerator, AlertDispatcher, TriageService
ml/ -- DebrisPenetrationModel, VitalSignsClassifier, UncertaintyEstimate
api/ -- axum REST + WebSocket router
integration/ -- SignalAdapter, NeuralAdapter, HardwareAdapter
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-core`](../wifi-densepose-core) | Foundation types and traits |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | CSI preprocessing for detection pipeline |
| [`wifi-densepose-nn`](../wifi-densepose-nn) | Neural inference for ML models |
| [`wifi-densepose-hardware`](../wifi-densepose-hardware) | Hardware sensor data ingestion |
| [`ruvector-solver`](https://crates.io/crates/ruvector-solver) | Triangulation and position math |
| [`ruvector-temporal-tensor`](https://crates.io/crates/ruvector-temporal-tensor) | Compressed CSI buffering |
## License
MIT OR Apache-2.0

View File

@@ -9,6 +9,7 @@ documentation.workspace = true
keywords = ["neural-network", "onnx", "inference", "densepose", "deep-learning"]
categories = ["science", "computer-vision"]
description = "Neural network inference for WiFi-DensePose pose estimation"
readme = "README.md"
[features]
default = ["onnx"]
@@ -46,7 +47,6 @@ tokio = { workspace = true, features = ["sync", "rt"] }
# Additional utilities
parking_lot = "0.12"
once_cell = "1.19"
memmap2 = "0.9"
[dev-dependencies]

View File

@@ -0,0 +1,89 @@
# wifi-densepose-nn
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-nn.svg)](https://crates.io/crates/wifi-densepose-nn)
[![Documentation](https://docs.rs/wifi-densepose-nn/badge.svg)](https://docs.rs/wifi-densepose-nn)
[![License](https://img.shields.io/crates/l/wifi-densepose-nn.svg)](LICENSE)
Multi-backend neural network inference for WiFi-based DensePose estimation.
## Overview
`wifi-densepose-nn` provides the inference engine that maps processed WiFi CSI features to
DensePose body surface predictions. It supports three backends -- ONNX Runtime (default),
PyTorch via `tch-rs`, and Candle -- so models can run on CPU, CUDA GPU, or TensorRT depending
on the deployment target.
The crate implements two key neural components:
- **DensePose Head** -- Predicts 24 body part segmentation masks and per-part UV coordinate
regression.
- **Modality Translator** -- Translates CSI feature embeddings into visual feature space,
bridging the domain gap between WiFi signals and image-based pose estimation.
## Features
- **ONNX Runtime backend** (default) -- Load and run `.onnx` models with CPU or GPU execution
providers.
- **PyTorch backend** (`tch-backend`) -- Native PyTorch inference via libtorch FFI.
- **Candle backend** (`candle-backend`) -- Pure-Rust inference with `candle-core` and
`candle-nn`.
- **CUDA acceleration** (`cuda`) -- GPU execution for supported backends.
- **TensorRT optimization** (`tensorrt`) -- INT8/FP16 optimized inference via ONNX Runtime.
- **Batched inference** -- Process multiple CSI frames in a single forward pass.
- **Model caching** -- Memory-mapped model weights via `memmap2`.
### Feature flags
| Flag | Default | Description |
|-------------------|---------|-------------------------------------|
| `onnx` | yes | ONNX Runtime backend |
| `tch-backend` | no | PyTorch (tch-rs) backend |
| `candle-backend` | no | Candle pure-Rust backend |
| `cuda` | no | CUDA GPU acceleration |
| `tensorrt` | no | TensorRT via ONNX Runtime |
| `all-backends` | no | Enable onnx + tch + candle together |
## Quick Start
```rust
use wifi_densepose_nn::{InferenceEngine, DensePoseConfig, OnnxBackend};
// Create inference engine with ONNX backend
let config = DensePoseConfig::default();
let backend = OnnxBackend::from_file("model.onnx")?;
let engine = InferenceEngine::new(backend, config)?;
// Run inference on a CSI feature tensor
let input = ndarray::Array4::zeros((1, 256, 64, 64));
let output = engine.infer(&input)?;
println!("Body parts: {}", output.body_parts.shape()[1]); // 24
```
## Architecture
```text
wifi-densepose-nn/src/
lib.rs -- Re-exports, constants (NUM_BODY_PARTS=24), prelude
densepose.rs -- DensePoseHead, DensePoseConfig, DensePoseOutput
inference.rs -- Backend trait, InferenceEngine, InferenceOptions
onnx.rs -- OnnxBackend, OnnxSession (feature-gated)
tensor.rs -- Tensor, TensorShape utilities
translator.rs -- ModalityTranslator (CSI -> visual space)
error.rs -- NnError, NnResult
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-core`](../wifi-densepose-core) | Foundation types and `NeuralInference` trait |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | Produces CSI features consumed by inference |
| [`wifi-densepose-train`](../wifi-densepose-train) | Trains the models this crate loads |
| [`ort`](https://crates.io/crates/ort) | ONNX Runtime Rust bindings |
| [`tch`](https://crates.io/crates/tch) | PyTorch Rust bindings |
| [`candle-core`](https://crates.io/crates/candle-core) | Hugging Face pure-Rust ML framework |
## License
MIT OR Apache-2.0

View File

@@ -4,6 +4,12 @@ version.workspace = true
edition.workspace = true
description = "Lightweight Axum server for WiFi sensing UI with RuVector signal processing"
license.workspace = true
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository.workspace = true
documentation = "https://docs.rs/wifi-densepose-sensing-server"
keywords = ["wifi", "sensing", "server", "websocket", "csi"]
categories = ["web-programming::http-server", "science"]
readme = "README.md"
[lib]
name = "wifi_densepose_sensing_server"
@@ -35,7 +41,7 @@ chrono = { version = "0.4", features = ["serde"] }
clap = { workspace = true }
# Multi-BSSID WiFi scanning pipeline (ADR-022 Phase 3)
wifi-densepose-wifiscan = { path = "../wifi-densepose-wifiscan" }
wifi-densepose-wifiscan = { version = "0.1.0", path = "../wifi-densepose-wifiscan" }
[dev-dependencies]
tempfile = "3.10"

View File

@@ -0,0 +1,124 @@
# wifi-densepose-sensing-server
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-sensing-server.svg)](https://crates.io/crates/wifi-densepose-sensing-server)
[![Documentation](https://docs.rs/wifi-densepose-sensing-server/badge.svg)](https://docs.rs/wifi-densepose-sensing-server)
[![License](https://img.shields.io/crates/l/wifi-densepose-sensing-server.svg)](LICENSE)
Lightweight Axum server for real-time WiFi sensing with RuVector signal processing.
## Overview
`wifi-densepose-sensing-server` is the operational backend for WiFi-DensePose. It receives raw CSI
frames from ESP32 hardware over UDP, runs them through the RuVector-powered signal processing
pipeline, and broadcasts processed sensing updates to browser clients via WebSocket. A built-in
static file server hosts the sensing UI on the same port.
The crate ships both a library (`wifi_densepose_sensing_server`) exposing the training and inference
modules, and a binary (`sensing-server`) that starts the full server stack.
Integrates [wifi-densepose-wifiscan](../wifi-densepose-wifiscan) for multi-BSSID WiFi scanning
per ADR-022 Phase 3.
## Features
- **UDP CSI ingestion** -- Receives ESP32 CSI frames on port 5005 and parses them into the internal
`CsiFrame` representation.
- **Vital sign detection** -- Pure-Rust FFT-based breathing rate (0.1--0.5 Hz) and heart rate
(0.67--2.0 Hz) estimation from CSI amplitude time series (ADR-021).
- **RVF container** -- Standalone binary container format for packaging model weights, metadata, and
configuration into a single `.rvf` file with 64-byte aligned segments.
- **RVF pipeline** -- Progressive model loading with streaming segment decoding.
- **Graph Transformer** -- Cross-attention bottleneck between antenna-space CSI features and the
COCO 17-keypoint body graph, followed by GCN message passing (ADR-023 Phase 2). Pure `std`, no ML
dependencies.
- **SONA adaptation** -- LoRA + EWC++ online adaptation for environment drift without catastrophic
forgetting (ADR-023 Phase 5).
- **Contrastive CSI embeddings** -- Self-supervised SimCLR-style pretraining with InfoNCE loss,
projection head, fingerprint indexing, and cross-modal pose alignment (ADR-024).
- **Sparse inference** -- Activation profiling, sparse matrix-vector multiply, INT8/FP16
quantization, and a full sparse inference engine for edge deployment (ADR-023 Phase 6).
- **Dataset pipeline** -- Training dataset loading and batching.
- **Multi-BSSID scanning** -- Windows `netsh` integration for BSSID discovery via
`wifi-densepose-wifiscan` (ADR-022).
- **WebSocket broadcast** -- Real-time sensing updates pushed to all connected clients at
`ws://localhost:8765/ws/sensing`.
- **Static file serving** -- Hosts the sensing UI on port 8080 with CORS headers.
## Modules
| Module | Description |
|--------|-------------|
| `vital_signs` | Breathing and heart rate extraction via FFT spectral analysis |
| `rvf_container` | RVF binary format builder and reader |
| `rvf_pipeline` | Progressive model loading from RVF containers |
| `graph_transformer` | Graph Transformer + GCN for CSI-to-pose estimation |
| `trainer` | Training loop orchestration |
| `dataset` | Training data loading and batching |
| `sona` | LoRA adapters and EWC++ continual learning |
| `sparse_inference` | Neuron profiling, sparse matmul, INT8/FP16 quantization |
| `embedding` | Contrastive CSI embedding model and fingerprint index |
## Quick Start
```bash
# Build the server
cargo build -p wifi-densepose-sensing-server
# Run with default settings (HTTP :8080, UDP :5005, WS :8765)
cargo run -p wifi-densepose-sensing-server
# Run with custom ports
cargo run -p wifi-densepose-sensing-server -- \
--http-port 9000 \
--udp-port 5005 \
--static-dir ./ui
```
### Using as a library
```rust
use wifi_densepose_sensing_server::vital_signs::VitalSignDetector;
// Create a detector with 20 Hz sample rate
let mut detector = VitalSignDetector::new(20.0);
// Feed CSI amplitude samples
for amplitude in csi_amplitudes.iter() {
detector.push_sample(*amplitude);
}
// Extract vital signs
if let Some(vitals) = detector.detect() {
println!("Breathing: {:.1} BPM", vitals.breathing_rate_bpm);
println!("Heart rate: {:.0} BPM", vitals.heart_rate_bpm);
}
```
## Architecture
```text
ESP32 ──UDP:5005──> [ CSI Receiver ]
|
[ Signal Pipeline ]
(vital_signs, graph_transformer, sona)
|
[ WebSocket Broadcast ]
|
Browser <──WS:8765── [ Axum Server :8080 ] ──> Static UI files
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-wifiscan`](../wifi-densepose-wifiscan) | Multi-BSSID WiFi scanning (ADR-022) |
| [`wifi-densepose-core`](../wifi-densepose-core) | Shared types and traits |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | CSI signal processing algorithms |
| [`wifi-densepose-hardware`](../wifi-densepose-hardware) | ESP32 hardware interfaces |
| [`wifi-densepose-wasm`](../wifi-densepose-wasm) | Browser WASM bindings for the sensing UI |
| [`wifi-densepose-train`](../wifi-densepose-train) | Full training pipeline with ruvector |
| [`wifi-densepose-mat`](../wifi-densepose-mat) | Disaster detection module |
## License
MIT OR Apache-2.0

File diff suppressed because it is too large Load Diff

View File

@@ -486,6 +486,16 @@ impl CsiToPoseTransformer {
}
pub fn config(&self) -> &TransformerConfig { &self.config }
/// Extract body-part feature embeddings without regression heads.
/// Returns 17 vectors of dimension d_model (same as forward() but stops
/// before xyz_head/conf_head).
pub fn embed(&self, csi_features: &[Vec<f32>]) -> Vec<Vec<f32>> {
let embedded: Vec<Vec<f32>> = csi_features.iter()
.map(|f| self.csi_embed.forward(f)).collect();
let attended = self.cross_attn.forward(&self.keypoint_queries, &embedded, &embedded);
self.gnn.forward(&attended)
}
/// Collect all trainable parameters into a flat vec.
///
/// Layout: csi_embed | keypoint_queries (flat) | cross_attn | gnn | xyz_head | conf_head

View File

@@ -12,3 +12,4 @@ pub mod trainer;
pub mod dataset;
pub mod sona;
pub mod sparse_inference;
pub mod embedding;

View File

@@ -13,7 +13,7 @@ mod rvf_pipeline;
mod vital_signs;
// Training pipeline modules (exposed via lib.rs)
use wifi_densepose_sensing_server::{graph_transformer, trainer, dataset};
use wifi_densepose_sensing_server::{graph_transformer, trainer, dataset, embedding};
use std::collections::VecDeque;
use std::net::SocketAddr;
@@ -122,6 +122,22 @@ struct Args {
/// Directory for training checkpoints
#[arg(long, value_name = "DIR")]
checkpoint_dir: Option<PathBuf>,
/// Run self-supervised contrastive pretraining (ADR-024)
#[arg(long)]
pretrain: bool,
/// Number of pretraining epochs (default 50)
#[arg(long, default_value = "50")]
pretrain_epochs: usize,
/// Extract embeddings mode: load model and extract CSI embeddings
#[arg(long)]
embed: bool,
/// Build fingerprint index from embeddings (env|activity|temporal|person)
#[arg(long, value_name = "TYPE")]
build_index: Option<String>,
}
// ── Data types ───────────────────────────────────────────────────────────────
@@ -1536,6 +1552,221 @@ async fn main() {
return;
}
// Handle --pretrain mode: self-supervised contrastive pretraining (ADR-024)
if args.pretrain {
eprintln!("=== WiFi-DensePose Contrastive Pretraining (ADR-024) ===");
let ds_path = args.dataset.clone().unwrap_or_else(|| PathBuf::from("data"));
let source = match args.dataset_type.as_str() {
"wipose" => dataset::DataSource::WiPose(ds_path.clone()),
_ => dataset::DataSource::MmFi(ds_path.clone()),
};
let pipeline = dataset::DataPipeline::new(dataset::DataConfig {
source, ..Default::default()
});
// Generate synthetic or load real CSI windows
let generate_synthetic_windows = || -> Vec<Vec<Vec<f32>>> {
(0..50).map(|i| {
(0..4).map(|a| {
(0..56).map(|s| ((i * 7 + a * 13 + s) as f32 * 0.31).sin() * 0.5).collect()
}).collect()
}).collect()
};
let csi_windows: Vec<Vec<Vec<f32>>> = match pipeline.load() {
Ok(s) if !s.is_empty() => {
eprintln!("Loaded {} samples from {}", s.len(), ds_path.display());
s.into_iter().map(|s| s.csi_window).collect()
}
_ => {
eprintln!("Using synthetic data for pretraining.");
generate_synthetic_windows()
}
};
let n_subcarriers = csi_windows.first()
.and_then(|w| w.first())
.map(|f| f.len())
.unwrap_or(56);
let tf_config = graph_transformer::TransformerConfig {
n_subcarriers, n_keypoints: 17, d_model: 64, n_heads: 4, n_gnn_layers: 2,
};
let transformer = graph_transformer::CsiToPoseTransformer::new(tf_config);
eprintln!("Transformer params: {}", transformer.param_count());
let trainer_config = trainer::TrainerConfig {
epochs: args.pretrain_epochs,
batch_size: 8, lr: 0.001, warmup_epochs: 2, min_lr: 1e-6,
early_stop_patience: args.pretrain_epochs + 1,
pretrain_temperature: 0.07,
..Default::default()
};
let mut t = trainer::Trainer::with_transformer(trainer_config, transformer);
let e_config = embedding::EmbeddingConfig {
d_model: 64, d_proj: 128, temperature: 0.07, normalize: true,
};
let mut projection = embedding::ProjectionHead::new(e_config.clone());
let augmenter = embedding::CsiAugmenter::new();
eprintln!("Starting contrastive pretraining for {} epochs...", args.pretrain_epochs);
let start = std::time::Instant::now();
for epoch in 0..args.pretrain_epochs {
let loss = t.pretrain_epoch(&csi_windows, &augmenter, &mut projection, 0.07, epoch);
if epoch % 10 == 0 || epoch == args.pretrain_epochs - 1 {
eprintln!(" Epoch {epoch}: contrastive loss = {loss:.4}");
}
}
let elapsed = start.elapsed().as_secs_f64();
eprintln!("Pretraining complete in {elapsed:.1}s");
// Save pretrained model as RVF with embedding segment
if let Some(ref save_path) = args.save_rvf {
eprintln!("Saving pretrained model to RVF: {}", save_path.display());
t.sync_transformer_weights();
let weights = t.params().to_vec();
let mut proj_weights = Vec::new();
projection.flatten_into(&mut proj_weights);
let mut builder = RvfBuilder::new();
builder.add_manifest(
"wifi-densepose-pretrained",
env!("CARGO_PKG_VERSION"),
"WiFi DensePose contrastive pretrained model (ADR-024)",
);
builder.add_weights(&weights);
builder.add_embedding(
&serde_json::json!({
"d_model": e_config.d_model,
"d_proj": e_config.d_proj,
"temperature": e_config.temperature,
"normalize": e_config.normalize,
"pretrain_epochs": args.pretrain_epochs,
}),
&proj_weights,
);
match builder.write_to_file(save_path) {
Ok(()) => eprintln!("RVF saved ({} transformer + {} projection params)",
weights.len(), proj_weights.len()),
Err(e) => eprintln!("Failed to save RVF: {e}"),
}
}
return;
}
// Handle --embed mode: extract embeddings from CSI data
if args.embed {
eprintln!("=== WiFi-DensePose Embedding Extraction (ADR-024) ===");
let model_path = match &args.model {
Some(p) => p.clone(),
None => {
eprintln!("Error: --embed requires --model <path> to a pretrained .rvf file");
std::process::exit(1);
}
};
let reader = match RvfReader::from_file(&model_path) {
Ok(r) => r,
Err(e) => { eprintln!("Failed to load model: {e}"); std::process::exit(1); }
};
let weights = reader.weights().unwrap_or_default();
let (embed_config_json, proj_weights) = reader.embedding().unwrap_or_else(|| {
eprintln!("Warning: no embedding segment in RVF, using defaults");
(serde_json::json!({"d_model":64,"d_proj":128,"temperature":0.07,"normalize":true}), Vec::new())
});
let d_model = embed_config_json["d_model"].as_u64().unwrap_or(64) as usize;
let d_proj = embed_config_json["d_proj"].as_u64().unwrap_or(128) as usize;
let tf_config = graph_transformer::TransformerConfig {
n_subcarriers: 56, n_keypoints: 17, d_model, n_heads: 4, n_gnn_layers: 2,
};
let e_config = embedding::EmbeddingConfig {
d_model, d_proj, temperature: 0.07, normalize: true,
};
let mut extractor = embedding::EmbeddingExtractor::new(tf_config, e_config.clone());
// Load transformer weights
if !weights.is_empty() {
if let Err(e) = extractor.transformer.unflatten_weights(&weights) {
eprintln!("Warning: failed to load transformer weights: {e}");
}
}
// Load projection weights
if !proj_weights.is_empty() {
let (proj, _) = embedding::ProjectionHead::unflatten_from(&proj_weights, &e_config);
extractor.projection = proj;
}
// Load dataset and extract embeddings
let _ds_path = args.dataset.clone().unwrap_or_else(|| PathBuf::from("data"));
let csi_windows: Vec<Vec<Vec<f32>>> = (0..10).map(|i| {
(0..4).map(|a| {
(0..56).map(|s| ((i * 7 + a * 13 + s) as f32 * 0.31).sin() * 0.5).collect()
}).collect()
}).collect();
eprintln!("Extracting embeddings from {} CSI windows...", csi_windows.len());
let embeddings = extractor.extract_batch(&csi_windows);
for (i, emb) in embeddings.iter().enumerate() {
let norm: f32 = emb.iter().map(|x| x * x).sum::<f32>().sqrt();
eprintln!(" Window {i}: {d_proj}-dim embedding, ||e|| = {norm:.4}");
}
eprintln!("Extracted {} embeddings of dimension {d_proj}", embeddings.len());
return;
}
// Handle --build-index mode: build a fingerprint index from embeddings
if let Some(ref index_type_str) = args.build_index {
eprintln!("=== WiFi-DensePose Fingerprint Index Builder (ADR-024) ===");
let index_type = match index_type_str.as_str() {
"env" | "environment" => embedding::IndexType::EnvironmentFingerprint,
"activity" => embedding::IndexType::ActivityPattern,
"temporal" => embedding::IndexType::TemporalBaseline,
"person" => embedding::IndexType::PersonTrack,
_ => {
eprintln!("Unknown index type '{}'. Use: env, activity, temporal, person", index_type_str);
std::process::exit(1);
}
};
let tf_config = graph_transformer::TransformerConfig::default();
let e_config = embedding::EmbeddingConfig::default();
let mut extractor = embedding::EmbeddingExtractor::new(tf_config, e_config);
// Generate synthetic CSI windows for demo
let csi_windows: Vec<Vec<Vec<f32>>> = (0..20).map(|i| {
(0..4).map(|a| {
(0..56).map(|s| ((i * 7 + a * 13 + s) as f32 * 0.31).sin() * 0.5).collect()
}).collect()
}).collect();
let mut index = embedding::FingerprintIndex::new(index_type);
for (i, window) in csi_windows.iter().enumerate() {
let emb = extractor.extract(window);
index.insert(emb, format!("window_{i}"), i as u64 * 100);
}
eprintln!("Built {:?} index with {} entries", index_type, index.len());
// Test a query
let query_emb = extractor.extract(&csi_windows[0]);
let results = index.search(&query_emb, 5);
eprintln!("Top-5 nearest to window_0:");
for r in &results {
eprintln!(" entry={}, distance={:.4}, metadata={}", r.entry, r.distance, r.metadata);
}
return;
}
// Handle --train mode: train a model and exit
if args.train {
eprintln!("=== WiFi-DensePose Training Mode ===");
@@ -1860,6 +2091,8 @@ async fn main() {
// Stream endpoints
.route("/api/v1/stream/status", get(stream_status))
.route("/api/v1/stream/pose", get(ws_pose_handler))
// Sensing WebSocket on the HTTP port so the UI can reach it without a second port
.route("/ws/sensing", get(ws_sensing_handler))
// Static UI files
.nest_service("/ui", ServeDir::new(&ui_path))
.layer(SetResponseHeaderLayer::overriding(

View File

@@ -37,6 +37,10 @@ const SEG_META: u8 = 0x07;
const SEG_WITNESS: u8 = 0x0A;
/// Domain profile declarations.
const SEG_PROFILE: u8 = 0x0B;
/// Contrastive embedding model weights and configuration (ADR-024).
pub const SEG_EMBED: u8 = 0x0C;
/// LoRA adaptation profile (named LoRA weight sets for environment-specific fine-tuning).
pub const SEG_LORA: u8 = 0x0D;
// ── Pure-Rust CRC32 (IEEE 802.3 polynomial) ────────────────────────────────
@@ -304,6 +308,35 @@ impl RvfBuilder {
self.push_segment(seg_type, payload);
}
/// Add a named LoRA adaptation profile (ADR-024 Phase 7).
///
/// Segment format: `[name_len: u16 LE][name_bytes: UTF-8][weights: f32 LE...]`
pub fn add_lora_profile(&mut self, name: &str, lora_weights: &[f32]) {
let name_bytes = name.as_bytes();
let name_len = name_bytes.len() as u16;
let mut payload = Vec::with_capacity(2 + name_bytes.len() + lora_weights.len() * 4);
payload.extend_from_slice(&name_len.to_le_bytes());
payload.extend_from_slice(name_bytes);
for &w in lora_weights {
payload.extend_from_slice(&w.to_le_bytes());
}
self.push_segment(SEG_LORA, &payload);
}
/// Add contrastive embedding config and projection head weights (ADR-024).
/// Serializes embedding config as JSON followed by projection weights as f32 LE.
pub fn add_embedding(&mut self, config_json: &serde_json::Value, proj_weights: &[f32]) {
let config_bytes = serde_json::to_vec(config_json).unwrap_or_default();
let config_len = config_bytes.len() as u32;
let mut payload = Vec::with_capacity(4 + config_bytes.len() + proj_weights.len() * 4);
payload.extend_from_slice(&config_len.to_le_bytes());
payload.extend_from_slice(&config_bytes);
for &w in proj_weights {
payload.extend_from_slice(&w.to_le_bytes());
}
self.push_segment(SEG_EMBED, &payload);
}
/// Add witness/proof data as a Witness segment.
pub fn add_witness(&mut self, training_hash: &str, metrics: &serde_json::Value) {
let witness = serde_json::json!({
@@ -528,6 +561,73 @@ impl RvfReader {
.and_then(|data| serde_json::from_slice(data).ok())
}
/// Parse and return the embedding config JSON and projection weights, if present.
pub fn embedding(&self) -> Option<(serde_json::Value, Vec<f32>)> {
let data = self.find_segment(SEG_EMBED)?;
if data.len() < 4 {
return None;
}
let config_len = u32::from_le_bytes([data[0], data[1], data[2], data[3]]) as usize;
if 4 + config_len > data.len() {
return None;
}
let config: serde_json::Value = serde_json::from_slice(&data[4..4 + config_len]).ok()?;
let weight_data = &data[4 + config_len..];
if weight_data.len() % 4 != 0 {
return None;
}
let weights: Vec<f32> = weight_data
.chunks_exact(4)
.map(|c| f32::from_le_bytes([c[0], c[1], c[2], c[3]]))
.collect();
Some((config, weights))
}
/// Retrieve a named LoRA profile's weights, if present.
/// Returns None if no profile with the given name exists.
pub fn lora_profile(&self, name: &str) -> Option<Vec<f32>> {
for (h, payload) in &self.segments {
if h.seg_type != SEG_LORA || payload.len() < 2 {
continue;
}
let name_len = u16::from_le_bytes([payload[0], payload[1]]) as usize;
if 2 + name_len > payload.len() {
continue;
}
let seg_name = std::str::from_utf8(&payload[2..2 + name_len]).ok()?;
if seg_name == name {
let weight_data = &payload[2 + name_len..];
if weight_data.len() % 4 != 0 {
return None;
}
let weights: Vec<f32> = weight_data
.chunks_exact(4)
.map(|c| f32::from_le_bytes([c[0], c[1], c[2], c[3]]))
.collect();
return Some(weights);
}
}
None
}
/// List all stored LoRA profile names.
pub fn lora_profiles(&self) -> Vec<String> {
let mut names = Vec::new();
for (h, payload) in &self.segments {
if h.seg_type != SEG_LORA || payload.len() < 2 {
continue;
}
let name_len = u16::from_le_bytes([payload[0], payload[1]]) as usize;
if 2 + name_len > payload.len() {
continue;
}
if let Ok(name) = std::str::from_utf8(&payload[2..2 + name_len]) {
names.push(name.to_string());
}
}
names
}
/// Number of segments in the container.
pub fn segment_count(&self) -> usize {
self.segments.len()
@@ -911,4 +1011,91 @@ mod tests {
assert!(!info.has_quant_info);
assert!(!info.has_witness);
}
#[test]
fn test_rvf_embedding_segment_roundtrip() {
let config = serde_json::json!({
"d_model": 64,
"d_proj": 128,
"temperature": 0.07,
"normalize": true,
});
let weights: Vec<f32> = (0..256).map(|i| (i as f32 * 0.13).sin()).collect();
let mut builder = RvfBuilder::new();
builder.add_manifest("embed-test", "1.0", "embedding test");
builder.add_embedding(&config, &weights);
let data = builder.build();
let reader = RvfReader::from_bytes(&data).unwrap();
assert_eq!(reader.segment_count(), 2);
let (decoded_config, decoded_weights) = reader.embedding()
.expect("embedding segment should be present");
assert_eq!(decoded_config["d_model"], 64);
assert_eq!(decoded_config["d_proj"], 128);
assert!((decoded_config["temperature"].as_f64().unwrap() - 0.07).abs() < 1e-4);
assert_eq!(decoded_weights.len(), weights.len());
for (a, b) in decoded_weights.iter().zip(weights.iter()) {
assert_eq!(a.to_bits(), b.to_bits(), "weight mismatch");
}
}
// ── Phase 7: RVF LoRA profile tests ───────────────────────────────
#[test]
fn test_rvf_lora_profile_roundtrip() {
let weights: Vec<f32> = (0..100).map(|i| (i as f32 * 0.37).sin()).collect();
let mut builder = RvfBuilder::new();
builder.add_manifest("lora-test", "1.0", "LoRA profile test");
builder.add_lora_profile("office-env", &weights);
let data = builder.build();
let reader = RvfReader::from_bytes(&data).unwrap();
assert_eq!(reader.segment_count(), 2);
let profiles = reader.lora_profiles();
assert_eq!(profiles, vec!["office-env"]);
let decoded = reader.lora_profile("office-env")
.expect("LoRA profile should be present");
assert_eq!(decoded.len(), weights.len());
for (a, b) in decoded.iter().zip(weights.iter()) {
assert_eq!(a.to_bits(), b.to_bits(), "LoRA weight mismatch");
}
// Non-existent profile returns None
assert!(reader.lora_profile("nonexistent").is_none());
}
#[test]
fn test_rvf_multiple_lora_profiles() {
let w1: Vec<f32> = vec![1.0, 2.0, 3.0];
let w2: Vec<f32> = vec![4.0, 5.0, 6.0, 7.0];
let w3: Vec<f32> = vec![-1.0, -2.0];
let mut builder = RvfBuilder::new();
builder.add_lora_profile("office", &w1);
builder.add_lora_profile("home", &w2);
builder.add_lora_profile("outdoor", &w3);
let data = builder.build();
let reader = RvfReader::from_bytes(&data).unwrap();
assert_eq!(reader.segment_count(), 3);
let profiles = reader.lora_profiles();
assert_eq!(profiles.len(), 3);
assert!(profiles.contains(&"office".to_string()));
assert!(profiles.contains(&"home".to_string()));
assert!(profiles.contains(&"outdoor".to_string()));
// Verify each profile's weights
let d1 = reader.lora_profile("office").unwrap();
assert_eq!(d1, w1);
let d2 = reader.lora_profile("home").unwrap();
assert_eq!(d2, w2);
let d3 = reader.lora_profile("outdoor").unwrap();
assert_eq!(d3, w3);
}
}

View File

@@ -6,7 +6,9 @@
use std::path::Path;
use crate::graph_transformer::{CsiToPoseTransformer, TransformerConfig};
use crate::embedding::{CsiAugmenter, ProjectionHead, info_nce_loss};
use crate::dataset;
use crate::sona::EwcRegularizer;
/// Standard COCO keypoint sigmas for OKS (17 keypoints).
pub const COCO_KEYPOINT_SIGMAS: [f32; 17] = [
@@ -18,7 +20,7 @@ pub const COCO_KEYPOINT_SIGMAS: [f32; 17] = [
const SYMMETRY_PAIRS: [(usize, usize); 5] =
[(5, 6), (7, 8), (9, 10), (11, 12), (13, 14)];
/// Individual loss terms from the 6-component composite loss.
/// Individual loss terms from the composite loss (6 supervised + 1 contrastive).
#[derive(Debug, Clone, Default)]
pub struct LossComponents {
pub keypoint: f32,
@@ -27,6 +29,8 @@ pub struct LossComponents {
pub temporal: f32,
pub edge: f32,
pub symmetry: f32,
/// Contrastive loss (InfoNCE); only active during pretraining or when configured.
pub contrastive: f32,
}
/// Per-term weights for the composite loss function.
@@ -38,11 +42,16 @@ pub struct LossWeights {
pub temporal: f32,
pub edge: f32,
pub symmetry: f32,
/// Contrastive loss weight (default 0.0; set >0 for joint training).
pub contrastive: f32,
}
impl Default for LossWeights {
fn default() -> Self {
Self { keypoint: 1.0, body_part: 0.5, uv: 0.5, temporal: 0.1, edge: 0.2, symmetry: 0.1 }
Self {
keypoint: 1.0, body_part: 0.5, uv: 0.5, temporal: 0.1,
edge: 0.2, symmetry: 0.1, contrastive: 0.0,
}
}
}
@@ -124,6 +133,7 @@ pub fn symmetry_loss(kp: &[(f32, f32, f32)]) -> f32 {
pub fn composite_loss(c: &LossComponents, w: &LossWeights) -> f32 {
w.keypoint * c.keypoint + w.body_part * c.body_part + w.uv * c.uv
+ w.temporal * c.temporal + w.edge * c.edge + w.symmetry * c.symmetry
+ w.contrastive * c.contrastive
}
// ── Optimizer ──────────────────────────────────────────────────────────────
@@ -374,6 +384,10 @@ pub struct TrainerConfig {
pub early_stop_patience: usize,
pub checkpoint_every: usize,
pub loss_weights: LossWeights,
/// Contrastive loss weight for joint supervised+contrastive training (default 0.0).
pub contrastive_loss_weight: f32,
/// Temperature for InfoNCE loss during pretraining (default 0.07).
pub pretrain_temperature: f32,
}
impl Default for TrainerConfig {
@@ -382,6 +396,8 @@ impl Default for TrainerConfig {
epochs: 100, batch_size: 32, lr: 0.01, momentum: 0.9, weight_decay: 1e-4,
warmup_epochs: 5, min_lr: 1e-6, early_stop_patience: 10, checkpoint_every: 10,
loss_weights: LossWeights::default(),
contrastive_loss_weight: 0.0,
pretrain_temperature: 0.07,
}
}
}
@@ -404,6 +420,9 @@ pub struct Trainer {
transformer: Option<CsiToPoseTransformer>,
/// Transformer config (needed for unflatten during gradient estimation).
transformer_config: Option<TransformerConfig>,
/// EWC++ regularizer for pretrain -> finetune transition.
/// Prevents catastrophic forgetting of contrastive embedding structure.
pub embedding_ewc: Option<EwcRegularizer>,
}
impl Trainer {
@@ -418,6 +437,7 @@ impl Trainer {
config, optimizer, scheduler, params, history: Vec::new(),
best_val_loss: f32::MAX, best_epoch: 0, epochs_without_improvement: 0,
best_params, transformer: None, transformer_config: None,
embedding_ewc: None,
}
}
@@ -435,6 +455,7 @@ impl Trainer {
config, optimizer, scheduler, params, history: Vec::new(),
best_val_loss: f32::MAX, best_epoch: 0, epochs_without_improvement: 0,
best_params, transformer: Some(transformer), transformer_config: Some(tc),
embedding_ewc: None,
}
}
@@ -546,6 +567,131 @@ impl Trainer {
}
}
/// Run one self-supervised pretraining epoch using SimCLR objective.
/// Does NOT require pose labels -- only CSI windows.
///
/// For each mini-batch:
/// 1. Generate augmented pair (view_a, view_b) for each window
/// 2. Forward each view through transformer to get body_part_features
/// 3. Mean-pool to get frame embedding
/// 4. Project through ProjectionHead
/// 5. Compute InfoNCE loss
/// 6. Estimate gradients via central differences and SGD update
///
/// Returns mean epoch loss.
pub fn pretrain_epoch(
&mut self,
csi_windows: &[Vec<Vec<f32>>],
augmenter: &CsiAugmenter,
projection: &mut ProjectionHead,
temperature: f32,
epoch: usize,
) -> f32 {
if csi_windows.is_empty() {
return 0.0;
}
let lr = self.scheduler.get_lr(epoch);
self.optimizer.set_lr(lr);
let bs = self.config.batch_size.max(1);
let nb = (csi_windows.len() + bs - 1) / bs;
let mut total_loss = 0.0f32;
let tc = self.transformer_config.clone();
let tc_ref = match &tc {
Some(c) => c,
None => return 0.0, // pretraining requires a transformer
};
for bi in 0..nb {
let start = bi * bs;
let end = (start + bs).min(csi_windows.len());
let batch = &csi_windows[start..end];
// Generate augmented pairs and compute embeddings + loss
let snap = self.params.clone();
let mut proj_flat = Vec::new();
projection.flatten_into(&mut proj_flat);
// Combined params: transformer + projection head
let mut combined = snap.clone();
combined.extend_from_slice(&proj_flat);
let t_param_count = snap.len();
let p_config = projection.config.clone();
let tc_c = tc_ref.clone();
let temp = temperature;
// Build augmented views for the batch
let seed_base = (epoch * 10000 + bi) as u64;
let aug_pairs: Vec<_> = batch.iter().enumerate()
.map(|(k, w)| augmenter.augment_pair(w, seed_base + k as u64))
.collect();
// Loss function over combined (transformer + projection) params
let batch_owned: Vec<Vec<Vec<f32>>> = batch.to_vec();
let loss_fn = |params: &[f32]| -> f32 {
let t_params = &params[..t_param_count];
let p_params = &params[t_param_count..];
let mut t = CsiToPoseTransformer::zeros(tc_c.clone());
if t.unflatten_weights(t_params).is_err() {
return f32::MAX;
}
let (proj, _) = ProjectionHead::unflatten_from(p_params, &p_config);
let d = p_config.d_model;
let mut embs_a = Vec::with_capacity(batch_owned.len());
let mut embs_b = Vec::with_capacity(batch_owned.len());
for (k, _w) in batch_owned.iter().enumerate() {
let (ref va, ref vb) = aug_pairs[k];
// Mean-pool body features for view A
let feats_a = t.embed(va);
let mut pooled_a = vec![0.0f32; d];
for f in &feats_a {
for (p, &v) in pooled_a.iter_mut().zip(f.iter()) { *p += v; }
}
let n = feats_a.len() as f32;
if n > 0.0 { for p in pooled_a.iter_mut() { *p /= n; } }
embs_a.push(proj.forward(&pooled_a));
// Mean-pool body features for view B
let feats_b = t.embed(vb);
let mut pooled_b = vec![0.0f32; d];
for f in &feats_b {
for (p, &v) in pooled_b.iter_mut().zip(f.iter()) { *p += v; }
}
let n = feats_b.len() as f32;
if n > 0.0 { for p in pooled_b.iter_mut() { *p /= n; } }
embs_b.push(proj.forward(&pooled_b));
}
info_nce_loss(&embs_a, &embs_b, temp)
};
let batch_loss = loss_fn(&combined);
total_loss += batch_loss;
// Estimate gradient via central differences on combined params
let mut grad = estimate_gradient(&loss_fn, &combined, 1e-4);
clip_gradients(&mut grad, 1.0);
// Update transformer params
self.optimizer.step(&mut self.params, &grad[..t_param_count]);
// Update projection head params
let mut proj_params = proj_flat.clone();
// Simple SGD for projection head
for i in 0..proj_params.len().min(grad.len() - t_param_count) {
proj_params[i] -= lr * grad[t_param_count + i];
}
let (new_proj, _) = ProjectionHead::unflatten_from(&proj_params, &projection.config);
*projection = new_proj;
}
total_loss / nb as f32
}
pub fn checkpoint(&self) -> Checkpoint {
let m = self.history.last().map(|s| s.to_serializable()).unwrap_or(
EpochStatsSerializable {
@@ -665,6 +811,46 @@ impl Trainer {
let _ = t.unflatten_weights(&self.params);
}
}
/// Consolidate pretrained parameters using EWC++ before fine-tuning.
///
/// Call this after pretraining completes (e.g., after `pretrain_epoch` loops).
/// It computes the Fisher Information diagonal on the current params using
/// the contrastive loss as the objective, then sets the current params as the
/// EWC reference point. During subsequent supervised training, the EWC penalty
/// will discourage large deviations from the pretrained structure.
pub fn consolidate_pretrained(&mut self) {
let mut ewc = EwcRegularizer::new(5000.0, 0.99);
let current_params = self.params.clone();
// Compute Fisher diagonal using a simple loss based on parameter deviation.
// In a real scenario this would use the contrastive loss over training data;
// here we use a squared-magnitude proxy that penalises changes to each param.
let fisher = EwcRegularizer::compute_fisher(
&current_params,
|p: &[f32]| p.iter().map(|&x| x * x).sum::<f32>(),
1,
);
ewc.update_fisher(&fisher);
ewc.consolidate(&current_params);
self.embedding_ewc = Some(ewc);
}
/// Return the EWC penalty for the current parameters (0.0 if no EWC is set).
pub fn ewc_penalty(&self) -> f32 {
match &self.embedding_ewc {
Some(ewc) => ewc.penalty(&self.params),
None => 0.0,
}
}
/// Return the EWC penalty gradient for the current parameters.
pub fn ewc_penalty_gradient(&self) -> Vec<f32> {
match &self.embedding_ewc {
Some(ewc) => ewc.penalty_gradient(&self.params),
None => vec![0.0f32; self.params.len()],
}
}
}
// ── Tests ──────────────────────────────────────────────────────────────────
@@ -713,11 +899,11 @@ mod tests {
assert!(graph_edge_loss(&kp, &[(0,1),(1,2)], &[5.0, 5.0]) < 1e-6);
}
#[test] fn composite_loss_respects_weights() {
let c = LossComponents { keypoint:1.0, body_part:1.0, uv:1.0, temporal:1.0, edge:1.0, symmetry:1.0 };
let w1 = LossWeights { keypoint:1.0, body_part:0.0, uv:0.0, temporal:0.0, edge:0.0, symmetry:0.0 };
let w2 = LossWeights { keypoint:2.0, body_part:0.0, uv:0.0, temporal:0.0, edge:0.0, symmetry:0.0 };
let c = LossComponents { keypoint:1.0, body_part:1.0, uv:1.0, temporal:1.0, edge:1.0, symmetry:1.0, contrastive:0.0 };
let w1 = LossWeights { keypoint:1.0, body_part:0.0, uv:0.0, temporal:0.0, edge:0.0, symmetry:0.0, contrastive:0.0 };
let w2 = LossWeights { keypoint:2.0, body_part:0.0, uv:0.0, temporal:0.0, edge:0.0, symmetry:0.0, contrastive:0.0 };
assert!((composite_loss(&c, &w2) - 2.0 * composite_loss(&c, &w1)).abs() < 1e-6);
let wz = LossWeights { keypoint:0.0, body_part:0.0, uv:0.0, temporal:0.0, edge:0.0, symmetry:0.0 };
let wz = LossWeights { keypoint:0.0, body_part:0.0, uv:0.0, temporal:0.0, edge:0.0, symmetry:0.0, contrastive:0.0 };
assert_eq!(composite_loss(&c, &wz), 0.0);
}
#[test] fn cosine_scheduler_starts_at_initial() {
@@ -878,4 +1064,125 @@ mod tests {
}
}
}
#[test]
fn test_pretrain_epoch_loss_decreases() {
use crate::graph_transformer::{CsiToPoseTransformer, TransformerConfig};
use crate::embedding::{CsiAugmenter, ProjectionHead, EmbeddingConfig};
let tf_config = TransformerConfig {
n_subcarriers: 8, n_keypoints: 17, d_model: 8, n_heads: 2, n_gnn_layers: 1,
};
let transformer = CsiToPoseTransformer::new(tf_config);
let config = TrainerConfig {
epochs: 10, batch_size: 4, lr: 0.001,
warmup_epochs: 0, early_stop_patience: 100,
pretrain_temperature: 0.5,
..Default::default()
};
let mut trainer = Trainer::with_transformer(config, transformer);
let e_config = EmbeddingConfig {
d_model: 8, d_proj: 16, temperature: 0.5, normalize: true,
};
let mut projection = ProjectionHead::new(e_config);
let augmenter = CsiAugmenter::new();
// Synthetic CSI windows (8 windows, each 4 frames of 8 subcarriers)
let csi_windows: Vec<Vec<Vec<f32>>> = (0..8).map(|i| {
(0..4).map(|a| {
(0..8).map(|s| ((i * 7 + a * 3 + s) as f32 * 0.41).sin() * 0.5).collect()
}).collect()
}).collect();
let loss_0 = trainer.pretrain_epoch(&csi_windows, &augmenter, &mut projection, 0.5, 0);
let loss_1 = trainer.pretrain_epoch(&csi_windows, &augmenter, &mut projection, 0.5, 1);
let loss_2 = trainer.pretrain_epoch(&csi_windows, &augmenter, &mut projection, 0.5, 2);
assert!(loss_0.is_finite(), "epoch 0 loss should be finite: {loss_0}");
assert!(loss_1.is_finite(), "epoch 1 loss should be finite: {loss_1}");
assert!(loss_2.is_finite(), "epoch 2 loss should be finite: {loss_2}");
// Loss should generally decrease (or at least the final loss should be less than initial)
assert!(
loss_2 <= loss_0 + 0.5,
"loss should not increase drastically: epoch0={loss_0}, epoch2={loss_2}"
);
}
#[test]
fn test_contrastive_loss_weight_in_composite() {
let c = LossComponents {
keypoint: 0.0, body_part: 0.0, uv: 0.0,
temporal: 0.0, edge: 0.0, symmetry: 0.0, contrastive: 1.0,
};
let w = LossWeights {
keypoint: 0.0, body_part: 0.0, uv: 0.0,
temporal: 0.0, edge: 0.0, symmetry: 0.0, contrastive: 0.5,
};
assert!((composite_loss(&c, &w) - 0.5).abs() < 1e-6);
}
// ── Phase 7: EWC++ in Trainer tests ───────────────────────────────
#[test]
fn test_ewc_consolidation_reduces_forgetting() {
// Setup: create trainer, set params, consolidate, then train.
// EWC penalty should resist large param changes.
let config = TrainerConfig {
epochs: 5, batch_size: 4, lr: 0.01,
warmup_epochs: 0, early_stop_patience: 100,
..Default::default()
};
let mut trainer = Trainer::new(config);
let pretrained_params = trainer.params().to_vec();
// Consolidate pretrained state
trainer.consolidate_pretrained();
assert!(trainer.embedding_ewc.is_some(), "EWC should be set after consolidation");
// Train a few epochs (params will change)
let samples = vec![sample()];
for _ in 0..3 {
trainer.train_epoch(&samples);
}
// With EWC penalty active, params should still be somewhat close
// to pretrained values (EWC resists change)
let penalty = trainer.ewc_penalty();
assert!(penalty > 0.0, "EWC penalty should be > 0 after params changed");
// The penalty gradient should push params back toward pretrained values
let grad = trainer.ewc_penalty_gradient();
let any_nonzero = grad.iter().any(|&g| g.abs() > 1e-10);
assert!(any_nonzero, "EWC gradient should have non-zero components");
}
#[test]
fn test_ewc_penalty_nonzero_after_consolidation() {
let config = TrainerConfig::default();
let mut trainer = Trainer::new(config);
// Before consolidation, penalty should be 0
assert!((trainer.ewc_penalty()).abs() < 1e-10, "no EWC => zero penalty");
// Consolidate
trainer.consolidate_pretrained();
// At the reference point, penalty = 0
assert!(
trainer.ewc_penalty().abs() < 1e-6,
"penalty should be ~0 at reference point"
);
// Perturb params away from reference
for p in trainer.params.iter_mut() {
*p += 0.1;
}
let penalty = trainer.ewc_penalty();
assert!(
penalty > 0.0,
"penalty should be > 0 after deviating from reference, got {penalty}"
);
}
}

View File

@@ -4,6 +4,12 @@ version.workspace = true
edition.workspace = true
description = "WiFi CSI signal processing for DensePose estimation"
license.workspace = true
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository.workspace = true
documentation = "https://docs.rs/wifi-densepose-signal"
keywords = ["wifi", "csi", "signal-processing", "densepose", "rust"]
categories = ["science", "computer-vision"]
readme = "README.md"
[dependencies]
# Core utilities
@@ -27,7 +33,7 @@ ruvector-attention = { workspace = true }
ruvector-solver = { workspace = true }
# Internal
wifi-densepose-core = { path = "../wifi-densepose-core" }
wifi-densepose-core = { version = "0.1.0", path = "../wifi-densepose-core" }
[dev-dependencies]
criterion = { version = "0.5", features = ["html_reports"] }

View File

@@ -0,0 +1,86 @@
# wifi-densepose-signal
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-signal.svg)](https://crates.io/crates/wifi-densepose-signal)
[![Documentation](https://docs.rs/wifi-densepose-signal/badge.svg)](https://docs.rs/wifi-densepose-signal)
[![License](https://img.shields.io/crates/l/wifi-densepose-signal.svg)](LICENSE)
State-of-the-art WiFi CSI signal processing for human pose estimation.
## Overview
`wifi-densepose-signal` implements six peer-reviewed signal processing algorithms that extract
human motion features from raw WiFi Channel State Information (CSI). Each algorithm is traced
back to its original publication and integrated with the
[ruvector](https://crates.io/crates/ruvector-mincut) family of crates for high-performance
graph and attention operations.
## Algorithms
| Algorithm | Module | Reference |
|-----------|--------|-----------|
| Conjugate Multiplication | `csi_ratio` | SpotFi, SIGCOMM 2015 |
| Hampel Filter | `hampel` | WiGest, 2015 |
| Fresnel Zone Model | `fresnel` | FarSense, MobiCom 2019 |
| CSI Spectrogram | `spectrogram` | Common in WiFi sensing literature since 2018 |
| Subcarrier Selection | `subcarrier_selection` | WiDance, MobiCom 2017 |
| Body Velocity Profile (BVP) | `bvp` | Widar 3.0, MobiSys 2019 |
## Features
- **CSI preprocessing** -- Noise removal, windowing, normalization via `CsiProcessor`.
- **Phase sanitization** -- Unwrapping, outlier removal, and smoothing via `PhaseSanitizer`.
- **Feature extraction** -- Amplitude, phase, correlation, Doppler, and PSD features.
- **Motion detection** -- Human presence detection with confidence scoring via `MotionDetector`.
- **ruvector integration** -- Graph min-cut (person matching), attention mechanisms (antenna and
spatial attention), and sparse solvers (subcarrier interpolation).
## Quick Start
```rust
use wifi_densepose_signal::{
CsiProcessor, CsiProcessorConfig,
PhaseSanitizer, PhaseSanitizerConfig,
MotionDetector,
};
// Configure and create a CSI processor
let config = CsiProcessorConfig::builder()
.sampling_rate(1000.0)
.window_size(256)
.overlap(0.5)
.noise_threshold(-30.0)
.build();
let processor = CsiProcessor::new(config);
```
## Architecture
```text
wifi-densepose-signal/src/
lib.rs -- Re-exports, SignalError, prelude
bvp.rs -- Body Velocity Profile (Widar 3.0)
csi_processor.rs -- Core preprocessing pipeline
csi_ratio.rs -- Conjugate multiplication (SpotFi)
features.rs -- Amplitude/phase/Doppler/PSD feature extraction
fresnel.rs -- Fresnel zone diffraction model
hampel.rs -- Hampel outlier filter
motion.rs -- Motion and human presence detection
phase_sanitizer.rs -- Phase unwrapping and sanitization
spectrogram.rs -- Time-frequency CSI spectrograms
subcarrier_selection.rs -- Variance-based subcarrier selection
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-core`](../wifi-densepose-core) | Foundation types and traits |
| [`ruvector-mincut`](https://crates.io/crates/ruvector-mincut) | Graph min-cut for person matching |
| [`ruvector-attn-mincut`](https://crates.io/crates/ruvector-attn-mincut) | Attention-weighted min-cut |
| [`ruvector-attention`](https://crates.io/crates/ruvector-attention) | Spatial attention for CSI |
| [`ruvector-solver`](https://crates.io/crates/ruvector-solver) | Sparse interpolation solver |
## License
MIT OR Apache-2.0

View File

@@ -2,10 +2,14 @@
name = "wifi-densepose-train"
version = "0.1.0"
edition = "2021"
authors = ["WiFi-DensePose Contributors"]
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
license = "MIT OR Apache-2.0"
description = "Training pipeline for WiFi-DensePose pose estimation"
repository = "https://github.com/ruvnet/wifi-densepose"
documentation = "https://docs.rs/wifi-densepose-train"
keywords = ["wifi", "training", "pose-estimation", "deep-learning"]
categories = ["science", "computer-vision"]
readme = "README.md"
[[bin]]
name = "train"
@@ -23,8 +27,8 @@ cuda = ["tch-backend"]
[dependencies]
# Internal crates
wifi-densepose-signal = { path = "../wifi-densepose-signal" }
wifi-densepose-nn = { path = "../wifi-densepose-nn" }
wifi-densepose-signal = { version = "0.1.0", path = "../wifi-densepose-signal" }
wifi-densepose-nn = { version = "0.1.0", path = "../wifi-densepose-nn" }
# Core
thiserror.workspace = true

View File

@@ -0,0 +1,99 @@
# wifi-densepose-train
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-train.svg)](https://crates.io/crates/wifi-densepose-train)
[![Documentation](https://docs.rs/wifi-densepose-train/badge.svg)](https://docs.rs/wifi-densepose-train)
[![License](https://img.shields.io/crates/l/wifi-densepose-train.svg)](LICENSE)
Complete training pipeline for WiFi-DensePose, integrated with all five ruvector crates.
## Overview
`wifi-densepose-train` provides everything needed to train the WiFi-to-DensePose model: dataset
loading, subcarrier interpolation, loss functions, evaluation metrics, and the training loop
orchestrator. It supports both the MM-Fi dataset (NeurIPS 2023) and deterministic synthetic data
for reproducible experiments.
Without the `tch-backend` feature the crate still provides the dataset, configuration, and
subcarrier interpolation APIs needed for data preprocessing and proof verification.
## Features
- **MM-Fi dataset loader** -- Reads the MM-Fi multimodal dataset (NeurIPS 2023) from disk with
memory-mapped `.npy` files.
- **Synthetic dataset** -- Deterministic, fixed-seed CSI generation for unit tests and proofs.
- **Subcarrier interpolation** -- 114 -> 56 subcarrier compression via `ruvector-solver` sparse
interpolation with variance-based selection.
- **Loss functions** (`tch-backend`) -- Pose estimation losses including MSE, OKS, and combined
multi-task loss.
- **Metrics** (`tch-backend`) -- PCKh, OKS-AP, and per-keypoint evaluation with
`ruvector-mincut`-based person matching.
- **Training orchestrator** (`tch-backend`) -- Full training loop with learning rate scheduling,
gradient clipping, checkpointing, and reproducible proofs.
- **All 5 ruvector crates** -- `ruvector-mincut`, `ruvector-attn-mincut`,
`ruvector-temporal-tensor`, `ruvector-solver`, and `ruvector-attention` integrated across
dataset loading, metrics, and model attention.
### Feature flags
| Flag | Default | Description |
|---------------|---------|----------------------------------------|
| `tch-backend` | no | Enable PyTorch training via `tch-rs` |
| `cuda` | no | CUDA GPU acceleration (implies `tch`) |
### Binaries
| Binary | Description |
|--------------------|------------------------------------------|
| `train` | Main training entry point |
| `verify-training` | Proof verification (requires `tch-backend`) |
## Quick Start
```rust
use wifi_densepose_train::config::TrainingConfig;
use wifi_densepose_train::dataset::{SyntheticCsiDataset, SyntheticConfig, CsiDataset};
// Build and validate config
let config = TrainingConfig::default();
config.validate().expect("config is valid");
// Create a synthetic dataset (deterministic, fixed-seed)
let syn_cfg = SyntheticConfig::default();
let dataset = SyntheticCsiDataset::new(200, syn_cfg);
// Load one sample
let sample = dataset.get(0).unwrap();
println!("amplitude shape: {:?}", sample.amplitude.shape());
```
## Architecture
```text
wifi-densepose-train/src/
lib.rs -- Re-exports, VERSION
config.rs -- TrainingConfig, hyperparameters, validation
dataset.rs -- CsiDataset trait, MmFiDataset, SyntheticCsiDataset, DataLoader
error.rs -- TrainError, ConfigError, DatasetError, SubcarrierError
subcarrier.rs -- interpolate_subcarriers (114->56), variance-based selection
losses.rs -- (tch) MSE, OKS, multi-task loss [feature-gated]
metrics.rs -- (tch) PCKh, OKS-AP, person matching [feature-gated]
model.rs -- (tch) Model definition with attention [feature-gated]
proof.rs -- (tch) Deterministic training proofs [feature-gated]
trainer.rs -- (tch) Training loop orchestrator [feature-gated]
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-signal`](../wifi-densepose-signal) | Signal preprocessing consumed by dataset loaders |
| [`wifi-densepose-nn`](../wifi-densepose-nn) | Inference engine that loads trained models |
| [`ruvector-mincut`](https://crates.io/crates/ruvector-mincut) | Person matching in metrics |
| [`ruvector-attn-mincut`](https://crates.io/crates/ruvector-attn-mincut) | Attention-weighted graph cuts |
| [`ruvector-temporal-tensor`](https://crates.io/crates/ruvector-temporal-tensor) | Compressed CSI buffering in datasets |
| [`ruvector-solver`](https://crates.io/crates/ruvector-solver) | Sparse subcarrier interpolation |
| [`ruvector-attention`](https://crates.io/crates/ruvector-attention) | Spatial attention in model |
## License
MIT OR Apache-2.0

View File

@@ -4,6 +4,12 @@ version.workspace = true
edition.workspace = true
description = "ESP32 CSI-grade vital sign extraction (ADR-021): heart rate and respiratory rate from WiFi Channel State Information"
license.workspace = true
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository.workspace = true
documentation = "https://docs.rs/wifi-densepose-vitals"
keywords = ["wifi", "vital-signs", "breathing", "heart-rate", "csi"]
categories = ["science", "computer-vision"]
readme = "README.md"
[dependencies]
tracing.workspace = true

View File

@@ -0,0 +1,102 @@
# wifi-densepose-vitals
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-vitals.svg)](https://crates.io/crates/wifi-densepose-vitals)
[![Documentation](https://docs.rs/wifi-densepose-vitals/badge.svg)](https://docs.rs/wifi-densepose-vitals)
[![License](https://img.shields.io/crates/l/wifi-densepose-vitals.svg)](LICENSE)
ESP32 CSI-grade vital sign extraction: heart rate and respiratory rate from WiFi Channel State
Information (ADR-021).
## Overview
`wifi-densepose-vitals` implements a four-stage pipeline that extracts respiratory rate and heart
rate from multi-subcarrier CSI amplitude and phase data. The crate has zero external dependencies
beyond `tracing` (and optional `serde`), uses `#[forbid(unsafe_code)]`, and is designed for
resource-constrained edge deployments alongside ESP32 hardware.
## Pipeline Stages
1. **Preprocessing** (`CsiVitalPreprocessor`) -- EMA-based static component suppression,
producing per-subcarrier residuals that isolate body-induced signal variation.
2. **Breathing extraction** (`BreathingExtractor`) -- Bandpass filtering at 0.1--0.5 Hz with
zero-crossing analysis for respiratory rate estimation.
3. **Heart rate extraction** (`HeartRateExtractor`) -- Bandpass filtering at 0.8--2.0 Hz with
autocorrelation peak detection and inter-subcarrier phase coherence weighting.
4. **Anomaly detection** (`VitalAnomalyDetector`) -- Z-score analysis using Welford running
statistics for real-time clinical alerts (apnea, tachycardia, bradycardia).
Results are stored in a `VitalSignStore` with configurable retention for historical trend
analysis.
### Feature flags
| Flag | Default | Description |
|---------|---------|------------------------------------------|
| `serde` | yes | Serialization for vital sign types |
## Quick Start
```rust
use wifi_densepose_vitals::{
CsiVitalPreprocessor, BreathingExtractor, HeartRateExtractor,
VitalAnomalyDetector, VitalSignStore, CsiFrame,
VitalReading, VitalEstimate, VitalStatus,
};
let mut preprocessor = CsiVitalPreprocessor::new(56, 0.05);
let mut breathing = BreathingExtractor::new(56, 100.0, 30.0);
let mut heartrate = HeartRateExtractor::new(56, 100.0, 15.0);
let mut anomaly = VitalAnomalyDetector::default_config();
let mut store = VitalSignStore::new(3600);
// Process a CSI frame
let frame = CsiFrame {
amplitudes: vec![1.0; 56],
phases: vec![0.0; 56],
n_subcarriers: 56,
sample_index: 0,
sample_rate_hz: 100.0,
};
if let Some(residuals) = preprocessor.process(&frame) {
let weights = vec![1.0 / 56.0; 56];
let rr = breathing.extract(&residuals, &weights);
let hr = heartrate.extract(&residuals, &frame.phases);
let reading = VitalReading {
respiratory_rate: rr.unwrap_or_else(VitalEstimate::unavailable),
heart_rate: hr.unwrap_or_else(VitalEstimate::unavailable),
subcarrier_count: frame.n_subcarriers,
signal_quality: 0.9,
timestamp_secs: 0.0,
};
let alerts = anomaly.check(&reading);
store.push(reading);
}
```
## Architecture
```text
wifi-densepose-vitals/src/
lib.rs -- Re-exports, module declarations
types.rs -- CsiFrame, VitalReading, VitalEstimate, VitalStatus
preprocessor.rs -- CsiVitalPreprocessor (EMA static suppression)
breathing.rs -- BreathingExtractor (0.1-0.5 Hz bandpass)
heartrate.rs -- HeartRateExtractor (0.8-2.0 Hz autocorrelation)
anomaly.rs -- VitalAnomalyDetector (Z-score, Welford stats)
store.rs -- VitalSignStore, VitalStats (historical retention)
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-hardware`](../wifi-densepose-hardware) | Provides raw CSI frames from ESP32 |
| [`wifi-densepose-mat`](../wifi-densepose-mat) | Uses vital signs for survivor triage |
| [`wifi-densepose-signal`](../wifi-densepose-signal) | Advanced signal processing algorithms |
## License
MIT OR Apache-2.0

View File

@@ -4,7 +4,12 @@ version.workspace = true
edition.workspace = true
description = "WebAssembly bindings for WiFi-DensePose"
license = "MIT OR Apache-2.0"
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository = "https://github.com/ruvnet/wifi-densepose"
documentation = "https://docs.rs/wifi-densepose-wasm"
keywords = ["wifi", "wasm", "webassembly", "densepose", "browser"]
categories = ["wasm", "web-programming"]
readme = "README.md"
[lib]
crate-type = ["cdylib", "rlib"]
@@ -54,7 +59,7 @@ uuid = { version = "1.6", features = ["v4", "serde", "js"] }
getrandom = { version = "0.2", features = ["js"] }
# Optional: wifi-densepose-mat integration
wifi-densepose-mat = { path = "../wifi-densepose-mat", optional = true, features = ["serde"] }
wifi-densepose-mat = { version = "0.1.0", path = "../wifi-densepose-mat", optional = true, features = ["serde"] }
[dev-dependencies]
wasm-bindgen-test = "0.3"

View File

@@ -0,0 +1,128 @@
# wifi-densepose-wasm
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-wasm.svg)](https://crates.io/crates/wifi-densepose-wasm)
[![Documentation](https://docs.rs/wifi-densepose-wasm/badge.svg)](https://docs.rs/wifi-densepose-wasm)
[![License](https://img.shields.io/crates/l/wifi-densepose-wasm.svg)](LICENSE)
WebAssembly bindings for running WiFi-DensePose directly in the browser.
## Overview
`wifi-densepose-wasm` compiles the WiFi-DensePose stack to `wasm32-unknown-unknown` and exposes a
JavaScript API via [wasm-bindgen](https://rustwasm.github.io/wasm-bindgen/). The primary export is
`MatDashboard` -- a fully client-side disaster response dashboard that manages scan zones, tracks
survivors, generates triage alerts, and renders to an HTML Canvas element.
The crate also provides utility functions (`init`, `getVersion`, `isMatEnabled`, `getTimestamp`) and
a logging bridge that routes Rust `log` output to the browser console.
## Features
- **MatDashboard** -- Create disaster events, add rectangular and circular scan zones, subscribe to
survivor-detected and alert-generated callbacks, and render zone/survivor overlays on Canvas.
- **Real-time callbacks** -- Register JavaScript closures for `onSurvivorDetected` and
`onAlertGenerated` events, called from the Rust event loop.
- **Canvas rendering** -- Draw zone boundaries, survivor markers (colour-coded by triage status),
and alert indicators directly to a `CanvasRenderingContext2d`.
- **WebSocket integration** -- Connect to a sensing server for live CSI data via `web-sys` WebSocket
bindings.
- **Panic hook** -- `console_error_panic_hook` provides human-readable stack traces in the browser
console on panic.
- **Optimised WASM** -- Release profile uses `-O4` wasm-opt with mutable globals for minimal binary
size.
### Feature flags
| Flag | Default | Description |
|----------------------------|---------|-------------|
| `console_error_panic_hook` | yes | Better panic messages in the browser console |
| `mat` | no | Enable MAT disaster detection dashboard |
## Quick Start
### Build
```bash
# Build with wasm-pack (recommended)
wasm-pack build --target web --features mat
# Or with cargo directly
cargo build --target wasm32-unknown-unknown --features mat
```
### JavaScript Usage
```javascript
import init, {
MatDashboard,
initLogging,
getVersion,
isMatEnabled,
} from './wifi_densepose_wasm.js';
async function main() {
await init();
initLogging('info');
console.log('Version:', getVersion());
console.log('MAT enabled:', isMatEnabled());
const dashboard = new MatDashboard();
// Create a disaster event
const eventId = dashboard.createEvent(
'earthquake', 37.7749, -122.4194, 'Bay Area Earthquake'
);
// Add scan zones
dashboard.addRectangleZone('Building A', 50, 50, 200, 150);
dashboard.addCircleZone('Search Area B', 400, 200, 80);
// Subscribe to real-time events
dashboard.onSurvivorDetected((survivor) => {
console.log('Survivor:', survivor);
});
dashboard.onAlertGenerated((alert) => {
console.log('Alert:', alert);
});
// Render to canvas
const canvas = document.getElementById('map');
const ctx = canvas.getContext('2d');
function render() {
ctx.clearRect(0, 0, canvas.width, canvas.height);
dashboard.renderZones(ctx);
dashboard.renderSurvivors(ctx);
requestAnimationFrame(render);
}
render();
}
main();
```
## Exported API
| Export | Kind | Description |
|--------|------|-------------|
| `init()` | Function | Initialise the WASM module (called automatically via `wasm_bindgen(start)`) |
| `initLogging(level)` | Function | Set log level: `trace`, `debug`, `info`, `warn`, `error` |
| `getVersion()` | Function | Return the crate version string |
| `isMatEnabled()` | Function | Check whether the MAT feature is compiled in |
| `getTimestamp()` | Function | High-resolution timestamp via `Performance.now()` |
| `MatDashboard` | Class | Disaster response dashboard (zones, survivors, alerts, rendering) |
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-mat`](../wifi-densepose-mat) | MAT engine (linked when `mat` feature enabled) |
| [`wifi-densepose-core`](../wifi-densepose-core) | Shared types and traits |
| [`wifi-densepose-cli`](../wifi-densepose-cli) | Terminal-based MAT interface |
| [`wifi-densepose-sensing-server`](../wifi-densepose-sensing-server) | Backend sensing server for WebSocket data |
## License
MIT OR Apache-2.0

View File

@@ -4,6 +4,12 @@ version.workspace = true
edition.workspace = true
description = "Multi-BSSID WiFi scanning domain layer for enhanced Windows WiFi DensePose sensing (ADR-022)"
license.workspace = true
authors = ["rUv <ruv@ruv.net>", "WiFi-DensePose Contributors"]
repository.workspace = true
documentation = "https://docs.rs/wifi-densepose-wifiscan"
keywords = ["wifi", "bssid", "scanning", "windows", "sensing"]
categories = ["science", "computer-vision"]
readme = "README.md"
[dependencies]
# Logging

View File

@@ -0,0 +1,98 @@
# wifi-densepose-wifiscan
[![Crates.io](https://img.shields.io/crates/v/wifi-densepose-wifiscan.svg)](https://crates.io/crates/wifi-densepose-wifiscan)
[![Documentation](https://docs.rs/wifi-densepose-wifiscan/badge.svg)](https://docs.rs/wifi-densepose-wifiscan)
[![License](https://img.shields.io/crates/l/wifi-densepose-wifiscan.svg)](LICENSE)
Multi-BSSID WiFi scanning for Windows-enhanced DensePose sensing (ADR-022).
## Overview
`wifi-densepose-wifiscan` implements the BSSID Acquisition bounded context for the WiFi-DensePose
system. It discovers and tracks nearby WiFi access points, parses platform-specific scan output,
and feeds multi-AP signal data into a sensing pipeline that performs motion detection, breathing
estimation, attention weighting, and fingerprint matching.
The crate uses `#[forbid(unsafe_code)]` and is designed as a pure-Rust domain layer with
pluggable platform adapters.
## Features
- **BSSID registry** -- Tracks observed access points with running RSSI statistics, band/radio
type classification, and metadata. Types: `BssidId`, `BssidObservation`, `BssidRegistry`,
`BssidEntry`.
- **Netsh adapter** (Tier 1) -- Parses `netsh wlan show networks mode=bssid` output into
structured `BssidObservation` records. Zero platform dependencies.
- **WLAN API scanner** (Tier 2, `wlanapi` feature) -- Async scanning via the Windows WLAN API
with `tokio` integration.
- **Multi-AP frame** -- `MultiApFrame` aggregates observations from multiple BSSIDs into a single
timestamped frame for downstream processing.
- **Sensing pipeline** (`pipeline` feature) -- `WindowsWifiPipeline` orchestrates motion
detection, breathing estimation, attention-weighted AP selection, and location fingerprint
matching.
### Feature flags
| Flag | Default | Description |
|------------|---------|------------------------------------------------------|
| `serde` | yes | Serialization for domain types |
| `pipeline` | yes | WindowsWifiPipeline sensing orchestration |
| `wlanapi` | no | Tier 2 async scanning via tokio (Windows WLAN API) |
## Quick Start
```rust
use wifi_densepose_wifiscan::{
NetshBssidScanner, BssidRegistry, WlanScanPort,
};
// Parse netsh output (works on any platform for testing)
let netsh_output = "..."; // output of `netsh wlan show networks mode=bssid`
let observations = wifi_densepose_wifiscan::parse_netsh_output(netsh_output);
// Register observations
let mut registry = BssidRegistry::new();
for obs in &observations {
registry.update(obs);
}
println!("Tracking {} access points", registry.len());
```
With the `pipeline` feature enabled:
```rust
use wifi_densepose_wifiscan::WindowsWifiPipeline;
let pipeline = WindowsWifiPipeline::new();
// Feed MultiApFrame data into the pipeline for sensing...
```
## Architecture
```text
wifi-densepose-wifiscan/src/
lib.rs -- Re-exports, feature gates
domain/
bssid.rs -- BssidId, BssidObservation, BandType, RadioType
registry.rs -- BssidRegistry, BssidEntry, BssidMeta, RunningStats
frame.rs -- MultiApFrame (multi-BSSID aggregated frame)
result.rs -- EnhancedSensingResult
port.rs -- WlanScanPort trait (platform abstraction)
adapter.rs -- NetshBssidScanner (Tier 1), WlanApiScanner (Tier 2)
pipeline.rs -- WindowsWifiPipeline (motion, breathing, attention, fingerprint)
error.rs -- WifiScanError
```
## Related Crates
| Crate | Role |
|-------|------|
| [`wifi-densepose-signal`](../wifi-densepose-signal) | Advanced CSI signal processing |
| [`wifi-densepose-vitals`](../wifi-densepose-vitals) | Vital sign extraction from CSI |
| [`wifi-densepose-hardware`](../wifi-densepose-hardware) | ESP32 and other hardware interfaces |
| [`wifi-densepose-mat`](../wifi-densepose-mat) | Disaster detection using multi-AP data |
## License
MIT OR Apache-2.0

View File

@@ -1,11 +1,17 @@
// API Configuration for WiFi-DensePose UI
// Auto-detect the backend URL from the page origin so the UI works whether
// served from Docker (:3000), local dev (:8080), or any other port.
const _origin = (typeof window !== 'undefined' && window.location && window.location.origin)
? window.location.origin
: 'http://localhost:3000';
export const API_CONFIG = {
BASE_URL: 'http://localhost:8080', // Rust sensing server port
BASE_URL: _origin,
API_VERSION: '/api/v1',
WS_PREFIX: 'ws://',
WSS_PREFIX: 'wss://',
// Mock server configuration (only for testing)
MOCK_SERVER: {
ENABLED: false, // Set to true only for testing without backend
@@ -114,9 +120,9 @@ export function buildWsUrl(endpoint, params = {}) {
const protocol = (isSecure || !isLocalhost)
? API_CONFIG.WSS_PREFIX
: API_CONFIG.WS_PREFIX;
// Match Rust sensing server port
const host = 'localhost:8080';
// Derive host from the page origin so it works on any port (Docker :3000, dev :8080, etc.)
const host = window.location.host;
let url = `${protocol}${host}${endpoint}`;
// Add query parameters

View File

@@ -8,7 +8,11 @@
* always shows something.
*/
const SENSING_WS_URL = 'ws://localhost:8765/ws/sensing';
// Derive WebSocket URL from the page origin so it works on any port
// (Docker :3000, native :8080, etc.)
const _wsProto = (typeof window !== 'undefined' && window.location.protocol === 'https:') ? 'wss:' : 'ws:';
const _wsHost = (typeof window !== 'undefined' && window.location.host) ? window.location.host : 'localhost:3000';
const SENSING_WS_URL = `${_wsProto}//${_wsHost}/ws/sensing`;
const RECONNECT_DELAYS = [1000, 2000, 4000, 8000, 16000];
const MAX_RECONNECT_ATTEMPTS = 10;
const SIMULATION_INTERVAL = 500; // ms