|
|
|
using System.Diagnostics.CodeAnalysis;
|
|
|
|
using System.Text;
|
|
|
|
using System.Text.Json;
|
|
|
|
using Recyclarr.Json;
|
|
|
|
|
|
|
|
namespace Recyclarr.Cli.Processors.ErrorHandling;
|
|
|
|
|
|
|
|
public sealed class ErrorResponseParser
|
|
|
|
{
|
|
|
|
private readonly ILogger _log;
|
|
|
|
private readonly Func<Stream> _streamFactory;
|
|
|
|
private readonly JsonSerializerOptions _jsonSettings;
|
|
|
|
|
|
|
|
public ErrorResponseParser(ILogger log, string responseBody)
|
|
|
|
{
|
|
|
|
_log = log;
|
|
|
|
_streamFactory = () => new MemoryStream(Encoding.UTF8.GetBytes(responseBody));
|
|
|
|
_jsonSettings = GlobalJsonSerializerSettings.Services;
|
|
|
|
}
|
|
|
|
|
|
|
|
[SuppressMessage("Design", "CA1031:Do not catch general exception types")]
|
|
|
|
public bool DeserializeList(Func<IEnumerable<JsonElement>, IEnumerable<string>> expr)
|
|
|
|
{
|
|
|
|
try
|
|
|
|
{
|
|
|
|
using var stream = _streamFactory();
|
|
|
|
var value = JsonSerializer.Deserialize<List<JsonElement>>(stream, _jsonSettings);
|
|
|
|
if (value is null)
|
|
|
|
{
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
var parsed = expr(value);
|
|
|
|
foreach (var s in parsed)
|
|
|
|
{
|
|
|
|
_log.Error("Error message from remote service: {Message:l}", s);
|
|
|
|
}
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
catch
|
|
|
|
{
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
[SuppressMessage("Design", "CA1031:Do not catch general exception types")]
|
|
|
|
public bool Deserialize(Func<JsonElement, string?> expr)
|
|
|
|
{
|
|
|
|
try
|
|
|
|
{
|
|
|
|
using var stream = _streamFactory();
|
|
|
|
var value = expr(JsonSerializer.Deserialize<JsonElement>(stream, _jsonSettings));
|
|
|
|
if (value is null)
|
|
|
|
{
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
_log.Error("Error message from remote service: {Message:l}", value);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
catch
|
|
|
|
{
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|