diff options
| author | Georgios Andreadis <G.Andreadis@student.tudelft.nl> | 2017-10-04 23:23:09 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-10-04 23:23:09 +0200 |
| commit | fcaaae65d34003874c76e0c01134dedf94248e09 (patch) | |
| tree | 2aae1422168651e832a1904623f6f5b100fc17ec /src/api/socket.js | |
| parent | 0a62dfb55c5700013d42a589b930c7448e5bff71 (diff) | |
| parent | 606d1de0be09f3597165248f65d54e158a13860c (diff) | |
Merge pull request #42 from atlarge-research/auto-reformat
Standardize code format
Diffstat (limited to 'src/api/socket.js')
| -rw-r--r-- | src/api/socket.js | 60 |
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]; } |
