Add insecure flag to skip https cert verification and move logger to pkg for consumer to customize loging

assets/assets.go

@@ -21,7 +21,7 @@ import (
 	"embed"
 	"strings"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 //go:embed *

cmd/swctl/main.go

@@ -43,8 +43,8 @@ import (
 	"github.com/apache/skywalking-cli/internal/commands/records"
 	"github.com/apache/skywalking-cli/internal/commands/service"
 	"github.com/apache/skywalking-cli/internal/commands/trace"
-	"github.com/apache/skywalking-cli/internal/logger"
 	intutil "github.com/apache/skywalking-cli/internal/util"
+	"github.com/apache/skywalking-cli/pkg/logger"
 	"github.com/apache/skywalking-cli/pkg/util"
 
 	"github.com/sirupsen/logrus"
@@ -173,6 +173,12 @@ func flags() []cli.Flag {
 				"if `authorization` is set, `--username` and `--password` are ignored",
 			Value: "",
 		}),
+		altsrc.NewStringFlag(&cli.StringFlag{
+			Name:     "insecure",
+			Required: false,
+			Usage:    "skip TLS certificate verification",
+			Value:    "",
+		}),
 		altsrc.NewStringFlag(&cli.StringFlag{
 			Name:     "timezone",
 			Required: false,

internal/commands/event/report.go

@@ -26,11 +26,11 @@ import (
 
 	"github.com/apache/skywalking-cli/internal/commands/interceptor"
 	"github.com/apache/skywalking-cli/internal/flags"
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/internal/model"
 	"github.com/apache/skywalking-cli/pkg/display"
 	"github.com/apache/skywalking-cli/pkg/display/displayable"
 	"github.com/apache/skywalking-cli/pkg/grpc"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 var reportCommand = &cli.Command{

internal/commands/healthcheck/healthcheck.go

@@ -22,8 +22,8 @@ import (
 
 	"github.com/apache/skywalking-cli/pkg/healthcheck"
 
-	"github.com/apache/skywalking-cli/internal/logger"
 	hc "github.com/apache/skywalking-cli/pkg/graphql/healthcheck"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 var Command = &cli.Command{

internal/commands/interceptor/duration.go

@@ -30,8 +30,8 @@ import (
 
 	"github.com/urfave/cli/v2"
 
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/internal/model"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 func TryParseTime(unparsed string, userStep api.Step) (api.Step, time.Time, error) {

internal/commands/interceptor/entity.go

@@ -26,8 +26,8 @@ import (
 	"github.com/sirupsen/logrus"
 	"github.com/urfave/cli/v2"
 
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/pkg/graphql/utils"
+	"github.com/apache/skywalking-cli/pkg/logger"
 
 	api "skywalking.apache.org/repo/goapi/query"
 )

internal/commands/interceptor/interceptor.go

@@ -30,6 +30,7 @@ func BeforeChain(beforeFunctions ...cli.BeforeFunc) cli.BeforeFunc {
 	return func(cliCtx *cli.Context) error {
 		ctx := cliCtx.Context
 		ctx = context.WithValue(ctx, contextkey.BaseURL{}, cliCtx.String("base-url"))
+		ctx = context.WithValue(ctx, contextkey.Insecure{}, cliCtx.Bool("insecure"))
 		ctx = context.WithValue(ctx, contextkey.Username{}, cliCtx.String("username"))
 		ctx = context.WithValue(ctx, contextkey.Password{}, cliCtx.String("password"))
 		ctx = context.WithValue(ctx, contextkey.Authorization{}, cliCtx.String("authorization"))

internal/commands/interceptor/service.go

@@ -25,8 +25,8 @@ import (
 	"github.com/urfave/cli/v2"
 	api "skywalking.apache.org/repo/goapi/query"
 
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/pkg/graphql/metadata"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 type nodeType int

internal/commands/interceptor/timezone.go

@@ -23,8 +23,8 @@ import (
 
 	"github.com/urfave/cli/v2"
 
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/pkg/graphql/metadata"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 // TimezoneInterceptor sets the server timezone if the server supports the API,

internal/commands/metrics/aggregation/metrics.go

@@ -24,11 +24,11 @@ import (
 
 	"github.com/apache/skywalking-cli/internal/commands/interceptor"
 	"github.com/apache/skywalking-cli/internal/flags"
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/internal/model"
 	"github.com/apache/skywalking-cli/pkg/display"
 	"github.com/apache/skywalking-cli/pkg/display/displayable"
 	"github.com/apache/skywalking-cli/pkg/graphql/metrics"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 var SortedMetrics = &cli.Command{

internal/commands/metrics/aggregation/sampled-record.go

@@ -26,12 +26,12 @@ import (
 
 	"github.com/apache/skywalking-cli/internal/commands/interceptor"
 	"github.com/apache/skywalking-cli/internal/flags"
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/internal/model"
 	"github.com/apache/skywalking-cli/pkg/display"
 	"github.com/apache/skywalking-cli/pkg/display/displayable"
 	"github.com/apache/skywalking-cli/pkg/graphql/metadata"
 	"github.com/apache/skywalking-cli/pkg/graphql/metrics"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 var SampledRecords = &cli.Command{

internal/commands/metrics/aggregation/topn.go

@@ -24,11 +24,11 @@ import (
 
 	"github.com/apache/skywalking-cli/internal/commands/interceptor"
 	"github.com/apache/skywalking-cli/internal/flags"
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/internal/model"
 	"github.com/apache/skywalking-cli/pkg/display"
 	"github.com/apache/skywalking-cli/pkg/display/displayable"
 	"github.com/apache/skywalking-cli/pkg/graphql/metrics"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 var TopN = &cli.Command{

pkg/contextkey/contextkey.go

@@ -19,6 +19,7 @@ package contextkey
 
 type (
 	BaseURL       struct{}
+	Insecure      struct{}
 	Username      struct{}
 	Password      struct{}
 	Authorization struct{}

pkg/display/graph/flamegraph/flamegraph.go

@@ -26,7 +26,7 @@ import (
 	"path/filepath"
 	"time"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 
 	api "skywalking.apache.org/repo/goapi/query"
 )

pkg/display/graph/tree/list.go

@@ -30,7 +30,7 @@ import (
 	ui "github.com/gizak/termui/v3"
 	"github.com/gizak/termui/v3/widgets"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 const (

pkg/display/graph/tree/tree.go

@@ -24,7 +24,7 @@ import (
 	ui "github.com/gizak/termui/v3"
 	"github.com/gizak/termui/v3/widgets"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 type Node struct {

pkg/display/table/table.go

@@ -23,7 +23,7 @@ import (
 
 	d "github.com/apache/skywalking-cli/pkg/display/displayable"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 
 	"github.com/olekukonko/tablewriter"
 )

pkg/graphql/client/client.go

@@ -19,20 +19,32 @@ package client
 
 import (
 	"context"
+	"crypto/tls"
 	"encoding/base64"
+	"net/http"
 
 	"github.com/machinebox/graphql"
 
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/pkg/contextkey"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
-func newClient(ctx context.Context) (client *graphql.Client) {
-	client = graphql.NewClient(ctx.Value(contextkey.BaseURL{}).(string))
+func newClient(ctx context.Context) *graphql.Client {
+	options := []graphql.ClientOption{}
+
+	insecure := ctx.Value(contextkey.Insecure{}).(bool)
+	if insecure {
+		customTransport := http.DefaultTransport.(*http.Transport).Clone()
+		customTransport.TLSClientConfig = &tls.Config{InsecureSkipVerify: insecure} // #nosec G402
+		httpClient := &http.Client{Transport: customTransport}
+		options = append(options, graphql.WithHTTPClient(httpClient))
+	}
+
+	client := graphql.NewClient(ctx.Value(contextkey.BaseURL{}).(string), options...)
 	client.Log = func(msg string) {
 		logger.Log.Debugln(msg)
 	}
-	return
+	return client
 }
 
 // ExecuteQuery executes the `request` and parse to the `response`, returning `error` if there is any.

pkg/graphql/dashboard/global.go

@@ -36,9 +36,9 @@ import (
 	"gopkg.in/yaml.v2"
 
 	"github.com/apache/skywalking-cli/assets"
-	"github.com/apache/skywalking-cli/internal/logger"
 	"github.com/apache/skywalking-cli/pkg/graphql/metrics"
 	"github.com/apache/skywalking-cli/pkg/graphql/utils"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 type ButtonTemplate struct {

pkg/graphql/utils/adapter.go

@@ -24,12 +24,13 @@ import (
 
 	api "skywalking.apache.org/repo/goapi/query"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 // MetricsValuesArrayToMap converts Array of MetricsValues into a map that uses time as key.
 func MetricsValuesArrayToMap(duration api.Duration, mvArray []api.MetricsValues,
-	labelsMap map[string]string) map[string]map[string]*displayable.MetricValue {
+	labelsMap map[string]string,
+) map[string]map[string]*displayable.MetricValue {
 	ret := make(map[string]map[string]*displayable.MetricValue, len(mvArray))
 	for _, mvs := range mvArray {
 		label := *mvs.Label
@@ -47,7 +48,6 @@ func MetricsValuesToMap(duration api.Duration, metricsValues api.MetricsValues)
 	ret := map[string]*displayable.MetricValue{}
 	format := StepFormats[duration.Step]
 	startTime, err := time.Parse(format, duration.Start)
-
 	if err != nil {
 		logger.Log.Fatalln(err)
 	}

pkg/healthcheck/grpc.go

@@ -22,7 +22,7 @@ import (
 	"crypto/tls"
 	"time"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
@@ -43,7 +43,8 @@ func HealthCheck(addr string, enableTLS bool) int {
 
 	opts := []grpc.DialOption{
 		grpc.WithUserAgent("swctl_health_probe"),
-		grpc.WithBlock()}
+		grpc.WithBlock(),
+	}
 	if enableTLS {
 		// #nosec
 		creds := credentials.NewTLS(&tls.Config{

pkg/util/io.go

@@ -21,7 +21,7 @@ import (
 	"os/user"
 	"strings"
 
-	"github.com/apache/skywalking-cli/internal/logger"
+	"github.com/apache/skywalking-cli/pkg/logger"
 )
 
 // UserHomeDir returns the current user's home directory absolute path,