Refactoring IAssetStorage

Author: usercode

src/DragonFly.API.Core/ClientAPI/AssetApiStorage.cs

@@ -39,7 +39,7 @@ public async Task<Result> UploadAsync(Guid assetId, string mimetype, Stream stre
         return await Client.SendAsync(requestMessage).ReadResultFromJsonAsync();
     }
 
-    public async Task<Result<Stream>> GetStreamAsync(Guid assetId)
+    public async Task<Result<Stream>> OpenStreamAsync(Guid assetId)
     {
         return await Client.GetStreamAsync($"api/asset/{assetId}/download");
     }

src/DragonFly.API/Rest/AssetApiExtensions.cs

@@ -104,7 +104,7 @@ private static async Task<IResult> MapDownload(HttpContext context, IAssetStorag
 
         context.Response.GetTypedHeaders().CacheControl = new CacheControlHeaderValue() { Public = true, MaxAge = TimeSpan.FromDays(30) };
 
-        Stream assetStream = await storage.GetStreamAsync(asset.Id);
+        Stream assetStream = await storage.OpenStreamAsync(asset.Id);
 
         return TypedResults.Stream(assetStream, contentType: asset.MimeType, entityTag: etag, enableRangeProcessing: true);
     }

src/DragonFly.AspNetCore/Permissions/AuthorizationExtensions.cs

@@ -40,4 +40,29 @@ public static IDisposable DisableAuthorization(this IDragonFlyApi api)
 
         return new DisableAuthorization(context);
     }
+
+    public static async Task UseNoAuthorizationAsync(this IDragonFlyApi api, Func<Task> action)
+    {
+        using (DisableAuthorization(api))
+        {
+            await action();
+        }
+    }
+
+    public static async Task<T> UseNoAuthorizationAsync<T>(this IDragonFlyApi api, Func<Task<T>> action)
+    {
+        using (DisableAuthorization(api))
+        {
+            return await action();
+        }
+    }
+
+    public static void UseNoAuthorization(this IDragonFlyApi api, Action action)
+    {
+        using (DisableAuthorization(api))
+        {
+            action();
+        }
+    }
+
 }

src/DragonFly.AspNetCore/Permissions/Storages/AssetPermissionStorage.cs

@@ -56,9 +56,9 @@ public async Task<Result> DeleteAsync(Asset asset)
         return await Api.AuthorizeAsync(PrincipalContext.Current, AssetPermissions.ReadAsset).ThenAsync(x  => Storage.GetAssetAsync(id));
     }
 
-    public async Task<Result<Stream>> GetStreamAsync(Guid assetId)
+    public async Task<Result<Stream>> OpenStreamAsync(Guid assetId)
     {
-        return await Api.AuthorizeAsync(PrincipalContext.Current, AssetPermissions.DownloadAsset).ThenAsync(x => Storage.GetStreamAsync(assetId));
+        return await Api.AuthorizeAsync(PrincipalContext.Current, AssetPermissions.DownloadAsset).ThenAsync(x => Storage.OpenStreamAsync(assetId));
     }
 
     public async Task<Result> PublishAsync(Asset asset)

src/DragonFly.Core/Modules/Assets/IAssetStorage.cs

@@ -25,7 +25,7 @@ public interface IAssetStorage
 
     Task<Result> UploadAsync(Guid assetId, string mimetype, Stream stream);
 
-    Task<Result<Stream>> GetStreamAsync(Guid assetId);
+    Task<Result<Stream>> OpenStreamAsync(Guid assetId);
 
     Task<Result> ApplyMetadataAsync(Asset asset);
 

src/DragonFly.ImageWizard/DragonFlyLoader.cs

@@ -55,7 +55,7 @@ public override async Task<LoaderResult> GetAsync(string source, ICachedData? ex
                 return LoaderResult.Failed();
             }
 
-            Stream stream = await Storage.GetStreamAsync(asset.Id);
+            Stream stream = await Storage.OpenStreamAsync(asset.Id);
 
             return LoaderResult.Success(new OriginalData(asset.MimeType, stream));
         }

src/DragonFly.MongoDB/Storages/AssetMongoStorage.cs

@@ -159,7 +159,7 @@ public async Task<Result> UploadAsync(Guid assetId, string mimetype, Stream stre
         return Result.Ok();
     }
 
-    public async Task<Result<Stream>> GetStreamAsync(Guid assetId)
+    public async Task<Result<Stream>> OpenStreamAsync(Guid assetId)
     {
         return await AssetData.OpenDownloadStreamByNameAsync(assetId.ToString());
     }