ToxicMushroom/mare.client
1
0
Fork 0
mirror of https://github.com/Caraxi/mare.client.git synced 2025-12-13 23:04:16 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

reconnect once properly reconnected

Browse source
This commit is contained in:
Stanley Dimant 2022-09-10 15:45:06 +02:00
parent 4f19589386
commit d63d84c673
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
MareSynchronos/WebAPI/ApiController.Connectivity.cs
View file

@ -205,6 +205,7 @@ namespace MareSynchronos.WebAPI
_mareHub.Closed += MareHubOnClosed; _mareHub.Closed += MareHubOnClosed;
_mareHub.Reconnecting += MareHubOnReconnecting; _mareHub.Reconnecting += MareHubOnReconnecting;
_mareHub.Reconnected += MareHubOnReconnected;
} }
} }
catch (HubException ex) catch (HubException ex)
@ -247,6 +248,12 @@ namespace MareSynchronos.WebAPI
} }
} }
private Task MareHubOnReconnected(string? arg)
{
_ = Task.Run(CreateConnections);
return Task.CompletedTask;
}
private async Task InitializeData(CancellationToken token) private async Task InitializeData(CancellationToken token)
{ {
if (_mareHub == null) return; if (_mareHub == null) return;
@ -331,7 +338,6 @@ namespace MareSynchronos.WebAPI
Logger.Warn(arg?.StackTrace ?? string.Empty); Logger.Warn(arg?.StackTrace ?? string.Empty);
Disconnected?.Invoke(); Disconnected?.Invoke();
ServerState = ServerState.Offline; ServerState = ServerState.Offline;
_ = Task.Run(CreateConnections);
return Task.CompletedTask; return Task.CompletedTask;
} }
@ -343,6 +349,7 @@ namespace MareSynchronos.WebAPI
Logger.Info("Stopping existing connection"); Logger.Info("Stopping existing connection");
_mareHub.Closed -= MareHubOnClosed; _mareHub.Closed -= MareHubOnClosed;
_mareHub.Reconnecting -= MareHubOnReconnecting; _mareHub.Reconnecting -= MareHubOnReconnecting;
_mareHub.Reconnected -= MareHubOnReconnected;
await _mareHub.StopAsync(token); await _mareHub.StopAsync(token);
await _mareHub.DisposeAsync(); await _mareHub.DisposeAsync();
CurrentUploads.Clear(); CurrentUploads.Clear();