e30ae8ed09
- App.tsx: full navigation (Auth stack + Main tabs with 5 screens) - Auth: LoginScreen, RegisterScreen, ForgotPasswordScreen - HomeScreen: dashboard with IoT metrics, weather widget, alerts, quick actions, sensors - MapScreen: interactive map with layer toggles (6 layers) - MarketplaceScreen: categories (6), products (5), search - ChatScreen: AI chat with quick prompts (4), bot responses - ProfileScreen: user info, stats, menu (9 items), logout - AlertsScreen: alert list with severity, acknowledge - SensorsScreen: sensor list with type filters (6 types), search - ZonesScreen: zone cards with stats - SettingsScreen: language picker (FR/EN/ES/DE), privacy, about - Stores: iotStore (sensors, zones, alerts), notificationStore, uiStore + i18n - Hooks: useSensors, useAlerts, useNotifications, useLocation - Components: Card, Button, LoadingSpinner, ErrorBoundary, Header - Services: iotService, notificationService (with axios API client) - Utils: formatters (temp, AQI, noise, dates), validators (email, password, IBAN) - Theme: colors.ts with full design system (Blue Ocean palette) - Ditto: fixed MongoDB connection, new JWT secrets, official gateway image
62 lines
2.0 KiB
JavaScript
62 lines
2.0 KiB
JavaScript
import ExpoLocation from './ExpoLocation';
|
|
import { LocationEventEmitter } from './LocationEventEmitter';
|
|
let nextWatchId = 0;
|
|
class Subscriber {
|
|
eventName;
|
|
eventDataField;
|
|
callbacks = {};
|
|
eventSubscription = null;
|
|
constructor(eventName, eventDataField) {
|
|
this.eventName = eventName;
|
|
this.eventDataField = eventDataField;
|
|
}
|
|
maybeInitializeSubscription() {
|
|
if (this.eventSubscription) {
|
|
return;
|
|
}
|
|
this.eventSubscription = LocationEventEmitter.addListener(this.eventName, (event) => this.trigger(event));
|
|
}
|
|
/**
|
|
* Registers given callback under new id which is then returned.
|
|
*/
|
|
registerCallback(callback) {
|
|
this.maybeInitializeSubscription();
|
|
const id = ++nextWatchId;
|
|
this.callbacks[id] = callback;
|
|
return id;
|
|
}
|
|
/**
|
|
* Unregisters a callback with given id and revokes the subscription if possible.
|
|
*/
|
|
unregisterCallback(id) {
|
|
// Do nothing if we have already unregistered the callback.
|
|
if (!this.callbacks[id]) {
|
|
return;
|
|
}
|
|
delete this.callbacks[id];
|
|
ExpoLocation.removeWatchAsync(id);
|
|
if (Object.keys(this.callbacks).length === 0 && this.eventSubscription) {
|
|
LocationEventEmitter.removeSubscription(this.eventSubscription);
|
|
this.eventSubscription = null;
|
|
}
|
|
}
|
|
trigger(event) {
|
|
const watchId = event.watchId;
|
|
const callback = this.callbacks[watchId];
|
|
if (callback) {
|
|
callback(event[this.eventDataField]);
|
|
}
|
|
else {
|
|
ExpoLocation.removeWatchAsync(watchId);
|
|
}
|
|
}
|
|
}
|
|
export const LocationSubscriber = new Subscriber('Expo.locationChanged', 'location');
|
|
export const HeadingSubscriber = new Subscriber('Expo.headingChanged', 'heading');
|
|
/**
|
|
* @private Necessary for some unit tests.
|
|
*/
|
|
export function _getCurrentWatchId() {
|
|
return nextWatchId;
|
|
}
|
|
//# sourceMappingURL=LocationSubscribers.js.map
|