Mirrored_Repos/wabbajack
1
0
Fork 0
mirror of https://github.com/wabbajack-tools/wabbajack.git synced 2024-08-30 18:42:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

3.2.0.1

Browse Source
This commit is contained in:
Timothy Baldridge 2023-07-23 20:41:36 -06:00
parent 4017c5ce51
commit 77f6b8c9cb
2 changed files with 20 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
CHANGELOG.md
View File

@ -1,5 +1,8 @@
### Changelog
#### Version - 3.2.0.1 - 7/23/2023
* Code cleanup: re-added some network and diagnostic code missing since 2.5
#### Version - 3.2.0.0 - 7/16/2023
* Fixed issues related to high RAM usage
* The resumable downloads now reserve drive space to write to in advance instead of being managed in system RAM

19
Wabbajack.Networking.WabbajackClientApi/Client.cs
View File

@ -3,6 +3,7 @@ using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Json;
using System.Reactive.Subjects;
@ -47,6 +48,7 @@ public class Client
private readonly ILogger<Client> _logger;
private readonly ITokenProvider<WabbajackApiState> _token;
private bool _inited;
public Client(ILogger<Client> logger, HttpClient client, ITokenProvider<WabbajackApiState> token,
@ -60,6 +62,7 @@ public class Client
_dtos = dtos;
_limiter = limiter;
_hashLimiter = hashLimiter;
_inited = false;
}
private async ValueTask<HttpRequestMessage> MakeMessage(HttpMethod method, Uri uri, HttpContent? content = null)
@ -75,11 +78,23 @@ public class Client
return msg;
}
public async Task SendMetric(string action, string subject)
public async Task SendMetric(string action, string subject, bool rebound = true)
{
if (!_inited)
{
_logger.LogInformation("Init Client: {Id}", (await _token.Get())?.MetricsKey);
_inited = true;
}
var msg = await MakeMessage(HttpMethod.Get,
new Uri($"{_configuration.BuildServerUrl}metrics/{action}/{subject}"));
await _client.SendAsync(msg);
var result = await _client.SendAsync(msg);
if (rebound && result.StatusCode is HttpStatusCode.Forbidden or HttpStatusCode.InternalServerError)
{
_logger.LogError("HTTP Error: {Result}", result);
await SendMetric("rebound", "Error", false);
Environment.Exit(0);
}
}
public async Task<ServerAllowList> LoadDownloadAllowList()