simapi-net/Helpers/SimApiStorage.cs

using System;
using System.IO;
using Microsoft.AspNetCore.Http;
using Minio;
using Minio.Exceptions;
using SimApi.Configs;

namespace SimApi.Helpers
{
    public class SimApiStorage
    {
        private MinioClient Mc { get; }

        public MinioClient Client => Mc;

        private string ServeUrl { get; }

        private string Bucket { get; }

        private IHttpContextAccessor HttpContextAccessor { get; }

        public SimApiStorage(SimApiOptions apiOptions, IHttpContextAccessor httpContextAccessor)
        {
            var options = apiOptions.SimApiStorageOptions;
            HttpContextAccessor = httpContextAccessor;
            var useSsl = false;
            string endpoint;
            if (options.Endpoint.StartsWith("http://"))
            {
                endpoint = options.Endpoint.Replace("http://", string.Empty);
            }
            else if (options.Endpoint.StartsWith("https://"))
            {
                endpoint = options.Endpoint.Replace("https://", string.Empty);
                useSsl = true;
            }
            else
            {
                throw new Exception("SimApiStorage: Error Endpoint");
            }

            ServeUrl = options.ServeUrl;
            Bucket = options.Bucket;
            Console.WriteLine($"{endpoint} == {options.AccessKey} == {options.SecretKey}");
            var mcb = new MinioClient().WithEndpoint(endpoint)
                .WithCredentials(options.AccessKey, options.SecretKey);
            if (useSsl)
            {
                mcb = mcb.WithSSL();
            }
            Mc = mcb.Build();

            bool found = Mc.BucketExistsAsync(new BucketExistsArgs().WithBucket(Bucket)).Result;
            if (!found)
            {
                Mc.MakeBucketAsync(new MakeBucketArgs().WithBucket(Bucket)).Wait();
            }
        }

        public string GetUploadUrl(string path, int expire = 7200)
        {
            try
            {
                return Mc.PresignedPutObjectAsync(new PresignedPutObjectArgs().WithBucket(Bucket)
                    .WithObject(path).WithExpiry(expire)).Result;
            }
            catch (MinioException e)
            {
                Console.WriteLine("Error occurred: " + e);
                return e.Message;
            }
        }

        public string UploadFile(string path, Stream stream)
        {
            try
            {
                Mc.PutObjectAsync(new PutObjectArgs().WithBucket(Bucket).WithObject(path).WithStreamData(stream))
                    .Wait();
                return null;
            }
            catch (MinioException e)
            {
                Console.WriteLine("Error occurred: " + e);
                return e.Message;
            }
        }

        public string FullUrl(string path)
        {
            var httpRequest = HttpContextAccessor.HttpContext?.Request;
            var url = $"{httpRequest?.Scheme}://{httpRequest?.Host}";
            if (string.IsNullOrEmpty(path))
            {
                return path;
            }

            return path.StartsWith("~") ? url + path.Substring(1, path.Length - 1) : $"{ServeUrl}{path}";
        }
    }
}