refactor: add https support

etc/kuiper.yaml

@@ -18,7 +18,7 @@ basic:
   # The URL where hosts all of pre-build plugins. By default it's at packages.emqx.io
   # There could be several hosts (host can be separated with comma), if same package could be found in the several hosts,
   # then the package in the 1st host will have the highest priority.
-  pluginHosts: https://packages.emqx.io
+  pluginHosts:  https://www.emqx.io/downloads
 
 # The default options for all rules. Each rule can override this setting by defining its own option
 rule:

plugins/manager.go

@@ -2,6 +2,7 @@ package plugins
 
 import (
 	"archive/zip"
+	"crypto/tls"
 	"errors"
 	"fmt"
 	"github.com/emqx/kuiper/common"
@@ -543,7 +544,14 @@ func downloadFile(filepath string, uri string) error {
 		src = srcFile
 	case "http", "https":
 		// Get the data
-		resp, err := http.Get(uri)
+		timeout := time.Duration(10 * time.Second)
+		client := &http.Client{
+			Timeout: timeout,
+			Transport: &http.Transport{
+				TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+			},
+		}
+		resp, err := client.Get(uri)
 		if err != nil {
 			return err
 		}

xstream/server/server/rest.go

@@ -1,6 +1,7 @@
 package server
 
 import (
+	"crypto/tls"
 	"encoding/json"
 	"fmt"
 	"github.com/emqx/kuiper/common"
@@ -487,7 +488,14 @@ func fetchPluginList(hosts, ptype, os, arch string) (err error, result map[strin
 		tmp := []string{host, "kuiper-plugins", version, os, ptype}
 		//The url is similar to http://host:port/kuiper-plugins/0.9.1/debian/sinks/
 		url := strings.Join(tmp, "/")
-		resp, err := http.Get(url)
+		timeout := time.Duration(10 * time.Second)
+		client := &http.Client{
+			Timeout: timeout,
+			Transport: &http.Transport{
+				TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+			},
+		}
+		resp, err := client.Get(url)
 		logger.Infof("Trying to fetch plugins from url: %s\n", url)
 
 		if err != nil {