server.js

const express = require('express');
const http = require('http');
const path = require('path');
const { Server } = require('socket.io');

const app = express();
const server = http.createServer(app);
const io = new Server(server);

const PORT = process.env.PORT || 3000;

app.use(express.static(path.join(__dirname, 'public')));

const state = {
  users: new Map(),
  revealed: false,
  history: []
};

function computeStats() {
  const stats = {};
  for (const entry of state.history) {
    for (const [name, vote] of Object.entries(entry.votes)) {
      const num = Number(vote);
      if (!Number.isFinite(num)) continue;
      if (!stats[name]) {
        stats[name] = { count: 0, sum: 0, last: null, min: num, max: num };
      }
      const s = stats[name];
      s.count += 1;
      s.sum += num;
      s.last = num;
      s.min = Math.min(s.min, num);
      s.max = Math.max(s.max, num);
    }
  }
  for (const name of Object.keys(stats)) {
    const s = stats[name];
    s.avg = Number((s.sum / s.count).toFixed(2));
  }
  return stats;
}

function snapshot() {
  const users = Array.from(state.users.values()).map((u) => ({
    id: u.id,
    name: u.name,
    vote: u.vote
  }));

  let sum = 0;
  let count = 0;
  for (const user of state.users.values()) {
    const num = Number(user.vote);
    if (!Number.isFinite(num)) continue;
    sum += num;
    count += 1;
  }

  return {
    users,
    revealed: state.revealed,
    history: state.history,
    stats: computeStats(),
    roundAverage: count ? Number((sum / count).toFixed(2)) : null,
    roundCount: count
  };
}

function broadcast() {
  io.emit('state', snapshot());
}

io.on('connection', (socket) => {
  state.users.set(socket.id, { id: socket.id, name: '', vote: null });
  socket.emit('state', snapshot());

  socket.on('set_name', (name) => {
    const user = state.users.get(socket.id);
    if (!user) return;
    const clean = String(name || '').trim().slice(0, 24);
    user.name = clean || `Player-${socket.id.slice(0, 4)}`;
    broadcast();
  });

  socket.on('vote', (vote) => {
    const user = state.users.get(socket.id);
    if (!user) return;
    user.vote = vote;
    broadcast();
  });

  socket.on('reveal', () => {
    if (state.revealed) return;
    state.revealed = true;
    const votes = {};
    for (const user of state.users.values()) {
      if (user.name) votes[user.name] = user.vote ?? null;
    }
    state.history.unshift({ ts: new Date().toISOString(), votes });
    broadcast();
  });

  socket.on('reset', () => {
    state.revealed = false;
    for (const user of state.users.values()) {
      user.vote = null;
    }
    broadcast();
  });

  socket.on('disconnect', () => {
    state.users.delete(socket.id);
    broadcast();
  });
});

server.listen(PORT, () => {
  console.log(`Server running on http://localhost:${PORT}`);
});