Files
wifi-densepose/ui/app.js
ruv d956c30f9e feat: Rust sensing server with full DensePose-compatible API
Replace Python FastAPI + WebSocket servers with a single 2.1MB Rust binary
(wifi-densepose-sensing-server) that serves all UI endpoints:

- REST: /health/*, /api/v1/info, /api/v1/pose/current, /api/v1/pose/stats,
  /api/v1/pose/zones/summary, /api/v1/stream/status
- WebSocket: /api/v1/stream/pose (pose_data with 17 COCO keypoints),
  /ws/sensing (raw sensing_update stream on port 8765)
- Static: /ui/* with no-cache headers

WiFi-derived pose estimation: derive_pose_from_sensing() generates 17 COCO
keypoints from CSI/WiFi signal data with motion-driven animation.

Data sources: ESP32 CSI via UDP :5005, Windows WiFi via netsh, simulation
fallback. Auto-detection probes each in order.

UI changes:
- Point all endpoints to Rust server on :8080 (was Python :8000)
- Fix WebSocket sensing URL to include /ws/sensing path
- Remove sensingOnlyMode gating — all tabs init normally
- Remove api.service.js sensing-only short-circuit
- Fix clearPingInterval bug in websocket.service.js

Also removes obsolete k8s/ template manifests.

Co-Authored-By: claude-flow <ruv@ruv.net>
2026-02-28 21:29:45 -05:00

311 lines
9.1 KiB
JavaScript

// WiFi DensePose Application - Main Entry Point
import { TabManager } from './components/TabManager.js';
import { DashboardTab } from './components/DashboardTab.js';
import { HardwareTab } from './components/HardwareTab.js';
import { LiveDemoTab } from './components/LiveDemoTab.js';
import { SensingTab } from './components/SensingTab.js';
import { apiService } from './services/api.service.js';
import { wsService } from './services/websocket.service.js';
import { healthService } from './services/health.service.js';
import { backendDetector } from './utils/backend-detector.js';
class WiFiDensePoseApp {
constructor() {
this.components = {};
this.isInitialized = false;
}
// Initialize application
async init() {
try {
console.log('Initializing WiFi DensePose UI...');
// Set up error handling
this.setupErrorHandling();
// Initialize services
await this.initializeServices();
// Initialize UI components
this.initializeComponents();
// Set up global event listeners
this.setupEventListeners();
this.isInitialized = true;
console.log('WiFi DensePose UI initialized successfully');
} catch (error) {
console.error('Failed to initialize application:', error);
this.showGlobalError('Failed to initialize application. Please refresh the page.');
}
}
// Initialize services
async initializeServices() {
// Add request interceptor for error handling
apiService.addResponseInterceptor(async (response, url) => {
if (!response.ok && response.status === 401) {
console.warn('Authentication required for:', url);
// Handle authentication if needed
}
return response;
});
// Detect backend availability and initialize accordingly
const useMock = await backendDetector.shouldUseMockServer();
if (useMock) {
console.log('🧪 Initializing with mock server for testing');
// Import and start mock server only when needed
const { mockServer } = await import('./utils/mock-server.js');
mockServer.start();
// Show notification to user
this.showBackendStatus('Mock server active - testing mode', 'warning');
} else {
console.log('🔌 Connecting to backend...');
try {
const health = await healthService.checkLiveness();
console.log('✅ Backend responding:', health);
this.showBackendStatus('Connected to Rust sensing server', 'success');
} catch (error) {
console.warn('⚠️ Backend not available:', error.message);
this.showBackendStatus('Backend unavailable — start sensing-server', 'warning');
}
}
}
// Initialize UI components
initializeComponents() {
const container = document.querySelector('.container');
if (!container) {
throw new Error('Main container not found');
}
// Initialize tab manager
this.components.tabManager = new TabManager(container);
this.components.tabManager.init();
// Initialize tab components
this.initializeTabComponents();
// Set up tab change handling
this.components.tabManager.onTabChange((newTab, oldTab) => {
this.handleTabChange(newTab, oldTab);
});
}
// Initialize individual tab components
initializeTabComponents() {
// Dashboard tab
const dashboardContainer = document.getElementById('dashboard');
if (dashboardContainer) {
this.components.dashboard = new DashboardTab(dashboardContainer);
this.components.dashboard.init().catch(error => {
console.error('Failed to initialize dashboard:', error);
});
}
// Hardware tab
const hardwareContainer = document.getElementById('hardware');
if (hardwareContainer) {
this.components.hardware = new HardwareTab(hardwareContainer);
this.components.hardware.init();
}
// Live demo tab
const demoContainer = document.getElementById('demo');
if (demoContainer) {
this.components.demo = new LiveDemoTab(demoContainer);
this.components.demo.init();
}
// Sensing tab
const sensingContainer = document.getElementById('sensing');
if (sensingContainer) {
this.components.sensing = new SensingTab(sensingContainer);
}
// Architecture tab - static content, no component needed
// Performance tab - static content, no component needed
// Applications tab - static content, no component needed
}
// Handle tab changes
handleTabChange(newTab, oldTab) {
console.log(`Tab changed from ${oldTab} to ${newTab}`);
// Stop demo if leaving demo tab
if (oldTab === 'demo' && this.components.demo) {
this.components.demo.stopDemo();
}
// Update components based on active tab
switch (newTab) {
case 'dashboard':
// Dashboard auto-updates when visible
break;
case 'hardware':
// Hardware visualization is always active
break;
case 'demo':
// Demo starts manually
break;
case 'sensing':
// Lazy-init sensing tab on first visit
if (this.components.sensing && !this.components.sensing.splatRenderer) {
this.components.sensing.init().catch(error => {
console.error('Failed to initialize sensing tab:', error);
});
}
break;
}
}
// Set up global event listeners
setupEventListeners() {
// Handle window resize
window.addEventListener('resize', () => {
this.handleResize();
});
// Handle visibility change
document.addEventListener('visibilitychange', () => {
this.handleVisibilityChange();
});
// Handle before unload
window.addEventListener('beforeunload', () => {
this.cleanup();
});
}
// Handle window resize
handleResize() {
// Update canvas sizes if needed
const canvases = document.querySelectorAll('canvas');
canvases.forEach(canvas => {
const rect = canvas.parentElement.getBoundingClientRect();
if (canvas.width !== rect.width || canvas.height !== rect.height) {
canvas.width = rect.width;
canvas.height = rect.height;
}
});
}
// Handle visibility change
handleVisibilityChange() {
if (document.hidden) {
// Pause updates when page is hidden
console.log('Page hidden, pausing updates');
healthService.stopHealthMonitoring();
} else {
// Resume updates when page is visible
console.log('Page visible, resuming updates');
healthService.startHealthMonitoring();
}
}
// Set up error handling
setupErrorHandling() {
window.addEventListener('error', (event) => {
if (event.error) {
console.error('Global error:', event.error);
this.showGlobalError('An unexpected error occurred');
}
});
window.addEventListener('unhandledrejection', (event) => {
if (event.reason) {
console.error('Unhandled promise rejection:', event.reason);
this.showGlobalError('An unexpected error occurred');
}
});
}
// Show backend status notification
showBackendStatus(message, type) {
// Create status notification if it doesn't exist
let statusToast = document.getElementById('backendStatusToast');
if (!statusToast) {
statusToast = document.createElement('div');
statusToast.id = 'backendStatusToast';
statusToast.className = 'backend-status-toast';
document.body.appendChild(statusToast);
}
statusToast.textContent = message;
statusToast.className = `backend-status-toast ${type}`;
statusToast.classList.add('show');
// Auto-hide success messages, keep warnings and errors longer
const timeout = type === 'success' ? 3000 : 8000;
setTimeout(() => {
statusToast.classList.remove('show');
}, timeout);
}
// Show global error message
showGlobalError(message) {
// Create error toast if it doesn't exist
let errorToast = document.getElementById('globalErrorToast');
if (!errorToast) {
errorToast = document.createElement('div');
errorToast.id = 'globalErrorToast';
errorToast.className = 'error-toast';
document.body.appendChild(errorToast);
}
errorToast.textContent = message;
errorToast.classList.add('show');
setTimeout(() => {
errorToast.classList.remove('show');
}, 5000);
}
// Clean up resources
cleanup() {
console.log('Cleaning up application resources...');
// Dispose all components
Object.values(this.components).forEach(component => {
if (component && typeof component.dispose === 'function') {
component.dispose();
}
});
// Disconnect all WebSocket connections
wsService.disconnectAll();
// Stop health monitoring
healthService.dispose();
}
// Public API
getComponent(name) {
return this.components[name];
}
isReady() {
return this.isInitialized;
}
}
// Initialize app when DOM is ready
document.addEventListener('DOMContentLoaded', () => {
window.wifiDensePoseApp = new WiFiDensePoseApp();
window.wifiDensePoseApp.init();
});
// Export for testing
export { WiFiDensePoseApp };