feat(client): add debug struct logging

client/cmd/trdl/command/template.go

@@ -12,7 +12,8 @@ const (
 		`{{$visibleFlags := visibleFlags .Flags}}` +
 		`{{$explicitlyExposedFlags := exposed .}}` +
 		`{{$optionsCmdFor := optionsCmdFor .}}` +
-		`{{$usageLine := usageLine .}}`
+		`{{$usageLine := usageLine .}}` +
+		`{{$versionLine := versionLine .}}`
 
 	// SectionAliases is the help template section that displays command aliases.
 	SectionAliases = `{{if gt .Aliases 0}}Aliases:
@@ -45,6 +46,10 @@ const (
 	// SectionTipsHelp is the help template section that displays the '--help' hint.
 	SectionTipsHelp = `{{if .HasSubCommands}}Use "{{$rootCmd}} <command> --help" for more information about a given command.
 {{end}}`
+
+	// SectionVersion is the help template section that displays the command's version.
+	SectionVersion = `
+{{ $versionLine }}`
 )
 
 // MainHelpTemplate if the template for 'help' used by most commands.
@@ -63,6 +68,7 @@ func MainUsageTemplate() string {
 		SectionFlags,
 		SectionUsage,
 		SectionTipsHelp,
+		SectionVersion,
 	}
 	return strings.TrimRightFunc(strings.Join(sections, ""), unicode.IsSpace)
 }

client/cmd/trdl/command/templater.go

@@ -13,6 +13,7 @@ import (
 
 	"github.com/werf/logboek"
 	"github.com/werf/logboek/pkg/types"
+	"github.com/werf/trdl/client/pkg/trdl"
 )
 
 type FlagExposer interface {
@@ -82,6 +83,7 @@ func (t *templater) templateFuncs(exposedFlags ...string) template.FuncMap {
 		"isRootCmd":           t.isRootCmd,
 		"optionsCmdFor":       t.optionsCmdFor,
 		"usageLine":           t.usageLine,
+		"versionLine":         t.versionLine,
 		"exposed": func(c *cobra.Command) *flag.FlagSet {
 			exposed := flag.NewFlagSet("exposed", flag.ContinueOnError)
 			if len(exposedFlags) > 0 {
@@ -186,6 +188,10 @@ func UsageLine(c *cobra.Command) string {
 	return usage
 }
 
+func (t *templater) versionLine(c *cobra.Command) string {
+	return fmt.Sprintf("Version: %s\n", trdl.Version)
+}
+
 func FlagsUsages(f *flag.FlagSet) string {
 	x := new(bytes.Buffer)
 

client/cmd/trdl/main.go

@@ -8,9 +8,13 @@ import (
 	"github.com/spf13/cobra"
 
 	"github.com/werf/trdl/client/cmd/trdl/command"
+	"github.com/werf/trdl/client/pkg/logger"
 )
 
-var homeDir string
+var (
+	homeDir string
+	debug   bool
+)
 
 func main() {
 	if err := rootCmd().Execute(); err != nil {
@@ -26,6 +30,16 @@ func rootCmd() *cobra.Command {
 		Long:          "The universal package manager for delivering your software updates securely from a TUF repository (more details on https://trdl.dev)",
 		SilenceUsage:  true,
 		SilenceErrors: true,
+		PersistentPreRun: func(cmd *cobra.Command, args []string) {
+			logLevel := "info"
+			if debug {
+				logLevel = "debug"
+			}
+			logger.GlobalLogger = logger.SetupGlobalLogger(logger.LoggerOptions{
+				Level:     logLevel,
+				LogFormat: "text",
+			})
+		},
 		CompletionOptions: cobra.CompletionOptions{
 			DisableDefaultCmd: true,
 		},
@@ -34,6 +48,8 @@ func rootCmd() *cobra.Command {
 	rootCmd.SetHelpCommand(&cobra.Command{Hidden: true})
 	SetupHomeDir(rootCmd)
 
+	rootCmd.PersistentFlags().BoolVarP(&debug, "debug", "d", false, "Enable debug output")
+
 	groups := &command.Groups{}
 	*groups = append(*groups, command.Groups{
 		{

client/pkg/logger/log.go

@@ -0,0 +1,102 @@
+package logger
+
+import (
+	"log/slog"
+	"os"
+)
+
+var GlobalLogger *Logger
+
+type LoggerInterface interface {
+	Debug(msg string, args ...any)
+	Error(msg string, args ...any)
+	Info(msg string, args ...any)
+	Warn(msg string, args ...any)
+	With(args ...any) LoggerInterface
+}
+
+type Logger struct {
+	LoggerInterface
+}
+
+type LoggerOptions struct {
+	Level     string
+	LogFormat string
+}
+
+func SetupGlobalLogger(opts LoggerOptions) *Logger {
+	return NewLogger(&SlogWrapper{
+		logger: NewSlogLogger(SlogOptions{
+			Handler: slogHandler(opts.LogFormat, slogLevel(opts.Level)),
+		}),
+	})
+}
+
+func NewLogger(l LoggerInterface) *Logger {
+	return &Logger{LoggerInterface: l}
+}
+
+type SlogOptions struct {
+	Handler slog.Handler
+}
+
+func NewSlogLogger(opts SlogOptions) *slog.Logger {
+	return slog.New(opts.Handler)
+}
+
+type SlogWrapper struct {
+	logger *slog.Logger
+}
+
+func (s *SlogWrapper) Debug(msg string, args ...any) {
+	s.logger.Debug(msg, args...)
+}
+
+func (s *SlogWrapper) Error(msg string, args ...any) {
+	s.logger.Error(msg, args...)
+}
+
+func (s *SlogWrapper) Info(msg string, args ...any) {
+	s.logger.Info(msg, args...)
+}
+
+func (s *SlogWrapper) Warn(msg string, args ...any) {
+	s.logger.Warn(msg, args...)
+}
+
+func (s *SlogWrapper) With(args ...any) LoggerInterface {
+	return &SlogWrapper{
+		logger: s.logger.With(args...),
+	}
+}
+
+func (l *Logger) With(args ...any) *Logger {
+	return &Logger{LoggerInterface: l.LoggerInterface.With(args...)}
+}
+
+func slogLevel(l string) slog.Level {
+	switch l {
+	case "debug":
+		return slog.LevelDebug
+	case "info":
+		return slog.LevelInfo
+	case "warn":
+		return slog.LevelWarn
+	case "error":
+		return slog.LevelError
+	default:
+		return slog.LevelInfo
+	}
+}
+
+func slogHandler(format string, level slog.Level) slog.Handler {
+	options := &slog.HandlerOptions{
+		Level: level,
+	}
+	switch format {
+	case "json":
+		return slog.NewJSONHandler(os.Stdout, options)
+	default:
+		return slog.NewTextHandler(os.Stdout, options)
+	}
+}

client/pkg/tuf/client.go

@@ -2,6 +2,7 @@ package tuf
 
 import (
 	"fmt"
+	"net/http"
 	"os"
 	"time"
 
@@ -11,6 +12,7 @@ import (
 
 	"github.com/werf/lockgate"
 	"github.com/werf/lockgate/pkg/file_locker"
+	"github.com/werf/trdl/client/pkg/logger"
 	"github.com/werf/trdl/client/pkg/util"
 )
 
@@ -85,7 +87,14 @@ func (c *Client) initTufClient() error {
 		}
 	}
 
-	remote, err := tufClient.HTTPRemoteStore(c.repoUrl, nil, nil)
+	var remote tufClient.RemoteStore
+	httpClient := &http.Client{
+		Transport: &TracingTransport{
+			Transport: http.DefaultTransport,
+			Logger:    *logger.GlobalLogger,
+		},
+	}
+	remote, err = tufClient.HTTPRemoteStore(c.repoUrl, nil, httpClient)
 	if err != nil {
 		return fmt.Errorf("unable to init http remote store: %w", err)
 	}

client/pkg/tuf/trace.go

@@ -0,0 +1,58 @@
+package tuf
+
+import (
+	"net/http"
+	"net/http/httptrace"
+	"time"
+
+	"github.com/werf/trdl/client/pkg/logger"
+)
+
+type TracingTransport struct {
+	Transport http.RoundTripper
+	Logger    logger.Logger
+}
+
+func (t *TracingTransport) RoundTrip(req *http.Request) (*http.Response, error) {
+	log := t.Logger.With("sorce", "tuf-client")
+	startTime := time.Now()
+
+	log.Debug("Request started",
+		"method", req.Method,
+		"url", req.URL.String(),
+	)
+
+	trace := &httptrace.ClientTrace{
+		DNSDone: func(info httptrace.DNSDoneInfo) {
+			log.Debug("DNS lookup done", "host", info.Addrs)
+		},
+		ConnectDone: func(network, addr string, err error) {
+			if err != nil {
+				log.Debug("Failed to connect",
+					"host", addr,
+					"error", err,
+				)
+				return
+			}
+			log.Debug("Connected", "address", addr)
+		},
+	}
+
+	req = req.WithContext(httptrace.WithClientTrace(req.Context(), trace))
+
+	resp, err := t.Transport.RoundTrip(req)
+	if err != nil {
+		log.Debug("Failed to send request",
+			"url", req.URL.String(),
+			"error", err,
+		)
+		return nil, err
+	}
+
+	log.Debug("Request completed",
+		"status", resp.Status,
+		"duration", time.Since(startTime).Seconds(),
+	)
+
+	return resp, nil
+}

e2e/tests/client/basic_test.go

@@ -18,7 +18,7 @@ var _ = Describe("Basic", func() {
 		testutil.RunSucceedCommand(
 			"",
 			trdlBinPath,
-			"add", testRepoName, validRepoUrl, validRootVersion, validRootSHA512,
+			"add", "-d", testRepoName, validRepoUrl, validRootVersion, validRootSHA512,
 		)
 
 		AssertRepoFieldsInListOutput([]string{testRepoName, validRepoUrl, trdl.DefaultChannel})
@@ -29,7 +29,7 @@ var _ = Describe("Basic", func() {
 			testutil.RunSucceedCommand(
 				"",
 				trdlBinPath,
-				"add", testRepoName, validRepoUrl, validRootVersion, validRootSHA512,
+				"add", "-d", testRepoName, validRepoUrl, validRootVersion, validRootSHA512,
 			)
 		})