3 files changed, 174 insertions, 0 deletions
diff --git a/src/main/java/com/detrav/net/DetravNetwork.java b/src/main/java/com/detrav/net/DetravNetwork.java
new file mode 100644
index 0000000000..ea79d4cdc3
--- /dev/null
+++ b/src/main/java/com/detrav/net/DetravNetwork.java
@@ -0,0 +1,63 @@
+package com.detrav.net;
+
+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 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;
+import net.minecraft.entity.player.EntityPlayerMP;
+
+import java.util.EnumMap;
+import java.util.List;
+
+/**
+ * Created by wital_000 on 20.03.2016.
+ */
+@ChannelHandler.Sharable
+public class DetravNetwork extends MessageToMessageCodec<FMLProxyPacket, DetravPacket> {
+
+    static public DetravNetwork INSTANCE;
+    private final EnumMap<Side, FMLEmbeddedChannel> mChannel;
+    private DetravPacket[] mSubChannels;
+
+    public DetravNetwork()
+    {
+        INSTANCE = this;
+        this.mChannel = NetworkRegistry.INSTANCE.newChannel("DetravScanner", new ChannelHandler[]{this, new HandlerShared()});
+        this.mSubChannels = new DetravPacket[]{new DetravProPickPacket01()};
+    }
+
+    @Override
+    protected void encode(ChannelHandlerContext ctx, DetravPacket msg, List<Object> out) throws Exception {
+        out.add(new FMLProxyPacket(Unpooled.buffer().writeByte(msg.getPacketID()).writeBytes(msg.encode()).copy(),(String) ctx.channel().attr(NetworkRegistry.FML_CHANNEL).get()));
+    }
+
+    @Override
+    protected void decode(ChannelHandlerContext ctx, FMLProxyPacket msg, List<Object> out) throws Exception {
+        ByteArrayDataInput aData = ByteStreams.newDataInput(msg.payload().array());
+        out.add(this.mSubChannels[aData.readByte()].decode(aData));
+    }
+
+    public void sendToPlayer(DetravPacket aPacket, EntityPlayerMP aPlayer) {
+        ((FMLEmbeddedChannel) this.mChannel.get(Side.SERVER)).attr(FMLOutboundHandler.FML_MESSAGETARGET).set(FMLOutboundHandler.OutboundTarget.PLAYER);
+        ((FMLEmbeddedChannel) this.mChannel.get(Side.SERVER)).attr(FMLOutboundHandler.FML_MESSAGETARGETARGS).set(aPlayer);
+        ((FMLEmbeddedChannel) this.mChannel.get(Side.SERVER)).writeAndFlush(aPacket);
+    }
+
+    @ChannelHandler.Sharable
+    static final class HandlerShared
+            extends SimpleChannelInboundHandler<DetravPacket> {
+        protected void channelRead0(ChannelHandlerContext ctx, DetravPacket aPacket)
+                throws Exception {
+            //EntityPlayer aPlayer = GT_Values.GT.getThePlayer();
+            aPacket.process();
+        }
+    }
+}
diff --git a/src/main/java/com/detrav/net/DetravPacket.java b/src/main/java/com/detrav/net/DetravPacket.java
new file mode 100644
index 0000000000..a2b3697bac
--- /dev/null
+++ b/src/main/java/com/detrav/net/DetravPacket.java
@@ -0,0 +1,17 @@
+package com.detrav.net;
+
+import com.google.common.io.ByteArrayDataInput;
+
+/**
+ * Created by wital_000 on 20.03.2016.
+ */
+public abstract class DetravPacket {
+
+    public abstract int getPacketID() ;
+
+    public abstract byte[] encode() ;
+
+    public abstract Object decode(ByteArrayDataInput aData) ;
+
+    public abstract void process();
+}
diff --git a/src/main/java/com/detrav/net/DetravProPickPacket01.java b/src/main/java/com/detrav/net/DetravProPickPacket01.java
new file mode 100644
index 0000000000..ad6aba226e
--- /dev/null
+++ b/src/main/java/com/detrav/net/DetravProPickPacket01.java
@@ -0,0 +1,94 @@
+package com.detrav.net;
+
+import com.google.common.io.ByteArrayDataInput;
+import com.google.common.io.ByteArrayDataOutput;
+import com.google.common.io.ByteStreams;
+import net.minecraft.client.Minecraft;
+import net.minecraft.util.ChatComponentText;
+
+import java.util.HashMap;
+
+/**
+ * Created by wital_000 on 20.03.2016.
+ */
+public class DetravProPickPacket01 extends DetravPacket {
+    public int chunkX;
+    public int chunkZ;
+    public int size;
+    HashMap<Byte,Short>[][] map = null;
+
+    @Override
+    public int getPacketID() {
+        return 0;
+    }
+
+    public int level = -1;
+
+    @Override
+    public byte[] encode() {
+        ByteArrayDataOutput tOut = ByteStreams.newDataOutput(1);
+        tOut.writeInt(level);
+        tOut.writeInt(chunkX);
+        tOut.writeInt(chunkZ);
+        tOut.writeInt(size);
+        int aSize = (size*2+1)*16;
+        int checkOut = 0;
+        for(int i =0; i<aSize; i++)
+            for(int j =0; j<aSize; j++)
+            {
+                if(map[i][j]==null)
+                    tOut.writeByte(0);
+                else
+                {
+                    tOut.writeByte(map[i][j].keySet().size());
+                    for(byte key : map[i][j].keySet())
+                    {
+                        tOut.writeByte(key);
+                        tOut.writeShort(map[i][j].get(key));
+                        checkOut++;
+                    }
+                }
+            }
+        tOut.writeInt(checkOut);
+        return tOut.toByteArray();
+    }
+
+    @Override
+    public Object decode(ByteArrayDataInput aData) {
+        DetravProPickPacket01 packet = new DetravProPickPacket01();
+        packet.level = aData.readInt();
+        packet.chunkX = aData.readInt();
+        packet.chunkZ = aData.readInt();
+        packet.size = aData.readInt();
+        packet.map = new HashMap[(packet.size * 2 + 1) * 16][(packet.size * 2 + 1) * 16];
+        int aSize = (packet.size * 2 + 1) * 16;
+        int checkOut = 0;
+        for (int i = 0; i < aSize; i++)
+            for (int j = 0; j < aSize; j++) {
+                byte kSize = aData.readByte();
+                if(kSize == 0) continue;
+                packet.map[i][j] = new HashMap<Byte, Short>();
+                for (int k = 0; k < kSize; k++) {
+                    packet.map[i][j].put(aData.readByte(),aData.readShort());
+                    checkOut++;
+                }
+            }
+        int checkOut2 = aData.readInt();
+        if(checkOut != checkOut2) return new DetravProPickPacket01();
+        return packet;
+    }
+
+    @Override
+    public void process() {
+        Minecraft.getMinecraft().thePlayer.addChatMessage(new ChatComponentText("NetworkTested: " + Integer.toString(level)));
+    }
+
+    public void addBlock(int x, int y, int z, short metaData) {
+        if(map == null) map = new HashMap[(size*2+1)*16][(size*2+1)*16];
+        int aX = x - (chunkX-size)*16;
+        int aZ = z - (chunkZ-size)*16;
+        if(map[aX][aZ] == null) map[aX][aZ] = new HashMap<Byte, Short>();
+        map[aX][aZ].put((byte)y,metaData);
+        //String key = String.format(("x_y"))
+    }
+}