R3944Realms/Ambassador
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

In eventloop now

Browse Source
This commit is contained in:
Adrian Bergqvist 2022-09-30 00:09:10 +02:00
parent 110def6eb1
commit e4d4730362
No known key found for this signature in database
GPG Key ID: FAE7D8EDE225E686
1 changed files with 1 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/main/java/org/adde0109/ambassador/velocity/VelocityEventHandler.java
View File

@ -36,35 +36,6 @@ public class VelocityEventHandler {
continuation.resume(); continuation.resume();
return; return;
} }
phase.handleLogin(player,null,continuation); player.getConnection().eventLoop().submit(() -> phase.handleLogin(player,null,continuation));
} }
/*@Subscribe
public void onServerLoginPluginMessageEvent(ServerLoginPluginMessageEvent event, Continuation continuation) {
if (!Objects.equals(event.getIdentifier().getId(), "fml:loginwrapper") || !(((ConnectedPlayer)event.getConnection().getPlayer()).getPhase() instanceof VelocityForgeClientConnectionPhase)) {
continuation.resume();
return;
}
final VelocityServerConnection serverCon = (VelocityServerConnection) event.getConnection();
final MinecraftConnection connection = serverCon.getConnection();
if (connection == null) {
//This should never happen.
continuation.resumeWithException(new NullPointerException());
return;
}
connection.eventLoop().submit(() -> {
if (event.getSequenceId() == 0) {
connection.setType(new ForgeFML2ConnectionType());
serverCon.setConnectionPhase(new VelocityForgeBackendConnectionPhase(ambassador));
byte[] response = ((VelocityForgeBackendConnectionPhase)serverCon.getPhase()).generateResponse(serverCon.getPlayer(), Unpooled.wrappedBuffer(event.getContents()));
event.setResult(ServerLoginPluginMessageEvent.ResponseResult.reply(response));
MinecraftSessionHandler sessionHandler = new VelocityForgeBackendHandshakeHandler(connection.getSessionHandler(),serverCon);
connection.setSessionHandler(sessionHandler);
((ForgeFML2ClientConnectionPhase) serverCon.getPlayer().getPhase()).reset(serverCon.getPlayer(), serverCon.getPlayer().getConnection(),event.getContents());
} else {
((ForgeFML2ClientConnectionPhase) serverCon.getPlayer().getPhase()).send(serverCon.getPlayer(), new LoginPluginMessage(event.getSequenceId(),event.getIdentifier().getId(),Unpooled.wrappedBuffer(event.getContents())));
}
continuation.resume();
});
}*/
} }