Foxnouns.NET/Foxnouns.Backend/Services/ObjectStorageService.cs

using Minio;
using Minio.DataModel.Args;
using Minio.Exceptions;

namespace Foxnouns.Backend.Services;

public class ObjectStorageService(ILogger logger, Config config, IMinioClient minio)
{
    private readonly ILogger _logger = logger.ForContext<ObjectStorageService>();

    public async Task RemoveObjectAsync(string path)
    {
        _logger.Debug("Deleting object at path {Path}", path);
        try
        {
            await minio.RemoveObjectAsync(new RemoveObjectArgs().WithBucket(config.Storage.Bucket).WithObject(path));
        }
        catch (InvalidObjectNameException)
        {
            // ignore non-existent objects
        }
    }

    public async Task PutObjectAsync(string path, Stream data, string contentType)
    {
        _logger.Debug("Putting object at path {Path} with length {Length} and content type {ContentType}", path,
            data.Length, contentType);

        await minio.PutObjectAsync(new PutObjectArgs()
            .WithBucket(config.Storage.Bucket)
            .WithObject(path)
            .WithObjectSize(data.Length)
            .WithStreamData(data)
            .WithContentType(contentType)
        );
    }
}