1 files changed, 40 insertions, 0 deletions
diff --git a/src/api/socket.js b/src/api/socket.js
new file mode 100644
index 00000000..86422808
--- /dev/null
+++ b/src/api/socket.js
@@ -0,0 +1,40 @@
+import io from "socket.io-client";
+import {getAuthToken} from "../auth/index";
+
+let socket;
+let requestIdCounter = 0;
+const callbacks = {};
+
+export function setupSocketConnection(onConnect) {
+    socket = io.connect("http://localhost:8081");
+    socket.on("connect", onConnect);
+    socket.on("response", onSocketResponse);
+}
+
+export function sendSocketRequest(request, callback) {
+    if (!socket.connected) {
+        console.error("Attempted to send request over unconnected socket");
+        return;
+    }
+
+    const newId = requestIdCounter++;
+    callbacks[newId] = callback;
+
+    request.id = newId;
+    request.token = getAuthToken();
+
+    if (!request.isRootRoute) {
+        request.path = "/v1" + request.path;
+    }
+
+    socket.emit("request", request);
+
+    console.log("Sent socket request:", request);
+}
+
+function onSocketResponse(json) {
+    const response = JSON.parse(json);
+    console.log("Received socket response:", response);
+    callbacks[response.id](response);
+    delete callbacks[response.id];
+}