mirror of
https://github.com/ajvpot/meshexplorer.git
synced 2026-06-25 04:10:56 +02:00
ajvpot
393 lines
16 KiB
TypeScript
393 lines
16 KiB
TypeScript
"use client";
|
|
import { MapContainer, TileLayer, useMapEvents, Marker, Popup, MapContainerProps, useMap } from "react-leaflet";
|
|
import { useRouter, useSearchParams } from "next/navigation";
|
|
import { useEffect, useMemo, useRef, useState } from "react";
|
|
import 'leaflet/dist/leaflet.css';
|
|
import L from "leaflet";
|
|
import 'leaflet.markercluster/dist/leaflet.markercluster.js';
|
|
import 'leaflet.markercluster/dist/MarkerCluster.css';
|
|
import 'leaflet.markercluster/dist/MarkerCluster.Default.css';
|
|
import { useConfig } from "./ConfigContext";
|
|
import moment from "moment";
|
|
|
|
const DEFAULT = {
|
|
lat: 47.6062, // Seattle
|
|
lng: -122.3321,
|
|
zoom: 12,
|
|
};
|
|
|
|
type NodePosition = {
|
|
node_id: string;
|
|
latitude: number;
|
|
longitude: number;
|
|
altitude?: number;
|
|
last_seen?: string;
|
|
type?: string;
|
|
short_name?: string;
|
|
name?: string | null;
|
|
};
|
|
|
|
type ClusteredMarkersProps = { nodes: NodePosition[] };
|
|
function ClusteredMarkers({ nodes }: ClusteredMarkersProps) {
|
|
const map = useMap();
|
|
const { config } = useConfig ? useConfig() : { config: undefined };
|
|
useEffect(() => {
|
|
if (!map) return;
|
|
// Remove any previous layers
|
|
map.eachLayer((layer: any) => {
|
|
if (layer && layer._isClusterLayer) {
|
|
map.removeLayer(layer);
|
|
}
|
|
});
|
|
if (config?.clustering === false) {
|
|
// Add markers individually
|
|
const markerLayers: any[] = [];
|
|
nodes.forEach((node: NodePosition) => {
|
|
const markerClass =
|
|
node.type === "meshtastic"
|
|
? "custom-node-marker custom-node-marker--green"
|
|
: node.type === "meshcore"
|
|
? "custom-node-marker custom-node-marker--blue custom-node-marker--top"
|
|
: "custom-node-marker";
|
|
const label = (config?.showNodeNames !== false && node.short_name) ? `<div class='custom-node-label'>${node.short_name}</div>` : '';
|
|
const icon = L.divIcon({
|
|
className: 'custom-node-marker-container',
|
|
iconSize: [16, 32],
|
|
iconAnchor: [8, 8],
|
|
html: `${label}<div class='${markerClass}'></div>`,
|
|
});
|
|
const marker = L.marker([node.latitude, node.longitude], { icon });
|
|
(marker as any).options.nodeData = node;
|
|
let popupHtml = `<div>`;
|
|
popupHtml += `<div><b>ID:</b> ${node.node_id}</div>`;
|
|
popupHtml += `<div><b>Full Name:</b> ${node.name ?? "-"}</div>`;
|
|
popupHtml += `<div><b>Short Name:</b> ${node.short_name ?? "-"}</div>`;
|
|
popupHtml += `<div><b>Type:</b> ${node.type ?? "-"}</div>`;
|
|
popupHtml += `<div><b>Lat:</b> ${node.latitude}</div>`;
|
|
popupHtml += `<div><b>Lng:</b> ${node.longitude}</div>`;
|
|
popupHtml += `<div><b>Alt:</b> ${node.altitude !== undefined ? node.altitude : "-"}</div>`;
|
|
if (node.last_seen) {
|
|
// Parse as UTC, display UTC, and show local relative time
|
|
const utcTime = moment.utc(node.last_seen);
|
|
const localAgo = utcTime.local().fromNow();
|
|
popupHtml += `<div><b>Last seen:</b> ${utcTime.format('YYYY-MM-DD HH:mm:ss')} <span style='color: #888;'>(UTC)</span><br/><span style='color: #888;'>${localAgo}</span></div>`;
|
|
} else {
|
|
popupHtml += `<div><b>Last seen:</b> -</div>`;
|
|
}
|
|
popupHtml += `</div>`;
|
|
marker.bindPopup(popupHtml);
|
|
marker.addTo(map);
|
|
markerLayers.push(marker);
|
|
});
|
|
// Mark for cleanup
|
|
markerLayers.forEach(layer => { layer._isClusterLayer = true; });
|
|
return () => {
|
|
markerLayers.forEach(layer => map.removeLayer(layer));
|
|
};
|
|
} else {
|
|
// Clustered mode (existing logic)
|
|
const iconCreateFunction = (cluster: any) => {
|
|
const children = cluster.getAllChildMarkers();
|
|
let meshtasticCount = 0;
|
|
let meshcoreCount = 0;
|
|
children.forEach((marker: any) => {
|
|
const node = marker.options && marker.options.nodeData;
|
|
if (node?.type === 'meshtastic') meshtasticCount++;
|
|
else if (node?.type === 'meshcore') meshcoreCount++;
|
|
});
|
|
const total = meshtasticCount + meshcoreCount;
|
|
const percentMeshcore = total ? meshcoreCount / total : 0;
|
|
const percentMeshtastic = total ? meshtasticCount / total : 0;
|
|
// Pie chart SVG
|
|
const r = 18;
|
|
const c = 2 * Math.PI * r;
|
|
const meshcoreArc = percentMeshcore * c;
|
|
const meshtasticArc = percentMeshtastic * c;
|
|
return L.divIcon({
|
|
html: `
|
|
<div style="position: relative; width: 40px; height: 40px; display: flex; align-items: center; justify-content: center; border-radius: 50%; background: transparent;">
|
|
<svg width="40" height="40" viewBox="0 0 40 40" style="border-radius: 50%; background: transparent;">
|
|
<circle
|
|
r="18"
|
|
cx="20"
|
|
cy="20"
|
|
fill="#fff"
|
|
stroke="#fff"
|
|
stroke-width="4"
|
|
opacity="0.7"
|
|
/>
|
|
<circle
|
|
r="18"
|
|
cx="20"
|
|
cy="20"
|
|
fill="transparent"
|
|
stroke="#2563eb"
|
|
stroke-width="36"
|
|
stroke-dasharray="${meshcoreArc} ${c - meshcoreArc}"
|
|
stroke-dashoffset="0"
|
|
transform="rotate(-90 20 20)"
|
|
opacity="0.7"
|
|
/>
|
|
<circle
|
|
r="18"
|
|
cx="20"
|
|
cy="20"
|
|
fill="transparent"
|
|
stroke="#22c55e"
|
|
stroke-width="36"
|
|
stroke-dasharray="${meshtasticArc} ${c - meshtasticArc}"
|
|
stroke-dashoffset="-${meshcoreArc}"
|
|
transform="rotate(-90 20 20)"
|
|
opacity="0.7"
|
|
/>
|
|
</svg>
|
|
<span style="position: absolute; top: 50%; left: 50%; transform: translate(-50%, -50%); color: #111; font-weight: bold; font-size: 15px; line-height: 1; text-shadow: 0 0 2px #fff, 0 0 2px #fff, 0 0 2px #fff, 0 0 2px #fff; background: none; opacity: 1; z-index: 200; pointer-events: none;">${total}</span>
|
|
</div>
|
|
`,
|
|
className: 'custom-cluster-icon',
|
|
iconSize: [40, 40],
|
|
iconAnchor: [20, 20],
|
|
});
|
|
};
|
|
const markers = (L as any).markerClusterGroup({
|
|
iconCreateFunction,
|
|
maxClusterRadius: 40,
|
|
});
|
|
nodes.forEach((node: NodePosition) => {
|
|
const markerClass =
|
|
node.type === "meshtastic"
|
|
? "custom-node-marker custom-node-marker--green"
|
|
: node.type === "meshcore"
|
|
? "custom-node-marker custom-node-marker--blue custom-node-marker--top"
|
|
: "custom-node-marker";
|
|
const label = (config?.showNodeNames !== false && node.short_name) ? `<div class='custom-node-label'>${node.short_name}</div>` : '';
|
|
const icon = L.divIcon({
|
|
className: 'custom-node-marker-container',
|
|
iconSize: [16, 32],
|
|
iconAnchor: [8, 8],
|
|
html: `${label}<div class='${markerClass}'></div>`,
|
|
});
|
|
const marker = L.marker([node.latitude, node.longitude], { icon });
|
|
(marker as any).options.nodeData = node;
|
|
let popupHtml = `<div>`;
|
|
popupHtml += `<div><b>ID:</b> ${node.node_id}</div>`;
|
|
popupHtml += `<div><b>Full Name:</b> ${node.name ?? "-"}</div>`;
|
|
popupHtml += `<div><b>Short Name:</b> ${node.short_name ?? "-"}</div>`;
|
|
popupHtml += `<div><b>Type:</b> ${node.type ?? "-"}</div>`;
|
|
popupHtml += `<div><b>Lat:</b> ${node.latitude}</div>`;
|
|
popupHtml += `<div><b>Lng:</b> ${node.longitude}</div>`;
|
|
popupHtml += `<div><b>Alt:</b> ${node.altitude !== undefined ? node.altitude : "-"}</div>`;
|
|
if (node.last_seen) {
|
|
// Parse as UTC, display UTC, and show local relative time
|
|
const utcTime = moment.utc(node.last_seen);
|
|
const localAgo = utcTime.local().fromNow();
|
|
popupHtml += `<div><b>Last seen:</b> ${utcTime.format('YYYY-MM-DD HH:mm:ss')} <span style='color: #888;'>(UTC)</span><br/><span style='color: #888;'>${localAgo}</span></div>`;
|
|
} else {
|
|
popupHtml += `<div><b>Last seen:</b> -</div>`;
|
|
}
|
|
popupHtml += `</div>`;
|
|
marker.bindPopup(popupHtml);
|
|
markers.addLayer(marker);
|
|
});
|
|
markers._isClusterLayer = true;
|
|
map.addLayer(markers);
|
|
return () => {
|
|
map.removeLayer(markers);
|
|
};
|
|
}
|
|
}, [map, nodes, config?.clustering, config?.showNodeNames]);
|
|
return null;
|
|
}
|
|
|
|
export default function MapView() {
|
|
const [nodePositions, setNodePositions] = useState<NodePosition[]>([]);
|
|
const [bounds, setBounds] = useState<[[number, number], [number, number]] | null>(null);
|
|
const [loading, setLoading] = useState(false);
|
|
const [lastResultCount, setLastResultCount] = useState<number>(0);
|
|
const fetchController = useRef<AbortController | null>(null);
|
|
const lastRequestedBounds = useRef<[[number, number], [number, number]] | null>(null);
|
|
const { config } = useConfig ? useConfig() : { config: undefined };
|
|
|
|
type TileLayerKey = 'openstreetmap' | 'opentopomap' | 'esri';
|
|
const tileLayerOptions: Record<TileLayerKey, { url: string; attribution: string; maxZoom: number; subdomains?: string[] }> = {
|
|
openstreetmap: {
|
|
url: "https://{s}.tile.openstreetmap.org/{z}/{x}/{y}.png",
|
|
attribution: 'Tiles © <a href="https://www.openstreetmap.org/copyright">OpenStreetMap</a> | Data from <a target="_blank" href="https://meshtastic.org/docs/software/integrations/mqtt/">Meshtastic</a>',
|
|
maxZoom: 22,
|
|
},
|
|
opentopomap: {
|
|
url: "https://{s}.tile.opentopomap.org/{z}/{x}/{y}.png",
|
|
attribution: 'Tiles © <a href="https://www.openstreetmap.org/copyright">OpenStreetMap</a>',
|
|
maxZoom: 17,
|
|
},
|
|
esri: {
|
|
url: "https://server.arcgisonline.com/ArcGIS/rest/services/World_Imagery/MapServer/tile/{z}/{y}/{x}",
|
|
attribution: 'Tiles © <a href="https://developers.arcgis.com/documentation/mapping-apis-and-services/deployment/basemap-attribution/">Esri</a> | Data from <a target="_blank" href="https://meshtastic.org/docs/software/integrations/mqtt/">Meshtastic</a>',
|
|
maxZoom: 21,
|
|
},
|
|
};
|
|
const selectedTileLayer = tileLayerOptions[(config?.tileLayer as TileLayerKey) || 'openstreetmap'];
|
|
|
|
function fetchNodes(bounds?: [[number, number], [number, number]]) {
|
|
if (fetchController.current) {
|
|
fetchController.current.abort();
|
|
}
|
|
const controller = new AbortController();
|
|
fetchController.current = controller;
|
|
setLoading(true);
|
|
let url = "/api/map";
|
|
const params = [];
|
|
if (bounds) {
|
|
const [[minLat, minLng], [maxLat, maxLng]] = bounds;
|
|
params.push(`minLat=${minLat}`);
|
|
params.push(`maxLat=${maxLat}`);
|
|
params.push(`minLng=${minLng}`);
|
|
params.push(`maxLng=${maxLng}`);
|
|
}
|
|
if (config?.nodeTypes && config.nodeTypes.length > 0) {
|
|
for (const type of config.nodeTypes) {
|
|
params.push(`nodeTypes=${encodeURIComponent(type)}`);
|
|
}
|
|
}
|
|
if (config?.lastSeen !== null && config?.lastSeen !== undefined) {
|
|
params.push(`lastSeen=${config.lastSeen}`);
|
|
}
|
|
if (params.length > 0) {
|
|
url += `?${params.join("&")}`;
|
|
}
|
|
fetch(url, { signal: controller.signal })
|
|
.then((res) => res.json())
|
|
.then((data) => {
|
|
if (Array.isArray(data)) {
|
|
setNodePositions(data);
|
|
setLastResultCount(data.length);
|
|
}
|
|
if (fetchController.current === controller) setLoading(false);
|
|
})
|
|
.catch((err) => {
|
|
if (err.name !== "AbortError") setNodePositions([]);
|
|
if (fetchController.current === controller) setLoading(false);
|
|
});
|
|
}
|
|
|
|
function isBoundsInside(inner: [[number, number], [number, number]], outer: [[number, number], [number, number]]) {
|
|
// inner: [[minLat, minLng], [maxLat, maxLng]]
|
|
// outer: [[minLat, minLng], [maxLat, maxLng]]
|
|
return (
|
|
inner[0][0] >= outer[0][0] && // minLat
|
|
inner[0][1] >= outer[0][1] && // minLng
|
|
inner[1][0] <= outer[1][0] && // maxLat
|
|
inner[1][1] <= outer[1][1] // maxLng
|
|
);
|
|
}
|
|
|
|
function MapEventCatcher() {
|
|
useMapEvents({
|
|
moveend: (e) => {
|
|
const b = e.target.getBounds();
|
|
const buffer = 0.2; // 20% buffer
|
|
const latDiff = b.getNorthEast().lat - b.getSouthWest().lat;
|
|
const lngDiff = b.getNorthEast().lng - b.getSouthWest().lng;
|
|
const newBounds: [[number, number], [number, number]] = [
|
|
[
|
|
b.getSouthWest().lat - latDiff * buffer,
|
|
b.getSouthWest().lng - lngDiff * buffer,
|
|
],
|
|
[
|
|
b.getNorthEast().lat + latDiff * buffer,
|
|
b.getNorthEast().lng + lngDiff * buffer,
|
|
],
|
|
];
|
|
// Only always refetch if we have too many nodes depending on clustering setting.
|
|
if (
|
|
(lastResultCount > (config?.clustering ? 5000: 1000)) ||
|
|
!lastRequestedBounds.current ||
|
|
!isBoundsInside(newBounds, lastRequestedBounds.current)
|
|
) {
|
|
setBounds(newBounds);
|
|
}
|
|
},
|
|
zoomend: (e) => {
|
|
const b = e.target.getBounds();
|
|
const buffer = 0.2; // 20% buffer
|
|
const latDiff = b.getNorthEast().lat - b.getSouthWest().lat;
|
|
const lngDiff = b.getNorthEast().lng - b.getSouthWest().lng;
|
|
const newBounds: [[number, number], [number, number]] = [
|
|
[
|
|
b.getSouthWest().lat - latDiff * buffer,
|
|
b.getSouthWest().lng - lngDiff * buffer,
|
|
],
|
|
[
|
|
b.getNorthEast().lat + latDiff * buffer,
|
|
b.getNorthEast().lng + lngDiff * buffer,
|
|
],
|
|
];
|
|
// Only always refetch if clustering is disabled and lastResultCount > 1000
|
|
if (
|
|
(config?.clustering === false && lastResultCount > 1000) ||
|
|
!lastRequestedBounds.current ||
|
|
!isBoundsInside(newBounds, lastRequestedBounds.current)
|
|
) {
|
|
setBounds(newBounds);
|
|
}
|
|
},
|
|
});
|
|
return null;
|
|
}
|
|
|
|
// Set initial bounds on first render using the map instance
|
|
function InitialBoundsSetter() {
|
|
const map = useMap();
|
|
useEffect(() => {
|
|
if (!bounds && map) {
|
|
const b = map.getBounds();
|
|
setBounds([
|
|
[b.getSouthWest().lat, b.getSouthWest().lng],
|
|
[b.getNorthEast().lat, b.getNorthEast().lng],
|
|
]);
|
|
}
|
|
}, [map]);
|
|
return null;
|
|
}
|
|
|
|
useEffect(() => {
|
|
fetchController.current?.abort(); // abort any in-flight request on effect cleanup
|
|
if (bounds) {
|
|
fetchNodes(bounds);
|
|
lastRequestedBounds.current = bounds;
|
|
} else {
|
|
// Don't fetch until bounds is set
|
|
setNodePositions([]);
|
|
lastRequestedBounds.current = null;
|
|
}
|
|
return () => {
|
|
fetchController.current?.abort();
|
|
};
|
|
}, [bounds, config?.nodeTypes, config?.lastSeen]);
|
|
|
|
return (
|
|
<div style={{ width: "100%", height: "100%", position: "relative" }}>
|
|
{loading && (
|
|
<div style={{ position: "absolute", top: 16, right: 16, zIndex: 1000 }}>
|
|
<div className="map-spinner" />
|
|
</div>
|
|
)}
|
|
<MapContainer
|
|
center={[DEFAULT.lat, DEFAULT.lng]}
|
|
zoom={DEFAULT.zoom}
|
|
style={{ width: "100%", height: "100%", zIndex: 1 }}
|
|
className="bg-gray-200"
|
|
>
|
|
<InitialBoundsSetter />
|
|
<MapEventCatcher />
|
|
<TileLayer
|
|
attribution={selectedTileLayer.attribution}
|
|
url={selectedTileLayer.url}
|
|
maxZoom={selectedTileLayer.maxZoom}
|
|
{...(selectedTileLayer.subdomains ? { subdomains: selectedTileLayer.subdomains } : {})}
|
|
/>
|
|
<ClusteredMarkers nodes={nodePositions} />
|
|
</MapContainer>
|
|
</div>
|
|
);
|
|
}
|