Function handleAcknowledgeMessagesReceived

Extensions/Multiplayer/messageManager.ts:936–1012

()

    };

    const handleAcknowledgeMessagesReceived = () => {
      if (!gdjs.multiplayer.isReadyToSendOrReceiveGameUpdateMessages()) {
        // Acknowledgment messages are mainly a response for ownership change, destruction, and custom messages,
        // which are not sent when the game is not ready.
        return;
      }

      const p2pMessagesMap = gdjs.multiplayerPeerJsHelper.getAllMessagesMap();
      const messageNamesArray = Array.from(p2pMessagesMap.keys());
      // When we receive acknowledgement messages, save it in the extension, to avoid sending the message again.
      const acknowledgedMessageNames = messageNamesArray.filter(
        isMessageAcknowledgement
      );
      acknowledgedMessageNames.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();
          debugLogger.info(
            `Received acknowledgment for message ${messageName}.`
          );
          const regex = getRegexFromAckMessageName(messageName);
          if (!regex) {
            // This should not happen.
            logger.error(`Invalid acknowledgment message ${messageName}.`);
            return;
          }

          const matches = regex.exec(messageName);
          if (!matches) {
            // This should not happen.
            logger.error(`Invalid acknowledgment message ${messageName}.`);
            return;
          }
          if (!expectedMessageAcknowledgements[messageName]) {
            // This should not happen, but if we receive an acknowledgment for a message we did not expect, let's not error.
            return;
          }
          if (!expectedMessageAcknowledgements[messageName][messageSender]) {
            // This should not happen, but if we receive an acknowledgment from a sender we did not expect, let's not error.
            return;
          }

          // If a clock is provided in the message, ensure that we only process the message if the clock is newer than the last one received.
          const messageInstanceClock = messageData['_clock'];
          if (messageInstanceClock !== undefined) {
            const instanceNetworkId = matches[3];
            const sceneNetworkId = matches[4];
            const lastClock = getLastClockReceivedForInstanceOnScene({
              sceneNetworkId,
              instanceNetworkId,
            });
            if (messageInstanceClock <= lastClock) {
              // Ignore old messages.
              return;