diff options
| author | Georgios Andreadis <info@gandreadis.com> | 2020-06-29 15:47:09 +0200 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2020-08-24 16:08:41 +0200 |
| commit | 90fae26aa4bd0e0eb3272ff6e6524060e9004fbb (patch) | |
| tree | bf6943882f5fa5f3114c01fc571503c79ee1056d /src/api/socket.js | |
| parent | 7032a007d4431f5a0c4c5e2d3f3bd20462d49950 (diff) | |
Prepare frontend repository for monorepo
This change prepares the frontend Git repository for the monorepo
residing at https://github.com/atlarge-research.com/opendc. To
accomodate for this, we move all files into a frontend subdirectory.
Diffstat (limited to 'src/api/socket.js')
| -rw-r--r-- | src/api/socket.js | 52 |
1 files changed, 0 insertions, 52 deletions
diff --git a/src/api/socket.js b/src/api/socket.js deleted file mode 100644 index cba60288..00000000 --- a/src/api/socket.js +++ /dev/null @@ -1,52 +0,0 @@ -import io from "socket.io-client"; -import { getAuthToken } from "../auth/index"; - -let socket; -let requestIdCounter = 0; -const callbacks = {}; - -export function setupSocketConnection(onConnect) { - let port = window.location.port; - if (process.env.NODE_ENV !== "production") { - port = 8081; - } - socket = io.connect( - window.location.protocol + "//" + window.location.hostname + ":" + port - ); - 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); - - if (process.env.NODE_ENV !== "production") { - console.log("Sent socket request:", request); - } -} - -function onSocketResponse(json) { - const response = JSON.parse(json); - - if (process.env.NODE_ENV !== "production") { - console.log("Received socket response:", response); - } - - callbacks[response.id](response); - delete callbacks[response.id]; -} |
