ApiServiceCreateData test now checks file upload/download result

Author: Harold-Morgan

examples/minio/CommunityToolkit.Aspire.Hosting.Minio.ApiService/Program.cs

@@ -32,4 +32,46 @@
      return Results.NotFound();
 });
 
+app.MapPost("/buckets/{bucketName}/{fileName}/upload",
+    async ([FromRoute] string bucketName,
+        [FromRoute] string fileName,
+        HttpRequest request,
+        [FromServices] IMinioClient minioClient) =>
+    {
+        var memstream = new MemoryStream();
+        
+        await request.Body.CopyToAsync(memstream);
+        
+        var length = memstream.Length;
+        memstream.Seek(0, SeekOrigin.Begin);
+        
+        var putObjectArgs = new PutObjectArgs()
+            .WithObject(fileName)
+            .WithBucket(bucketName)
+            .WithStreamData(memstream)
+            .WithObjectSize(length);
+
+        await minioClient.PutObjectAsync(putObjectArgs);
+
+        return Results.Ok();
+    }).DisableAntiforgery();
+
+app.MapGet("/buckets/{bucketName}/{fileName}/download",
+    async (string bucketName, string fileName, [FromServices] IMinioClient minioClient) =>
+    {
+        var memStream = new MemoryStream();
+        
+        var getObjectArgs = new GetObjectArgs()
+            .WithBucket(bucketName)
+            .WithObject(fileName)
+            .WithCallbackStream(stream =>
+            {
+                stream.CopyToAsync(memStream);
+            });
+        
+        await minioClient.GetObjectAsync(getObjectArgs);
+        
+        return Results.File(memStream.ToArray(), "application/octet-stream", fileName);
+    });
+
 app.Run();

tests/CommunityToolkit.Aspire.Hosting.Minio.Tests/AppHostTests.cs

@@ -2,10 +2,8 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 
 using Aspire.Components.Common.Tests;
-using Aspire.Hosting;
 using CommunityToolkit.Aspire.Testing;
-using Microsoft.Extensions.Configuration;
-using Microsoft.Extensions.Hosting;
+using System.Text;
 
 namespace CommunityToolkit.Aspire.Hosting.Minio.Tests;
 
@@ -41,5 +39,19 @@ public async Task ApiServiceCreateData()
 
         var getBucketResponse = await httpClient.GetAsync($"/buckets/{bucketName}");
         Assert.Equal(HttpStatusCode.OK, getBucketResponse.StatusCode);
+
+        var uploadedString = "Hello World";
+        var bytes = Encoding.UTF8.GetBytes(uploadedString);
+        using var content = new ByteArrayContent(bytes);
+        content.Headers.ContentType = new("plain/text");
+
+        var uploadFileResponse = await httpClient.PostAsync($"/buckets/{bucketName}/fileName/upload", content);
+        Assert.Equal(HttpStatusCode.OK, uploadFileResponse.StatusCode);
+        
+        var downloadFileResponse = await httpClient.GetAsync($"/buckets/{bucketName}/fileName/download");
+        Assert.Equal(HttpStatusCode.OK, downloadFileResponse.StatusCode);
+
+        var downloadedString = await downloadFileResponse.Content.ReadAsStringAsync();
+        Assert.Equal(uploadedString, downloadedString);
     }
 }