log

Author: rolodato

client.go

@@ -32,9 +32,8 @@ type Client struct {
 
 	environment state
 
-	log               *slog.Logger
-	logHandlerOptions *slog.HandlerOptions
-	client            *resty.Client
+	log    *slog.Logger
+	client *resty.Client
 }
 
 // NewClient creates a Flagsmith [Client] using the environment determined by apiKey.

logger.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"fmt"
 	"log/slog"
-	"os"
 	"time"
 
 	"github.com/go-resty/resty/v2"
@@ -31,7 +30,7 @@ func (s restySlogLogger) Debugf(format string, v ...interface{}) {
 }
 
 func defaultLogger() *slog.Logger {
-	return slog.New(slog.NewJSONHandler(os.Stderr, nil)).WithGroup("flagsmith")
+	return slog.Default().WithGroup("flagsmith")
 }
 
 func newRestyLogRequestMiddleware(logger *slog.Logger) resty.RequestMiddleware {

options.go

@@ -158,16 +158,3 @@ func WithRealtimeBaseURL(url string) Option {
 		c.config.realtimeBaseUrl = url
 	}
 }
-
-// WithLogLevel sets the log level to a [slog.Level] value.
-func WithLogLevel(level slog.Leveler) Option {
-	return withLogHandlerOptions(&slog.HandlerOptions{
-		Level: level,
-	})
-}
-
-func withLogHandlerOptions(opts *slog.HandlerOptions) Option {
-	return func(c *Client) {
-		c.logHandlerOptions = opts
-	}
-}

realtime.go

@@ -26,7 +26,7 @@ func (c *Client) startRealtimeUpdates(ctx context.Context) {
 		default:
 			resp, err := http.Get(stream_url)
 			if err != nil {
-				c.log.Error("failed to connect to SSE service", "error", err)
+				c.log.Error("failed to connect to realtime service", "error", err)
 				continue
 			}
 			defer resp.Body.Close()
@@ -37,7 +37,7 @@ func (c *Client) startRealtimeUpdates(ctx context.Context) {
 				if strings.HasPrefix(line, "data: ") {
 					parsedTime, err := parseUpdatedAtFromSSE(line)
 					if err != nil {
-						c.log.Error("failed to parse real-time update event", "error", err, "raw_event", line)
+						c.log.Error("failed to parse realtime update event", "error", err, "raw_event", line)
 						continue
 					}
 					if parsedTime.After(envUpdatedAt) {
@@ -54,7 +54,7 @@ func (c *Client) startRealtimeUpdates(ctx context.Context) {
 				}
 			}
 			if err := scanner.Err(); err != nil {
-				c.log.Error("failed to read from real-time stream", "error", err)
+				c.log.Error("failed to read from realtime stream", "error", err, "stream_url", &resp.Request.URL)
 			}
 		}
 	}