My socket.io web socket application is not sending data to some users.

[muratyvz13]

I've created a live quiz application using Node.js and socket.io over web sockets. Briefly, there's a specific time limit for each question, and I'm sending the countdown to the user with

     io.to(roomName).emit('countdown', countdown);
     io.to(roomName).emit('question', question);

along with 4-5 other similar parameters. The client side is a web application that I wrote with Next.js. The application scores the questions and ranks the top 10 participants. I've tested it at home with 4-5 devices without any issues, and also with a group of 10 friends, all fine. However, someone who wanted to use it for an event tried it with around 50-60 people, and apparently, half of the participants didn't receive the questions.

Do you think the issue could be server-related? I'm using Heroku, paying about $7 for basic plan a month. Would moving to a hosting solution that provides better internet speed solve this problem? Or could it be unrelated to the server side? I'm terminating the connection if no response is received within 5 seconds; could it have something to do with that?

const express = require('express');
const http = require('http');
const { PrismaClient } = require('@prisma/client');


const cors = require('cors');  // Bu satırı ekleyin

const app = express();
app.use(cors({
    origin: '*'
}));
app.use((req, res, next) => {
    res.header('Access-Control-Allow-Origin', '*');
    res.header('Access-Control-Allow-Methods', 'GET, POST, PUT, DELETE');
    res.header('Access-Control-Allow-Headers', 'Content-Type, Authorization');
    next();
  });
const prisma = new PrismaClient();
const server = http.createServer(app);

const io = require('socket.io')(server, {
    cors: {
      origin: '*', /
      methods: ['GET', 'POST'], 
    },
    pingInterval: 25000, 
    pingTimeout: 5000, 
  });
  
 

let advertisingImage="/images/chaingptadvert.jpeg"
let users = {}; 
let currentQuestionIndex = 0;
let waiting=0;
let init=0;
let roomName="tuNNcay";
let finish=0;
let quizName="Blockchain Quiz";
let optionCountA=0;
let optionCountB=0;
let optionCountC=0;
let optionCountD=0;

io.on('connection', (socket) => {
    console.log('Bir istemci bağlandı.');
    socket.on('joinRoom', (room) => {
        try {
            socket.join(room);
            console.log(`${socket.id} ${room} odasına katıldı.`);
        } catch (error) {
            console.error(`joinRoom error: ${error.message}`);
        }
    });
    socket.on('setParams', (params) => {
        try {
            socket.username = params.username;
            users[socket.id] = {
                username: socket.username,
                score: 0,
                time: 0,
                rank: 10,
                imageSrc: "/images/icardi.jpg",
            };
            console.log(`Yeni kullanıcı ayarlandı: ${socket.username}`);
        } catch (error) {
            console.error(`setParams error: ${error.message}`);
        }
    });
      
    socket.on('setQuizName', (quizname) => {
        try {
            quizName = quizname.toString();
            console.log(`Quiz adı ayarlandı: ${quizName}`);
        } catch (error) {
            console.error(`setQuizName error: ${error.message}`);
        }
    });
    socket.on('ping', () => {
        console.log('ping gönderildi');
      });
      
      socket.on('pong', (latency) => {
        console.log(`pong alındı, gecikme süresi: ${latency}ms`);
      });
    socket.on('init', (questions1, sayi) => {
        try {
            if(currentQuestionIndex == 0 && parseInt(sayi) == 5) {
                questions = questions1;
                init = 1;
                io.to(roomName).emit('init', init);
                io.to(roomName).emit('quizName', quizName);
                sendQuestion(socket);
            }
        } catch (error) {
            console.error(`init error: ${error.message}`);
        }
    });
    
    socket.on('increaseScore', () => {
        try {
            if (users[socket.id]) {
                users[socket.id].score += 10;
                console.log(`${socket.username} adlı kullanıcının puanı artırıldı.`);
            }
        } catch (error) {
            console.error(`increaseScore error: ${error.message}`);
        }
    });

    socket.on('optionACounter', () => {
        try {
            optionCountA += 1;
        } catch (error) {
            console.error(`optionACounter error: ${error.message}`);
        }
    });

    socket.on('optionBCounter', () => {
        try {
            optionCountB += 1;
        } catch (error) {
            console.error(`optionBCounter error: ${error.message}`);
        }
    });

    socket.on('optionCCounter', () => {
        try {
            optionCountC += 1;
        } catch (error) {
            console.error(`optionCCounter error: ${error.message}`);
        }
    });

    socket.on('optionDCounter', () => {
        try {
            optionCountD += 1;
        } catch (error) {
            console.error(`optionDCounter error: ${error.message}`);
        }
    });

    socket.on('increaseTotalTime', (userTime) => {
        try {
            if (users[socket.id]) {
                users[socket.id].time += parseInt(userTime);
            }
        } catch (error) {
            console.error(`increaseTotalTime error: ${error.message}`);
        }
    });

    socket.on('getScore', () => {
        try {
            const userScore = getUserScore(socket);
            console.log(`${socket.username} adlı kullanıcının puanı: ${userScore}`);
            io.to(socket.id).emit('userScore', userScore);
        } catch (error) {
            console.error(`getScore error: ${error.message}`);
        }
    });
   
      
    socket.on('disconnect', () => {
        try {
            delete users[socket.id];
            console.log(`${socket.id} ayrıldı.`);
        } catch (error) {
            console.error(`disconnect error: ${error.message}`);
        }
    });
});
function findSocketIdByUsername(username) {
    for (const socketId in users) {
        if (users.hasOwnProperty(socketId) && users[socketId].username === username) {
            return socketId;
        }
    }
    return null;
}
const getUserScore = (socketId) => {
    if (users[socketId]) {
        return users[socketId].score;
    }
    return 0; // Kullanıcı odaya katılmamışsa 0 döndür
};
const sendUserScoresToAll = () => {
    for (const socketId in users) {
        if (users.hasOwnProperty(socketId)) {
            const userScore = getUserScore(socketId);
            io.to(socketId).emit('userScore', userScore);
        }
    }
};
function calculateTotalCount() {
    return optionCountA + optionCountB + optionCountC + optionCountD;
}
function calculatePercentage(optionCount) {
    const totalCount = calculateTotalCount();
    if (totalCount === 0) {
        return 0; // Toplam sayı sıfırsa, yüzde sıfır döndür
    }
    return (optionCount / totalCount) * 100;
}
function sendQuestion(socket ) {
    if (currentQuestionIndex < questions.length) {
        const currentQuestion = questions[currentQuestionIndex];
        waiting=0;
        //socket.emit('waiting', waiting);
        
        //io.to(socket.id).emit('userScore', getUserScore(socket.id));
        sendUserScoresToAll();
        optionCountA=0;
        optionCountB=0;
        optionCountC=0;
        optionCountD=0;
        io.to(roomName).emit('waiting', waiting);
        io.to(roomName).emit('question', currentQuestion.question);
        io.to(roomName).emit('advertisingImage', advertisingImage);
        let text=String(currentQuestionIndex)+","+String(questions.length);
        io.to(roomName).emit('currentQuestionIndex', text);
        console.log(currentQuestion.advertisingImage);
        io.to(roomName).emit('options', currentQuestion.options);
        //socket.emit('question', currentQuestion.question);
        io.to(roomName).emit('onlineUser', String(users.length));
        console.log("Users length");
        console.log(String(users.length));
        let countdown = 15;
        const countdownInterval = setInterval(() => {
            //socket.emit('countdown', countdown);
            io.to(roomName).emit('countdown', countdown);
            countdown--;

            if (countdown < 0) {
                clearInterval(countdownInterval);
                //socket.emit('answer', currentQuestion.answer);
                io.to(roomName).emit('answer', currentQuestion.answer);
                setTimeout(function () {
                    console.log("1 saniye sonra yapılan işlem");
                    const percentageA = calculatePercentage(optionCountA);
                    const percentageB = calculatePercentage(optionCountB);
                    const percentageC = calculatePercentage(optionCountC);
                    const percentageD = calculatePercentage(optionCountD);
                    let optionsCounts=String(percentageA)+","+String(percentageB)+","+String(percentageC)+","+String(percentageD);
                    io.to(roomName).emit('optionsCounts', optionsCounts);
                   }, 1000); 
                //socket.emit('waiting', waiting);
                setTimeout(function () {
                    // 1 saniye sonra yapılan işlemler
                    // Örneğin, bir başka mesaj gönderme veya başka bir eylem gerçekleştirme
                    
                    waiting=1;
                    io.to(roomName).emit('waiting', waiting);
                    // io.to(roomName).emit('waiting', waiting); // Burada kullanılabilir
                }, 3000);  
                
                setTimeout(() => {
                     
                    currentQuestionIndex++;
                    sendQuestion(socket);
                }, 5000); 
            }
        }, 1000);
    } else {
        const sortedUsers = Object.values(users)
  .filter(user => user.username && user.username.trim() !== "")
  .sort((a, b) => {
    // İlk önce skorlarına göre sırala
    if (b.score - a.score !== 0) {
      return b.score - a.score;
    }

    // Eğer skorları eşitse, zamanlarına göre sırala
    return b.time - a.time;
  });

        //const sortedUsers = Object.values(users).filter(user => user.username && user.username.trim() !== "").sort((a, b) => b.score - a.score);
        //const sortedUsers = Object.values(users).sort((a, b) => b.score - a.score);
        const top10Users = sortedUsers.slice(0, 10);
        io.to(roomName).emit('gameOver', top10Users);
        console.log(sortedUsers);
        io.to(roomName).emit('AllUsers', sortedUsers);
        console.log(users);
        assignTrophiesBasedOnRanking(sortedUsers);
        pushdbQuiz();
        users = {}; 
        currentQuestionIndex = 0;
        waiting=0;
        init=0;
        finish=0;
        optionCountA=0;
        optionCountB=0;
        optionCountC=0;
        optionCountD=0;
        //socket.emit('gameOver', 'Sorular bitti.');
        

    }
}
const getScore = (socket) => {
    if (users[socket.id]) {
        return users[socket.id].score;
    }
    return 0; //Kullanıcı odaya katılmamışsa 0 dondur
};

async function assignTrophiesBasedOnRanking(sortedUsers) {
    for (let index = 0; index < sortedUsers.length; index++) {
      const user = sortedUsers[index];
      
      // Kullanıcı bilgisini güncel değerlerle çek
      const currentUser = await prisma.users.findUnique({
        where: { user_username: user.username },
      });
  
      if (!currentUser) {
        console.log(`Kullanıcı bulunamadı: ${user.username}`);
        continue;
      }
  
      const trophiesUpdates = {
        user_participation_trophy: currentUser.user_participation_trophy + 1,
      };
  
      if (index < 10) {
        trophiesUpdates.user_top_ten_trophy = currentUser.user_top_ten_trophy + 1;
      }
  
      if (index < 3) {
        trophiesUpdates.user_top_three_trophy = currentUser.user_top_three_trophy + 1;
      }
  
      if (index === 0) {
        trophiesUpdates.user_championship_trophy = currentUser.user_championship_trophy + 1;
      }
  
      // Güncel değerleri kullanarak kullanıcıyı güncelle
      await prisma.users.update({
        where: { user_username: user.username },
        data: trophiesUpdates,
      });
    }
  
    console.log('Kullanıcı kupaları güncellendi.');
  }
  

  
async function pushdbQuiz() {
    const usersArray = Object.values(users);

    for (const user of usersArray) {
        
        
        try {
            const user_name = user.username;
            const score = user.score;
            const time = user.time;
            const userData = await prisma.users.findUnique({
            where: {
              user_username: user_name,
            },
            select: {
              user_id: true, // Sadece user_id'yi döndür
            },
          });
        console.log(userData);
        if (userData) {
            const post = await prisma.users_quiz_history.create({
                data: {
                    quiz_id: 2, // Fonksiyona parametre olarak geçirilen quizId
                    user_id: userData.user_id, // Kullanıcının benzersiz ID'si
                    quiz_score: user.score, // Kullanıcının quizdeki skoru
                    quiz_result: `${user.score/10}/${questions.length}`, // Kullanıcının quiz sonucu (örneğin, 'Kazandı', 'Kaybetti' vb.)
                    // register_date otomatik olarak şu anki zamanı alır, ayrıca belirtmeye gerek yoktur
                  }
            });
            console.log(`Kullanıcı Adı: ${user_name}, Puan: ${score}, Zaman: ${time}`);
        }
            
        } catch (error) {
            console.error('Veritabanına yazma hatası:', error);
        }
    }
}




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

server.listen(PORT, () => {
    console.log('Sunucu dinleniyor: http://localhost:8000');
});