summaryrefslogtreecommitdiff
path: root/frontend/src/api/socket.js
diff options
context:
space:
mode:
authorGeorgios Andreadis <info@gandreadis.com>2020-07-01 13:33:31 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2020-08-24 19:47:17 +0200
commitde8f12d74faef5fa3f9e38d1340948cab2d06ea3 (patch)
tree678bf1af3e5fa2334f0df43388d45294785bbf1e /frontend/src/api/socket.js
parent44236756c4cf689806dc17c6950a2cff3e9227bf (diff)
Manually generate IDs
Diffstat (limited to 'frontend/src/api/socket.js')
-rw-r--r--frontend/src/api/socket.js70
1 files changed, 35 insertions, 35 deletions
diff --git a/frontend/src/api/socket.js b/frontend/src/api/socket.js
index fadb77ad..ce5f7587 100644
--- a/frontend/src/api/socket.js
+++ b/frontend/src/api/socket.js
@@ -1,52 +1,52 @@
-import io from "socket.io-client";
-import { getAuthToken } from "../auth/index";
+import io from 'socket.io-client'
+import { getAuthToken } from '../auth/index'
-let socket;
-let requestIdCounter = 0;
-const callbacks = {};
+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 = "/v2" + request.path;
- }
+ if (!request.isRootRoute) {
+ request.path = '/v2' + 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]
}