feat(warehousing): ppoo monitoring added

this will monitor ppoo every 45 seconds as long as someone is on the page.

closes #13

backend/socket.io/roomCache.socket.ts

@@ -1,4 +1,4 @@
-import type { RoomId } from "./types.socket.js";
+import type { RoomId } from "./roomDefinitions.socket.js";
 
 export const MAX_HISTORY = 50;
 export const FLUSH_INTERVAL = 100; // 50ms change higher if needed

backend/socket.io/roomDefinitions.socket.ts

@@ -1,17 +1,50 @@
 import { desc } from "drizzle-orm";
 import { db } from "../db/db.controller.js";
 import { logs } from "../db/schema/logs.schema.js";
-import type { RoomId } from "./types.socket.js";
+import { ppoRun } from "../warehousing/warehousing.ppooMonitor.js";
 
 type RoomDefinition<T = unknown> = {
 	seed: (limit: number) => Promise<T[]>;
 };
 
-export const protectedRooms: any = {
+export type StaticRoomId = "logs" | "labels" | "admin" | "admin:build" | "ppoo";
+export type DynamicRoomId = `dockDoorLoading:${string}`;
+export type RoomId = StaticRoomId | DynamicRoomId;
+
+export type RoomConfig = {
+	requiresAuth?: boolean;
+	role?: string[];
+	seed?: (limit: number, roomId: RoomId) => Promise<unknown[]>;
+};
+
+export const protectedRooms: Record<StaticRoomId, RoomConfig> = {
 	logs: { requiresAuth: true, role: ["admin", "systemAdmin"] },
 	//admin: { requiresAuth: false, role: ["admin", "systemAdmin"] },
+	labels: {},
+	admin: {},
+	"admin:build": {},
+	ppoo: {},
 };
 
+export function getRoomConfig(roomId: string): RoomConfig | null {
+	if (roomId in protectedRooms) {
+		return protectedRooms[roomId as StaticRoomId];
+	}
+
+	if (roomId.startsWith("dockDoorLoading:")) {
+		const dockId = roomId.split(":")[1];
+
+		if (!dockId) return null;
+
+		return {
+			requiresAuth: true,
+			role: ["admin", "systemAdmin", "dockDoor"],
+		};
+	}
+
+	return null;
+}
+
 export const roomDefinition: Record<RoomId, RoomDefinition> = {
 	logs: {
 		seed: async (limit) => {
@@ -48,4 +81,14 @@ export const roomDefinition: Record<RoomId, RoomDefinition> = {
 			return [];
 		},
 	},
+	ppoo: {
+		seed: async (limit) => {
+			console.log(limit);
+			return {
+				type: "snapshot",
+				items: await ppoRun(),
+				createdAt: new Date().toISOString(),
+			} as any;
+		},
+	},
 };

backend/socket.io/roomEmitter.socket.ts

@@ -1,6 +1,6 @@
 // the emitter setup
 
-import type { RoomId } from "./types.socket.js";
+import type { RoomId } from "./roomDefinitions.socket.js";
 
 let addDataToRoom: ((roomId: RoomId, payload: unknown[]) => void) | null = null;
 

backend/socket.io/roomService.socket.ts

@@ -7,18 +7,33 @@ import {
 	roomFlushTimers,
 	roomHistory,
 } from "./roomCache.socket.js";
-import { roomDefinition } from "./roomDefinitions.socket.js";
-import type { RoomId } from "./types.socket.js";
+import { type RoomId, roomDefinition } from "./roomDefinitions.socket.js";
 
 // get the db data if not exiting already
 const log = createLogger({ module: "socket.io", subModule: "roomService" });
+let ioRef: Server | null = null;
 
+export const registerRoomService = (io: Server) => {
+	ioRef = io;
+};
+
+export const hasRoomMembers = (roomId: string): boolean => {
+	if (!ioRef) return false;
+
+	return (ioRef.sockets.adapter.rooms.get(roomId)?.size ?? 0) > 0;
+};
+
+export const getRoomMemberCount = (roomId: string): number => {
+	if (!ioRef) return 0;
+
+	return ioRef.sockets.adapter.rooms.get(roomId)?.size ?? 0;
+};
 export const preseedRoom = async (roomId: RoomId) => {
 	if (roomHistory.has(roomId)) {
 		return roomHistory.get(roomId);
 	}
 
-	const roomDef = roomDefinition[roomId];
+	const roomDef = roomDefinition[roomId] as any;
 
 	if (!roomDef) {
 		log.error({}, `Room ${roomId} is not defined`);
@@ -32,7 +47,7 @@ export const preseedRoom = async (roomId: RoomId) => {
 };
 
 export const createRoomEmitter = (io: Server) => {
-	const addDataToRoom = <T>(roomId: RoomId, payload: T) => {
+	const addDataToRoom = <T>(roomId: RoomId, payload: T[]) => {
 		if (!roomHistory.has(roomId)) {
 			roomHistory.set(roomId, []);
 		}

backend/socket.io/serverSetup.ts

@@ -7,7 +7,11 @@ import { Server } from "socket.io";
 import { createLogger } from "../logger/logger.controller.js";
 import { allowedOrigins } from "../utils/cors.utils.js";
 import { registerEmitter } from "./roomEmitter.socket.js";
-import { createRoomEmitter, preseedRoom } from "./roomService.socket.js";
+import {
+	createRoomEmitter,
+	preseedRoom,
+	registerRoomService,
+} from "./roomService.socket.js";
 
 //const __filename = fileURLToPath(import.meta.url);
 //const __dirname = dirname(__filename);
@@ -15,7 +19,7 @@ const log = createLogger({ module: "socket.io", subModule: "setup" });
 
 import { auth } from "../utils/auth.utils.js";
 //import type { Session, User } from "better-auth"; // adjust if needed
-import { protectedRooms } from "./roomDefinitions.socket.js";
+import { getRoomConfig } from "./roomDefinitions.socket.js";
 
 // declare module "socket.io" {
 // 	interface Socket {
@@ -33,6 +37,9 @@ export const setupSocketIORoutes = (baseUrl: string, server: HttpServer) => {
 		},
 	});
 
+	// manage members of the rooms.
+	registerRoomService(io);
+
 	// ✅ Create emitter instance
 	const { addDataToRoom } = createRoomEmitter(io);
 	registerEmitter(addDataToRoom);
@@ -78,38 +85,76 @@ export const setupSocketIORoutes = (baseUrl: string, server: HttpServer) => {
 			version: "1.0.0",
 		});
 
-		s.on("join-room", async (rn) => {
-			const config = protectedRooms[rn];
+		// s.on("join-room", async (rn) => {
+		// 	const config = protectedRooms[rn];
 
-			if (config?.requiresAuth && !s.user) {
+		// 	if (config?.requiresAuth && !s.user) {
+		// 		return s.emit("room-error", {
+		// 			room: rn,
+		// 			message: "Authentication required",
+		// 		});
+		// 	}
+
+		// 	const roles = Array.isArray(config?.role) ? config?.role : [config?.role];
+
+		// 	//if (config?.role && s.user?.role !== config.role) {
+		// 	if (config?.role && !roles.includes(s.user?.role)) {
+		// 		return s.emit("room-error", {
+		// 			roomId: rn,
+		// 			message: `Not authorized to be in room: ${rn}`,
+		// 		});
+		// 	}
+		// 	s.join(rn);
+
+		// 	// get room seeded
+		// 	const history = await preseedRoom(rn);
+		// 	log.info({}, `User joined ${rn}: ${s.id}`);
+		// 	// send the intial data
+		// 	s.emit("room-update", {
+		// 		roomId: rn,
+		// 		payloads: history,
+		// 		initial: true,
+		// 	});
+		// });
+
+		s.on("join-room", async (rn: string) => {
+			const config = getRoomConfig(rn);
+
+			if (!config) {
 				return s.emit("room-error", {
-					room: rn,
+					roomId: rn,
+					message: `Unknown room: ${rn}`,
+				});
+			}
+
+			if (config.requiresAuth && !s.user) {
+				return s.emit("room-error", {
+					roomId: rn,
 					message: "Authentication required",
 				});
 			}
 
-			const roles = Array.isArray(config?.role) ? config?.role : [config?.role];
+			const roles = Array.isArray(config.role) ? config.role : [];
 
-			//if (config?.role && s.user?.role !== config.role) {
-			if (config?.role && !roles.includes(s.user?.role)) {
+			if (roles.length > 0 && !roles.includes(s.user?.role)) {
 				return s.emit("room-error", {
 					roomId: rn,
 					message: `Not authorized to be in room: ${rn}`,
 				});
 			}
+
 			s.join(rn);
 
-			// get room seeded
-			const history = await preseedRoom(rn);
+			const history = await preseedRoom(rn as any);
+
 			log.info({}, `User joined ${rn}: ${s.id}`);
-			// send the intial data
+
 			s.emit("room-update", {
 				roomId: rn,
 				payloads: history,
 				initial: true,
 			});
 		});
-
 		s.on("leave-room", (room) => {
 			s.leave(room);
 			log.info({}, `${s.id} left room: ${room}`);