Fixed logger (#30)

* fix(logger): fixed logger so it logs only correct levels

* refactor: removed some unneccessary logging

apps/discord/internal/client/client.go

@@ -49,16 +49,18 @@ func New(opts ClientOpts) error {
 		lrRepo: opts.LiverolesRepo,
 	}
 
-	router.Use(func(hf disroute.HandlerFunc) disroute.HandlerFunc {
-		return func(ctx *disroute.Ctx) disroute.Response {
-			c.logger.Debug("interaction",
-				slog.String("type", ctx.Interaction().Type.String()),
-				slog.String("id", ctx.Interaction().ID),
-				slog.String("user", ctx.Interaction().Member.User.GlobalName))
-
-			return hf(ctx)
-		}
-	})
+	if opts.Cfg.Environment != "prod" {
+		router.Use(func(hf disroute.HandlerFunc) disroute.HandlerFunc {
+			return func(ctx *disroute.Ctx) disroute.Response {
+				c.logger.Debug("interaction",
+					slog.String("type", ctx.Interaction().Type.String()),
+					slog.String("id", ctx.Interaction().ID),
+					slog.String("user", ctx.Interaction().Member.User.GlobalName))
+
+				return hf(ctx)
+			}
+		})
+	}
 
 	router.Use(func(hf disroute.HandlerFunc) disroute.HandlerFunc {
 		return func(ctx *disroute.Ctx) disroute.Response {

apps/discord/internal/client/handlers.go

@@ -45,11 +45,15 @@ func (c *Client) onStatusChanged(_ *discordgo.Session, u *discordgo.PresenceUpda
 			slog.Any("error", err),
 			slog.String("guild_id", u.GuildID),
 		)
+
+		return
 	}
 
 	roles, err := c.lrRepo.GetLiveroles(ctx, int64(guildId))
 	if err != nil {
-		c.logger.Error("could not give streaming role", err)
+		c.logger.Warn("could not get liveroles from db", err)
+
+		return
 	}
 
 	var member *discordgo.Member
@@ -83,10 +87,6 @@ func (c *Client) onStatusChanged(_ *discordgo.Session, u *discordgo.PresenceUpda
 			if err != nil {
 				c.logger.Error("could not add role", err)
 			}
-			c.logger.Debug("Role added",
-				slog.Int("role", role.DiscordRoleID),
-				slog.String("user", u.Presence.User.ID),
-			)
 		}
 	} else {
 		for _, liveroleId := range liverolesIds {

apps/discord/internal/client/logger.go

@@ -31,6 +31,10 @@ func (c *Client) registerLogger() {
 
 		r := slog.NewRecord(time.Now(), lvl, msg, pcs[0])
 
-		_ = c.logger.Handler().Handle(context.Background(), r)
+		if !c.logger.Handler().Enabled(context.Background(), lvl) {
+			return
+		}
+
+		_ = c.logger.Handler().Handle(context.Background(), r) //nolint: errcheck
 	}
 }

libs/logger/logger.go

@@ -16,6 +16,7 @@ import (
 type Logger interface {
 	Info(input string, fields ...any)
 	Error(input string, fields ...any)
+	Warn(input string, fields ...any)
 	Debug(input string, fields ...any)
 	Handler() slog.Handler
 }
@@ -30,12 +31,12 @@ func New(service string) func() Logger {
 	}
 }
 
-func newLogger(service string) Logger {
+func newLogger(service string) Logger { //nolint: ireturn
 	var log *slog.Logger
 
 	replaceAttr := func(groups []string, attr slog.Attr) slog.Attr {
 		if attr.Key == slog.SourceKey {
-			source := attr.Value.Any().(*slog.Source)
+			source := attr.Value.Any().(*slog.Source) //nolint: forcetypeassert
 
 			pathParts := strings.Split(source.File, "/")
 			p := pathParts[len(pathParts)-4:]
@@ -58,7 +59,7 @@ func newLogger(service string) Logger {
 			slog.NewJSONHandler(
 				os.Stdout,
 				&slog.HandlerOptions{
-					Level:       slog.LevelError,
+					Level:       slog.LevelWarn,
 					AddSource:   true,
 					ReplaceAttr: replaceAttr,
 				},
@@ -93,13 +94,22 @@ func (c *logger) handle(level slog.Level, input string, fields ...any) {
 	for _, f := range fields {
 		r.Add(f)
 	}
-	_ = c.log.Handler().Handle(context.Background(), r)
+
+	if !c.log.Handler().Enabled(context.Background(), level) {
+		return
+	}
+
+	_ = c.log.Handler().Handle(context.Background(), r) //nolint: errcheck
 }
 
 func (c *logger) Info(input string, fields ...any) {
 	c.handle(slog.LevelInfo, input, fields...)
 }
 
+func (c *logger) Warn(input string, fields ...any) {
+	c.handle(slog.LevelWarn, input, fields...)
+}
+
 func (c *logger) Error(input string, fields ...any) {
 	c.handle(slog.LevelError, input, fields...)
 }