mirror of
https://github.com/ruvnet/RuView
synced 2026-07-18 16:43:18 +00:00
ruv
fdc7142dfa
- Added IosRssiService to handle synthetic RSSI data for iOS. - Created WebRssiService to simulate RSSI scanning on the web. - Defined shared types for WifiNetwork and RssiService in rssi.service.ts. - Introduced simulation service to generate synthetic sensing data. - Implemented WebSocket service for real-time data handling with reconnection logic. - Established Zustand stores for managing application state related to MAT and pose data. - Developed theme context and utility functions for consistent styling and formatting. - Added type definitions for various application entities including API responses and sensing data. - Created utility functions for color mapping and URL validation. - Configured TypeScript settings for the mobile application.
72 lines
1.9 KiB
TypeScript
72 lines
1.9 KiB
TypeScript
import { create } from 'zustand';
|
|
import { RingBuffer } from '@/utils/ringBuffer';
|
|
import type { Classification, ConnectionStatus, FeatureSet, SensingFrame, SignalField } from '@/types/sensing';
|
|
|
|
export interface PoseState {
|
|
connectionStatus: ConnectionStatus;
|
|
isSimulated: boolean;
|
|
lastFrame: SensingFrame | null;
|
|
rssiHistory: number[];
|
|
features: FeatureSet | null;
|
|
classification: Classification | null;
|
|
signalField: SignalField | null;
|
|
messageCount: number;
|
|
uptimeStart: number | null;
|
|
handleFrame: (frame: SensingFrame) => void;
|
|
setConnectionStatus: (status: ConnectionStatus) => void;
|
|
reset: () => void;
|
|
}
|
|
|
|
const MAX_RSSI_HISTORY = 60;
|
|
const rssiHistory = new RingBuffer<number>(MAX_RSSI_HISTORY, (a, b) => a - b);
|
|
|
|
export const usePoseStore = create<PoseState>((set) => ({
|
|
connectionStatus: 'disconnected',
|
|
isSimulated: false,
|
|
lastFrame: null,
|
|
rssiHistory: [],
|
|
features: null,
|
|
classification: null,
|
|
signalField: null,
|
|
messageCount: 0,
|
|
uptimeStart: null,
|
|
|
|
handleFrame: (frame: SensingFrame) => {
|
|
if (typeof frame.features?.mean_rssi === 'number') {
|
|
rssiHistory.push(frame.features.mean_rssi);
|
|
}
|
|
|
|
set((state) => ({
|
|
lastFrame: frame,
|
|
features: frame.features,
|
|
classification: frame.classification,
|
|
signalField: frame.signal_field,
|
|
messageCount: state.messageCount + 1,
|
|
uptimeStart: state.uptimeStart ?? Date.now(),
|
|
rssiHistory: rssiHistory.toArray(),
|
|
}));
|
|
},
|
|
|
|
setConnectionStatus: (status: ConnectionStatus) => {
|
|
set({
|
|
connectionStatus: status,
|
|
isSimulated: status === 'simulated',
|
|
});
|
|
},
|
|
|
|
reset: () => {
|
|
rssiHistory.clear();
|
|
set({
|
|
connectionStatus: 'disconnected',
|
|
isSimulated: false,
|
|
lastFrame: null,
|
|
rssiHistory: [],
|
|
features: null,
|
|
classification: null,
|
|
signalField: null,
|
|
messageCount: 0,
|
|
uptimeStart: null,
|
|
});
|
|
},
|
|
}));
|