import { getPublicUser, prisma } from "@repo/db";
import { pubClient } from "modules/redis";
import { Server, Socket } from "socket.io";

export const handleConnectDispatch =
	(socket: Socket, io: Server) =>
	async ({
		logoffTime,
		selectedZone,
	}: {
		logoffTime: string;
		selectedZone: string;
	}) => {
		try {
			const userId = socket.data.user.id; // User ID aus dem JWT-Token
			console.log("User connected to dispatch server");
			const user = await prisma.user.findUnique({
				where: {
					id: userId,
				},
			});

			if (!user) return Error("User not found");

			let parsedLogoffDate = null;
			if (logoffTime.length > 0) {
				const now = new Date();
				const [hours, minutes] = logoffTime.split(":").map(Number);
				if (!hours || !minutes) {
					throw new Error("Invalid logoffTime format");
				}
				parsedLogoffDate = new Date(now);
				parsedLogoffDate.setHours(hours, minutes, 0, 0);

				// If the calculated time is earlier than now, add one day to make it tomorrow
				if (parsedLogoffDate <= now) {
					parsedLogoffDate.setDate(parsedLogoffDate.getDate() + 1);
				}

				// If the calculated time is in the past, add one day to make it in the future
				if (parsedLogoffDate <= now) {
					parsedLogoffDate.setDate(parsedLogoffDate.getDate() + 1);
				}
			}

			const connectedDispatcherEntry = await prisma.connectedDispatcher.create({
				data: {
					publicUser: getPublicUser(user) as any,
					esimatedLogoutTime: parsedLogoffDate?.toISOString() || null,
					lastHeartbeat: new Date().toISOString(),
					userId: userId,
					loginTime: new Date().toISOString(),
				},
			});

			socket.join("dispatchers"); // Dem Dispatcher-Raum beitreten
			socket.join(`user:${userId}`); // Dem User-Raum beitreten

			/* 		const keys = await pubClient.keys("Dispatcher:*");
			await Promise.all(
				keys.map(async (key) => {
					return await pubClient.json.get(key);
					}),
					); */
			io.to("dispatchers").emit("dispatcher-update");
			io.to("pilots").emit("dispatcher-update");

			socket.on("disconnect", async () => {
				console.log("Disconnected from dispatch server");
				await prisma.connectedDispatcher.update({
					where: {
						id: connectedDispatcherEntry.id,
					},
					data: {
						logoutTime: new Date().toISOString(),
					},
				});
			});
			socket.on("reconnect", async () => {
				console.log("Reconnected to dispatch server");
			});
		} catch (error) {
			console.error("Error connecting to dispatch server:", error);
			console.log("Error connecting to dispatch server:", error);
		}
	};