Spaces:
Sleeping
Sleeping
File size: 1,728 Bytes
fe83268 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 | const { send, broadcast } = require("./utils");
const rooms = new Map(); // roomCode -> { host: ws, participants: Set<ws> }
function generateRoomCode() {
const chars = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
let code = "";
for (let i = 0; i < 6; i++) code += chars[Math.floor(Math.random() * chars.length)];
return code;
}
function getRoom(roomCode) {
return rooms.get(roomCode);
}
function createRoom(ws) {
removeFromRoom(ws);
let roomCode = generateRoomCode();
while (rooms.has(roomCode)) roomCode = generateRoomCode();
const room = { host: ws, participants: new Set([ws]) };
rooms.set(roomCode, room);
ws._roomCode = roomCode;
return roomCode;
}
function joinRoom(ws, roomCode) {
const room = rooms.get(roomCode);
if (!room) return null;
removeFromRoom(ws);
room.participants.add(ws);
ws._roomCode = roomCode;
return room;
}
function removeFromRoom(ws) {
const roomCode = ws._roomCode;
if (!roomCode) return;
const room = rooms.get(roomCode);
if (!room) return;
room.participants.delete(ws);
ws._roomCode = null;
if (room.participants.size === 0) {
rooms.delete(roomCode);
return;
}
// Reassign host if the host left
if (room.host === ws) {
room.host = room.participants.values().next().value;
send(room.host, { type: "promoted-to-host" });
}
broadcast(room, { type: "participant-update", count: room.participants.size, members: getParticipantList(room) });
}
function getParticipantList(room) {
const members = [];
for (const p of room.participants) {
members.push({ url: p._url || null });
}
return members;
}
module.exports = { rooms, generateRoomCode, createRoom, joinRoom, removeFromRoom, getRoom, getParticipantList };
|