Function handleHeartbeatsReceived

Extensions/Multiplayer/messageManager.ts:1993–2137

()

    };

    const handleHeartbeatsReceived = () => {
      const p2pMessagesMap = gdjs.multiplayerPeerJsHelper.getAllMessagesMap();
      const messageNamesArray = Array.from(p2pMessagesMap.keys());
      const heartbeatMessageNames = messageNamesArray.filter((messageName) =>
        messageName.startsWith(heartbeatMessageNamePrefix)
      );
      heartbeatMessageNames.forEach((messageName) => {
        const messagesList = p2pMessagesMap.get(messageName);
        if (!messagesList) return; // Should not happen.
        const messages = messagesList.getMessages();
        if (!messages.length) return; // No messages to process for this name.
        messages.forEach((message) => {
          const messageData = message.getData();
          const messageSender = message.getSender();
          const matches = heartbeatMessageRegex.exec(messageName);
          if (!matches) {
            return;
          }
          const playerNumber = parseInt(matches[1], 10);
          // Ensure we know who is who.
          _peerIdToPlayerNumber[messageSender] = playerNumber;

          // If we are not the host, save what the host told us about the other players info
          // and respond with a heartbeat immediately, informing the host of our playerId and username.
          if (!gdjs.multiplayer.isCurrentPlayerHost()) {
            const currentPlayerNumber =
              gdjs.multiplayer.getCurrentPlayerNumber();
            const currentlyKnownPlayerNumbers = Object.keys(_playersInfo).map(
              (playerNumber) => parseInt(playerNumber, 10)
            );
            const receivedPlayerNumbers = Object.keys(
              messageData.playersInfo
            ).map((playerNumber) => parseInt(playerNumber, 10));
            const currentlyKnownPingForCurrentUser =
              _playersInfo[currentPlayerNumber] &&
              _playersInfo[currentPlayerNumber].ping;
            // If there are no players info yet, we're probably just connecting.
            // This can happen when joining a game that is already running.
            // Do not handle this case to avoid displaying too many notifications.
            if (!!currentlyKnownPlayerNumbers.length) {
              // Look at the players info received to know if there are new players who just connected.
              const newPlayerNumbers = receivedPlayerNumbers.filter(
                (playerNumber) =>
                  !currentlyKnownPlayerNumbers.includes(playerNumber) &&
                  playerNumber !== currentPlayerNumber // Do not consider ourselves as a new player.
              );
              _playerNumbersWhoJustJoined.push(...newPlayerNumbers);
              // Or players who have disconnected.
              const playerNumbersWhoHaveDisconnected =
                currentlyKnownPlayerNumbers.filter(
                  (playerNumber) =>
                    !receivedPlayerNumbers.includes(playerNumber)
                );
              _playerNumbersWhoJustLeft.push(
                ...playerNumbersWhoHaveDisconnected
              );
              for (const playerNumber of playerNumbersWhoHaveDisconnected) {
                // Temporarily save the username in another variable to be used for the notification,