From d72550b3c16eeb55dfc08ed94630e0a3ff0921b6 Mon Sep 17 00:00:00 2001
From: William Bruno <wbruno@intrepidnet.org>
Date: Sat, 18 Apr 2026 08:08:47 -0400
Subject: [PATCH] fixes

---
 src/components/SetLocationDialog.vue  |  2 +-
 src/components/SocketTest.vue         |  2 +-
 src/components/models.ts              |  7 ++++
 src/functions/reverseGeocodeSocket.ts | 24 ++++++++++++++
 src/stores/socketio.ts                | 48 +++++++++++++++++++++------
 5 files changed, 70 insertions(+), 13 deletions(-)
 create mode 100644 src/functions/reverseGeocodeSocket.ts

diff --git a/src/components/SetLocationDialog.vue b/src/components/SetLocationDialog.vue
index 2528d74..b0ffa82 100644
--- a/src/components/SetLocationDialog.vue
+++ b/src/components/SetLocationDialog.vue
@@ -33,7 +33,7 @@
 
 <script setup lang="ts">
 import { useDialogPluginComponent } from 'quasar';
-import { reverseGeocodeRateLimited } from 'functions/reverseGeocode';
+import { reverseGeocodeRateLimited } from 'functions/reverseGeocodeSocket';
 import { ref, onMounted } from 'vue';
 import FormattedAddress from 'components/FormattedAddress.vue';
 
diff --git a/src/components/SocketTest.vue b/src/components/SocketTest.vue
index 108c9cb..320c8d2 100644
--- a/src/components/SocketTest.vue
+++ b/src/components/SocketTest.vue
@@ -32,7 +32,7 @@ function handleEmit() {
   const event = sockEvent.value;
   const jsonArgs = eventArgs.value;
   socket.emit(event as keyof ClientToServerEvents, jsonArgs, (resp: unknown) => {
-    console.log('Server Reponse: ' + String(resp));
+    console.log('Server Response: %s', resp);
   });
   sockEvent.value = '';
   eventArgs.value = '';
diff --git a/src/components/models.ts b/src/components/models.ts
index 52dfdd0..f750c84 100644
--- a/src/components/models.ts
+++ b/src/components/models.ts
@@ -237,6 +237,13 @@ export interface ClientToServerEvents {
     },
     callback?: (response: LocationMarkUpdateResponse) => void,
   ) => void;
+  reverse_geocode: (
+    args: {
+      latitude: number;
+      longitude: number;
+    },
+    callback?: (response: NominatimResponse) => void,
+  ) => void;
 }
 
 export interface SimulationControlResponse {
diff --git a/src/functions/reverseGeocodeSocket.ts b/src/functions/reverseGeocodeSocket.ts
new file mode 100644
index 0000000..0831d87
--- /dev/null
+++ b/src/functions/reverseGeocodeSocket.ts
@@ -0,0 +1,24 @@
+// services/nominatimService.ts
+import { useSocketioStore } from 'stores/socketio';
+import type { NominatimResponse, NominatimRequest } from 'components/models';
+
+const socketStore = useSocketioStore();
+
+let lastRequestTime = 0;
+
+export const reverseGeocodeRateLimited = async (
+  lat: number,
+  lon: number,
+): Promise<NominatimResponse> => {
+  const now = Date.now();
+  const timeSinceLast = now - lastRequestTime;
+
+  // Wait if less than 1000ms has passed
+  if (timeSinceLast < 1000) {
+    await new Promise((resolve) => setTimeout(resolve, 1000 - timeSinceLast));
+  }
+  const response: NominatimResponse = await socketStore.revGeoCode({latitude: lat, longitude: lon} as NominatimRequest);
+
+  lastRequestTime = Date.now();
+  return response;
+};
diff --git a/src/stores/socketio.ts b/src/stores/socketio.ts
index 4f12c0d..27bf12a 100644
--- a/src/stores/socketio.ts
+++ b/src/stores/socketio.ts
@@ -14,6 +14,8 @@ import type {
   SimulationStatus,
   LocationMarkUpdateResponse,
   LocationItemUpdate,
+  NominatimResponse,
+  NominatimRequest,
 } from 'components/models';
 
 const $q = useQuasar();
@@ -159,9 +161,10 @@ export const useSocketioStore = defineStore('socketio', {
         console.log('Location item update received, data: ', inData);
         this.locationQueueData[inData.loc_id] = inData.data;
       });
+      /*
       socket.onAny((eventName, ...args) => {
         console.log('Event received: ', eventName, ' Args: ', args, '');
-        /*        if (serverToClientKnownEvents.includes(eventName)) {
+                if (serverToClientKnownEvents.includes(eventName)) {
           console.log('Known event received: ', eventName, ' Args: ', args, '');
         } else {
           console.log(
@@ -175,8 +178,9 @@ export const useSocketioStore = defineStore('socketio', {
           );
           console.log(`Received UNKNOWN Event: ${eventName}`, args);
           }
-          */
+
       });
+     */
     },
     connect() {
       if (debugLog) {
@@ -396,7 +400,7 @@ export const useSocketioStore = defineStore('socketio', {
               if (response.command_status === 'ERROR') {
                 throw new Error(response.message);
               } else {
-                this.simulationState = response.data?.simulation_queue_state
+                this.simulationState = response.data?.simulation_queue_state;
                 if (debugLog) {
                   console.log('response from simulate_control_test-mode: ', response);
                 }
@@ -495,11 +499,17 @@ export const useSocketioStore = defineStore('socketio', {
             throw new Error('latitude or longitude not set');
           }
           if (!address) {
-            address = "{latitude}, {longitude}"
+            address = '{latitude}, {longitude}';
           }
           socket.emit(
             'simulation_control',
-            { command: 'add', latitude: latitude, longitude: longitude, delay: delay, address: address },
+            {
+              command: 'add',
+              latitude: latitude,
+              longitude: longitude,
+              delay: delay,
+              address: address,
+            },
             (response) => {
               if (response.command_status == 'ERROR') {
                 throw new Error(response.message);
@@ -575,15 +585,31 @@ export const useSocketioStore = defineStore('socketio', {
     setDeviceState(state: boolean) {
       this.deviceConnected = state;
     },
+    revGeoCode(nomRequest: NominatimRequest): Promise<NominatimResponse> {
+      return new Promise((resolve) => {
+        socket.emit('reverse_geocode', { latitude: nomRequest.latitude, longitude: nomRequest.longitude }, (response) => {
+          resolve(response);
+        });
+      });
+    },
     updateLocationMark(loc_id: string, key: string, value: string | number) {
-      let fnctRtn: { command_status: string, message: string } = { command_status: '', message: '' };
+      let fnctRtn: { command_status: string; message: string } = {
+        command_status: '',
+        message: '',
+      };
       if (debugLog) {
-        console.log('socketStore: Update LocationMark request, loc_id: %s, key: %s, new value: %s', loc_id, key, value);
+        console.log(
+          'socketStore: Update LocationMark request, loc_id: %s, key: %s, new value: %s',
+          loc_id,
+          key,
+          value,
+        );
       }
-      if (
-        !this.locationQueueData[loc_id]
-      ) {
-        fnctRtn = { command_status: 'error', message: 'Location Id: ' + loc_id + ' is not in the simulation queue' };
+      if (!this.locationQueueData[loc_id]) {
+        fnctRtn = {
+          command_status: 'error',
+          message: 'Location Id: ' + loc_id + ' is not in the simulation queue',
+        };
         throw new Error('loc_id ' + loc_id + 'not found');
       }
       if (debugLog) {