2019-06-29 23:14:32 +00:00
|
|
|
import React, { useEffect } from 'react';
|
2019-06-29 23:57:11 +00:00
|
|
|
import { Websocket } from '@/plugins/Websocket';
|
2019-07-10 04:25:57 +00:00
|
|
|
import { ServerContext } from '@/state/server';
|
2019-09-25 03:20:29 +00:00
|
|
|
import getWebsocketToken from '@/api/server/getWebsocketToken';
|
2019-06-29 23:14:32 +00:00
|
|
|
|
|
|
|
export default () => {
|
2019-07-10 04:25:57 +00:00
|
|
|
const server = ServerContext.useStoreState(state => state.server.data);
|
2019-09-28 20:09:47 +00:00
|
|
|
const { instance } = ServerContext.useStoreState(state => state.socket);
|
2019-07-10 04:25:57 +00:00
|
|
|
const setServerStatus = ServerContext.useStoreActions(actions => actions.status.setServerStatus);
|
|
|
|
const { setInstance, setConnectionState } = ServerContext.useStoreActions(actions => actions.socket);
|
2019-06-29 23:14:32 +00:00
|
|
|
|
2019-09-28 20:09:47 +00:00
|
|
|
const updateToken = (uuid: string, socket: Websocket) => {
|
|
|
|
getWebsocketToken(uuid)
|
|
|
|
.then(data => socket.setToken(data.token))
|
|
|
|
.catch(error => console.error(error));
|
|
|
|
};
|
|
|
|
|
2019-06-29 23:14:32 +00:00
|
|
|
useEffect(() => {
|
|
|
|
// If there is already an instance or there is no server, just exit out of this process
|
|
|
|
// since we don't need to make a new connection.
|
|
|
|
if (instance || !server) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2019-09-25 03:20:29 +00:00
|
|
|
const socket = new Websocket();
|
2019-06-29 23:57:11 +00:00
|
|
|
|
|
|
|
socket.on('SOCKET_OPEN', () => setConnectionState(true));
|
|
|
|
socket.on('SOCKET_CLOSE', () => setConnectionState(false));
|
|
|
|
socket.on('SOCKET_ERROR', () => setConnectionState(false));
|
|
|
|
socket.on('status', (status) => setServerStatus(status));
|
2019-06-29 23:14:32 +00:00
|
|
|
|
2019-09-28 20:09:47 +00:00
|
|
|
socket.on('daemon error', message => {
|
|
|
|
console.warn('Got error message from daemon socket:', message);
|
|
|
|
});
|
|
|
|
|
|
|
|
socket.on('token expiring', () => updateToken(server.uuid, socket));
|
|
|
|
socket.on('token expired', () => updateToken(server.uuid, socket));
|
|
|
|
|
2019-09-25 03:20:29 +00:00
|
|
|
getWebsocketToken(server.uuid)
|
|
|
|
.then(data => {
|
|
|
|
socket.setToken(data.token).connect(data.socket);
|
|
|
|
setInstance(socket);
|
|
|
|
})
|
2019-09-09 00:48:37 +00:00
|
|
|
.catch(error => console.error(error));
|
|
|
|
|
|
|
|
return () => {
|
|
|
|
socket && socket.close();
|
|
|
|
instance && instance!.removeAllListeners();
|
|
|
|
};
|
2019-06-29 23:57:11 +00:00
|
|
|
}, [ server ]);
|
2019-06-29 23:14:32 +00:00
|
|
|
|
|
|
|
return null;
|
|
|
|
};
|