43 lines
1 KiB
JavaScript
43 lines
1 KiB
JavaScript
import * as ACTIONS from 'constants/action_types';
|
|
import { getAuthToken } from 'util/saved-passwords';
|
|
import { doNotificationList } from 'redux/actions/notifications';
|
|
|
|
let socket = null;
|
|
export const doSocketConnect = () => dispatch => {
|
|
const authToken = getAuthToken();
|
|
if (!authToken) {
|
|
console.error('Unable to connect to web socket because auth token is missing'); // eslint-disable-line
|
|
return;
|
|
}
|
|
|
|
if (socket !== null) {
|
|
socket.close();
|
|
}
|
|
|
|
socket = new WebSocket(`wss://api.lbry.com/subscribe?auth_token=${authToken}`);
|
|
|
|
socket.onmessage = e => {
|
|
const data = JSON.parse(e.data);
|
|
|
|
if (data.type === 'pending_notification') {
|
|
dispatch(doNotificationList());
|
|
}
|
|
};
|
|
|
|
socket.onerror = e => {
|
|
console.error('Error connecting to websocket', e); // eslint-disable-line
|
|
};
|
|
|
|
socket.onclose = e => {
|
|
// Reconnect?
|
|
};
|
|
|
|
socket.onopen = e => {
|
|
console.log('\nConnected to WS \n\n'); // eslint-disable-line
|
|
};
|
|
};
|
|
|
|
export const doSocketDisconnect = () => ({
|
|
type: ACTIONS.WS_DISCONNECT,
|
|
});
|