diff --git a/.idea/misc.xml b/.idea/misc.xml
index 8bddb52..18ad7e3 100644
--- a/.idea/misc.xml
+++ b/.idea/misc.xml
@@ -1,5 +1,5 @@
-
+
\ No newline at end of file
diff --git a/eaglerbungee/src/main/java/net/md_5/bungee/UserConnection.java b/eaglerbungee/src/main/java/net/md_5/bungee/UserConnection.java
index cb96059..e265079 100644
--- a/eaglerbungee/src/main/java/net/md_5/bungee/UserConnection.java
+++ b/eaglerbungee/src/main/java/net/md_5/bungee/UserConnection.java
@@ -71,6 +71,8 @@ public final class UserConnection implements ProxiedPlayer
private int clientEntityId;
+ private final Map attachment = new WeakHashMap();
+
public void setServer(ServerConnection server) {
this.server = server;
}
@@ -239,11 +241,11 @@ public final class UserConnection implements ProxiedPlayer
this.tabList = tabList;
}
- public void sendPacket(PacketWrapper packet)
- {
- ch.write( packet );
+ public void sendPacket(final byte[] b) {
+ this.ch.write(b);
}
+
@Deprecated
public boolean isActive()
{
@@ -429,8 +431,7 @@ public final class UserConnection implements ProxiedPlayer
@Override
public Map getAttachment() { // fix this (maybe)
- System.out.println("This might be a problem");
- return Map.of();
+ return attachment;
}
@Override
diff --git a/eaglerbungee/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java b/eaglerbungee/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java
index e668f1c..d7b9d03 100644
--- a/eaglerbungee/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java
+++ b/eaglerbungee/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java
@@ -9,6 +9,7 @@ import java.io.DataInput;
import java.net.InetAddress;
import java.util.Objects;
+import io.netty.buffer.Unpooled;
import net.md_5.bungee.*;
import net.md_5.bungee.api.ProxyServer;
import net.md_5.bungee.api.config.ServerInfo;
@@ -71,12 +72,10 @@ public class DownstreamBridge extends PacketHandler
}
@Override
- public void handle(PacketWrapper packet) throws Exception
- {
- if ( !server.isObsolete() )
- {
- EntityMap.rewrite( packet.buf, con.getServerEntityId(), con.getClientEntityId() );
- con.sendPacket( packet );
+ public void handle(final byte[] buf) throws Exception {
+ if (!this.server.isObsolete()) {
+ EntityMap.rewrite(Unpooled.wrappedBuffer(buf), this.con.getServerEntityId(), this.con.getClientEntityId());
+ this.con.sendPacket(buf);
}
}
diff --git a/eaglerbungee/src/main/java/net/md_5/bungee/connection/InitialHandler.java b/eaglerbungee/src/main/java/net/md_5/bungee/connection/InitialHandler.java
index 327529a..cdc44cb 100644
--- a/eaglerbungee/src/main/java/net/md_5/bungee/connection/InitialHandler.java
+++ b/eaglerbungee/src/main/java/net/md_5/bungee/connection/InitialHandler.java
@@ -65,6 +65,7 @@ public class InitialHandler extends PacketHandler implements PendingConnection {
@Override
public void connected(final ChannelWrapper channel) throws Exception {
+ System.out.println("[InitialHandler] - connected (I think)");
this.ch = channel;
}
diff --git a/eaglerbungee/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java b/eaglerbungee/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java
index d2e5afe..14d5415 100644
--- a/eaglerbungee/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java
+++ b/eaglerbungee/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java
@@ -1,5 +1,6 @@
package net.md_5.bungee.connection;
+import io.netty.buffer.Unpooled;
import net.md_5.bungee.BungeeCord;
import net.md_5.bungee.EntityMap;
import net.md_5.bungee.UserConnection;
@@ -57,12 +58,10 @@ public class UpstreamBridge extends PacketHandler
}
@Override
- public void handle(PacketWrapper packet) throws Exception
- {
- EntityMap.rewrite( packet.buf, con.getClientEntityId(), con.getServerEntityId() );
- if ( con.getServer() != null )
- {
- con.getServer().getCh().write( packet );
+ public void handle(final byte[] buf) throws Exception {
+ EntityMap.rewrite(Unpooled.wrappedBuffer(buf), this.con.getClientEntityId(), this.con.getServerEntityId());
+ if (this.con.getServer() != null && this.con.getServer().getCh() != null) {
+ this.con.getServer().getCh().write(buf); // Change to buf if its a problem
}
}
diff --git a/eaglerbungee/src/main/java/net/md_5/bungee/eaglercraft/WebSocketListener.java b/eaglerbungee/src/main/java/net/md_5/bungee/eaglercraft/WebSocketListener.java
index e150297..13efd7b 100644
--- a/eaglerbungee/src/main/java/net/md_5/bungee/eaglercraft/WebSocketListener.java
+++ b/eaglerbungee/src/main/java/net/md_5/bungee/eaglercraft/WebSocketListener.java
@@ -180,7 +180,6 @@ public class WebSocketListener extends WebSocketServer {
System.out.println("[WebsocketListener] - onMessage called");
Object o = arg0.getAttachment();
if(o == null || (o instanceof PendingSocket)) {
- System.out.println("o is null");
InetAddress realAddr;
if(o == null) {
realAddr = arg0.getRemoteSocketAddress().getAddress();
@@ -210,7 +209,6 @@ public class WebSocketListener extends WebSocketServer {
o = proxyObj;
}
if(o != null) {
- System.out.println("o is not null");
if(o instanceof WebSocketProxy) {
System.out.println("Instance of WebSocketProxy, sending packet");
((WebSocketProxy)o).sendPacket(arg1);
diff --git a/eaglerbungee/src/main/java/net/md_5/bungee/netty/HandlerBoss.java b/eaglerbungee/src/main/java/net/md_5/bungee/netty/HandlerBoss.java
index bf1a5d8..d87be82 100644
--- a/eaglerbungee/src/main/java/net/md_5/bungee/netty/HandlerBoss.java
+++ b/eaglerbungee/src/main/java/net/md_5/bungee/netty/HandlerBoss.java
@@ -1,123 +1,88 @@
+//
+// Decompiled by Procyon v0.5.36
+//
+
package net.md_5.bungee.netty;
-import com.google.common.base.Preconditions;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInboundHandlerAdapter;
-import io.netty.handler.timeout.ReadTimeoutException;
import java.io.IOException;
import java.util.logging.Level;
+
+import com.google.common.base.Preconditions;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.channel.MessageList;
+import io.netty.handler.timeout.ReadTimeoutException;
import net.md_5.bungee.api.ProxyServer;
import net.md_5.bungee.connection.CancelSendSignal;
import net.md_5.bungee.connection.InitialHandler;
import net.md_5.bungee.connection.PingHandler;
-import net.md_5.bungee.protocol.BadPacketException;
-
-/**
- * This class is a primitive wrapper for {@link PacketHandler} instances tied to
- * channels to maintain simple states, and only call the required, adapted
- * methods when the channel is connected.
- */
-public class HandlerBoss extends ChannelInboundHandlerAdapter
-{
+public class HandlerBoss extends ChannelInboundHandlerAdapter {
private ChannelWrapper channel;
private PacketHandler handler;
- public void setHandler(PacketHandler handler)
- {
- Preconditions.checkArgument( handler != null, "handler" );
+ public void setHandler(final PacketHandler handler) {
+ Preconditions.checkArgument(handler != null, (Object) "handler");
this.handler = handler;
}
- @Override
- public void channelActive(ChannelHandlerContext ctx) throws Exception
- {
- if ( handler != null )
- {
- channel = new ChannelWrapper( ctx );
- handler.connected( channel );
-
- if ( !( handler instanceof InitialHandler || handler instanceof PingHandler ) )
- {
- ProxyServer.getInstance().getLogger().log( Level.INFO, "{0} has connected", handler );
+ public void channelActive(final ChannelHandlerContext ctx) throws Exception {
+ if (this.handler != null) {
+ this.channel = new ChannelWrapper(ctx);
+ this.handler.connected(this.channel);
+ if (!(this.handler instanceof InitialHandler) && !(this.handler instanceof PingHandler)) {
+ ProxyServer.getInstance().getLogger().log(Level.INFO, "{0} has connected", this.handler);
}
}
}
- @Override
- public void channelInactive(ChannelHandlerContext ctx) throws Exception
- {
- if ( handler != null )
- {
- handler.disconnected( channel );
-
- if ( !( handler instanceof InitialHandler || handler instanceof PingHandler ) )
- {
- ProxyServer.getInstance().getLogger().log( Level.INFO, "{0} has disconnected", handler );
+ public void channelInactive(final ChannelHandlerContext ctx) throws Exception {
+ if (this.handler != null) {
+ this.handler.disconnected(this.channel);
+ if (!(this.handler instanceof InitialHandler) && !(this.handler instanceof PingHandler)) {
+ ProxyServer.getInstance().getLogger().log(Level.INFO, "{0} has disconnected", this.handler);
}
}
}
- //@Override
- public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
- {
- if ( handler != null )
- {
- PacketWrapper packet = (PacketWrapper) msg;
- boolean sendPacket = true;
- try
- {
- if ( packet.packet != null )
- {
- try
- {
- packet.packet.handle( handler );
- } catch ( CancelSendSignal ex )
- {
+ public void messageReceived(final ChannelHandlerContext ctx, final MessageList