From ed425faf1a0cef1197e8f6fe82805fe1713d7871 Mon Sep 17 00:00:00 2001
From: Cfp <chaosflo44plus@gmail.com>
Date: Sun, 22 Jun 2025 11:08:04 +0200
Subject: [PATCH] feat: location marker with remote location support

---
 src/lib/components/lnv/Map.svelte             |  30 ++-
 src/lib/components/lnv/Sidebar.svelte         |  38 +++-
 src/lib/components/lnv/location.svelte.ts     | 183 ++++++++++++++++++
 src/lib/components/lnv/map.svelte.ts          |   6 +-
 src/lib/services/navigation/routing.svelte.ts |   9 +-
 5 files changed, 257 insertions(+), 9 deletions(-)
 create mode 100644 src/lib/components/lnv/location.svelte.ts

diff --git a/src/lib/components/lnv/Map.svelte b/src/lib/components/lnv/Map.svelte
index 0e13572..5f07137 100644
--- a/src/lib/components/lnv/Map.svelte
+++ b/src/lib/components/lnv/Map.svelte
@@ -10,7 +10,7 @@
 		Protocol,
 	} from "svelte-maplibre-gl";
 	import { view } from "./sidebar.svelte";
-	import { geolocate, map, pin } from "./map.svelte";
+	import { map, pin } from "./map.svelte";
 	import {
 		drawAllRoutes,
 		fetchRoute,
@@ -18,11 +18,15 @@
 	} from "$lib/services/navigation/routing.svelte";
 	import { createValhallaRequest } from "$lib/vehicles/ValhallaVehicles";
 	import { ROUTING_SERVER } from "$lib/services/hosts";
+	import { location } from "./location.svelte";
 
 	onMount(() => {
 		window.addEventListener("resize", map.updateMapPadding);
 		map.updateMapPadding();
 	});
+
+	let locationDot: HTMLDivElement | undefined = $state();
+	let locationAccuracyCircle: HTMLDivElement | undefined = $state();
 </script>
 
 <Protocol
@@ -60,6 +64,7 @@
 	padding={map.padding}
 	onload={async () => {
 		map.updateMapPadding();
+		location.locked = true;
 	}}
 	onclick={(e) => {
 		if (view.current.type == "main" || view.current.type == "info") {
@@ -67,9 +72,15 @@
 			pin.showInfo();
 		}
 	}}
+	onmove={(e) => {
+		// @ts-ignore
+		if (e.reason !== "location") {
+			location.locked = false;
+		}
+	}}
 >
 	<!-- <Hash /> -->
-	<GeolocateControl
+	<!-- <GeolocateControl
 		positionOptions={{
 			enableHighAccuracy: true,
 		}}
@@ -84,7 +95,7 @@
 			};
 			// $inspect(`Geolocation: ${e.coords.latitude}, ${e.coords.longitude} (Speed: ${speed} km/h, Accuracy: ${accuracy} m)`);
 		}}
-	/>
+	/> -->
 	{#if pin.isDropped}
 		<Marker lnglat={{ lat: pin.lat, lng: pin.lng }} />
 	{/if}
@@ -177,4 +188,17 @@
 			></LineLayer>
 		</GeoJSONSource>
 	{/if}
+
+	{#if location.available}
+		<div class="maplibregl-user-location-dot" bind:this={locationDot}></div>
+		<div class="maplibregl-user-location-accuracy-circle" bind:this={locationAccuracyCircle}></div>
+		<Marker
+			lnglat={{ lat: location.lat, lng: location.lng }}
+			element={locationDot}
+		/>
+		<Marker
+			lnglat={{ lat: location.lat, lng: location.lng }}
+			element={locationAccuracyCircle}
+		/>
+	{/if}
 </MapLibre>
diff --git a/src/lib/components/lnv/Sidebar.svelte b/src/lib/components/lnv/Sidebar.svelte
index eb1cdfa..414bc5e 100644
--- a/src/lib/components/lnv/Sidebar.svelte
+++ b/src/lib/components/lnv/Sidebar.svelte
@@ -8,10 +8,12 @@
 	import { map } from "./map.svelte";
 	import TripSidebar from "./sidebar/TripSidebar.svelte";
 	import Input from "../ui/input/input.svelte";
-	import { HomeIcon, SettingsIcon, UserIcon } from "@lucide/svelte";
+	import { EllipsisIcon, HomeIcon, SettingsIcon, UserIcon } from "@lucide/svelte";
 	import Button from "../ui/button/button.svelte";
 	import { search, type Feature } from "$lib/services/Search";
 	import SearchSidebar from "./sidebar/SearchSidebar.svelte";
+	import { advertiseRemoteLocation, location, remoteLocation } from "./location.svelte";
+	import * as Popover from "../ui/popover";
 
 	const views: {[key: string]: Component<any>} = {
 		main: MainSidebar,
@@ -112,6 +114,40 @@
 	<button>
 		<SettingsIcon />
 	</button>
+	<!-- <button onclick={() => {
+		location.toggleLock();
+	}}>
+		L
+	</button> -->
+	<Popover.Root>
+		<Popover.Trigger>
+			<button>
+				<EllipsisIcon />
+			</button>
+		</Popover.Trigger>
+		<Popover.Content>
+			<div class="flex flex-col gap-2">
+				<Button variant="outline" onclick={() => {
+					location.toggleLock();
+				}}>
+					{location.locked ? "Unlock Location" : "Lock Location"}
+				</Button>
+				{#if location.code}
+					<span>Advertise code: {location.code}</span>
+				{/if}
+				<Button variant="outline" onclick={() => {
+					advertiseRemoteLocation();
+				}}>
+					Advertise Location
+				</Button>
+				<Button variant="outline" onclick={() => {
+					remoteLocation(prompt("Code?") || "");
+				}}>
+					Join Remote Location
+				</Button>
+			</div>
+		</Popover.Content>
+	</Popover.Root>
 </div>
 
 <style>
diff --git a/src/lib/components/lnv/location.svelte.ts b/src/lib/components/lnv/location.svelte.ts
new file mode 100644
index 0000000..27c0727
--- /dev/null
+++ b/src/lib/components/lnv/location.svelte.ts
@@ -0,0 +1,183 @@
+import { LNV_SERVER } from "$lib/services/hosts"
+import { routing } from "$lib/services/navigation/routing.svelte"
+import { map } from "./map.svelte"
+
+export const location = $state({
+	available: false,
+	lat: 0,
+	lng: 0,
+	accuracy: 0,
+	speed: 0,
+	heading: null as number | null,
+	provider: "gps" as "gps" | "remote" | "simulated",
+	locked: true,
+	toggleLock: () => {
+		location.locked = !location.locked
+		console.log("Location lock toggled:", location.locked)
+		if (location.locked) {
+			map.value?.flyTo({
+				center: [location.lng, location.lat],
+				zoom: 16,
+				duration: 1000,
+				// bearing: location.heading !== null ? location.heading : undefined
+			}, {
+				reason: "location"
+			})
+		}
+	},
+	advertiser: null as WebSocket | null,
+	code: null as string | null,
+	lastUpdate: null as Date | null
+})
+
+export function watchLocation() {
+	if(navigator.geolocation) {
+		navigator.geolocation.watchPosition((pos) => {
+			if(location.provider !== "gps") return;
+			// console.log("Geolocation update:", pos)
+			location.lat = pos.coords.latitude
+			location.lng = pos.coords.longitude
+			location.accuracy = pos.coords.accuracy
+			location.speed = pos.coords.speed || 0
+			location.available = true
+			location.heading = pos.coords.heading
+			location.lastUpdate = new Date()
+	
+			if (location.locked) {
+				map.value?.flyTo({
+					center: [location.lng, location.lat],
+					zoom: 16,
+					duration: 1000,
+					// bearing: location.heading !== null ? location.heading : undefined
+				}, {
+					reason: "location"
+				})
+			}
+
+			// console.log(location.advertiser);
+	
+			if (location.advertiser) {
+				location.advertiser.send(JSON.stringify({
+					type: "location",
+					location: {
+						lat: location.lat,
+						lng: location.lng,
+						accuracy: location.accuracy,
+						speed: location.speed,
+						heading: location.heading
+					},
+					route: {
+						trip: routing.currentTrip,
+						info: routing.currentTripInfo,
+						geojson: routing.geojson
+					}
+				}))
+			}
+		}, (err) => {
+			console.error("Geolocation error:", err)
+		}, {
+			enableHighAccuracy: true
+		})
+	}
+}
+
+let checkRunning = false;
+
+if(!checkRunning) {
+	setInterval(() => {
+		checkRunning = true;
+		if(location.provider !== "gps") return;
+		// If the last update was more than 5 seconds ago, recall watchPosition
+		// console.log("Checking location update status")
+		if (location.lastUpdate && (new Date().getTime() - location.lastUpdate.getTime()) > 10000) {
+			console.warn("Location update is stale, rewatching position")
+			watchLocation();
+		}
+	}, 1000)
+	checkRunning = true;
+}
+
+watchLocation()
+
+export function advertiseRemoteLocation(code?: string) {
+	const ws = new WebSocket(
+		`${LNV_SERVER.replace("https", "wss").replace("http", "ws")}/ws`
+	);
+	ws.addEventListener("open", () => {
+		console.log("WebSocket connection established for remote location advertisement")
+		ws.send(JSON.stringify({ type: "advertise", code }))
+	});
+	ws.addEventListener("message", (event) => {
+		const data = JSON.parse(event.data);
+		console.log("WebSocket message received:", data);
+
+		if (data.type === "advertising") {
+			console.log("Advertising code:", data.code);
+			// alert(`You are now advertising your location with code: ${data.code}`);
+			location.locked = true; // Lock the location when advertising
+			location.advertiser = ws; // Store the WebSocket for sending location updates
+			location.code = data.code; // Store the advertising code
+		} else if (data.type === "error") {
+			console.error("WebSocket error:", data.message);
+		}
+	});
+}
+
+export function remoteLocation(code: string) {
+	// Open websocket connection
+	// Use LNV_SERVER, change to ws or wss based on protocol
+	const ws = new WebSocket(
+		`${LNV_SERVER.replace("https", "wss").replace("http", "ws")}/ws`
+	);
+	ws.addEventListener("open", () => {
+		console.log("WebSocket connection established for remote location")
+		ws.send(JSON.stringify({ type: "subscribe", code }))
+		location.provider = "remote"
+		location.code = code
+	})
+	ws.addEventListener("message", (event) => {
+		const data = JSON.parse(event.data)
+		if (data.type === "location") {
+			console.log("Remote location update:", data.location)
+			location.lat = data.location.lat
+			location.lng = data.location.lng
+			location.accuracy = data.location.accuracy
+			location.speed = data.location.speed || 0
+			location.available = true
+			location.heading = data.location.heading || null
+			routing.currentTrip = data.route.trip || null
+			routing.currentTripInfo = data.route.info || null
+			routing.geojson = data.route.geojson || null
+
+			if (location.locked) {
+				map.value?.flyTo({
+					center: [location.lng, location.lat],
+					zoom: 16,
+					duration: 1000,
+					// bearing: location.heading !== null ? location.heading : undefined
+				}, {
+					reason: "location"
+				})
+			}
+		}
+	})
+}
+
+// setInterval(() => {
+// 	// Move location towards heading (if available) at speed
+// 	// if (location.provider !== "simulated" || location.locked) return;
+// 	if (location.heading !== null && location.speed > 0) {
+// 		const rad = (location.heading * Math.PI) / 180
+// 		const distance = location.speed / 3600 // Convert speed from km/h to km/s
+// 		location.lat += (distance * Math.cos(rad)) / 111.32 // Approximate conversion from degrees to km
+// 		location.lng += (distance * Math.sin(rad)) / (111.32 * Math.cos((location.lat * Math.PI) / 180)) // Adjust for longitude
+// 		location.accuracy = 5 // Simulated accuracy
+// 		location.available = true
+
+// 		map.value?.flyTo({
+// 			center: [location.lng, location.lat],
+// 			zoom: 16,
+// 			duration: 1000
+// 		})
+// 	}
+// }, 100)
diff --git a/src/lib/components/lnv/map.svelte.ts b/src/lib/components/lnv/map.svelte.ts
index 4ea0a57..86da807 100644
--- a/src/lib/components/lnv/map.svelte.ts
+++ b/src/lib/components/lnv/map.svelte.ts
@@ -1,9 +1,9 @@
 import { reverseGeocode } from "$lib/services/Search";
 import { view } from "./sidebar.svelte";
 
-export const geolocate = $state({
-	currentLocation: null as WorldLocation | null,
-})
+// export const geolocate = $state({
+// 	currentLocation: null as WorldLocation | null,
+// })
 
 export const map = $state({
 	value: undefined as maplibregl.Map | undefined,
diff --git a/src/lib/services/navigation/routing.svelte.ts b/src/lib/services/navigation/routing.svelte.ts
index 8ae2d07..d903241 100644
--- a/src/lib/services/navigation/routing.svelte.ts
+++ b/src/lib/services/navigation/routing.svelte.ts
@@ -1,4 +1,5 @@
-import { geolocate, map } from "$lib/components/lnv/map.svelte";
+import { location } from "$lib/components/lnv/location.svelte";
+import { map } from "$lib/components/lnv/map.svelte";
 import type { ValhallaRequest } from "./ValhallaRequest";
 import type { LngLatBoundsLike } from "maplibre-gl";
 
@@ -204,7 +205,11 @@ export function stopNavigation() {
 }
 
 function getUserLocation(): WorldLocation {
-	return geolocate.currentLocation!;
+	// return geolocate.currentLocation!;
+	return {
+		lat: location.lat,
+		lon: location.lng
+	}
 	// const lnglat = window.geolocate._userLocationDotMarker.getLngLat();
 	// return { lat: lnglat.lat, lon: lnglat.lng };
 	// console.log(map.value!)