added support for log level and added logs

internal/logger/logger.go

@@ -1,24 +1,40 @@
 package logger
 
 import (
+	"fmt"
+	"github.com/caarlos0/env"
 	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
 	"net/http"
 )
 
-func NewSugardLogger() *zap.SugaredLogger {
-	l, err := zap.NewProduction()
+type LogConfig struct {
+	Level int `env:"LOG_LEVEL" envDefault:"0"` // default info
+}
+
+func InitLogger() (*zap.SugaredLogger, error) {
+	cfg := &LogConfig{}
+	err := env.Parse(cfg)
 	if err != nil {
-		panic("failed to create the default logger: " + err.Error())
+		fmt.Println("failed to parse logger env config: " + err.Error())
+		return nil, err
 	}
-	//l, err := zap.NewDevelopment()
-	/*l, err := zap.NewProduction()
+
+	config := zap.NewProductionConfig()
+	config.Level = zap.NewAtomicLevelAt(zapcore.Level(cfg.Level))
+	l, err := config.Build()
 	if err != nil {
-		panic("failed to create the default logger: " + err.Error())
+		fmt.Println("failed to create the default logger: " + err.Error())
+		return nil, err
 	}
-	Logger := l.Sugar()*/
-	return l.Sugar()
+	logger := l.Sugar()
+	return logger, nil
+}
+
+func NewSugardLogger() (*zap.SugaredLogger, error) {
+	return InitLogger()
 }
 
 func NewHttpClient() *http.Client {
 	return http.DefaultClient
-}
+}

pkg/clairService/ClairService.go

@@ -148,14 +148,15 @@ func (impl *ClairServiceImpl) ScanImage(scanEvent *common.ScanEvent) (*common.Sc
 }
 
 func (impl *ClairServiceImpl) GetVulnerabilityReportFromClair(scanEvent *common.ScanEvent) (*claircore.VulnerabilityReport, error) {
+	impl.logger.Infow("received vulnerability report creation request", "scanEvent", scanEvent)
 	//get manifest from image
 	manifest, err := impl.CreateClairManifest(scanEvent)
 	if err != nil {
 		impl.logger.Errorw("error in creating clair manifest", "err", err, "scanEvent", scanEvent)
 		return nil, err
 	}
 	//end get manifest
-
+	impl.logger.Debugw("created clair manifest", "scanEvent", scanEvent, "manifest", manifest)
 	//checking if index report exists for this manifest hash; if it does, no need of creating index report
 	exists, err := impl.CheckIfIndexReportExistsForManifestHash(manifest.Hash)
 	if err != nil {
@@ -168,6 +169,7 @@ func (impl *ClairServiceImpl) GetVulnerabilityReportFromClair(scanEvent *common.
 				impl.logger.Errorw("error in creating clair index report", "err", err, "manifest", manifest)
 				return nil, err
 			}
+			impl.logger.Debugw("created index report from manifest", "manifest", manifest)
 		}
 	} else if !exists {
 		//index report do not exist, creating index report for manifest
@@ -176,6 +178,7 @@ func (impl *ClairServiceImpl) GetVulnerabilityReportFromClair(scanEvent *common.
 			impl.logger.Errorw("error in creating clair index report", "err", err, "manifest", manifest)
 			return nil, err
 		}
+		impl.logger.Debugw("created index report from manifest", "manifest", manifest)
 	}
 
 	//index report created, now getting vulnerability report