Webiant Logo Webiant Logo
  1. No results found.

    Try your search with a different keyword or use * as a wildcard.

CloudflareImagesHttpClient.cs

using System.Net;
using Microsoft.Net.Http.Headers;
using Newtonsoft.Json;
using Nop.Core;

namespace Nop.Plugin.Misc.CloudflareImages.Services;

/// <summary>
/// Represents the HTTP client to request Cloudflare Images
/// </summary>
public class CloudflareImagesHttpClient
{
    #region Fields

    private readonly CloudflareImagesSettings _cloudflareImagesSettings;
    private readonly HttpClient _httpClient;

    #endregion

    #region Ctor

    public CloudflareImagesHttpClient(CloudflareImagesSettings cloudflareImagesSettings, HttpClient httpClient)
    {
        _cloudflareImagesSettings = cloudflareImagesSettings;
        httpClient.Timeout = TimeSpan.FromSeconds(_cloudflareImagesSettings.RequestTimeout ?? CloudflareImagesDefaults.RequestTimeout);
        _httpClient = httpClient;
    }

    #endregion

    #region Utilities

    /// <summary>
    /// HTTP request services
    /// </summary>
    /// <param name="apiUri">Request URL</param>
    /// <param name="data">Data to send</param>
    /// <param name="httpMethod">Request type. null == HttpMethod.Get</param>
    /// <returns>The asynchronous task whose result contains response details</returns>
    private async Task<string> RequestAsync(string apiUri = "", HttpContent data = null, HttpMethod httpMethod = null)
    {
        httpMethod ??= HttpMethod.Get;

        var requestUri = new Uri(string.Format(CloudflareImagesDefaults.BaseApiUrl, _cloudflareImagesSettings.AccountId, apiUri));

        var request = new HttpRequestMessage
        {
            Method = httpMethod,
            RequestUri = requestUri
        };

        request.Headers.TryAddWithoutValidation(HeaderNames.Authorization, $"Bearer {_cloudflareImagesSettings.AccessToken}");

        if (httpMethod == HttpMethod.Post)
            request.Content = data;

        var httpResponse = await _httpClient.SendAsync(request);
        var response = await httpResponse.Content.ReadAsStringAsync();

        if (httpResponse.StatusCode == HttpStatusCode.OK)
            return response;

        if (!string.IsNullOrEmpty(response))
            throw new NopException(response);

        throw new NopException($"{CloudflareImagesDefaults.SystemName} unknown error.");
    }

    #endregion

    #region Methods

    /// <summary>
    /// Save a picture thumb
    /// </summary>
    /// <param name="dataContent">Content</param>
    /// <returns>
    /// A task that represents the asynchronous operation
    /// The task result contains the response details
    /// </returns>
    public async Task<CloudflareImagesResponse> SaveThumbAsync(MultipartFormDataContent dataContent)
    {
        try
        {
            var result = await RequestAsync(string.Empty, dataContent, HttpMethod.Post);
            return JsonConvert.DeserializeObject<CloudflareImagesResponse>(result);
        }
        catch
        {
            return null;
        }
    }

    /// <summary>
    /// Delete picture thumb
    /// </summary>
    /// <param name="imageId">Image identifier</param>
    /// <returns>A task that represents the asynchronous operation</returns>
    public async Task DeleteThumbAsync(string imageId)
    {
        try
        {
            await RequestAsync($"/{imageId}", null, HttpMethod.Delete);
        }
        catch
        {
            // ignored
        }
    }

    #endregion

    #region Nested classes

    public class CloudflareImagesResponse
    {
        [JsonProperty("errors")]
        public List<ResponseInfo> Errors { get; set; } = new();

        [JsonProperty("messages")]
        public List<ResponseInfo> Messages { get; set; } = new();

        [JsonProperty("result")]
        public Image Result { get; set; }

        /// <summary>
        /// Gets or sets whether the API call was successful
        /// </summary>
        [JsonProperty("success")]
        public bool Success { get; set; }
    }

    public class ResponseInfo
    {
        [JsonProperty("code")]
        public int Code { get; set; }

        [JsonProperty("message")]
        public string Message { get; set; }

        [JsonProperty("documentation_url")]
        public string DocumentationUrl { get; set; }
    }

    public class Image
    {
        /// <summary>
        /// Image unique identifier
        /// </summary>
        [JsonProperty("id")]
        public string Id { get; set; }

        /// <summary>
        /// Image file name
        /// </summary>
        [JsonProperty("filename")]
        public string FileName { get; set; }
    }

    #endregion
}