Merge pull request #320 from YangSen-qn/dev

uc host check scheme

Author: xwen-winnie

cmd/asyncfetch.go

@@ -46,9 +46,6 @@ func NewCmdAsyncCheck() *cobra.Command {
 		Run: func(cmd *cobra.Command, positionalArgs []string) {
 			bm := iqshell.GetBucketManager()
 
-			// let API choose APIHOST
-			bm.Cfg.ApiHost = ""
-
 			ret, err := bm.CheckAsyncFetchStatus(positionalArgs[0], positionalArgs[1])
 			if err != nil {
 				fmt.Fprintf(os.Stderr, "CheckAsyncFetchStatus: %v\n", err)

cmd/root.go

@@ -149,7 +149,6 @@ func initConfig() {
 	iqshell.SetDefaultAccPath(filepath.Join(rootPath, "account.json"))
 	iqshell.SetDefaultRsHost(storage.DefaultRsHost)
 	iqshell.SetDefaultRsfHost(storage.DefaultRsfHost)
-	iqshell.SetDefaultApiHost(storage.DefaultAPIHost)
 	iqshell.SetDefaultUcHost("https://uc.qbox.me")
 
 	if rErr := viper.ReadInConfig(); rErr != nil {

cmd/rsbatch.go

@@ -217,7 +217,8 @@ func (fc *fetchConfig) initFileExporter() {
 func (fc *fetchConfig) initBucketManager() {
 
 	cfg := storage.Config{
-		IoHost: fc.upHost,
+		IoHost:  fc.upHost,
+		ApiHost: iqshell.ApiHost(),
 	}
 	fc.bm = iqshell.GetBucketManagerWithConfig(&cfg)
 }

iqshell/config.go

@@ -4,6 +4,7 @@ import (
 	"github.com/spf13/pflag"
 	"github.com/spf13/viper"
 	"path/filepath"
+	"strings"
 )
 
 const (
@@ -241,10 +242,14 @@ func SetDefaultApiHost(val string) {
 
 func UcHost() string {
 	host := viper.GetString(HOST_UC[0])
-	if host != "" {
-		return host
+	if host == "" {
+		host = viper.GetString(HOST_UC[1])
+	}
+
+	if !strings.Contains(host, "://") {
+		host = Endpoint(true, host)
 	}
-	return viper.GetString(HOST_UC[1])
+	return host
 }
 
 func SetUcHost(val string) {

iqshell/utils.go

@@ -5,6 +5,7 @@ import (
 	"encoding/base64"
 	"encoding/json"
 	"errors"
+	"fmt"
 	"io"
 	"net/url"
 	"os"
@@ -285,3 +286,17 @@ func SimpleUnescape(s *string) string {
 		`\'`, `'`)
 	return r.Replace(*s)
 }
+
+func Endpoint(useHttps bool, host string) string {
+	host = strings.TrimSpace(host)
+	host = strings.TrimLeft(host, "http://")
+	host = strings.TrimLeft(host, "https://")
+	if host == "" {
+		return ""
+	}
+	scheme := "http://"
+	if useHttps {
+		scheme = "https://"
+	}
+	return fmt.Sprintf("%s%s", scheme, host)
+}