Tengo esta función de servicio asíncrono de actualización de GameScore, que se usa para agregar un nuevo registro si ya no hay un registro en la colección de GameScore con la identificación de usuario particular, o actualizar el registro relevante si existe:

 const updateGameScore = async (userId, gameId, score, date, res) => { const gameScore = await GameScore.findOne({ userId }); //If no record found with given userId, a new record will be created if (!gameScore) { let newGameScore = new GameScore({ userId, gameScores: { gameId, highScore: score }, totalScore: score, date, }); newGameScore = await newGameScore.save(); } //If there is already a record of the given userID else { //The totalscore field of that user will be updated by adding the new score to the current total score const totalScore = gameScore.totalScore + score; await GameScore.findByIdAndUpdate( { _id: gameScore._id }, { totalScore, date } ); }

Y luego llamo a esta función dentro de una función de mapa para hacer 50,000 llamadas desde una colección de db que ya existe.

 allPlayers = await Player.find(); await allPlayers.map((player) => { const userId = player.userId; const gameId = player.gameId; const score = player.score; const date = player.date; updateGameScore(userId, gameId, score, date, res); });

Sin embargo, mi código, la función updateGameScore funciona correctamente (si lo llamo uno por uno). pero cuando invoco 50 000 registros a la vez, todos los registros invocan esta función en paralelo y generan 50 000 registros nuevos en mi colección de GameScore, lo cual no es necesario que suceda. Solo necesito crear un nuevo registro si no existe un registro con el ID de usuario dado, pero actualizar el registro si existe un registro con el ID dado. Esto funcionaría correctamente si mi función de mapa llamara a la función updateGameScore secuencialmente, pero desafortunadamente no es así. Por favor, ayúdenme con esto ya que tengo muy poco conocimiento en js asíncrono.