File size: 1,450 Bytes
811126d |
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 |
import { Server } from "socket.io";
import prisma from "./lib/prisma";
const io = new Server({
cors: {
origin: "*",
},
path: "/",
});
// Map pour stocker les connexions des joueurs
const playerConnections = new Map();
io.on("connection", (socket) => {
console.log("New client connected");
// Rejoindre une room spécifique pour le jeu
socket.on("joinGame", (gameId) => {
socket.join(gameId);
console.log(`Client joined game: ${gameId}`);
});
// Gestion des offres WebRTC
socket.on("offer", (data) => {
socket.to(data.gameId).emit("offer", data.offer);
});
socket.on("answer", (data) => {
socket.to(data.gameId).emit("answer", data.answer);
});
socket.on("candidate", (data) => {
socket.to(data.gameId).emit("candidate", data.candidate);
});
// Gestion de l'état du jeu
socket.on("gameStateUpdate", (gameState) => {
socket.to(gameState.id).emit("gameStateUpdate", gameState);
});
// Gestion de l'audio
socket.on("speaking", (data) => {
socket.to(data.gameId).emit("playerSpeaking", {
playerId: data.playerId,
isSpeaking: true,
});
});
socket.on("stoppedSpeaking", (data) => {
socket.to(data.gameId).emit("playerSpeaking", {
playerId: data.playerId,
isSpeaking: false,
});
});
socket.on("disconnect", () => {
console.log("Client disconnected");
});
});
io.listen(5001);
console.log("Game server running on port 5001");
|