Project164/eaglerbungee/src/main/java/net/md_5/bungee/ServerConnection.java

83 lines
2.2 KiB
Java

package net.md_5.bungee;
import java.beans.ConstructorProperties;
import java.net.InetSocketAddress;
import java.util.concurrent.TimeUnit;
import net.md_5.bungee.api.connection.Connection;
import net.md_5.bungee.api.connection.Server;
import net.md_5.bungee.netty.ChannelWrapper;
import net.md_5.bungee.protocol.packet.DefinedPacket;
import net.md_5.bungee.protocol.packet.PacketFAPluginMessage;
import net.md_5.bungee.protocol.packet.PacketFFKick;
public class ServerConnection implements Server
{
private final ChannelWrapper ch;
private final BungeeServerInfo info;
private boolean isObsolete;
private final Connection.Unsafe unsafe;
@Override
public void sendData(String channel, byte[] data)
{
unsafe().sendPacket( new PacketFAPluginMessage( channel, data ) );
}
@Override
public synchronized void disconnect(final String reason) {
if (this.ch != null && !this.ch.isClosed()) {
this.unsafe().sendPacket(new PacketFFKick(reason));
this.ch.getHandle().eventLoop().schedule((Runnable) new Runnable() {
@Override
public void run() {
ServerConnection.this.ch.getHandle().close();
}
}, 100L, TimeUnit.MILLISECONDS);
}
}
@Override
public InetSocketAddress getAddress()
{
return getInfo().getAddress();
}
@Override
public Unsafe unsafe()
{
return unsafe;
}
@ConstructorProperties({ "ch", "info" })
public ServerConnection(final ChannelWrapper ch, final BungeeServerInfo info) {
this.unsafe = new Connection.Unsafe() {
@Override
public void sendPacket(final DefinedPacket packet) {
if (ServerConnection.this.ch != null) ServerConnection.this.ch.write(packet);
}
};
this.ch = ch;
this.info = info;
}
public ChannelWrapper getCh() {
return this.ch;
}
@Override
public BungeeServerInfo getInfo() {
return this.info;
}
public boolean isObsolete() {
return this.isObsolete;
}
public void setObsolete(final boolean isObsolete) {
this.isObsolete = isObsolete;
}
}