2017-02-03 23:34:31 +00:00
|
|
|
import WebSocketClient from 'websocket.js';
|
|
|
|
|
2018-05-18 01:32:35 +01:00
|
|
|
const randomIntUpTo = max => Math.floor(Math.random() * Math.floor(max));
|
|
|
|
|
2019-03-07 21:17:52 +00:00
|
|
|
export function connectStream(path, pollingRefresh = null, callbacks = () => ({ onConnect() {}, onDisconnect() {}, onReceive() {} })) {
|
2017-11-15 15:04:15 +00:00
|
|
|
return (dispatch, getState) => {
|
|
|
|
const streamingAPIBaseURL = getState().getIn(['meta', 'streaming_api_base_url']);
|
|
|
|
const accessToken = getState().getIn(['meta', 'access_token']);
|
2019-03-07 21:17:52 +00:00
|
|
|
const { onConnect, onDisconnect, onReceive } = callbacks(dispatch, getState);
|
2018-05-18 01:32:35 +01:00
|
|
|
|
2017-11-15 15:04:15 +00:00
|
|
|
let polling = null;
|
|
|
|
|
|
|
|
const setupPolling = () => {
|
2018-05-18 01:32:35 +01:00
|
|
|
pollingRefresh(dispatch, () => {
|
|
|
|
polling = setTimeout(() => setupPolling(), 20000 + randomIntUpTo(20000));
|
|
|
|
});
|
2017-11-15 15:04:15 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
const clearPolling = () => {
|
|
|
|
if (polling) {
|
2018-05-18 01:32:35 +01:00
|
|
|
clearTimeout(polling);
|
2017-11-15 15:04:15 +00:00
|
|
|
polling = null;
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
const subscription = getStream(streamingAPIBaseURL, accessToken, path, {
|
|
|
|
connected () {
|
|
|
|
if (pollingRefresh) {
|
|
|
|
clearPolling();
|
|
|
|
}
|
2019-03-07 21:17:52 +00:00
|
|
|
|
|
|
|
onConnect();
|
2017-11-15 15:04:15 +00:00
|
|
|
},
|
|
|
|
|
|
|
|
disconnected () {
|
|
|
|
if (pollingRefresh) {
|
2018-05-18 01:32:35 +01:00
|
|
|
polling = setTimeout(() => setupPolling(), randomIntUpTo(40000));
|
2017-11-15 15:04:15 +00:00
|
|
|
}
|
2018-05-18 01:32:35 +01:00
|
|
|
|
2017-11-15 15:04:15 +00:00
|
|
|
onDisconnect();
|
|
|
|
},
|
|
|
|
|
|
|
|
received (data) {
|
|
|
|
onReceive(data);
|
|
|
|
},
|
|
|
|
|
|
|
|
reconnected () {
|
|
|
|
if (pollingRefresh) {
|
|
|
|
clearPolling();
|
|
|
|
pollingRefresh(dispatch);
|
|
|
|
}
|
2019-03-07 21:17:52 +00:00
|
|
|
|
|
|
|
onConnect();
|
2017-11-15 15:04:15 +00:00
|
|
|
},
|
|
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
const disconnect = () => {
|
|
|
|
if (subscription) {
|
|
|
|
subscription.close();
|
|
|
|
}
|
2018-05-18 01:32:35 +01:00
|
|
|
|
2017-11-15 15:04:15 +00:00
|
|
|
clearPolling();
|
|
|
|
};
|
|
|
|
|
|
|
|
return disconnect;
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2017-04-15 01:32:42 +01:00
|
|
|
export default function getStream(streamingAPIBaseURL, accessToken, stream, { connected, received, disconnected, reconnected }) {
|
2017-12-13 01:12:41 +00:00
|
|
|
const params = [ `stream=${stream}` ];
|
|
|
|
|
2019-05-24 14:21:42 +01:00
|
|
|
const ws = new WebSocketClient(`${streamingAPIBaseURL}/api/v1/streaming/?${params.join('&')}`, accessToken);
|
2017-02-03 23:34:31 +00:00
|
|
|
|
2017-02-07 13:37:12 +00:00
|
|
|
ws.onopen = connected;
|
|
|
|
ws.onmessage = e => received(JSON.parse(e.data));
|
|
|
|
ws.onclose = disconnected;
|
|
|
|
ws.onreconnect = reconnected;
|
2017-02-03 23:34:31 +00:00
|
|
|
|
|
|
|
return ws;
|
|
|
|
};
|