simulated fleet for testing GPS, SOS and PTT flow

server/simulator.js

@@ -0,0 +1,94 @@
+// 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
+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);
+
+async function main() {
+  const login = await fetch(`${BASE}/api/login`, {
+    method: 'POST',
+    headers: { 'content-type': 'application/json' },
+    body: JSON.stringify({ username: process.env.ADMIN_USER || 'admin', password: process.env.ADMIN_PASS || 'admin' }),
+  });
+  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 groups = await (await fetch(`${BASE}/api/groups`, { headers })).json();
+  if (!groups.length) throw new Error('no talkgroups exist');
+  const groupId = groups[0].id;
+
+  const existing = await (await fetch(`${BASE}/api/members`, { headers })).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,
+        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);
+  }
+
+  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,
+  }));
+
+  for (const s of states) {
+    const ws = new WebSocket(BASE.replace(/^http/, 'ws') + '/ws');
+    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}`);
+    });
+    s.ws = ws;
+  }
+
+  setInterval(() => {
+    for (const s of states) {
+      s.lat += (Math.random() - 0.5) * 0.002;
+      s.lng += (Math.random() - 0.5) * 0.003;
+      if (Math.random() < 0.1) s.battery = Math.max(5, s.battery - 1);
+      if (s.ws.readyState === WebSocket.OPEN) {
+        s.ws.send(JSON.stringify({ type: 'gps', lat: s.lat, lng: s.lng, speed: 5 + Math.random() * 40, battery: s.battery }));
+      }
+    }
+  }, 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`);
+    }
+  }, 25000);
+
+  // units take turns requesting the PTT floor
+  let turn = 0;
+  setInterval(() => {
+    const s = states[turn++ % states.length];
+    if (s.ws.readyState !== WebSocket.OPEN) return;
+    s.ws.send(JSON.stringify({ type: 'ptt_start' }));
+    setTimeout(() => {
+      if (s.ws.readyState === WebSocket.OPEN) s.ws.send(JSON.stringify({ type: 'ptt_stop' }));
+    }, 4000);
+  }, 30000);
+
+  console.log(`simulating ${N} units against ${BASE} — Ctrl+C to stop`);
+}
+
+main().catch((e) => { console.error(e); process.exit(1); });