aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/gregtech/common/GT_Network.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/gregtech/common/GT_Network.java')
-rw-r--r--src/main/java/gregtech/common/GT_Network.java154
1 files changed, 0 insertions, 154 deletions
diff --git a/src/main/java/gregtech/common/GT_Network.java b/src/main/java/gregtech/common/GT_Network.java
deleted file mode 100644
index bf5826e9ae..0000000000
--- a/src/main/java/gregtech/common/GT_Network.java
+++ /dev/null
@@ -1,154 +0,0 @@
-package gregtech.common;
-
-import static gregtech.GT_Mod.GT_FML_LOGGER;
-
-import java.util.EnumMap;
-import java.util.List;
-
-import net.minecraft.entity.player.EntityPlayer;
-import net.minecraft.entity.player.EntityPlayerMP;
-import net.minecraft.world.World;
-import net.minecraft.world.chunk.Chunk;
-
-import com.google.common.io.ByteArrayDataInput;
-import com.google.common.io.ByteStreams;
-
-import cpw.mods.fml.common.network.FMLEmbeddedChannel;
-import cpw.mods.fml.common.network.FMLOutboundHandler;
-import cpw.mods.fml.common.network.NetworkRegistry;
-import cpw.mods.fml.common.network.internal.FMLProxyPacket;
-import cpw.mods.fml.relauncher.Side;
-import gregtech.api.enums.GT_Values;
-import gregtech.api.net.GT_Packet;
-import gregtech.api.net.GT_PacketTypes;
-import gregtech.api.net.GT_Packet_New;
-import gregtech.api.net.IGT_NetworkHandler;
-import io.netty.buffer.ByteBuf;
-import io.netty.buffer.Unpooled;
-import io.netty.channel.ChannelHandler;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.SimpleChannelInboundHandler;
-import io.netty.handler.codec.MessageToMessageCodec;
-
-@ChannelHandler.Sharable
-@SuppressWarnings("deprecation")
-public class GT_Network extends MessageToMessageCodec<FMLProxyPacket, GT_Packet> implements IGT_NetworkHandler {
-
- private final EnumMap<Side, FMLEmbeddedChannel> mChannel;
- private final GT_Packet[] mSubChannels;
-
- public GT_Network() {
- this("GregTech", GT_PacketTypes.referencePackets());
- }
-
- public GT_Network(String channelName, GT_Packet_New... packetTypes) {
- this.mChannel = NetworkRegistry.INSTANCE.newChannel(channelName, this, new HandlerShared());
- final int lastPId = packetTypes[packetTypes.length - 1].getPacketID();
- this.mSubChannels = new GT_Packet[lastPId + 1];
- for (GT_Packet packetType : packetTypes) {
- final int pId = packetType.getPacketID();
- if (this.mSubChannels[pId] == null) this.mSubChannels[pId] = packetType;
- else throw new IllegalArgumentException("Duplicate Packet ID! " + pId);
- }
- }
-
- @Override
- protected void encode(ChannelHandlerContext aContext, GT_Packet aPacket, List<Object> aOutput) {
- final ByteBuf tBuf = Unpooled.buffer()
- .writeByte(aPacket.getPacketID());
- aPacket.encode(tBuf);
- aOutput.add(
- new FMLProxyPacket(
- tBuf,
- aContext.channel()
- .attr(NetworkRegistry.FML_CHANNEL)
- .get()));
- }
-
- @Override
- protected void decode(ChannelHandlerContext aContext, FMLProxyPacket aPacket, List<Object> aOutput) {
- final ByteArrayDataInput aData = ByteStreams.newDataInput(
- aPacket.payload()
- .array());
- final GT_Packet tPacket = this.mSubChannels[aData.readByte()].decode(aData);
- tPacket.setINetHandler(aPacket.handler());
- aOutput.add(tPacket);
- }
-
- @Override
- public void sendToPlayer(GT_Packet aPacket, EntityPlayerMP aPlayer) {
- if (aPacket == null) {
- GT_FML_LOGGER.info("packet null");
- return;
- }
- if (aPlayer == null) {
- GT_FML_LOGGER.info("player null");
- return;
- }
- this.mChannel.get(Side.SERVER)
- .attr(FMLOutboundHandler.FML_MESSAGETARGET)
- .set(FMLOutboundHandler.OutboundTarget.PLAYER);
- this.mChannel.get(Side.SERVER)
- .attr(FMLOutboundHandler.FML_MESSAGETARGETARGS)
- .set(aPlayer);
- this.mChannel.get(Side.SERVER)
- .writeAndFlush(aPacket);
- }
-
- @Override
- public void sendToAllAround(GT_Packet aPacket, NetworkRegistry.TargetPoint aPosition) {
- this.mChannel.get(Side.SERVER)
- .attr(FMLOutboundHandler.FML_MESSAGETARGET)
- .set(FMLOutboundHandler.OutboundTarget.ALLAROUNDPOINT);
- this.mChannel.get(Side.SERVER)
- .attr(FMLOutboundHandler.FML_MESSAGETARGETARGS)
- .set(aPosition);
- this.mChannel.get(Side.SERVER)
- .writeAndFlush(aPacket);
- }
-
- @Override
- public void sendToAll(GT_Packet aPacket) {
- this.mChannel.get(Side.SERVER)
- .attr(FMLOutboundHandler.FML_MESSAGETARGET)
- .set(FMLOutboundHandler.OutboundTarget.ALL);
- this.mChannel.get(Side.SERVER)
- .writeAndFlush(aPacket);
- }
-
- @Override
- public void sendToServer(GT_Packet aPacket) {
- this.mChannel.get(Side.CLIENT)
- .attr(FMLOutboundHandler.FML_MESSAGETARGET)
- .set(FMLOutboundHandler.OutboundTarget.TOSERVER);
- this.mChannel.get(Side.CLIENT)
- .writeAndFlush(aPacket);
- }
-
- @Override
- public void sendPacketToAllPlayersInRange(World aWorld, GT_Packet aPacket, int aX, int aZ) {
- if (!aWorld.isRemote) {
- for (Object tObject : aWorld.playerEntities) {
- if (!(tObject instanceof EntityPlayerMP tPlayer)) {
- break;
- }
- Chunk tChunk = aWorld.getChunkFromBlockCoords(aX, aZ);
- if (tPlayer.getServerForPlayer()
- .getPlayerManager()
- .isPlayerWatchingChunk(tPlayer, tChunk.xPosition, tChunk.zPosition)) {
- sendToPlayer(aPacket, tPlayer);
- }
- }
- }
- }
-
- @ChannelHandler.Sharable
- static final class HandlerShared extends SimpleChannelInboundHandler<GT_Packet> {
-
- @Override
- protected void channelRead0(ChannelHandlerContext ctx, GT_Packet aPacket) {
- final EntityPlayer aPlayer = GT_Values.GT.getThePlayer();
- aPacket.process(aPlayer == null ? null : aPlayer.worldObj);
- }
- }
-}