Cache folder configuration for Azure and AWS Image Caches (Lombiq Technologies: OCORE-136)

src/ImageSharp.Web.Providers.AWS/Caching/AWSS3StorageCache.cs

@@ -17,6 +17,7 @@ public class AWSS3StorageCache : IImageCache
 {
     private readonly IAmazonS3 amazonS3Client;
     private readonly string bucketName;
+    private readonly string cacheFolder;
 
     /// <summary>
     /// Initializes a new instance of the <see cref="AWSS3StorageCache"/> class.
@@ -28,17 +29,21 @@ public AWSS3StorageCache(IOptions<AWSS3StorageCacheOptions> cacheOptions)
         AWSS3StorageCacheOptions options = cacheOptions.Value;
         this.bucketName = options.BucketName;
         this.amazonS3Client = AmazonS3ClientFactory.CreateClient(options);
+        this.cacheFolder = string.IsNullOrEmpty(options.CacheFolder)
+            ? string.Empty
+            : options.CacheFolder.Trim().Trim('/') + '/';
     }
 
     /// <inheritdoc/>
     public async Task<IImageCacheResolver?> GetAsync(string key)
     {
-        GetObjectMetadataRequest request = new() { BucketName = this.bucketName, Key = key };
+        string keyWithFolder = this.GetKeyWithFolder(key);
+        GetObjectMetadataRequest request = new() { BucketName = this.bucketName, Key = keyWithFolder };
         try
         {
             // HEAD request throws a 404 if not found.
             MetadataCollection metadata = (await this.amazonS3Client.GetObjectMetadataAsync(request)).Metadata;
-            return new AWSS3StorageCacheResolver(this.amazonS3Client, this.bucketName, key, metadata);
+            return new AWSS3StorageCacheResolver(this.amazonS3Client, this.bucketName, keyWithFolder, metadata);
         }
         catch
         {
@@ -52,7 +57,7 @@ public Task SetAsync(string key, Stream stream, ImageCacheMetadata metadata)
         PutObjectRequest request = new()
         {
             BucketName = this.bucketName,
-            Key = key,
+            Key = this.GetKeyWithFolder(key),
             ContentType = metadata.ContentType,
             InputStream = stream,
             AutoCloseStream = false
@@ -118,6 +123,9 @@ public Task SetAsync(string key, Stream stream, ImageCacheMetadata metadata)
         return null;
     }
 
+    private string GetKeyWithFolder(string key)
+        => this.cacheFolder + key;
+
     /// <summary>
     /// <see href="https://github.com/aspnet/AspNetIdentity/blob/b7826741279450c58b230ece98bd04b4815beabf/src/Microsoft.AspNet.Identity.Core/AsyncHelper.cs"/>
     /// </summary>

src/ImageSharp.Web.Providers.AWS/Caching/AWSS3StorageCacheOptions.cs

@@ -14,6 +14,11 @@ public class AWSS3StorageCacheOptions : IAWSS3BucketClientOptions
     /// <inheritdoc/>
     public string BucketName { get; set; } = null!;
 
+    /// <summary>
+    /// Gets or sets the cache folder's name that'll store cache files under the configured bucket.
+    /// </summary>
+    public string CacheFolder { get; set; } = null!;
+
     /// <inheritdoc/>
     public string? AccessKey { get; set; }
 

src/ImageSharp.Web.Providers.Azure/Caching/AzureBlobStorageCache.cs

@@ -16,6 +16,7 @@ namespace SixLabors.ImageSharp.Web.Caching.Azure;
 public class AzureBlobStorageCache : IImageCache
 {
     private readonly BlobContainerClient container;
+    private readonly string cacheFolder;
 
     /// <summary>
     /// Initializes a new instance of the <see cref="AzureBlobStorageCache"/> class.
@@ -27,12 +28,15 @@ public AzureBlobStorageCache(IOptions<AzureBlobStorageCacheOptions> cacheOptions
         AzureBlobStorageCacheOptions options = cacheOptions.Value;
 
         this.container = new BlobContainerClient(options.ConnectionString, options.ContainerName);
+        this.cacheFolder = string.IsNullOrEmpty(options.CacheFolder)
+            ? string.Empty
+            : options.CacheFolder.Trim().Trim('/') + '/';
     }
 
     /// <inheritdoc/>
     public async Task<IImageCacheResolver?> GetAsync(string key)
     {
-        BlobClient blob = this.container.GetBlobClient(key);
+        BlobClient blob = this.container.GetBlobClient(this.GetBlobName(key));
 
         if (!await blob.ExistsAsync())
         {
@@ -45,7 +49,7 @@ public AzureBlobStorageCache(IOptions<AzureBlobStorageCacheOptions> cacheOptions
     /// <inheritdoc/>
     public Task SetAsync(string key, Stream stream, ImageCacheMetadata metadata)
     {
-        BlobClient blob = this.container.GetBlobClient(key);
+        BlobClient blob = this.container.GetBlobClient(this.GetBlobName(key));
 
         BlobHttpHeaders headers = new()
         {
@@ -79,4 +83,7 @@ public static Response<BlobContainerInfo> CreateIfNotExists(
         AzureBlobStorageCacheOptions options,
         PublicAccessType accessType)
         => new BlobContainerClient(options.ConnectionString, options.ContainerName).CreateIfNotExists(accessType);
+
+    private string GetBlobName(string key)
+        => this.cacheFolder + key;
 }

src/ImageSharp.Web.Providers.Azure/Caching/AzureBlobStorageCacheOptions.cs

@@ -16,8 +16,15 @@ public class AzureBlobStorageCacheOptions
 
     /// <summary>
     /// Gets or sets the Azure Blob Storage container name.
-    /// Must conform to Azure Blob Storage container naming guidlines.
+    /// Must conform to Azure Blob Storage container naming guidelines.
     /// <see href="https://docs.microsoft.com/en-us/rest/api/storageservices/naming-and-referencing-containers--blobs--and-metadata#container-names"/>
     /// </summary>
     public string ContainerName { get; set; } = null!;
+
+    /// <summary>
+    /// Gets or sets the cache folder's name that'll store cache files under the configured container.
+    /// Must conform to Azure Blob Storage directory naming guidelines.
+    /// <see href="https://learn.microsoft.com/en-us/rest/api/storageservices/naming-and-referencing-containers--blobs--and-metadata#directory-names"/>
+    /// </summary>
+    public string CacheFolder { get; set; } = null!;
 }