58 lines
1.5 KiB
TypeScript
58 lines
1.5 KiB
TypeScript
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");
|
|
});
|
|
};
|