Add missing allowed check. Fixes #335

This commit is contained in:
Andrew Steinborn
2020-07-28 16:50:34 -04:00
parent 7ab56d0ca0
commit 5a515f37a3

View File

@@ -219,9 +219,11 @@ public class ClientPlaySessionHandler implements MinecraftSessionHandler {
PluginMessageEvent event = new PluginMessageEvent(player, serverConn, id,
ByteBufUtil.getBytes(packet.content()));
server.getEventManager().fire(event).thenAcceptAsync(pme -> {
PluginMessage message = new PluginMessage(packet.getChannel(),
Unpooled.wrappedBuffer(copy));
backendConn.write(message);
if (pme.getResult().isAllowed()) {
PluginMessage message = new PluginMessage(packet.getChannel(),
Unpooled.wrappedBuffer(copy));
backendConn.write(message);
}
}, backendConn.eventLoop());
}
}