Did some basic work on voice connections

.gitignore

@@ -1,3 +1,4 @@
 /.idea/
 /Lavalink.iml
 /logs/
+/application.yml

src/main/java/lavalink/server/Config.java

@@ -0,0 +1,19 @@
+package lavalink.server;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@ConfigurationProperties(prefix = "lavalink.server")
+@Component
+public class Config {
+
+    private String userId;
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+}

src/main/java/lavalink/server/Launcher.java

@@ -16,10 +16,12 @@
 @Controller
 public class Launcher {
 
+    public static Config config;
     public final SocketServer socketServer;
 
     @Autowired
-    public Launcher(SocketServer socketServer) {
+    public Launcher(Config config, SocketServer socketServer) {
+        Launcher.config = config;
         this.socketServer = socketServer;
     }
 

src/main/java/lavalink/server/io/CoreClientImpl.java

@@ -0,0 +1,42 @@
+package lavalink.server.io;
+
+import org.java_websocket.WebSocket;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class CoreClientImpl implements net.dv8tion.jda.CoreClient {
+
+    private static final Logger log = LoggerFactory.getLogger(CoreClientImpl.class);
+
+    private final WebSocket socket;
+
+    public CoreClientImpl(WebSocket socket) {
+        this.socket = socket;
+    }
+
+    @Override
+    public void sendWS(String s) {
+        log.info("SEND_WS " + s);
+    }
+
+    @Override
+    public boolean isConnected() {
+        return false;
+    }
+
+    @Override
+    public boolean inGuild(String s) {
+        return true;
+    }
+
+    @Override
+    public boolean voiceChannelExists(String s) {
+        return true;
+    }
+
+    @Override
+    public boolean hasPermissionInChannel(String s, long l) {
+        return true;
+    }
+
+}

src/main/java/lavalink/server/io/SocketContext.java

@@ -0,0 +1,31 @@
+package lavalink.server.io;
+
+import lavalink.server.Launcher;
+import net.dv8tion.jda.Core;
+import org.java_websocket.WebSocket;
+
+public class SocketContext {
+
+    private final WebSocket socket;
+    private final CoreClientImpl coreClient;
+    private final Core core;
+
+    SocketContext(WebSocket socket) {
+        this.socket = socket;
+        this.coreClient = new CoreClientImpl(socket);
+        this.core = new Core(Launcher.config.getUserId(), coreClient);
+    }
+
+    public WebSocket getSocket() {
+        return socket;
+    }
+
+    public CoreClientImpl getCoreClient() {
+        return coreClient;
+    }
+
+    public Core getCore() {
+        return core;
+    }
+
+}

src/main/java/lavalink/server/io/SocketServer.java

@@ -7,11 +7,15 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.HashMap;
+import java.util.Map;
+
 import static lavalink.server.io.WSCodes.*;
 
 public class SocketServer extends WebSocketServer {
 
     private static final Logger log = LoggerFactory.getLogger(SocketServer.class);
+    private static final Map<WebSocket, SocketContext> contextMap = new HashMap<>();
     private final String password;
 
     public SocketServer(String password) {
@@ -22,6 +26,7 @@ public SocketServer(String password) {
     public void onOpen(WebSocket webSocket, ClientHandshake clientHandshake) {
         if (clientHandshake.getFieldValue("Authorization").equals(password)) {
             log.info("Connection opened from " + webSocket.getRemoteSocketAddress() + " with protocol " + webSocket.getDraft());
+            contextMap.put(webSocket, new SocketContext(webSocket));
         } else {
             log.error("Authentication failed from " + webSocket.getRemoteSocketAddress() + " with protocol " + webSocket.getDraft());
             webSocket.close(AUTHORIZATION_REJECTED, "Authorization rejected");
@@ -31,6 +36,7 @@ public void onOpen(WebSocket webSocket, ClientHandshake clientHandshake) {
     @Override
     public void onClose(WebSocket webSocket, int i, String s, boolean b) {
         log.info("Connection closed from " + webSocket.getRemoteSocketAddress().toString() + " with protocol " + webSocket.getDraft());
+        contextMap.remove(webSocket);
     }
 
     @Override
@@ -42,9 +48,21 @@ public void onMessage(WebSocket webSocket, String s) {
         }
 
         switch (json.getString("op")) {
-            case "create":
+            case "connect":
+                contextMap.get(webSocket).getCore().getConnectionManager().queueAudioConnect(
+                        json.getString("guildId"),
+                        json.getString("channelId")
+                );
+                break;
+            case "voiceUpdate":
+                contextMap.get(webSocket).getCore().provideVoiceServerUpdate(
+                        json.getString("sessionId"),
+                        json.getJSONObject("event")
+                );
                 break;
-            case "destroy":
+            case "disconnect":
+                contextMap.get(webSocket).getCore().getAudioManager(json.getString("guildId"))
+                        .closeAudioConnection();
                 break;
         }
     }