summaryrefslogtreecommitdiff
path: root/src/api/socket.js
diff options
context:
space:
mode:
Diffstat (limited to 'src/api/socket.js')
-rw-r--r--src/api/socket.js60
1 files changed, 31 insertions, 29 deletions
diff --git a/src/api/socket.js b/src/api/socket.js
index 283e02e7..cba60288 100644
--- a/src/api/socket.js
+++ b/src/api/socket.js
@@ -1,50 +1,52 @@
import io from "socket.io-client";
-import {getAuthToken} from "../auth/index";
+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);
+ 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;
- }
+ if (!socket.connected) {
+ console.error("Attempted to send request over unconnected socket");
+ return;
+ }
- const newId = requestIdCounter++;
- callbacks[newId] = callback;
+ const newId = requestIdCounter++;
+ callbacks[newId] = callback;
- request.id = newId;
- request.token = getAuthToken();
+ request.id = newId;
+ request.token = getAuthToken();
- if (!request.isRootRoute) {
- request.path = "/v1" + request.path;
- }
+ if (!request.isRootRoute) {
+ request.path = "/v1" + request.path;
+ }
- socket.emit("request", request);
+ socket.emit("request", request);
- if (process.env.NODE_ENV !== 'production') {
- console.log("Sent socket request:", request);
- }
+ if (process.env.NODE_ENV !== "production") {
+ console.log("Sent socket request:", request);
+ }
}
function onSocketResponse(json) {
- const response = JSON.parse(json);
+ const response = JSON.parse(json);
- if (process.env.NODE_ENV !== 'production') {
- console.log("Received socket response:", response);
- }
+ if (process.env.NODE_ENV !== "production") {
+ console.log("Received socket response:", response);
+ }
- callbacks[response.id](response);
- delete callbacks[response.id];
+ callbacks[response.id](response);
+ delete callbacks[response.id];
}