Added network

5 files changed, 118 insertions, 5 deletions

diff --git a/src/main/java/com/detrav/DetravScannerMod.java b/src/main/java/com/detrav/DetravScannerMod.java
index a06dbe055d..c02308bb06 100644
--- a/src/main/java/com/detrav/DetravScannerMod.java
+++ b/src/main/java/com/detrav/DetravScannerMod.java
@@ -3,6 +3,7 @@ package com.detrav;
 import com.detrav.proxies.CommonProxy;
 import com.detrav.commands.DetravScannerCommand;
 import com.detrav.utils.DetravCreativeTab;
+import com.detrav.utils.DetravNetwork;
 import cpw.mods.fml.common.Mod;
 import cpw.mods.fml.common.Mod.EventHandler;
 import cpw.mods.fml.common.SidedProxy;
@@ -24,6 +25,7 @@ public class DetravScannerMod
     public  DetravScannerMod()
     {
         GregTech_API.sAfterGTPreload.add(new DetravLoader());
+        new DetravNetwork();
     }
 
     @SidedProxy(clientSide = "com.detrav.proxies.ClientProxy", serverSide = "com.detrav.proxies.ServerProxy")
diff --git a/src/main/java/com/detrav/items/behaviours/BehaviourDetravToolElectricProPick.java b/src/main/java/com/detrav/items/behaviours/BehaviourDetravToolElectricProPick.java
index 1ba9a77968..66260adccf 100644
--- a/src/main/java/com/detrav/items/behaviours/BehaviourDetravToolElectricProPick.java
+++ b/src/main/java/com/detrav/items/behaviours/BehaviourDetravToolElectricProPick.java
@@ -1,7 +1,10 @@
 package com.detrav.items.behaviours;
 
+import com.detrav.utils.DetravNetwork;
+import com.detrav.utils.DetravProPickPacket01;
 import gregtech.api.items.GT_MetaBase_Item;
 import net.minecraft.entity.player.EntityPlayer;
+import net.minecraft.entity.player.EntityPlayerMP;
 import net.minecraft.item.ItemStack;
 import net.minecraft.util.ChatComponentText;
 import net.minecraft.world.World;
@@ -22,11 +25,7 @@ public class BehaviourDetravToolElectricProPick extends BehaviourDetravToolProPi
             //aPlayer.openGui();
 
             aPlayer.addChatMessage(new ChatComponentText("Scanning Begin"));
-            try {
-                Thread.sleep(5000);
-            } catch (InterruptedException e) {
-                e.printStackTrace();
-            }
+            DetravNetwork.INSTANCE.sendToPlayer(new DetravProPickPacket01(),(EntityPlayerMP)aPlayer);
         }
         return super.onItemRightClick(aItem,aStack,aWorld,aPlayer);
     }
diff --git a/src/main/java/com/detrav/utils/DetravNetwork.java b/src/main/java/com/detrav/utils/DetravNetwork.java
new file mode 100644
index 0000000000..3b005ae8a0
--- /dev/null
+++ b/src/main/java/com/detrav/utils/DetravNetwork.java
@@ -0,0 +1,64 @@
+package com.detrav.utils;
+
+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.EntityPlayer;
+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/utils/DetravPacket.java b/src/main/java/com/detrav/utils/DetravPacket.java
new file mode 100644
index 0000000000..b1736ae928
--- /dev/null
+++ b/src/main/java/com/detrav/utils/DetravPacket.java
@@ -0,0 +1,17 @@
+package com.detrav.utils;
+
+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/utils/DetravProPickPacket01.java b/src/main/java/com/detrav/utils/DetravProPickPacket01.java
new file mode 100644
index 0000000000..cdd837f03f
--- /dev/null
+++ b/src/main/java/com/detrav/utils/DetravProPickPacket01.java
@@ -0,0 +1,31 @@
+package com.detrav.utils;
+
+import com.google.common.io.ByteArrayDataInput;
+import net.minecraft.client.Minecraft;
+import net.minecraft.entity.player.EntityPlayer;
+import net.minecraft.util.ChatComponentText;
+
+/**
+ * Created by wital_000 on 20.03.2016.
+ */
+public class DetravProPickPacket01 extends DetravPacket {
+    @Override
+    public int getPacketID() {
+        return 0;
+    }
+
+    @Override
+    public byte[] encode() {
+        return new byte[0];
+    }
+
+    @Override
+    public Object decode(ByteArrayDataInput aData) {
+        return new DetravProPickPacket01();
+    }
+
+    @Override
+    public void process() {
+        Minecraft.getMinecraft().thePlayer.addChatMessage(new ChatComponentText("NetworkTested"));
+    }
+}