Function handleCustomMessagesReceived

Extensions/Multiplayer/messageManager.ts:1528–1605

()

    };

    const handleCustomMessagesReceived = (): void => {
      if (!gdjs.multiplayer.isReadyToSendOrReceiveGameUpdateMessages()) {
        // Assume that the custom messages are not worth saving for later use.
        return;
      }

      const p2pMessagesMap = gdjs.multiplayerPeerJsHelper.getAllMessagesMap();
      const messageNamesArray = Array.from(p2pMessagesMap.keys());
      const customMessageNames = messageNamesArray.filter((messageName) =>
        messageName.startsWith(customMessageNamePrefix)
      );
      customMessageNames.forEach((messageName) => {
        const messagesList = p2pMessagesMap.get(messageName);
        if (!messagesList) {
          logger.error(`No messages list found for ${messageName}.`);
          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 uniqueMessageId = messageData.uniqueId;
          debugLogger.info(
            `Received custom message ${messageName} with data ${JSON.stringify(
              messageData
            )}.`
          );
          const matches = customMessageRegex.exec(messageName);
          if (!matches) {
            // This should not happen.
            logger.error(`Invalid custom message ${messageName}.`);
            return;
          }

          const customMessageCacheKey = `${messageName}#${uniqueMessageId}`;
          if (processedCustomMessagesCache.has(customMessageCacheKey)) {
            // Message has already been processed recently. This can happen if the message is sent multiple times,
            // after not being acknowledged properly.
            debugLogger.info(
              `Message ${messageName} has already been processed, skipping.`
            );
            return;
          }

          const acknowledgmentMessageName =
            createAcknowledgeCustomMessageNameFromCustomMessage(messageName);
          debugLogger.info(
            `Sending acknowledgment of custom message ${messageName} to ${messageSender}.`
          );
          sendDataTo([messageSender], acknowledgmentMessageName, {});

          // If we are the host,
          // so we need to relay the message to others.
          if (gdjs.multiplayer.isCurrentPlayerHost()) {
            // In the case of custom messages, we relay the message to all players, including the sender.