From 64ce25423922052ed4092c0722bf30b7e232db17 Mon Sep 17 00:00:00 2001
From: PxlLoewe <72106766+PxlLoewe@users.noreply.github.com>
Date: Wed, 21 May 2025 14:48:07 -0700
Subject: [PATCH] addd HPG state

---
 apps/dispatch-server/routes/mission.ts        |  73 +++++++++++++++++-
 .../socket-events/connect-desktop.ts          |  25 +++++-
 apps/dispatch/app/_components/Audio.tsx       |  12 +++
 .../app/_components/QueryProvider.tsx         |   3 +-
 apps/dispatch/app/_store/audioStore.ts        |   2 +-
 .../_components/pannel/MissionForm.tsx        |  41 +++++++---
 grafana/grafana.db                            | Bin 1122304 -> 1122304 bytes
 .../database/prisma/schema/mission.prisma     |  37 ++++++---
 8 files changed, 165 insertions(+), 28 deletions(-)

diff --git a/apps/dispatch-server/routes/mission.ts b/apps/dispatch-server/routes/mission.ts
index f1599890..cede9fa8 100644
--- a/apps/dispatch-server/routes/mission.ts
+++ b/apps/dispatch-server/routes/mission.ts
@@ -1,4 +1,4 @@
-import { prisma } from "@repo/db";
+import { HpgValidationState, Prisma, prisma } from "@repo/db";
 import { Router } from "express";
 import { io } from "../index";
 import { sendNtfyMission } from "modules/ntfy";
@@ -203,4 +203,75 @@ router.post("/:id/send-alert", async (req, res) => {
 	}
 });
 
+router.post("/:id/validate-hpg", async (req, res) => {
+	try {
+		const { id } = req.params;
+		const mission = await prisma.mission.findFirstOrThrow({
+			where: {
+				id: Number(id),
+			},
+		});
+
+		const activeAircraftinMission = await prisma.connectedAircraft.findFirst({
+			where: {
+				stationId: {
+					in: mission?.missionStationIds,
+				},
+				posH145active: true,
+				logoutTime: null,
+			},
+			include: {
+				Station: true,
+			},
+		});
+
+		/* if (activeAircraftinMission.length === 0) {
+			res.status(400).json({ error: "No active aircraft in mission" });
+			return;
+		} */
+
+		res.json({
+			message: "HPG validation started",
+		});
+
+		io.to(`desktop:${activeAircraftinMission}`).emit(
+			"hpg-validation",
+			{
+				hpgMissionType: mission?.hpgMissionString,
+				lat: mission?.addressLat,
+				lng: mission?.addressLng,
+			},
+			async (result: {
+				state: HpgValidationState;
+				lat: number;
+				lng: number;
+			}) => {
+				console.log("response from user:", result);
+
+				const newMission = await prisma.mission.update({
+					where: { id: Number(id) },
+					data: {
+						// save position of new mission
+						addressLat:
+							result.state === "POSITION_AMANDED"
+								? result.lat
+								: mission.addressLat,
+						addressLng:
+							result.state === "POSITION_AMANDED"
+								? result.lng
+								: mission.addressLng,
+						hpgLocationLat: result.lat,
+						hpgLocationLng: result.lng,
+						hpgValidationState: result.state,
+					},
+				});
+				io.to("dispatchers").emit("update-mission", newMission);
+			},
+		);
+	} catch (error) {
+		console.error(error);
+		res.json({ error: (error as Error).message || "Failed to validate HPG" });
+	}
+});
+
 export default router;
diff --git a/apps/dispatch-server/socket-events/connect-desktop.ts b/apps/dispatch-server/socket-events/connect-desktop.ts
index 7be52449..5c10e93a 100644
--- a/apps/dispatch-server/socket-events/connect-desktop.ts
+++ b/apps/dispatch-server/socket-events/connect-desktop.ts
@@ -1,13 +1,34 @@
-import { User } from "@repo/db";
+import { prisma, User } from "@repo/db";
 import { Socket, Server } from "socket.io";
 
 export const handleConnectDesktop = (socket: Socket, io: Server) => () => {
 	const user = socket.data.user as User;
-	console.log("connect-desktop", user.publicId);
+
+	const connectedAircraft = prisma.connectedAircraft.findFirst({
+		where: {
+			userId: user.id,
+			logoutTime: null,
+		},
+		include: {
+			Station: true,
+		},
+	});
+
+	const conenctedDispatchers = prisma.connectedDispatcher.findFirst({
+		where: {
+			userId: user.id,
+			logoutTime: null,
+		},
+	})
+
 	socket.join(`user:${user.id}`);
 	socket.join(`desktop:${user.id}`);
 
 	socket.on("ptt", (data) => {
 		socket.to(`user:${user.id}`).emit("ptt", data);
+		socket.to("pilots").emit("other-ptt", {
+			publicUser: user.publicId,
+			source: 
+		})
 	});
 };
diff --git a/apps/dispatch/app/_components/Audio.tsx b/apps/dispatch/app/_components/Audio.tsx
index 89df26b3..f0cc5dea 100644
--- a/apps/dispatch/app/_components/Audio.tsx
+++ b/apps/dispatch/app/_components/Audio.tsx
@@ -21,6 +21,8 @@ import { ROOMS } from "_data/livekitRooms";
 
 export const Audio = () => {
 	const connection = usePilotConnectionStore();
+	const [showSource, setShowSource] = useState(false);
+
 	const {
 		isTalking,
 		toggleTalking,
@@ -31,9 +33,16 @@ export const Audio = () => {
 		remoteParticipants,
 		room,
 		message,
+		source,
 	} = useAudioStore();
 	const [selectedRoom, setSelectedRoom] = useState<string>("LST_01");
 
+	useEffect(() => {
+		setShowSource(true);
+		setTimeout(() => {
+			setShowSource(false);
+		}, 2000);
+	}, [source, isTalking]);
 	useEffect(() => {
 		const joinRoom = async () => {
 			if (connection.status != "connected") return;
@@ -55,6 +64,9 @@ export const Audio = () => {
 				{state === "error" && (
 					<div className="h-4 flex items-center">{message}</div>
 				)}
+				{showSource && source && (
+					<div className="h-4 flex items-center">{source}</div>
+				)}
 				<button
 					onClick={() => {
 						if (state === "connected") toggleTalking();
diff --git a/apps/dispatch/app/_components/QueryProvider.tsx b/apps/dispatch/app/_components/QueryProvider.tsx
index fda9ae1b..0ffd0ca6 100644
--- a/apps/dispatch/app/_components/QueryProvider.tsx
+++ b/apps/dispatch/app/_components/QueryProvider.tsx
@@ -5,6 +5,7 @@ import { toast } from "react-hot-toast";
 import { QueryClient, QueryClientProvider } from "@tanstack/react-query";
 import { ReactNode, useEffect, useState } from "react";
 import { dispatchSocket } from "dispatch/socket";
+import { Mission } from "@repo/db";
 
 export function QueryProvider({ children }: { children: ReactNode }) {
 	const [queryClient] = useState(
@@ -22,7 +23,7 @@ export function QueryProvider({ children }: { children: ReactNode }) {
 			}),
 	);
 	useEffect(() => {
-		const invalidateMission = () => {
+		const invalidateMission = (mission: Mission) => {
 			queryClient.invalidateQueries({
 				queryKey: ["missions"],
 			});
diff --git a/apps/dispatch/app/_store/audioStore.ts b/apps/dispatch/app/_store/audioStore.ts
index 886eaa56..43166e16 100644
--- a/apps/dispatch/app/_store/audioStore.ts
+++ b/apps/dispatch/app/_store/audioStore.ts
@@ -45,7 +45,7 @@ export const useAudioStore = create<TalkState>((set, get) => ({
 		if (!room) return;
 		room.localParticipant.setMicrophoneEnabled(!isTalking);
 
-		set((state) => ({ isTalking: !state.isTalking }));
+		set((state) => ({ isTalking: !state.isTalking, source: "web-app" }));
 	},
 	connect: async (roomName) => {
 		set({ state: "connecting" });
diff --git a/apps/dispatch/app/dispatch/_components/pannel/MissionForm.tsx b/apps/dispatch/app/dispatch/_components/pannel/MissionForm.tsx
index 6ec9ed21..efc77f7a 100644
--- a/apps/dispatch/app/dispatch/_components/pannel/MissionForm.tsx
+++ b/apps/dispatch/app/dispatch/_components/pannel/MissionForm.tsx
@@ -105,6 +105,9 @@ export const MissionForm = () => {
 	});
 	const { missionFormValues, setOpen } = usePannelStore((state) => state);
 
+	const missionInfoText = form.watch("missionAdditionalInfo");
+	const hpgMissionString = form.watch("hpgMissionString");
+
 	useEffect(() => {
 		if (session.data?.user.id) {
 			form.setValue("createdUserId", session.data.user.id);
@@ -178,7 +181,7 @@ export const MissionForm = () => {
 				</div>
 				<input
 					type="text"
-					{...form.register("missionAdditionalInfo")}
+					{...form.register("addressAdditionalInfo")}
 					placeholder="Zusätzliche Adressinformationen"
 					className="input input-primary input-bordered w-full mt-4"
 				/>
@@ -332,10 +335,16 @@ export const MissionForm = () => {
 							onClick={form.handleSubmit(
 								async (mission: MissionOptionalDefaults) => {
 									try {
+										const hpgSzenario = mission.hpgMissionString?.split(":")[0];
 										const newMission = await editMissionMutation.mutateAsync({
 											id: Number(editingMissionId),
-											mission:
-												mission as unknown as Partial<Prisma.MissionUpdateInput>,
+											mission: {
+												...(mission as unknown as Prisma.MissionCreateInput),
+												missionAdditionalInfo:
+													!mission.missionAdditionalInfo.length && hpgSzenario
+														? `HPG-Szenario: ${hpgSzenario}`
+														: mission.missionAdditionalInfo,
+											},
 										});
 										toast.success(
 											`Einsatz ${newMission.id} erfolgreich aktualisiert`,
@@ -362,14 +371,18 @@ export const MissionForm = () => {
 								onClick={form.handleSubmit(
 									async (mission: MissionOptionalDefaults) => {
 										try {
+											const hpgSzenario =
+												mission.hpgMissionString?.split(":")[0];
 											const newMission =
-												await createMissionMutation.mutateAsync(
-													mission as unknown as Prisma.MissionCreateInput,
-												);
+												await createMissionMutation.mutateAsync({
+													...(mission as unknown as Prisma.MissionCreateInput),
+													missionAdditionalInfo:
+														!mission.missionAdditionalInfo.length && hpgSzenario
+															? `HPG-Szenario: ${hpgSzenario}`
+															: mission.missionAdditionalInfo,
+												});
 											await sendAlertMutation.mutateAsync(newMission.id);
 											setSeachOSMElements([]); // Reset search elements
-											toast.success(`Einsatz ${newMission.id} erstellt`);
-											// TODO: Einsatz alarmieren
 											setOpen(false);
 										} catch (error) {
 											toast.error(
@@ -387,10 +400,16 @@ export const MissionForm = () => {
 								onClick={form.handleSubmit(
 									async (mission: MissionOptionalDefaults) => {
 										try {
+											const hpgSzenario =
+												mission.hpgMissionString?.split(":")[0];
 											const newMission =
-												await createMissionMutation.mutateAsync(
-													mission as unknown as Prisma.MissionCreateInput,
-												);
+												await createMissionMutation.mutateAsync({
+													...(mission as unknown as Prisma.MissionCreateInput),
+													missionAdditionalInfo:
+														!mission.missionAdditionalInfo.length && hpgSzenario
+															? `HPG-Szenario: ${hpgSzenario}`
+															: mission.missionAdditionalInfo,
+												});
 											setSeachOSMElements([]); // Reset search elements
 
 											toast.success(`Einsatz ${newMission.publicId} erstellt`);
diff --git a/grafana/grafana.db b/grafana/grafana.db
index 6435de4eb5f886b0f81a97444ab5d305f917d2cb..3ff46f51cf50693a1e4a9958b59ceb93d7aa7abd 100644
GIT binary patch
delta 121
zcmZoT;L>owWr8$g`a~IL#`MO7)&$1Z1g6#m=GFw3)&$np1h&=$_N@sVy81ji8G4*b
z3=9m4mK-e8`|UZzrmxrMP-C5)q34k~{gyt5JgXu|Mf*Q}4j|?PVlE)&24Wr{<^^It
NAm-oxPhWuP0|57HC@BB{

delta 121
zcmZoT;L>owWr8%L+e8^>Mz_X<)&$1Z1g6#m=GFw3)&$np1h&=$_N@sVy81lY8M+bC
z3=9m4mK-e8`|UZzrmxrMP-Csh(EXb={gyt5JgY*6Zd!KxKYb1$<^*CcAm#>Q9w6og
PVm=_|-~LZufawDOIFu=;

diff --git a/packages/database/prisma/schema/mission.prisma b/packages/database/prisma/schema/mission.prisma
index 18ee92cc..845137c1 100644
--- a/packages/database/prisma/schema/mission.prisma
+++ b/packages/database/prisma/schema/mission.prisma
@@ -1,30 +1,32 @@
 model Mission {
-    id                         Int          @id @default(autoincrement())
-    publicId                   String       @default("")
-    type                       missionType  @default(primär)
-    state                      MissionState @default(draft)
+    id                         Int                @id @default(autoincrement())
+    publicId                   String             @default("")
+    type                       missionType        @default(primär)
+    state                      MissionState       @default(draft)
     addressLat                 Float
     addressLng                 Float
     addressStreet              String?
     addressCity                String?
     addressZip                 String?
-    addressOSMways             Json[]       @default([])
+    addressAdditionalInfo      String?
+    addressOSMways             Json[]             @default([])
     missionKeywordCategory     String?
     missionKeywordName         String?
     missionKeywordAbbreviation String?
     missionPatientInfo         String
     missionAdditionalInfo      String
-    missionStationIds          Int[]        @default([])
-    missionStationUserIds      String[]     @default([])
-    missionLog                 Json[]       @default([])
+    missionStationIds          Int[]              @default([])
+    missionStationUserIds      String[]           @default([])
+    missionLog                 Json[]             @default([])
     hpgMissionString           String?
     hpgAmbulanceState          HpgState?
     hpgFireEngineState         HpgState?
     hpgPoliceState             HpgState?
-    hpgLocationLat             Float?       @default(0)
-    hpgLocationLng             Float?       @default(0)
-    createdAt                  DateTime     @default(now())
-    updatedAt                  DateTime     @updatedAt
+    hpgLocationLat             Float?             @default(0)
+    hpgLocationLng             Float?             @default(0)
+    hpgValidationState         HpgValidationState @default(NOT_VALIDATED)
+    createdAt                  DateTime           @default(now())
+    updatedAt                  DateTime           @updatedAt
     createdUserId              String
 
     // relations:
@@ -75,3 +77,14 @@ enum HpgState {
     arrived
     onway
 }
+
+enum HpgValidationState {
+    NOT_VALIDATED
+    PENDING
+    VALID
+    INVALID
+    HPG_DISCONNECT
+    HPG_BUSY
+    HPG_INVALID_MISSION
+    POSITION_AMANDED
+}