.

2 files changed, 61 insertions, 5 deletions

diff --git a/src/main/java/de/torui/coflsky/websocket/WSClient.java b/src/main/java/de/torui/coflsky/websocket/WSClient.java
index c26edf0..9641277 100644
--- a/src/main/java/de/torui/coflsky/websocket/WSClient.java
+++ b/src/main/java/de/torui/coflsky/websocket/WSClient.java
@@ -9,7 +9,10 @@ import org.java_websocket.handshake.ServerHandshake;
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 
+import de.torui.coflsky.WSCommandHandler;
 import de.torui.coflsky.core.Command;
+import net.minecraft.client.Minecraft;
+import net.minecraft.server.MinecraftServer;
 
 
 public class WSClient extends WebSocketClient{
@@ -43,12 +46,11 @@ public class WSClient extends WebSocketClient{
 
 	@Override
 	public void onMessage(String message) {
-		System.out.println(message);
+		//System.out.println(message);
 		
 		Command cmd = gson.fromJson(message, Command.class);
-
-		
-		System.out.println(cmd);
+		//System.out.println(cmd);
+		WSCommandHandler.HandleCommand(cmd, Minecraft.getMinecraft().thePlayer);
 	}
 
 	@Override
@@ -62,7 +64,8 @@ public class WSClient extends WebSocketClient{
 	}
 	
 	public void SendCommand(Command command) {
-		
+		String json = gson.toJson(command);
+		this.send(json);
 	}
 	
 }
diff --git a/src/main/java/de/torui/coflsky/websocket/WSClientWrapper.java b/src/main/java/de/torui/coflsky/websocket/WSClientWrapper.java
new file mode 100644
index 0000000..ef2ee8b
--- /dev/null
+++ b/src/main/java/de/torui/coflsky/websocket/WSClientWrapper.java
@@ -0,0 +1,53 @@
+package de.torui.coflsky.websocket;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.UUID;
+
+import de.torui.coflsky.CoflSky;
+import de.torui.coflsky.core.Command;
+
+
+public class WSClientWrapper {
+    public WSClient socket;
+    public Thread thread;
+    public boolean isRunning;
+    public String uri = "";
+    
+    public WSClientWrapper(String uri) {
+    	this.uri = uri;
+    }
+    
+    public synchronized void start() {
+    	if(!isRunning) {
+    		 String uuid = CoflSky.PlayerUUID;
+    		try {
+				socket = new WSClient(new URI(uri + uuid));
+			} catch (URISyntaxException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+    		thread = new Thread(socket);
+    		thread.start();
+    		isRunning=true;
+    	}
+    }
+    
+    public synchronized void stop() {
+    	if(isRunning) {
+    		try {
+				socket.closeBlocking();
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+    		isRunning = false;
+    		socket = null;
+    		socket = null;
+    	}
+    }
+    
+    public synchronized void SendMessage(Command cmd){
+    	this.socket.SendCommand(cmd);
+    }
+}