AbortException.cs

Go to the documentation of this file.

using Fauna.Core;
using Fauna.Mapping;
using Fauna.Serialization;
 
namespace Fauna.Exceptions;
 
public class AbortException : ServiceException
{
    private readonly MappingContext _ctx;
    private readonly Dictionary<Type, object?> _cache = new();
    private readonly object? _abortRaw;
 
 
    public AbortException(string message, QueryFailure failure, MappingContext ctx)
        : base(message, failure)
    {
        _ctx = ctx;
        _abortRaw = failure.Abort;
    }
 
    public object? GetData() => GetData(Serializer.Dynamic);
 
    public T? GetData<T>() where T : notnull => GetData(Serializer.Generate<T>(_ctx));
 
    public T? GetData<T>(ISerializer<T> serializer)
    {
        var typeKey = typeof(T);
        if (_cache.TryGetValue(typeKey, out var cachedData)) return (T?)cachedData;
 
        if (_abortRaw == null) return (T?)cachedData;
 
        var abortDataString = _abortRaw.ToString();
        if (string.IsNullOrEmpty(abortDataString)) return (T?)cachedData;
 
        // TODO(matt) pull from context
        var reader = new Utf8FaunaReader(abortDataString);
        reader.Read();
 
        var deserializedResult = serializer.Deserialize(_ctx, ref reader);
        _cache[typeKey] = deserializedResult;
        return deserializedResult;
    }
}