Add missing allowed check to 1.0.x. Fixes #335

This commit is contained in:
Andrew Steinborn
2020-07-28 16:53:15 -04:00
parent e038a71baf
commit e011f1d783

View File

@@ -230,8 +230,11 @@ public class ClientPlaySessionHandler implements MinecraftSessionHandler {
} else { } else {
PluginMessageEvent event = new PluginMessageEvent(player, serverConn, id, PluginMessageEvent event = new PluginMessageEvent(player, serverConn, id,
packet.getData()); packet.getData());
server.getEventManager().fire(event).thenAcceptAsync(pme -> backendConn.write(packet), server.getEventManager().fire(event).thenAcceptAsync(pme -> {
backendConn.eventLoop()); if (pme.getResult().isAllowed()) {
backendConn.write(packet);
}
}, backendConn.eventLoop());
} }
} }
} }