Spotify.NET/SpotifyAPI.Web/Http/APIConnector.cs
2023-11-03 23:23:54 +01:00

294 lines
10 KiB
C#

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
namespace SpotifyAPI.Web.Http
{
public class APIConnector : IAPIConnector
{
private readonly Uri _baseAddress;
private readonly IAuthenticator? _authenticator;
private readonly IJSONSerializer _jsonSerializer;
private readonly IHTTPClient _httpClient;
private readonly IRetryHandler? _retryHandler;
private readonly IHTTPLogger? _httpLogger;
public event EventHandler<IResponse>? ResponseReceived;
public APIConnector(Uri baseAddress, IAuthenticator authenticator) :
this(baseAddress, authenticator, new NewtonsoftJSONSerializer(), new NetHttpClient(), null, null)
{ }
public APIConnector(
Uri baseAddress,
IAuthenticator? authenticator,
IJSONSerializer jsonSerializer,
IHTTPClient httpClient,
IRetryHandler? retryHandler,
IHTTPLogger? httpLogger)
{
_baseAddress = baseAddress;
_authenticator = authenticator;
_jsonSerializer = jsonSerializer;
_httpClient = httpClient;
_retryHandler = retryHandler;
_httpLogger = httpLogger;
}
public Task<T> Delete<T>(Uri uri, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Delete, cancel: cancel);
}
public Task<T> Delete<T>(Uri uri, IDictionary<string, string>? parameters, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Delete, parameters, cancel: cancel);
}
public Task<T> Delete<T>(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Delete, parameters, body, cancel: cancel);
}
public async Task<HttpStatusCode> Delete(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
var response = await SendAPIRequestDetailed(uri, HttpMethod.Delete, parameters, body, cancel: cancel).ConfigureAwait(false);
return response.StatusCode;
}
public Task<T> Get<T>(Uri uri, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Get, cancel: cancel);
}
public Task<T> Get<T>(Uri uri, IDictionary<string, string>? parameters, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Get, parameters, cancel: cancel);
}
public async Task<HttpStatusCode> Get(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
var response = await SendAPIRequestDetailed(uri, HttpMethod.Get, parameters, body, cancel: cancel).ConfigureAwait(false);
return response.StatusCode;
}
public Task<T> Post<T>(Uri uri, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Post, cancel: cancel);
}
public Task<T> Post<T>(Uri uri, IDictionary<string, string>? parameters, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Post, parameters, cancel: cancel);
}
public Task<T> Post<T>(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Post, parameters, body, cancel: cancel);
}
public Task<T> Post<T>(Uri uri, IDictionary<string, string>? parameters, object? body, Dictionary<string, string>? headers, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Post, parameters, body, headers, cancel: cancel);
}
public async Task<HttpStatusCode> Post(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
var response = await SendAPIRequestDetailed(uri, HttpMethod.Post, parameters, body, cancel: cancel).ConfigureAwait(false);
return response.StatusCode;
}
public Task<T> Put<T>(Uri uri, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Put, cancel: cancel);
}
public Task<T> Put<T>(Uri uri, IDictionary<string, string>? parameters, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Put, parameters, cancel: cancel);
}
public Task<T> Put<T>(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
return SendAPIRequest<T>(uri, HttpMethod.Put, parameters, body, cancel: cancel);
}
public async Task<HttpStatusCode> Put(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
var response = await SendAPIRequestDetailed(uri, HttpMethod.Put, parameters, body, cancel: cancel).ConfigureAwait(false);
return response.StatusCode;
}
public async Task<HttpStatusCode> PutRaw(Uri uri, IDictionary<string, string>? parameters, object? body, CancellationToken cancel)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
var response = await SendRawRequest(uri, HttpMethod.Put, parameters, body, cancel: cancel).ConfigureAwait(false);
return response.StatusCode;
}
public void SetRequestTimeout(TimeSpan timeout)
{
_httpClient.SetRequestTimeout(timeout);
}
private IRequest CreateRequest(
Uri uri,
HttpMethod method,
IDictionary<string, string>? parameters,
object? body,
IDictionary<string, string>? headers
)
{
Ensure.ArgumentNotNull(uri, nameof(uri));
Ensure.ArgumentNotNull(method, nameof(method));
return new Request(
_baseAddress,
uri,
method,
headers ?? new Dictionary<string, string>(),
parameters ?? new Dictionary<string, string>())
{
Body = body
};
}
private async Task<IAPIResponse<T>> DoSerializedRequest<T>(IRequest request, CancellationToken cancel)
{
_jsonSerializer.SerializeRequest(request);
var response = await DoRequest(request, cancel).ConfigureAwait(false);
return _jsonSerializer.DeserializeResponse<T>(response);
}
private async Task<IResponse> DoRequest(IRequest request, CancellationToken cancel)
{
await ApplyAuthenticator(request).ConfigureAwait(false);
_httpLogger?.OnRequest(request);
IResponse response = await _httpClient.DoRequest(request, cancel).ConfigureAwait(false);
_httpLogger?.OnResponse(response);
ResponseReceived?.Invoke(this, response);
if (_retryHandler != null)
{
response = await _retryHandler.HandleRetry(request, response, async (newRequest, ct) =>
{
await ApplyAuthenticator(request).ConfigureAwait(false);
var newResponse = await _httpClient.DoRequest(request, ct).ConfigureAwait(false);
_httpLogger?.OnResponse(newResponse);
ResponseReceived?.Invoke(this, response);
return newResponse;
}, cancel).ConfigureAwait(false);
}
ProcessErrors(response);
return response;
}
private async Task ApplyAuthenticator(IRequest request)
{
if (_authenticator != null
&& !request.Endpoint.IsAbsoluteUri
#if NETSTANDARD2_1_OR_GREATER || NET5_0_OR_GREATER
|| request.Endpoint.AbsoluteUri.Contains("https://api.spotify.com", StringComparison.InvariantCulture))
#else
|| request.Endpoint.AbsoluteUri.Contains("https://api.spotify.com"))
#endif
{
await _authenticator!.Apply(request, this).ConfigureAwait(false);
}
}
public Task<IResponse> SendRawRequest(
Uri uri,
HttpMethod method,
IDictionary<string, string>? parameters = null,
object? body = null,
IDictionary<string, string>? headers = null,
CancellationToken cancel = default
)
{
var request = CreateRequest(uri, method, parameters, body, headers);
return DoRequest(request, cancel);
}
public async Task<T> SendAPIRequest<T>(
Uri uri,
HttpMethod method,
IDictionary<string, string>? parameters = null,
object? body = null,
IDictionary<string, string>? headers = null,
CancellationToken cancel = default
)
{
var request = CreateRequest(uri, method, parameters, body, headers);
IAPIResponse<T> apiResponse = await DoSerializedRequest<T>(request, cancel).ConfigureAwait(false);
return apiResponse.Body!;
}
public async Task<IResponse> SendAPIRequestDetailed(
Uri uri,
HttpMethod method,
IDictionary<string, string>? parameters = null,
object? body = null,
IDictionary<string, string>? headers = null,
CancellationToken cancel = default
)
{
var request = CreateRequest(uri, method, parameters, body, headers);
var response = await DoSerializedRequest<object>(request, cancel).ConfigureAwait(false);
return response.Response;
}
private static void ProcessErrors(IResponse response)
{
Ensure.ArgumentNotNull(response, nameof(response));
if ((int)response.StatusCode >= 200 && (int)response.StatusCode < 400)
{
return;
}
throw response.StatusCode switch
{
HttpStatusCode.Unauthorized => new APIUnauthorizedException(response),
// TODO: Remove hack once .netstandard 2.0 is not supported
(HttpStatusCode)429 => new APITooManyRequestsException(response),
_ => new APIException(response),
};
}
}
}