Fix #157

Author: dries-c

PMUtils.php

@@ -8,6 +8,8 @@
 use pocketmine\network\mcpe\PacketBroadcaster;
 use pocketmine\network\mcpe\protocol\ProtocolInfo;
 use pocketmine\network\mcpe\raklib\RakLibInterface;
+use pocketmine\network\mcpe\StandardEntityEventBroadcaster;
+use pocketmine\network\mcpe\StandardPacketBroadcaster;
 use pocketmine\Server;
 use ReflectionClass;
 use function method_exists;
@@ -20,26 +22,16 @@ public static function getPacketBroadcaster(Server $server): PacketBroadcaster
             return $server->getPacketBroadcaster(ProtocolInfo::CURRENT_PROTOCOL);
         }
 
-        $packetBroadcaster = self::getRaklibInterfacePropertyValue($server, 'packetBroadcaster');
-        if ($packetBroadcaster instanceof PacketBroadcaster) {
-            return $packetBroadcaster;
-        }
-
-        throw new Exception("PacketBroadcaster isn't valid");
+        return new StandardPacketBroadcaster($server);
     }
 
-    public static function getEntityEventBroadcaster(Server $server): EntityEventBroadcaster
+    public static function getEntityEventBroadcaster(Server $server, PacketBroadcaster $packetBroadcaster): EntityEventBroadcaster
     {
         if (method_exists($server, 'getEntityEventBroadcaster')) {
-            return $server->getEntityEventBroadcaster(self::getPacketBroadcaster($server), TypeConverter::getInstance());
-        }
-
-        $entityEventBroadcaster = self::getRaklibInterfacePropertyValue($server, 'entityEventBroadcaster');
-        if ($entityEventBroadcaster instanceof EntityEventBroadcaster) {
-            return $entityEventBroadcaster;
+            return $server->getEntityEventBroadcaster($packetBroadcaster, TypeConverter::getInstance());
         }
 
-        throw new Exception("EntityEventBroadcaster isn't valid");
+        return new StandardEntityEventBroadcaster($packetBroadcaster, TypeConverter::getInstance());
     }
 
     private static function getRaklibInterfacePropertyValue(Server $server, string $propertyName): mixed

ProxyNetworkInterface.php

@@ -130,7 +130,7 @@ public function __construct(PluginBase $plugin, int $port, ?string $composerPath
         $this->threadToMainReader = new PthreadsChannelReader($threadToMainBuffer);
 
         $this->packetBroadcaster = PMUtils::getPacketBroadcaster($server);
-        $this->entityEventBroadcaster = PMUtils::getEntityEventBroadcaster($server);
+        $this->entityEventBroadcaster = PMUtils::getEntityEventBroadcaster($server, $this->packetBroadcaster);
 
         PacketPool::getInstance()->registerPacket(new TickSyncPacket());