import { 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;
	}) => {
		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,
			},
		});
		const connectedDispatcherEntry = await prisma.connectedDispatcher.create({
			data: {
				publicUser: {},
				esimatedLogoutTime: logoffTime,
				lastHeartbeat: new Date(),
				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");
		});
	};