新的配置方式,新的SimApiStorage,移除了SimApiUPload

2021-06-03 13:43:46 +08:00
parent 8f41ba0150
commit 3ec378c4fa
8 changed files with 377 additions and 294 deletions
@@ -0,0 +1,81 @@
+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; }
+        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;
+            var endpoint = string.Empty;
+            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;
+            if (useSsl)
+            {
+                Mc = new MinioClient(endpoint, options.AccessKey, options.SecretKey).WithSSL();
+            }
+            else
+            {
+                Mc = new MinioClient(endpoint, options.AccessKey, options.SecretKey);
+            }
+
+            bool found = Mc.BucketExistsAsync(Bucket).Result;
+            if (!found)
+            {
+                Mc.MakeBucketAsync(Bucket).Wait();
+            }
+        }
+
+        public string UploadFile(string path, Stream stream)
+        {
+            try
+            {
+                Mc.PutObjectAsync(Bucket, path, stream, stream.Length).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}";
+        }
+    }
+}