fleet simulator

server/simulator.js

@@ -1,13 +1,12 @@
-// Simulated fleet: drives GPS updates, an SOS and PTT floor requests against a
-// running server, so you can watch the console move without real devices.
-//
-//   cd server && npm run sim
-//   SERVER_URL=http://localhost:8080 SIM_CENTER=48.8566,2.3522 node simulator.js
+// Simulated fleet for the dispatch console.
+// Usage (server running on :8080):  node simulator.js
+// Env: SERVER_URL, SIM_UNITS, SIM_CENTER="lat,lng", ADMIN_USER, ADMIN_PASS
 import WebSocket from 'ws';
 
 const BASE = process.env.SERVER_URL || 'http://localhost:8080';
-const N = Number(process.env.SIM_UNITS) || 5;
-const [clat, clng] = (process.env.SIM_CENTER || '48.8566,2.3522').split(',').map(Number);
+const WS_URL = BASE.replace(/^http/, 'ws') + '/ws';
+const N = Number(process.env.SIM_UNITS || 5);
+const CENTER = (process.env.SIM_CENTER || '48.8566,2.3522').split(',').map(Number);
 
 async function main() {
   const login = await fetch(`${BASE}/api/login`, {
@@ -17,23 +16,23 @@ async function main() {
   });
   if (!login.ok) throw new Error(`login failed: ${login.status}`);
   const { token } = await login.json();
-  const headers = { authorization: `Bearer ${token}`, 'content-type': 'application/json' };
+  const auth = { authorization: `Bearer ${token}`, 'content-type': 'application/json' };
 
-  const groups = await (await fetch(`${BASE}/api/groups`, { headers })).json();
-  if (!groups.length) throw new Error('no talkgroups exist');
+  const groups = await (await fetch(`${BASE}/api/groups`, { headers: auth })).json();
+  if (!groups.length) throw new Error('no talkgroups exist — create one first');
   const groupId = groups[0].id;
 
-  const existing = await (await fetch(`${BASE}/api/members`, { headers })).json();
+  const existing = await (await fetch(`${BASE}/api/members`, { headers: auth })).json();
   const units = [];
   for (let i = 1; i <= N; i++) {
     const deviceId = `sim-${i}`;
     let m = existing.find((x) => x.device_id === deviceId);
     if (!m) {
       const res = await fetch(`${BASE}/api/members`, {
-        method: 'POST', headers,
+        method: 'POST',
+        headers: auth,
         body: JSON.stringify({ name: `SIM Unit ${i}`, callsign: `SIM-${i}`, device_id: deviceId, group_id: groupId }),
       });
-      if (!res.ok) throw new Error(`could not create ${deviceId}: ${await res.text()}`);
       m = await res.json();
     }
     units.push(m);
@@ -41,19 +40,21 @@ async function main() {
 
   const states = units.map((m) => ({
     m,
-    lat: clat + (Math.random() - 0.5) * 0.08,
-    lng: clng + (Math.random() - 0.5) * 0.12,
-    battery: 60 + Math.floor(Math.random() * 40),
     ws: null,
+    lat: CENTER[0] + (Math.random() - 0.5) * 0.08,
+    lng: CENTER[1] + (Math.random() - 0.5) * 0.12,
+    battery: 60 + Math.floor(Math.random() * 40),
   }));
 
   for (const s of states) {
-    const ws = new WebSocket(BASE.replace(/^http/, 'ws') + '/ws');
+    const ws = new WebSocket(WS_URL);
     ws.on('open', () => ws.send(JSON.stringify({ type: 'auth', token, memberId: s.m.id })));
     ws.on('message', (d) => {
       const msg = JSON.parse(d.toString());
-      if (msg.type === 'ptt_denied') console.log(`[${s.m.name}] PTT denied — floor held by ${msg.holder}`);
+      if (msg.type === 'ptt_denied') console.log(`[${s.m.name}] ptt denied (held by ${msg.holder})`);
+      if (msg.type === 'floor' && msg.memberId === s.m.id) console.log(`[${s.m.name}] holding the floor on group ${msg.groupId}`);
     });
+    ws.on('error', (e) => console.error(`[${s.m.name}] ws error:`, e.message));
     s.ws = ws;
   }
 
@@ -68,19 +69,18 @@ async function main() {
     }
   }, 5000);
 
-  // one unit raises an SOS shortly after start
   setTimeout(() => {
     const s = states[0];
     if (s.ws.readyState === WebSocket.OPEN) {
       s.ws.send(JSON.stringify({ type: 'sos' }));
-      console.log(`[${s.m.name}] SOS sent`);
+      console.log('[SIM Unit 1] SOS sent');
     }
   }, 25000);
 
-  // units take turns requesting the PTT floor
   let turn = 0;
   setInterval(() => {
-    const s = states[turn++ % states.length];
+    const s = states[turn % states.length];
+    turn++;
     if (s.ws.readyState !== WebSocket.OPEN) return;
     s.ws.send(JSON.stringify({ type: 'ptt_start' }));
     setTimeout(() => {
@@ -88,7 +88,7 @@ async function main() {
     }, 4000);
   }, 30000);
 
-  console.log(`simulating ${N} units against ${BASE} — Ctrl+C to stop`);
+  console.log(`Simulating ${N} units against ${BASE} — Ctrl+C to stop.`);
 }
 
 main().catch((e) => { console.error(e); process.exit(1); });