From f998d20a862a0d1e188f2ac72026dd71b37ac12f Mon Sep 17 00:00:00 2001
From: zhangwenjian <zwj777@live.com>
Date: Mon, 21 Feb 2022 18:07:37 +0800
Subject: [PATCH] =?UTF-8?q?feat=E2=9C=A8:=20=20added=20obs,kodo?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 common/file_store/initialize.go | 48 +++++++++++++++++++++++++++------
 1 file changed, 40 insertions(+), 8 deletions(-)

diff --git a/common/file_store/initialize.go b/common/file_store/initialize.go
index 2190b217..fabce9fb 100644
--- a/common/file_store/initialize.go
+++ b/common/file_store/initialize.go
@@ -1,13 +1,45 @@
 package file_store
 
-type FileStore struct {
+import "fmt"
+
+type OXS struct {
+	// Endpoint 访问域名
+	Endpoint string
+	// AccessKeyID AK
+	AccessKeyID string
+	// AccessKeySecret AKS
+	AccessKeySecret string
+	// BucketName 桶名称
+	BucketName string
 }
 
-// Setup 配置数据库
-func (e *FileStore) Setup(driver string) {
-	//fileStoreType := driver
-	//if fileStoreType == "ALiYunOSS" {
-	//	var store = new(ALiYunOSS)
-	//	store.Setup()
-	//}
+// Setup 配置文件存储driver
+func (e *OXS) Setup(driver DriverType, options ...ClientOption) FileStoreType {
+	fileStoreType := driver
+	var fileStore FileStoreType
+	switch fileStoreType {
+	case AliYunOSS:
+		fileStore = new(ALiYunOSS)
+		err := fileStore.Setup(e.Endpoint, e.AccessKeyID, e.AccessKeySecret, e.BucketName)
+		if err != nil {
+			fmt.Println(err)
+		}
+		return fileStore
+	case HuaweiOBS:
+		fileStore = new(HuaWeiOBS)
+		err := fileStore.Setup(e.Endpoint, e.AccessKeyID, e.AccessKeySecret, e.BucketName)
+		if err != nil {
+			fmt.Println(err)
+		}
+		return fileStore
+	case QiNiuKodo:
+		fileStore = new(QiNiuKODO)
+		err := fileStore.Setup(e.Endpoint, e.AccessKeyID, e.AccessKeySecret, e.BucketName)
+		if err != nil {
+			fmt.Println(err)
+		}
+		return fileStore
+	}
+
+	return nil
 }