eae4075265
Replaces the device-events demo with the actual product:
- Prisma + PostGIS data layer (postgis/postgis:17-3.5). Lat/lng decimals
are the source of truth; a generated geometry(Point,4326) column with
a GIST index backs bbox queries. Migrations apply on container boot.
- JWT auth (bcryptjs + httpOnly cookie) with public registration that
creates an org; per-org roles (ORG_ADMIN/MEMBER/VIEWER) enforced by
guards on all /orgs/:orgId routes.
- Scoped API keys (X-API-Key, sha256-hashed, shown once) for
programmatic access, manageable by org admins.
- REST API: jobs/tickets CRUD with filters, points query (time range,
recordedAt cursor, bbox), members, devices, api-keys.
- MQTT ingest: devices publish to devices/{username}/points and /jobs;
unknown tickets auto-create stub jobs (source=DEVICE); every message
is raw-logged to device_events; acks on devices/{username}/jobs/ack.
Broker gets a dedicated backend user; testuser is now a plain device.
- Realtime: plain-WS gateway at /api/ws (socket.io removed) with
cookie auth and per-job channels feeding the map live.
- Next.js frontend: login/register, jobs list with filters, job detail
with live Google map (APWA utility colors, polylines per run) behind
a provider-neutral JobMap abstraction for a future Esri swap, and
settings pages for members/devices/api-keys.
- Seed: Umagul org, admin user, testuser device, demo job with RTK
points. Sample publisher updated to the new topic contract.
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
61 lines
1.6 KiB
TypeScript
61 lines
1.6 KiB
TypeScript
import { useEffect, useRef } from 'react';
|
|
import type { MapPoint } from '../components/map/types';
|
|
|
|
// Subscribes to live points for a job over the backend WebSocket.
|
|
// Reconnects with capped exponential backoff; resubscribes on reconnect.
|
|
export function useJobStream(jobId: string | null, onPoints: (points: MapPoint[]) => void) {
|
|
const handlerRef = useRef(onPoints);
|
|
handlerRef.current = onPoints;
|
|
|
|
useEffect(() => {
|
|
if (!jobId) {
|
|
return;
|
|
}
|
|
|
|
let socket: WebSocket | null = null;
|
|
let closed = false;
|
|
let attempt = 0;
|
|
let timer: ReturnType<typeof setTimeout> | null = null;
|
|
|
|
const connect = () => {
|
|
const proto = window.location.protocol === 'https:' ? 'wss' : 'ws';
|
|
socket = new WebSocket(`${proto}://${window.location.host}/api/ws`);
|
|
|
|
socket.onopen = () => {
|
|
attempt = 0;
|
|
socket?.send(JSON.stringify({ type: 'subscribe', channel: `job:${jobId}` }));
|
|
};
|
|
|
|
socket.onmessage = (event) => {
|
|
try {
|
|
const msg = JSON.parse(event.data);
|
|
if (msg.type === 'points' && msg.jobId === jobId) {
|
|
handlerRef.current(msg.points);
|
|
}
|
|
} catch {
|
|
// ignore malformed frames
|
|
}
|
|
};
|
|
|
|
socket.onclose = () => {
|
|
if (closed) {
|
|
return;
|
|
}
|
|
attempt += 1;
|
|
const delay = Math.min(1000 * 2 ** attempt, 15000);
|
|
timer = setTimeout(connect, delay);
|
|
};
|
|
};
|
|
|
|
connect();
|
|
|
|
return () => {
|
|
closed = true;
|
|
if (timer) {
|
|
clearTimeout(timer);
|
|
}
|
|
socket?.close();
|
|
};
|
|
}, [jobId]);
|
|
}
|