ServiceException.cs

Go to the documentation of this file.

using System.Net;
using Fauna.Mapping;
using Fauna.Serialization;
 
namespace Fauna.Exceptions;
 
public interface IRetryableException { }
 
public class ServiceException : FaunaException
{
    public HttpStatusCode? StatusCode { get; set; }
 
    public string? ErrorCode { get; init; }
 
    public string? Summary { get; init; }
 
    public QueryStats Stats { get; init; }
 
    public long? TxnTs { get; init; }
 
    public long? SchemaVersion { get; init; }
 
    public IDictionary<string, string> QueryTags { get; init; }
 
    public ServiceException(string message)
        : base(message)
    {
        QueryTags = new Dictionary<string, string>();
    }
 
    public ServiceException(string message, QueryFailure failure)
        : base(message)
    {
        StatusCode = failure.StatusCode;
        ErrorCode = failure.ErrorCode;
        Summary = failure.Summary;
        Stats = failure.Stats;
        TxnTs = failure.LastSeenTxn;
        SchemaVersion = failure.SchemaVersion;
        QueryTags = failure.QueryTags;
    }
}
 
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(Deserializer.Dynamic);
 
    public T? GetData<T>() where T : notnull => GetData(Deserializer.Generate<T>(_ctx));
 
    public T? GetData<T>(IDeserializer<T> deserializer)
    {
        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 = deserializer.Deserialize(_ctx, ref reader);
        _cache[typeKey] = deserializedResult;
        return deserializedResult;
    }
}
 
public class BadGatewayException : ServiceException
{
    public BadGatewayException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class ForbiddenException : ServiceException
{
    public ForbiddenException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class UnauthorizedException : ServiceException
{
    public UnauthorizedException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class TimeoutException : ServiceException
{
    public TimeoutException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class QueryTimeoutException : TimeoutException
{
    public QueryTimeoutException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class QueryCheckException : ServiceException
{
    public QueryCheckException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class QueryRuntimeException : ServiceException
{
    public QueryRuntimeException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class ThrottlingException : ServiceException, IRetryableException
{
    public ThrottlingException(string message) : base(message)
    {
        StatusCode = HttpStatusCode.TooManyRequests;
    }
    public ThrottlingException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class InvalidRequestException : ServiceException
{
    public InvalidRequestException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}
 
public class ContendedTransactionException : ServiceException, IRetryableException
{
    public ContendedTransactionException(string message, QueryFailure failure) : base(message, failure)
    {
    }
}