Merge pull request #8989 from owncloud/log-and-trace-fixes

log and trace fixes

services/frontend/pkg/command/events.go

@@ -56,23 +56,24 @@ func ListenForEvents(ctx context.Context, cfg *config.Config, l log.Logger) erro
 		return err
 	}
 
+	traceProvider, err := tracing.GetServiceTraceProvider(cfg.Tracing, cfg.Service.Name)
+	if err != nil {
+		l.Error().Err(err).Msg("cannot initialize tracing")
+		return err
+	}
+
 	gatewaySelector, err := pool.GatewaySelector(
 		cfg.Reva.Address,
 		pool.WithTLSCACert(cfg.GRPCClientTLS.CACert),
 		pool.WithTLSMode(tm),
 		pool.WithRegistry(registry.GetRegistry()),
+		pool.WithTracerProvider(traceProvider),
 	)
 	if err != nil {
 		l.Error().Err(err).Msg("cannot get gateway selector")
 		return err
 	}
 
-	traceProvider, err := tracing.GetServiceTraceProvider(cfg.Tracing, cfg.Service.Name)
-	if err != nil {
-		l.Error().Err(err).Msg("cannot initialize tracing")
-		return err
-	}
-
 	grpcClient, err := grpc.NewClient(
 		append(
 			grpc.GetClientOptions(cfg.GRPCClientTLS),

services/graph/pkg/identity/cache.go

@@ -88,6 +88,9 @@ func (cache IdentityCache) GetUser(ctx context.Context, userid string) (libregra
 	var user libregraph.User
 	if item := cache.users.Get(userid); item == nil {
 		gatewayClient, err := cache.gatewaySelector.Next()
+		if err != nil {
+			return libregraph.User{}, errorcode.New(errorcode.GeneralException, err.Error())
+		}
 		cs3UserID := &cs3User.UserId{
 			OpaqueId: userid,
 		}

services/postprocessing/pkg/command/server.go

@@ -85,6 +85,7 @@ func Server(cfg *config.Config) *cli.Command {
 				}, func(err error) {
 					logger.Error().
 						Err(err).
+						Str("server", "http").
 						Msg("Shutting down server")
 					cancel()
 					os.Exit(1)

services/search/pkg/config/http.go

@@ -1,8 +0,0 @@
-package config
-
-// HTTP defines the available http configuration.
-type HTTP struct {
-	Addr      string `ocisConfig:"addr" env:"SEARCH_HTTP_ADDR" desc:"The bind address of the HTTP service." introductionVersion:"pre5.0"`
-	Namespace string `ocisConfig:"-" yaml:"-"`
-	Root      string `ocisConfig:"root" env:"SEARCH_HTTP_ROOT" desc:"Subdirectory that serves as the root for this HTTP service." introductionVersion:"pre5.0"`
-}

services/settings/pkg/command/server.go

@@ -73,8 +73,11 @@ func Server(cfg *config.Config) *cli.Command {
 					Msg("Error initializing http service")
 				return fmt.Errorf("could not initialize http service: %w", err)
 			}
-			servers.Add(httpServer.Run, func(_ error) {
-				logger.Info().Str("server", "http").Msg("Shutting down server")
+			servers.Add(httpServer.Run, func(err error) {
+				logger.Error().
+					Err(err).
+					Str("server", "http").
+					Msg("shutting down server")
 				cancel()
 				os.Exit(1)
 			})
@@ -90,7 +93,10 @@ func Server(cfg *config.Config) *cli.Command {
 				grpc.TraceProvider(traceProvider),
 			)
 			servers.Add(grpcServer.Run, func(_ error) {
-				logger.Info().Str("server", "grpc").Msg("Shutting down server")
+				logger.Error().
+					Err(err).
+					Str("server", "grpc").
+					Msg("shutting down server")
 				cancel()
 				os.Exit(1)
 			})

services/sharing/pkg/command/server.go

@@ -73,7 +73,7 @@ func Server(cfg *config.Config) *cli.Command {
 			}, func(err error) {
 				logger.Error().
 					Err(err).
-					Str("server", cfg.Service.Name).
+					Str("server", "reva").
 					Msg("Shutting down server")
 
 				cancel()

services/storage-publiclink/pkg/command/server.go

@@ -57,7 +57,7 @@ func Server(cfg *config.Config) *cli.Command {
 			}, func(err error) {
 				logger.Error().
 					Err(err).
-					Str("server", cfg.Service.Name).
+					Str("server", "reva").
 					Msg("Shutting down server")
 
 				cancel()

services/storage-shares/pkg/command/server.go

@@ -57,7 +57,7 @@ func Server(cfg *config.Config) *cli.Command {
 			}, func(err error) {
 				logger.Error().
 					Err(err).
-					Str("server", cfg.Service.Name).
+					Str("server", "reva").
 					Msg("Shutting down server")
 
 				cancel()

services/storage-system/pkg/command/server.go

@@ -57,7 +57,7 @@ func Server(cfg *config.Config) *cli.Command {
 			}, func(err error) {
 				logger.Error().
 					Err(err).
-					Str("server", cfg.Service.Name).
+					Str("server", "reva").
 					Msg("Shutting down server")
 
 				cancel()

services/storage-users/pkg/command/server.go

@@ -59,7 +59,7 @@ func Server(cfg *config.Config) *cli.Command {
 			}, func(err error) {
 				logger.Error().
 					Err(err).
-					Str("server", cfg.Service.Name).
+					Str("server", "reva").
 					Msg("Shutting down server")
 
 				cancel()

services/thumbnails/pkg/command/server.go

@@ -109,7 +109,10 @@ func Server(cfg *config.Config) *cli.Command {
 			}
 
 			gr.Add(httpServer.Run, func(_ error) {
-				logger.Info().Str("server", "http").Msg("shutting down server")
+				logger.Error().
+					Err(err).
+					Str("server", "http").
+					Msg("Shutting down server")
 				cancel()
 			})
 

services/userlog/pkg/command/server.go

@@ -141,8 +141,8 @@ func Server(cfg *config.Config) *cli.Command {
 					return server.Run()
 				}, func(err error) {
 					logger.Error().
-						Str("transport", "http").
 						Err(err).
+						Str("server", "http").
 						Msg("Shutting down server")
 
 					cancel()

services/users/pkg/command/server.go

@@ -70,7 +70,7 @@ func Server(cfg *config.Config) *cli.Command {
 			}, func(err error) {
 				logger.Error().
 					Err(err).
-					Str("server", cfg.Service.Name).
+					Str("server", "reva").
 					Msg("Shutting down server")
 
 				cancel()

services/web/pkg/command/server.go

@@ -88,8 +88,9 @@ func Server(cfg *config.Config) *cli.Command {
 					}
 					return err
 				}, func(err error) {
-					logger.Info().
-						Str("transport", "http").
+					logger.Error().
+						Err(err).
+						Str("server", "http").
 						Msg("Shutting down server")
 
 					cancel()

services/webdav/pkg/command/server.go

@@ -69,7 +69,7 @@ func Server(cfg *config.Config) *cli.Command {
 				if err != nil {
 					logger.Info().
 						Err(err).
-						Str("transport", "http").
+						Str("server", "http").
 						Msg("Failed to initialize server")
 
 					return err
@@ -80,7 +80,7 @@ func Server(cfg *config.Config) *cli.Command {
 				}, func(err error) {
 					logger.Error().
 						Err(err).
-						Str("transport", "http").
+						Str("server", "http").
 						Msg("Shutting down server")
 
 					cancel()

services/webfinger/pkg/command/server.go

@@ -82,7 +82,7 @@ func Server(cfg *config.Config) *cli.Command {
 				if err != nil {
 					logger.Info().
 						Err(err).
-						Str("transport", "http").
+						Str("server", "http").
 						Msg("Failed to initialize server")
 
 					return err
@@ -93,7 +93,7 @@ func Server(cfg *config.Config) *cli.Command {
 				}, func(err error) {
 					logger.Error().
 						Err(err).
-						Str("transport", "http").
+						Str("server", "http").
 						Msg("Shutting down server")
 
 					cancel()