RPCS3/archived-discord-bot
1
0
Fork 0
mirror of https://github.com/RPCS3/discord-bot.git synced 2026-01-31 01:25:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

try to limit psn response time to 5 seconds and add more logging

Browse Source
This commit is contained in:
13xforever
2025-04-14 17:39:20 +05:00
parent 317222d596
commit 0b1f2f4809
1 changed files with 33 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
CompatBot/Database/Providers/TitleUpdateInfoProvider.cs
View File

@@ -11,35 +11,49 @@ public static class TitleUpdateInfoProvider
public static async ValueTask<TitlePatch?> GetAsync(string? productId, CancellationToken cancellationToken)
=> await GetCachedAsync(productId, false).ConfigureAwait(false)
?? await GetFromApiAsync(productId, cancellationToken).ConfigureAwait(false);
?? await GetFromApiAsync(productId, cancellationToken).ConfigureAwait(false)
?? await GetCachedAsync(productId, true).ConfigureAwait(false);
private static async ValueTask<TitlePatch?> GetFromApiAsync(string? productId, CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(productId))
return default;
return null;
productId = productId.ToUpper();
var (update, xml) = await Client.GetTitleUpdatesAsync(productId, cancellationToken).ConfigureAwait(false);
if (xml is {Length: > 10})
try
{
var xmlChecksum = xml.GetStableHash();
await using var wdb = await ThumbnailDb.OpenWriteAsync().ConfigureAwait(false);
var updateInfo = wdb.GameUpdateInfo.FirstOrDefault(ui => ui.ProductCode == productId);
if (updateInfo is null)
wdb.GameUpdateInfo.Add(new() {ProductCode = productId, MetaHash = xmlChecksum, MetaXml = xml, Timestamp = DateTime.UtcNow.Ticks});
else if (updateInfo.MetaHash != xmlChecksum && update?.Tag?.Packages is {Length: >0})
using var cts = new CancellationTokenSource(5_000);
using var linkedCts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, cts.Token);
var (update, xml) = await Client.GetTitleUpdatesAsync(productId, linkedCts.Token).ConfigureAwait(false);
if (xml is { Length: > 10 })
{
updateInfo.MetaHash = xmlChecksum;
updateInfo.MetaXml = xml;
updateInfo.Timestamp = DateTime.UtcNow.Ticks;
var xmlChecksum = xml.GetStableHash();
await using var wdb = await ThumbnailDb.OpenWriteAsync().ConfigureAwait(false);
var updateInfo = wdb.GameUpdateInfo.FirstOrDefault(ui => ui.ProductCode == productId);
if (updateInfo is null)
wdb.GameUpdateInfo.Add(new()
{
ProductCode = productId, MetaHash = xmlChecksum, MetaXml = xml,
Timestamp = DateTime.UtcNow.Ticks
});
else if (updateInfo.MetaHash != xmlChecksum && update?.Tag?.Packages is { Length: > 0 })
{
updateInfo.MetaHash = xmlChecksum;
updateInfo.MetaXml = xml;
updateInfo.Timestamp = DateTime.UtcNow.Ticks;
}
else if (updateInfo.MetaHash == xmlChecksum)
updateInfo.Timestamp = DateTime.UtcNow.Ticks;
await wdb.SaveChangesAsync(cancellationToken).ConfigureAwait(false);
}
else if (updateInfo.MetaHash == xmlChecksum)
updateInfo.Timestamp = DateTime.UtcNow.Ticks;
await wdb.SaveChangesAsync(cancellationToken).ConfigureAwait(false);
if (update is { Tag.Packages.Length: > 0 })
return update;
}
if (update is not {Tag.Packages.Length: >0})
return await GetCachedAsync(productId, true).ConfigureAwait(false);
return update;
catch (Exception e)
{
Config.Log.Warn(e, "Failed to get updates information from PSN API");
}
return null;
}
private static async ValueTask<TitlePatch?> GetCachedAsync(string? productId, bool returnStale = false)