46 lines
1.3 KiB
TypeScript
46 lines
1.3 KiB
TypeScript
// Copyright 2020 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import type {
|
|
CheckNetworkStatusPayloadType,
|
|
NetworkActionType,
|
|
} from '../state/ducks/network';
|
|
import { getSocketStatus } from '../shims/socketStatus';
|
|
import * as log from '../logging/log';
|
|
import { SECOND } from '../util/durations';
|
|
import { SocketStatus } from '../types/SocketStatus';
|
|
|
|
type NetworkActions = {
|
|
checkNetworkStatus: (x: CheckNetworkStatusPayloadType) => NetworkActionType;
|
|
closeConnectingGracePeriod: () => NetworkActionType;
|
|
};
|
|
|
|
export function initializeNetworkObserver(
|
|
networkActions: NetworkActions
|
|
): void {
|
|
log.info('Initializing network observer');
|
|
|
|
const refresh = () => {
|
|
const socketStatus = getSocketStatus();
|
|
|
|
if (socketStatus === SocketStatus.CLOSED) {
|
|
// If we couldn't connect during startup - we should still switch SQL to
|
|
// the main process to avoid stalling UI.
|
|
window.Signal.Data.goBackToMainProcess();
|
|
}
|
|
|
|
networkActions.checkNetworkStatus({
|
|
isOnline: navigator.onLine,
|
|
socketStatus,
|
|
});
|
|
};
|
|
|
|
window.Whisper.events.on('socketStatusChange', refresh);
|
|
|
|
window.addEventListener('online', refresh);
|
|
window.addEventListener('offline', refresh);
|
|
window.setTimeout(() => {
|
|
networkActions.closeConnectingGracePeriod();
|
|
}, 5 * SECOND);
|
|
}
|