diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-04-25 21:53:42 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-04-25 21:53:42 +0200 |
| commit | 128f76f7fd7c8abb41a3bbbd9f1980cbc20ae7a5 (patch) | |
| tree | add513890005233a7784466797bfe6f5052e9eeb /opendc-web/opendc-web-ui/src/api/socket.js | |
| parent | 128a1db017545597a5c035b7960eb3fd36b5f987 (diff) | |
| parent | 57b54b59ed74ec37338ae26b3864d051255aba49 (diff) | |
build: Flatten project structure
This change updates the project structure to become flattened.
Previously, the simulator, frontend and API each lived into their own directory.
With this change, all modules of the project live in the top-level directory of
the repository.
Diffstat (limited to 'opendc-web/opendc-web-ui/src/api/socket.js')
| -rw-r--r-- | opendc-web/opendc-web-ui/src/api/socket.js | 50 |
1 files changed, 50 insertions, 0 deletions
diff --git a/opendc-web/opendc-web-ui/src/api/socket.js b/opendc-web/opendc-web-ui/src/api/socket.js new file mode 100644 index 00000000..1c432167 --- /dev/null +++ b/opendc-web/opendc-web-ui/src/api/socket.js @@ -0,0 +1,50 @@ +import io from 'socket.io-client' +import { getAuthToken } from '../auth/index' + +let socket +let requestIdCounter = 0 +const callbacks = {} + +export function setupSocketConnection(onConnect) { + const apiUrl = + process.env.REACT_APP_API_BASE_URL || + `${window.location.protocol}//${window.location.hostname}:${window.location.port}` + + socket = io.connect(apiUrl) + 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 = '/v2' + 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] +} |
