diff --git a/src/client.java b/src/client.java index 12845bc..716286c 100644 --- a/src/client.java +++ b/src/client.java @@ -63,22 +63,26 @@ public class client extends Thread { while (socketInfo.isOnline(socketid)) { msg = readSocket(); parseInput(msg); + eventExecute(); + } + } - int id = socketInfo.findSocket.bySID(socketid); - if(id == -1){return;} - switch (socketInfo.EVENT.get(id)){ - case "play": eventHandler.play(socketid); - break; - case "pause": eventHandler.pause(socketid); - break; - case "next": eventHandler.next(socketid); - break; - case "prev": eventHandler.prev(socketid); - break; - case "wind": eventHandler.wind(socketid); - break; - } + public void eventExecute(){ + int id = socketInfo.findSocket.bySID(socketid); + if(id == -1){return;} + switch (socketInfo.EVENT.get(id)){ + case "play": eventHandler.play(socketid); + break; + case "pause": eventHandler.pause(socketid); + break; + case "next": eventHandler.next(socketid); + break; + case "prev": eventHandler.prev(socketid); + break; + case "wind": eventHandler.wind(socketid); + break; } + } private String bytesToStringUTFCustom(int[] ints) { diff --git a/src/eventHandler.java b/src/eventHandler.java index ed695d3..2dd03a0 100644 --- a/src/eventHandler.java +++ b/src/eventHandler.java @@ -10,7 +10,8 @@ import java.util.ArrayList; */ public class eventHandler { - + //TODO: переписать почти весь код здесь + //Нужно покончить с этим быдланством public static synchronized void connect(Integer sid){ JsonObjectBuilder creator = Json.createObjectBuilder(); creator.add("EVENT","SERVICE"); @@ -40,6 +41,7 @@ public class eventHandler { socketInfo.CLIENT.get(a.get(i)).sendSocket(lc.toString()); } } + socketInfo.CLIENT.get(id).eventExecute(); } }