/join <room>

server/client.test.ts

@@ -47,41 +47,41 @@ function flush(): Promise<void> {
 }
 
 Deno.test(
-	"broadcasts a message on connect to all clients",
+	"welcome all clients on open",
 	setup(async () => {
 		const [s1, m1] = await connect(href);
 		const [s2, m2] = await connect(href);
 
 		await flush();
 
-		assertEquals(m1, ["1 has joined!", "2 has joined!"]);
+		assertEquals(m1, ["Welcome 1, type /join <room>."]);
-		assertEquals(m2, ["2 has joined!"]);
+		assertEquals(m2, ["Welcome 2, type /join <room>."]);
 
 		await close(s2);
 		await close(s1);
 	}),
 );
 
-Deno.test(
+// Deno.test(
-	"removes a client from broadcast after it disconnects",
+// 	"removes a client from broadcast after it disconnects",
-	setup(async () => {
+// 	setup(async () => {
-		const [s1, m1] = await connect(href);
+// 		const [s1, m1] = await connect(href);
-		const [s2, m2] = await connect(href);
+// 		const [s2, m2] = await connect(href);
-		const [s3, m3] = await connect(href);
+// 		const [s3, m3] = await connect(href);
 
-		await flush();
+// 		await flush();
 
-		m1.length = 0;
+// 		m1.length = 0;
-		m2.length = 0;
+// 		m2.length = 0;
-		m3.length = 0;
+// 		m3.length = 0;
 
-		await close(s3);
+// 		await close(s3);
 
-		assertEquals(m1, ["3 has left!"]);
+// 		assertEquals(m1, ["3 has left!"]);
-		assertEquals(m2, ["3 has left!"]);
+// 		assertEquals(m2, ["3 has left!"]);
-		assertEquals(m3, []);
+// 		assertEquals(m3, []);
 
-		await close(s2);
+// 		await close(s2);
-		await close(s1);
+// 		await close(s1);
-	}),
+// 	}),
-);
+// );

server/deno.ts

@@ -5,30 +5,63 @@ export function startServer(
 	port: number = 8042,
 ): () => Promise<void> {
 	let nextId = 1;
-	const clientsMap = new Map<number, WebSocket>();
 
-	const broadcast = (message: string): void => {
+	const clientsMap = new Map<number, WebSocket>();
-		for (const socket of clientsMap.values()) {
+	const clientRoomMap = new Map<number, string>();
-			if (socket.readyState === WebSocket.OPEN) {
+	const roomsMap = new Map<string, number[]>();
+
+	const broadcast = (room: string, message: string): void => {
+		const members = roomsMap.get(room)!;
+
+		for (const member of members) {
+			const socket = clientsMap.get(member);
+			if (socket && socket.readyState === WebSocket.OPEN) {
 				socket.send(message);
 			}
 		}
 	};
 
+	const commands = {
+		join: (id: number, ...args: string[]) => {
+			const room = args[0];
+			roomsMap.getOrInsert(room, [id]);
+			clientRoomMap.getOrInsert(id, room);
+			broadcast(room, `${id} has joined!`);
+		},
+	} as const;
+
 	const handleConnection = (socket: WebSocket): void => {
 		const id = nextId++;
 
 		socket.onopen = () => {
 			clientsMap.set(id, socket);
-			broadcast(`${id} has joined!`);
+			socket.send(`Welcome ${id}, type /join <room>.`);
 		};
 
 		socket.onclose = () => {
+			const room = clientRoomMap.get(id);
+			if (room) {
+				clientRoomMap.delete(id);
+				const members = roomsMap.get(room)!;
+				members.splice(members.indexOf(id), 1);
+				broadcast(room, `${id} has left!`);
+			}
 			clientsMap.delete(id);
-			broadcast(`${id} has left!`);
 		};
 
-		socket.onmessage = console.log;
+		socket.onmessage = (message: MessageEvent) => {
+			const text = String(message.data);
+			if (text.startsWith("/")) {
+				const [command, ...args] = text.substring(1).split(" ");
+				try {
+					// @ts-ignore
+					commands[command](id, args);
+				} catch (error) {
+					socket.send(JSON.stringify(error));
+				}
+			}
+		};
+
 		socket.onerror = console.error;
 	};