Merge pull request #2946 from crobibero/api-image2
Move RemoteImageService to Jellyfin.APIpull/3369/head
David
4 years ago
committed by
GitHub
commit
226a9d5d2e
@ -0,0 +1,267 @@
|
|||||||
|
#nullable enable
|
||||||
|
|
||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.IO;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Net.Mime;
|
||||||
|
using System.Threading;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
using MediaBrowser.Common.Extensions;
|
||||||
|
using MediaBrowser.Common.Net;
|
||||||
|
using MediaBrowser.Controller;
|
||||||
|
using MediaBrowser.Controller.Library;
|
||||||
|
using MediaBrowser.Controller.Providers;
|
||||||
|
using MediaBrowser.Model.Entities;
|
||||||
|
using MediaBrowser.Model.IO;
|
||||||
|
using MediaBrowser.Model.Net;
|
||||||
|
using MediaBrowser.Model.Providers;
|
||||||
|
using Microsoft.AspNetCore.Authorization;
|
||||||
|
using Microsoft.AspNetCore.Http;
|
||||||
|
using Microsoft.AspNetCore.Mvc;
|
||||||
|
using Microsoft.AspNetCore.Mvc.ModelBinding;
|
||||||
|
|
||||||
|
namespace Jellyfin.Api.Controllers.Images
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Remote Images Controller.
|
||||||
|
/// </summary>
|
||||||
|
[Route("Images")]
|
||||||
|
[Authorize]
|
||||||
|
public class RemoteImageController : BaseJellyfinApiController
|
||||||
|
{
|
||||||
|
private readonly IProviderManager _providerManager;
|
||||||
|
private readonly IServerApplicationPaths _applicationPaths;
|
||||||
|
private readonly IHttpClient _httpClient;
|
||||||
|
private readonly ILibraryManager _libraryManager;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Initializes a new instance of the <see cref="RemoteImageController"/> class.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="providerManager">Instance of the <see cref="IProviderManager"/> interface.</param>
|
||||||
|
/// <param name="applicationPaths">Instance of the <see cref="IServerApplicationPaths"/> interface.</param>
|
||||||
|
/// <param name="httpClient">Instance of the <see cref="IHttpClient"/> interface.</param>
|
||||||
|
/// <param name="libraryManager">Instance of the <see cref="ILibraryManager"/> interface.</param>
|
||||||
|
public RemoteImageController(
|
||||||
|
IProviderManager providerManager,
|
||||||
|
IServerApplicationPaths applicationPaths,
|
||||||
|
IHttpClient httpClient,
|
||||||
|
ILibraryManager libraryManager)
|
||||||
|
{
|
||||||
|
_providerManager = providerManager;
|
||||||
|
_applicationPaths = applicationPaths;
|
||||||
|
_httpClient = httpClient;
|
||||||
|
_libraryManager = libraryManager;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Gets available remote images for an item.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="id">Item Id.</param>
|
||||||
|
/// <param name="type">The image type.</param>
|
||||||
|
/// <param name="startIndex">Optional. The record index to start at. All items with a lower index will be dropped from the results.</param>
|
||||||
|
/// <param name="limit">Optional. The maximum number of records to return.</param>
|
||||||
|
/// <param name="providerName">Optional. The image provider to use.</param>
|
||||||
|
/// <param name="includeAllLanguages">Optional. Include all languages.</param>
|
||||||
|
/// <response code="200">Remote Images returned.</response>
|
||||||
|
/// <response code="404">Item not found.</response>
|
||||||
|
/// <returns>Remote Image Result.</returns>
|
||||||
|
[HttpGet("{Id}/RemoteImages")]
|
||||||
|
[ProducesResponseType(StatusCodes.Status200OK)]
|
||||||
|
[ProducesResponseType(StatusCodes.Status404NotFound)]
|
||||||
|
public async Task<ActionResult<RemoteImageResult>> GetRemoteImages(
|
||||||
|
[FromRoute] string id,
|
||||||
|
[FromQuery] ImageType? type,
|
||||||
|
[FromQuery] int? startIndex,
|
||||||
|
[FromQuery] int? limit,
|
||||||
|
[FromQuery] string providerName,
|
||||||
|
[FromQuery] bool includeAllLanguages)
|
||||||
|
{
|
||||||
|
var item = _libraryManager.GetItemById(id);
|
||||||
|
if (item == null)
|
||||||
|
{
|
||||||
|
return NotFound();
|
||||||
|
}
|
||||||
|
|
||||||
|
var images = await _providerManager.GetAvailableRemoteImages(
|
||||||
|
item,
|
||||||
|
new RemoteImageQuery(providerName)
|
||||||
|
{
|
||||||
|
IncludeAllLanguages = includeAllLanguages,
|
||||||
|
IncludeDisabledProviders = true,
|
||||||
|
ImageType = type
|
||||||
|
}, CancellationToken.None)
|
||||||
|
.ConfigureAwait(false);
|
||||||
|
|
||||||
|
var imageArray = images.ToArray();
|
||||||
|
var allProviders = _providerManager.GetRemoteImageProviderInfo(item);
|
||||||
|
if (type.HasValue)
|
||||||
|
{
|
||||||
|
allProviders = allProviders.Where(o => o.SupportedImages.Contains(type.Value));
|
||||||
|
}
|
||||||
|
|
||||||
|
var result = new RemoteImageResult
|
||||||
|
{
|
||||||
|
TotalRecordCount = imageArray.Length,
|
||||||
|
Providers = allProviders.Select(o => o.Name)
|
||||||
|
.Distinct(StringComparer.OrdinalIgnoreCase)
|
||||||
|
.ToArray()
|
||||||
|
};
|
||||||
|
|
||||||
|
if (startIndex.HasValue)
|
||||||
|
{
|
||||||
|
imageArray = imageArray.Skip(startIndex.Value).ToArray();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (limit.HasValue)
|
||||||
|
{
|
||||||
|
imageArray = imageArray.Take(limit.Value).ToArray();
|
||||||
|
}
|
||||||
|
|
||||||
|
result.Images = imageArray;
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Gets available remote image providers for an item.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="id">Item Id.</param>
|
||||||
|
/// <response code="200">Returned remote image providers.</response>
|
||||||
|
/// <response code="404">Item not found.</response>
|
||||||
|
/// <returns>List of remote image providers.</returns>
|
||||||
|
[HttpGet("{Id}/RemoteImages/Providers")]
|
||||||
|
[ProducesResponseType(StatusCodes.Status200OK)]
|
||||||
|
[ProducesResponseType(StatusCodes.Status404NotFound)]
|
||||||
|
public ActionResult<IEnumerable<ImageProviderInfo>> GetRemoteImageProviders([FromRoute] string id)
|
||||||
|
{
|
||||||
|
var item = _libraryManager.GetItemById(id);
|
||||||
|
if (item == null)
|
||||||
|
{
|
||||||
|
return NotFound();
|
||||||
|
}
|
||||||
|
|
||||||
|
return Ok(_providerManager.GetRemoteImageProviderInfo(item));
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Gets a remote image.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="imageUrl">The image url.</param>
|
||||||
|
/// <response code="200">Remote image returned.</response>
|
||||||
|
/// <response code="404">Remote image not found.</response>
|
||||||
|
/// <returns>Image Stream.</returns>
|
||||||
|
[HttpGet("Remote")]
|
||||||
|
[Produces(MediaTypeNames.Application.Octet)]
|
||||||
|
[ProducesResponseType(StatusCodes.Status200OK)]
|
||||||
|
[ProducesResponseType(StatusCodes.Status404NotFound)]
|
||||||
|
public async Task<ActionResult<FileStreamResult>> GetRemoteImage([FromQuery, BindRequired] string imageUrl)
|
||||||
|
{
|
||||||
|
var urlHash = imageUrl.GetMD5();
|
||||||
|
var pointerCachePath = GetFullCachePath(urlHash.ToString());
|
||||||
|
|
||||||
|
string? contentPath = null;
|
||||||
|
var hasFile = false;
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
contentPath = await System.IO.File.ReadAllTextAsync(pointerCachePath).ConfigureAwait(false);
|
||||||
|
if (System.IO.File.Exists(contentPath))
|
||||||
|
{
|
||||||
|
hasFile = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (FileNotFoundException)
|
||||||
|
{
|
||||||
|
// The file isn't cached yet
|
||||||
|
}
|
||||||
|
catch (IOException)
|
||||||
|
{
|
||||||
|
// The file isn't cached yet
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!hasFile)
|
||||||
|
{
|
||||||
|
await DownloadImage(imageUrl, urlHash, pointerCachePath).ConfigureAwait(false);
|
||||||
|
contentPath = await System.IO.File.ReadAllTextAsync(pointerCachePath).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (string.IsNullOrEmpty(contentPath))
|
||||||
|
{
|
||||||
|
return NotFound();
|
||||||
|
}
|
||||||
|
|
||||||
|
var contentType = MimeTypes.GetMimeType(contentPath);
|
||||||
|
return File(System.IO.File.OpenRead(contentPath), contentType);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Downloads a remote image for an item.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="id">Item Id.</param>
|
||||||
|
/// <param name="type">The image type.</param>
|
||||||
|
/// <param name="imageUrl">The image url.</param>
|
||||||
|
/// <response code="200">Remote image downloaded.</response>
|
||||||
|
/// <response code="404">Remote image not found.</response>
|
||||||
|
/// <returns>Download status.</returns>
|
||||||
|
[HttpPost("{Id}/RemoteImages/Download")]
|
||||||
|
[ProducesResponseType(StatusCodes.Status200OK)]
|
||||||
|
[ProducesResponseType(StatusCodes.Status404NotFound)]
|
||||||
|
public async Task<ActionResult> DownloadRemoteImage(
|
||||||
|
[FromRoute] string id,
|
||||||
|
[FromQuery, BindRequired] ImageType type,
|
||||||
|
[FromQuery] string imageUrl)
|
||||||
|
{
|
||||||
|
var item = _libraryManager.GetItemById(id);
|
||||||
|
if (item == null)
|
||||||
|
{
|
||||||
|
return NotFound();
|
||||||
|
}
|
||||||
|
|
||||||
|
await _providerManager.SaveImage(item, imageUrl, type, null, CancellationToken.None)
|
||||||
|
.ConfigureAwait(false);
|
||||||
|
|
||||||
|
item.UpdateToRepository(ItemUpdateType.ImageUpdate, CancellationToken.None);
|
||||||
|
return Ok();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Gets the full cache path.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="filename">The filename.</param>
|
||||||
|
/// <returns>System.String.</returns>
|
||||||
|
private string GetFullCachePath(string filename)
|
||||||
|
{
|
||||||
|
return Path.Combine(_applicationPaths.CachePath, "remote-images", filename.Substring(0, 1), filename);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Downloads the image.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="url">The URL.</param>
|
||||||
|
/// <param name="urlHash">The URL hash.</param>
|
||||||
|
/// <param name="pointerCachePath">The pointer cache path.</param>
|
||||||
|
/// <returns>Task.</returns>
|
||||||
|
private async Task DownloadImage(string url, Guid urlHash, string pointerCachePath)
|
||||||
|
{
|
||||||
|
using var result = await _httpClient.GetResponse(new HttpRequestOptions
|
||||||
|
{
|
||||||
|
Url = url,
|
||||||
|
BufferContent = false
|
||||||
|
}).ConfigureAwait(false);
|
||||||
|
var ext = result.ContentType.Split('/').Last();
|
||||||
|
|
||||||
|
var fullCachePath = GetFullCachePath(urlHash + "." + ext);
|
||||||
|
|
||||||
|
Directory.CreateDirectory(Path.GetDirectoryName(fullCachePath));
|
||||||
|
await using (var stream = result.Content)
|
||||||
|
{
|
||||||
|
await using var fileStream = new FileStream(fullCachePath, FileMode.Create, FileAccess.Write, FileShare.Read, IODefaults.FileStreamBufferSize, true);
|
||||||
|
await stream.CopyToAsync(fileStream).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
|
||||||
|
Directory.CreateDirectory(Path.GetDirectoryName(pointerCachePath));
|
||||||
|
await System.IO.File.WriteAllTextAsync(pointerCachePath, fullCachePath, CancellationToken.None)
|
||||||
|
.ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -1,297 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
using System.IO;
|
|
||||||
using System.Linq;
|
|
||||||
using System.Threading;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using MediaBrowser.Common.Extensions;
|
|
||||||
using MediaBrowser.Common.Net;
|
|
||||||
using MediaBrowser.Controller;
|
|
||||||
using MediaBrowser.Controller.Configuration;
|
|
||||||
using MediaBrowser.Controller.Entities;
|
|
||||||
using MediaBrowser.Controller.Library;
|
|
||||||
using MediaBrowser.Controller.Net;
|
|
||||||
using MediaBrowser.Controller.Providers;
|
|
||||||
using MediaBrowser.Model.Entities;
|
|
||||||
using MediaBrowser.Model.IO;
|
|
||||||
using MediaBrowser.Model.Providers;
|
|
||||||
using MediaBrowser.Model.Services;
|
|
||||||
using Microsoft.Extensions.Logging;
|
|
||||||
|
|
||||||
namespace MediaBrowser.Api.Images
|
|
||||||
{
|
|
||||||
public class BaseRemoteImageRequest : IReturn<RemoteImageResult>
|
|
||||||
{
|
|
||||||
[ApiMember(Name = "Type", Description = "The image type", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
|
|
||||||
public ImageType? Type { get; set; }
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Skips over a given number of items within the results. Use for paging.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The start index.</value>
|
|
||||||
[ApiMember(Name = "StartIndex", Description = "Optional. The record index to start at. All items with a lower index will be dropped from the results.", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
|
|
||||||
public int? StartIndex { get; set; }
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// The maximum number of items to return
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The limit.</value>
|
|
||||||
[ApiMember(Name = "Limit", Description = "Optional. The maximum number of records to return", IsRequired = false, DataType = "int", ParameterType = "query", Verb = "GET")]
|
|
||||||
public int? Limit { get; set; }
|
|
||||||
|
|
||||||
[ApiMember(Name = "ProviderName", Description = "Optional. The image provider to use", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
|
|
||||||
public string ProviderName { get; set; }
|
|
||||||
|
|
||||||
[ApiMember(Name = "IncludeAllLanguages", Description = "Optional.", IsRequired = false, DataType = "bool", ParameterType = "query", Verb = "GET")]
|
|
||||||
public bool IncludeAllLanguages { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
[Route("/Items/{Id}/RemoteImages", "GET", Summary = "Gets available remote images for an item")]
|
|
||||||
[Authenticated]
|
|
||||||
public class GetRemoteImages : BaseRemoteImageRequest
|
|
||||||
{
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the id.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The id.</value>
|
|
||||||
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
|
|
||||||
public string Id { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
[Route("/Items/{Id}/RemoteImages/Providers", "GET", Summary = "Gets available remote image providers for an item")]
|
|
||||||
[Authenticated]
|
|
||||||
public class GetRemoteImageProviders : IReturn<List<ImageProviderInfo>>
|
|
||||||
{
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the id.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The id.</value>
|
|
||||||
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
|
|
||||||
public string Id { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class BaseDownloadRemoteImage : IReturnVoid
|
|
||||||
{
|
|
||||||
[ApiMember(Name = "Type", Description = "The image type", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
|
|
||||||
public ImageType Type { get; set; }
|
|
||||||
|
|
||||||
[ApiMember(Name = "ProviderName", Description = "The image provider", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
|
|
||||||
public string ProviderName { get; set; }
|
|
||||||
|
|
||||||
[ApiMember(Name = "ImageUrl", Description = "The image url", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET,POST")]
|
|
||||||
public string ImageUrl { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
[Route("/Items/{Id}/RemoteImages/Download", "POST", Summary = "Downloads a remote image for an item")]
|
|
||||||
[Authenticated(Roles = "Admin")]
|
|
||||||
public class DownloadRemoteImage : BaseDownloadRemoteImage
|
|
||||||
{
|
|
||||||
/// <summary>
|
|
||||||
/// Gets or sets the id.
|
|
||||||
/// </summary>
|
|
||||||
/// <value>The id.</value>
|
|
||||||
[ApiMember(Name = "Id", Description = "Item Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")]
|
|
||||||
public string Id { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
[Route("/Images/Remote", "GET", Summary = "Gets a remote image")]
|
|
||||||
public class GetRemoteImage
|
|
||||||
{
|
|
||||||
[ApiMember(Name = "ImageUrl", Description = "The image url", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")]
|
|
||||||
public string ImageUrl { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class RemoteImageService : BaseApiService
|
|
||||||
{
|
|
||||||
private readonly IProviderManager _providerManager;
|
|
||||||
|
|
||||||
private readonly IServerApplicationPaths _appPaths;
|
|
||||||
private readonly IHttpClient _httpClient;
|
|
||||||
private readonly IFileSystem _fileSystem;
|
|
||||||
|
|
||||||
private readonly ILibraryManager _libraryManager;
|
|
||||||
|
|
||||||
public RemoteImageService(
|
|
||||||
ILogger<RemoteImageService> logger,
|
|
||||||
IServerConfigurationManager serverConfigurationManager,
|
|
||||||
IHttpResultFactory httpResultFactory,
|
|
||||||
IProviderManager providerManager,
|
|
||||||
IServerApplicationPaths appPaths,
|
|
||||||
IHttpClient httpClient,
|
|
||||||
IFileSystem fileSystem,
|
|
||||||
ILibraryManager libraryManager)
|
|
||||||
: base(logger, serverConfigurationManager, httpResultFactory)
|
|
||||||
{
|
|
||||||
_providerManager = providerManager;
|
|
||||||
_appPaths = appPaths;
|
|
||||||
_httpClient = httpClient;
|
|
||||||
_fileSystem = fileSystem;
|
|
||||||
_libraryManager = libraryManager;
|
|
||||||
}
|
|
||||||
|
|
||||||
public object Get(GetRemoteImageProviders request)
|
|
||||||
{
|
|
||||||
var item = _libraryManager.GetItemById(request.Id);
|
|
||||||
|
|
||||||
var result = GetImageProviders(item);
|
|
||||||
|
|
||||||
return ToOptimizedResult(result);
|
|
||||||
}
|
|
||||||
|
|
||||||
private List<ImageProviderInfo> GetImageProviders(BaseItem item)
|
|
||||||
{
|
|
||||||
return _providerManager.GetRemoteImageProviderInfo(item).ToList();
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task<object> Get(GetRemoteImages request)
|
|
||||||
{
|
|
||||||
var item = _libraryManager.GetItemById(request.Id);
|
|
||||||
|
|
||||||
var images = await _providerManager.GetAvailableRemoteImages(item, new RemoteImageQuery(request.ProviderName)
|
|
||||||
{
|
|
||||||
IncludeAllLanguages = request.IncludeAllLanguages,
|
|
||||||
IncludeDisabledProviders = true,
|
|
||||||
ImageType = request.Type
|
|
||||||
|
|
||||||
}, CancellationToken.None).ConfigureAwait(false);
|
|
||||||
|
|
||||||
var imagesList = images.ToArray();
|
|
||||||
|
|
||||||
var allProviders = _providerManager.GetRemoteImageProviderInfo(item);
|
|
||||||
|
|
||||||
if (request.Type.HasValue)
|
|
||||||
{
|
|
||||||
allProviders = allProviders.Where(i => i.SupportedImages.Contains(request.Type.Value));
|
|
||||||
}
|
|
||||||
|
|
||||||
var result = new RemoteImageResult
|
|
||||||
{
|
|
||||||
TotalRecordCount = imagesList.Length,
|
|
||||||
Providers = allProviders.Select(i => i.Name)
|
|
||||||
.Distinct(StringComparer.OrdinalIgnoreCase)
|
|
||||||
.ToArray()
|
|
||||||
};
|
|
||||||
|
|
||||||
if (request.StartIndex.HasValue)
|
|
||||||
{
|
|
||||||
imagesList = imagesList.Skip(request.StartIndex.Value)
|
|
||||||
.ToArray();
|
|
||||||
}
|
|
||||||
|
|
||||||
if (request.Limit.HasValue)
|
|
||||||
{
|
|
||||||
imagesList = imagesList.Take(request.Limit.Value)
|
|
||||||
.ToArray();
|
|
||||||
}
|
|
||||||
|
|
||||||
result.Images = imagesList;
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Posts the specified request.
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="request">The request.</param>
|
|
||||||
public Task Post(DownloadRemoteImage request)
|
|
||||||
{
|
|
||||||
var item = _libraryManager.GetItemById(request.Id);
|
|
||||||
|
|
||||||
return DownloadRemoteImage(item, request);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Downloads the remote image.
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="item">The item.</param>
|
|
||||||
/// <param name="request">The request.</param>
|
|
||||||
/// <returns>Task.</returns>
|
|
||||||
private async Task DownloadRemoteImage(BaseItem item, BaseDownloadRemoteImage request)
|
|
||||||
{
|
|
||||||
await _providerManager.SaveImage(item, request.ImageUrl, request.Type, null, CancellationToken.None).ConfigureAwait(false);
|
|
||||||
|
|
||||||
item.UpdateToRepository(ItemUpdateType.ImageUpdate, CancellationToken.None);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Gets the specified request.
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="request">The request.</param>
|
|
||||||
/// <returns>System.Object.</returns>
|
|
||||||
public async Task<object> Get(GetRemoteImage request)
|
|
||||||
{
|
|
||||||
var urlHash = request.ImageUrl.GetMD5();
|
|
||||||
var pointerCachePath = GetFullCachePath(urlHash.ToString());
|
|
||||||
|
|
||||||
string contentPath;
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
contentPath = File.ReadAllText(pointerCachePath);
|
|
||||||
|
|
||||||
if (File.Exists(contentPath))
|
|
||||||
{
|
|
||||||
return await ResultFactory.GetStaticFileResult(Request, contentPath).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (FileNotFoundException)
|
|
||||||
{
|
|
||||||
// Means the file isn't cached yet
|
|
||||||
}
|
|
||||||
catch (IOException)
|
|
||||||
{
|
|
||||||
// Means the file isn't cached yet
|
|
||||||
}
|
|
||||||
|
|
||||||
await DownloadImage(request.ImageUrl, urlHash, pointerCachePath).ConfigureAwait(false);
|
|
||||||
|
|
||||||
// Read the pointer file again
|
|
||||||
contentPath = File.ReadAllText(pointerCachePath);
|
|
||||||
|
|
||||||
return await ResultFactory.GetStaticFileResult(Request, contentPath).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Downloads the image.
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="url">The URL.</param>
|
|
||||||
/// <param name="urlHash">The URL hash.</param>
|
|
||||||
/// <param name="pointerCachePath">The pointer cache path.</param>
|
|
||||||
/// <returns>Task.</returns>
|
|
||||||
private async Task DownloadImage(string url, Guid urlHash, string pointerCachePath)
|
|
||||||
{
|
|
||||||
using var result = await _httpClient.GetResponse(new HttpRequestOptions
|
|
||||||
{
|
|
||||||
Url = url,
|
|
||||||
BufferContent = false
|
|
||||||
}).ConfigureAwait(false);
|
|
||||||
var ext = result.ContentType.Split('/')[^1];
|
|
||||||
|
|
||||||
var fullCachePath = GetFullCachePath(urlHash + "." + ext);
|
|
||||||
|
|
||||||
Directory.CreateDirectory(Path.GetDirectoryName(fullCachePath));
|
|
||||||
var stream = result.Content;
|
|
||||||
await using (stream.ConfigureAwait(false))
|
|
||||||
{
|
|
||||||
var filestream = new FileStream(fullCachePath, FileMode.Create, FileAccess.Write, FileShare.Read, IODefaults.FileStreamBufferSize, true);
|
|
||||||
await using (filestream.ConfigureAwait(false))
|
|
||||||
{
|
|
||||||
await stream.CopyToAsync(filestream).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Directory.CreateDirectory(Path.GetDirectoryName(pointerCachePath));
|
|
||||||
File.WriteAllText(pointerCachePath, fullCachePath);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Gets the full cache path.
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="filename">The filename.</param>
|
|
||||||
/// <returns>System.String.</returns>
|
|
||||||
private string GetFullCachePath(string filename)
|
|
||||||
{
|
|
||||||
return Path.Combine(_appPaths.CachePath, "remote-images", filename.Substring(0, 1), filename);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in new issue