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; }

        public 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;
            var mcb = new MinioClient().WithEndpoint(endpoint)
                .WithCredentials(options.AccessKey, options.SecretKey);
            if (useSsl)
            {
                mcb = mcb.WithSSL();
            }
            Mc = mcb.Build();

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

        /// <summary>
        /// 获取上传的URL
        /// </summary>
        /// <param name="path"></param>
        /// <param name="expire"></param>
        /// <returns></returns>
        public string GetUploadUrl(string path, int expire = 7200)
        {
            return Mc.PresignedPutObjectAsync(new PresignedPutObjectArgs().WithBucket(Bucket)
                .WithObject(path).WithExpiry(expire)).Result;
        }

        /// <summary>
        /// 获取下载的URL
        /// </summary>
        /// <param name="path"></param>
        /// <param name="expire"></param>
        /// <returns></returns>
        public string GetDownloadUrl(string path, int expire = 600)
        {
            return Mc.PresignedGetObjectAsync(new PresignedGetObjectArgs().WithBucket(Bucket).WithObject(path)
                .WithExpiry(expire)).Result;
        }


        public string UploadFile(string path, Stream stream, string contentType = "image/png")
        {
            Mc.PutObjectAsync(new PutObjectArgs().WithBucket(Bucket).WithObject(path).WithObjectSize(stream.Length)
                .WithStreamData(stream).WithContentType(contentType)).Wait();
            return null;
        }

        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}";
        }
    }
}