Add ability to change log level (#1023)

internal/config/config.go

@@ -40,6 +40,7 @@ type Config struct {
 	bucketLocation      string
 	certificateLocation string
 	privateKeyLocation  string
+	LogLevel            logrus.Level
 }
 
 type EventConfig struct {
@@ -55,6 +56,7 @@ func Load(args []string) (Config, error) {
 	var cfg Config
 	var allowedCORSHeaders string
 	var eventList string
+	var givenLogLevel string
 
 	fs := flag.NewFlagSet("fake-gcs-server", flag.ContinueOnError)
 	fs.StringVar(&cfg.backend, "backend", filesystemBackend, "storage backend (memory or filesystem)")
@@ -73,12 +75,18 @@ func Load(args []string) (Config, error) {
 	fs.StringVar(&cfg.bucketLocation, "location", "US-CENTRAL1", "location for buckets")
 	fs.StringVar(&cfg.certificateLocation, "cert-location", "", "location for server certificate")
 	fs.StringVar(&cfg.privateKeyLocation, "private-key-location", "", "location for private key")
+	fs.StringVar(&givenLogLevel, "log-level", "info", "level for logging. Options same as for logrus: trace, debug, info, warn, error, fatal, and panic")
 
 	err := fs.Parse(args)
 	if err != nil {
 		return cfg, err
 	}
 
+	cfg.LogLevel, err = logrus.ParseLevel(givenLogLevel)
+	if err != nil {
+		return cfg, err
+	}
+
 	if allowedCORSHeaders != "" {
 		cfg.allowedCORSHeaders = strings.Split(allowedCORSHeaders, ",")
 	}
@@ -157,19 +165,21 @@ func (c *Config) ToFakeGcsOptions() fakestorage.Options {
 			}
 		}
 	}
-
-	return fakestorage.Options{
+	logger := logrus.New()
+	logger.SetLevel(c.LogLevel)
+	opts := fakestorage.Options{
 		StorageRoot:         storageRoot,
 		Scheme:              c.scheme,
 		Host:                c.host,
 		Port:                uint16(c.port),
 		PublicHost:          c.publicHost,
 		ExternalURL:         c.externalURL,
 		AllowedCORSHeaders:  c.allowedCORSHeaders,
-		Writer:              logrus.New().Writer(),
+		Writer:              logger.Writer(),
 		EventOptions:        eventOptions,
 		BucketsLocation:     c.bucketLocation,
 		CertificateLocation: c.certificateLocation,
 		PrivateKeyLocation:  c.privateKeyLocation,
 	}
+	return opts
 }

internal/config/config_test.go

@@ -11,6 +11,7 @@ import (
 	"github.com/fsouza/fake-gcs-server/internal/notification"
 	"github.com/google/go-cmp/cmp"
 	"github.com/google/go-cmp/cmp/cmpopts"
+	"github.com/sirupsen/logrus"
 )
 
 func TestLoadConfig(t *testing.T) {
@@ -38,6 +39,7 @@ func TestLoadConfig(t *testing.T) {
 				"-event.object-prefix", "uploads/",
 				"-event.list", "finalize,delete,metadataUpdate,archive",
 				"-location", "US-EAST1",
+				"-log-level", "warn",
 			},
 			expectedConfig: Config{
 				Seed:               "/var/gcs",
@@ -56,6 +58,7 @@ func TestLoadConfig(t *testing.T) {
 					list:            []string{"finalize", "delete", "metadataUpdate", "archive"},
 				},
 				bucketLocation: "US-EAST1",
+				LogLevel:       logrus.WarnLevel,
 			},
 		},
 		{
@@ -74,6 +77,7 @@ func TestLoadConfig(t *testing.T) {
 					list: []string{"finalize"},
 				},
 				bucketLocation: "US-CENTRAL1",
+				LogLevel:       logrus.InfoLevel,
 			},
 		},
 		{
@@ -111,6 +115,11 @@ func TestLoadConfig(t *testing.T) {
 			args:      []string{"-event.list", "invalid,stuff", "-event.pubsub-topic", "gcs-events", "-event.pubsub-project-id", "test-project"},
 			expectErr: true,
 		},
+		{
+			name:      "invalid log level",
+			args:      []string{"-log-level", "non-existent-level"},
+			expectErr: true,
+		},
 	}
 	for _, test := range tests {
 		test := test

main.go

@@ -29,6 +29,7 @@ func main() {
 		log.Fatal(err)
 	}
 	logger := logrus.New()
+	logger.SetLevel(cfg.LogLevel)
 
 	var emptyBuckets []string
 	opts := cfg.ToFakeGcsOptions()