zoriya/flood
1
0
Fork 0
mirror of https://github.com/zoriya/flood.git synced 2025-12-06 07:16:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

server: clientGatewayService: keep refreshing connection status when error occurred

Browse Source
This commit is contained in:
Jesse Chan
2020-11-02 19:53:59 +08:00
parent 5e7e5f4cbf
commit abf9554e31
2 changed files with 44 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/middleware/clientActivityStream.ts
View File

@@ -42,7 +42,7 @@ export default async (req: Request<unknown, unknown, unknown, {historySnapshot:
// Emit current state immediately on connection.
serverEvent.emit(Date.now(), 'CLIENT_CONNECTIVITY_STATUS_CHANGE', {
isConnected: !serviceInstances.clientGatewayService.hasError,
isConnected: serviceInstances.clientGatewayService.errorCount === 0,
});
// Disk usage change event
@@ -66,13 +66,13 @@ export default async (req: Request<unknown, unknown, unknown, {historySnapshot:
serviceInstances.notificationService.getNotificationCount(),
);
handleEvents(serviceInstances.clientGatewayService, 'CLIENT_CONNECTION_STATE_CHANGE', () => {
handleEvents(serviceInstances.clientGatewayService, 'CLIENT_CONNECTION_STATE_CHANGE', (isConnected: boolean) => {
serverEvent.emit(Date.now(), 'CLIENT_CONNECTIVITY_STATUS_CHANGE', {
isConnected: !serviceInstances.clientGatewayService?.hasError,
isConnected,
});
});
if (serviceInstances.clientGatewayService.hasError) {
if (serviceInstances.clientGatewayService.errorCount !== 0) {
serviceInstances.clientGatewayService.testGateway().catch(console.error);
}