merge sources and fix dependencies

3 files changed, 276 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..75e0a267ab
--- /dev/null
+++ b/src/main/java/com/detrav/net/DetravNetwork.java
@@ -0,0 +1,72 @@
+package com.detrav.net;
+
+import java.util.EnumMap;
+import java.util.List;
+
+import net.minecraft.entity.player.EntityPlayerMP;
+
+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.ByteBuf;
+import io.netty.buffer.ByteBufInputStream;
+import io.netty.buffer.ByteBufOutputStream;
+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;
+
+/**
+ * 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;
+
+    public DetravNetwork() {
+        INSTANCE = this;
+        this.mChannel = NetworkRegistry.INSTANCE.newChannel("DetravScanner", this, new HandlerShared());
+    }
+
+    @Override
+    protected void encode(ChannelHandlerContext ctx, DetravPacket msg, List<Object> out) throws Exception {
+        ByteBuf buf = Unpooled.buffer();
+        buf.writeByte(msg.getPacketID());
+        msg.encode(new ByteBufOutputStream(buf));
+        out.add(new FMLProxyPacket(buf, ctx.channel().attr(NetworkRegistry.FML_CHANNEL).get()));
+    }
+
+    @Override
+    protected void decode(ChannelHandlerContext ctx, FMLProxyPacket msg, List<Object> out) throws Exception {
+        ByteBuf payload = msg.payload();
+        payload.readByte(); // Sub Channel - Ignore
+        out.add(ProspectingPacket.decode(new ByteBufInputStream(payload)));
+    }
+
+    public void sendToPlayer(DetravPacket aPacket, EntityPlayerMP aPlayer) {
+        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);
+    }
+
+    public void sendToServer(DetravPacket aPacket) {
+        this.mChannel.get(Side.CLIENT).attr(FMLOutboundHandler.FML_MESSAGETARGET)
+                .set(FMLOutboundHandler.OutboundTarget.TOSERVER);
+        this.mChannel.get(Side.CLIENT).writeAndFlush(aPacket);
+    }
+
+    @ChannelHandler.Sharable
+    static final class HandlerShared extends SimpleChannelInboundHandler<DetravPacket> {
+
+        @Override
+        protected void channelRead0(ChannelHandlerContext ctx, DetravPacket aPacket) {
+            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..8659549045
--- /dev/null
+++ b/src/main/java/com/detrav/net/DetravPacket.java
@@ -0,0 +1,16 @@
+package com.detrav.net;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+/**
+ * Created by wital_000 on 20.03.2016.
+ */
+public abstract class DetravPacket {
+
+    public abstract int getPacketID();
+
+    public abstract void encode(OutputStream out) throws IOException;
+
+    public abstract void process();
+}
diff --git a/src/main/java/com/detrav/net/ProspectingPacket.java b/src/main/java/com/detrav/net/ProspectingPacket.java
new file mode 100644
index 0000000000..bc2f1bc9f2
--- /dev/null
+++ b/src/main/java/com/detrav/net/ProspectingPacket.java
@@ -0,0 +1,188 @@
+package com.detrav.net;
+
+import java.io.DataInput;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.HashMap;
+import java.util.zip.GZIPInputStream;
+import java.util.zip.GZIPOutputStream;
+
+import net.minecraft.util.StatCollector;
+import net.minecraftforge.fluids.FluidRegistry;
+import net.minecraftforge.fluids.FluidStack;
+
+import com.detrav.DetravScannerMod;
+import com.detrav.gui.DetravScannerGUI;
+import com.detrav.gui.textures.DetravMapTexture;
+import com.detrav.utils.GTppHelper;
+import com.github.bartimaeusnek.bartworks.system.material.Werkstoff;
+import com.google.common.base.Objects;
+
+import gregtech.api.GregTech_API;
+import gregtech.api.enums.Materials;
+import gregtech.api.util.GT_LanguageManager;
+
+/**
+ * Created by wital_000 on 20.03.2016.
+ */
+public class ProspectingPacket extends DetravPacket {
+
+    public final int chunkX;
+    public final int chunkZ;
+    public final int posX;
+    public final int posZ;
+    public final int size;
+    public final int ptype;
+    public final HashMap<Byte, Short>[][] map;
+    public final HashMap<String, Integer> ores;
+    public final HashMap<Short, String> metaMap;
+    public static final HashMap<Integer, short[]> fluidColors = new HashMap<>();
+
+    public int level = -1;
+
+    public ProspectingPacket(int chunkX, int chunkZ, int posX, int posZ, int size, int ptype) {
+        this.chunkX = chunkX;
+        this.chunkZ = chunkZ;
+        this.posX = posX;
+        this.posZ = posZ;
+        this.size = size;
+        this.ptype = ptype;
+        this.map = new HashMap[(size * 2 + 1) * 16][(size * 2 + 1) * 16];
+        this.ores = new HashMap<>();
+        this.metaMap = new HashMap<>();
+    }
+
+    private static void addOre(ProspectingPacket packet, byte y, int i, int j, short meta) {
+        final String name;
+        short[] rgba;
+
+        try {
+            if (packet.ptype == 0 || packet.ptype == 1) {
+                // Ore or Small Ore
+                if (meta < 7000 || meta > 7500) {
+                    if (meta > 0) {
+                        Materials tMaterial = GregTech_API.sGeneratedMaterials[meta % 1000];
+                        rgba = tMaterial.getRGBA();
+                        name = tMaterial.getLocalizedNameForItem(
+                                GT_LanguageManager.getTranslation("gt.blockores." + meta + ".name"));
+                    } else {
+                        final Werkstoff werkstoff = Werkstoff.werkstoffHashMap.getOrDefault((short) (meta * -1), null);
+                        String translated = GT_LanguageManager.getTranslation("bw.blocktype.ore");
+                        name = translated.replace("%material", werkstoff.getLocalizedName());
+                        rgba = werkstoff != null ? werkstoff.getRGBA() : new short[] { 0, 0, 0, 0 };
+                    }
+                } else {
+                    gtPlusPlus.core.material.Material pMaterial = GTppHelper.decodeoresGTpp.get((short) (meta - 7000));
+                    rgba = pMaterial.getRGBA();
+                    name = pMaterial.getLocalizedName() + " Ore";
+                }
+            } else if (packet.ptype == 2) {
+                // Fluid
+                rgba = fluidColors.get((int) meta);
+                if (rgba == null) {
+                    DetravScannerMod.proxy
+                            .sendPlayerExeption("Unknown fluid ID = " + meta + " Please add to FluidColors.java!");
+                    rgba = new short[] { 0, 0, 0, 0 };
+                }
+
+                name = Objects.firstNonNull(
+                        FluidRegistry.getFluid(meta).getLocalizedName(new FluidStack(FluidRegistry.getFluid(meta), 0)),
+                        StatCollector.translateToLocal("gui.detrav.scanner.unknown_fluid"));
+            } else if (packet.ptype == 3) {
+                // Pollution
+                name = StatCollector.translateToLocal("gui.detrav.scanner.pollution");
+                rgba = new short[] { 125, 123, 118, 0 };
+            } else {
+                return;
+            }
+        } catch (Exception ignored) {
+            return;
+        }
+        packet.ores.put(name, ((rgba[0] & 0xFF) << 16) + ((rgba[1] & 0xFF) << 8) + ((rgba[2] & 0xFF)));
+        packet.metaMap.put(meta, name);
+    }
+
+    public static Object decode(InputStream in) throws IOException {
+        DataInput aData = new DataInputStream(new GZIPInputStream(in));
+        ProspectingPacket packet = new ProspectingPacket(
+                aData.readInt(),
+                aData.readInt(),
+                aData.readInt(),
+                aData.readInt(),
+                aData.readInt(),
+                aData.readInt());
+        packet.level = aData.readInt();
+
+        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<>();
+            for (int k = 0; k < kSize; k++) {
+                final byte y = aData.readByte();
+                final short meta = aData.readShort();
+                packet.map[i][j].put(y, meta);
+                if (packet.ptype != 2 || y == 1) addOre(packet, y, i, j, meta);
+                checkOut++;
+            }
+        }
+        int checkOut2 = aData.readInt();
+        if (checkOut != checkOut2) return null;
+        return packet;
+    }
+
+    @Override
+    public int getPacketID() {
+        return 0;
+    }
+
+    @Override
+    public void encode(OutputStream out) throws IOException {
+        DataOutputStream tOut = new DataOutputStream(new GZIPOutputStream(out));
+        tOut.writeInt(chunkX);
+        tOut.writeInt(chunkZ);
+        tOut.writeInt(posX);
+        tOut.writeInt(posZ);
+        tOut.writeInt(size);
+        tOut.writeInt(ptype);
+        tOut.writeInt(level);
+
+        int aSize = (size * 2 + 1) * 16;
+        int checkOut = 0;
+        for (int i = 0; i < aSize; i++) for (int j = 0; j < aSize; j++) {
+            HashMap<Byte, Short> data = map[i][j];
+            if (data == null) tOut.writeByte(0);
+            else {
+                tOut.writeByte(data.keySet().size());
+                for (byte key : data.keySet()) {
+                    tOut.writeByte(key);
+                    tOut.writeShort(data.get(key));
+                    checkOut++;
+                }
+            }
+        }
+        tOut.writeInt(checkOut);
+        tOut.close();
+    }
+
+    @Override
+    public void process() {
+        DetravScannerGUI.newMap(new DetravMapTexture(this));
+        DetravScannerMod.proxy.openProspectorGUI();
+    }
+
+    public void addBlock(int x, int y, int z, short metaData) {
+        int aX = x - (chunkX - size) * 16;
+        int aZ = z - (chunkZ - size) * 16;
+        if (map[aX][aZ] == null) map[aX][aZ] = new HashMap<>();
+        map[aX][aZ].put((byte) y, metaData);
+    }
+
+    public int getSize() {
+        return (size * 2 + 1) * 16;
+    }
+}