feat!: v5

.github/workflows/go.yml

@@ -30,9 +30,6 @@ jobs:
       with:
         submodules: recursive
 
-    - name: Build evaluation context struct
-      run: make generate-evaluation-context
-
     - name: Get dependencies
       run: |
         go get -v -t -d ./...

analytics.go

@@ -3,6 +3,8 @@ package flagsmith
 import (
 	"context"
 	"fmt"
+	"log/slog"
+	"net/http"
 	"sync"
 	"time"
 
@@ -20,10 +22,10 @@ type AnalyticsProcessor struct {
 	client   *resty.Client
 	store    *analyticDataStore
 	endpoint string
-	log      Logger
+	log      *slog.Logger
 }
 
-func NewAnalyticsProcessor(ctx context.Context, client *resty.Client, baseURL string, timerInMilli *int, log Logger) *AnalyticsProcessor {
+func NewAnalyticsProcessor(ctx context.Context, client *resty.Client, baseURL string, timerInMilli *int, log *slog.Logger) *AnalyticsProcessor {
 	data := make(map[string]int)
 	dataStore := analyticDataStore{data: data}
 	tickerInterval := AnalyticsTimerInMilli
@@ -45,32 +47,34 @@ func (a *AnalyticsProcessor) start(ctx context.Context, tickerInterval int) {
 	for {
 		select {
 		case <-ticker.C:
-			if err := a.Flush(ctx); err != nil {
-				a.log.Warnf("Failed to send analytics data: %s", err)
+			if resp, err := a.Flush(ctx); err != nil {
+				a.log.Warn("failed to send analytics data",
+					"error", err,
+					slog.Int("status", resp.StatusCode),
+					slog.String("url", resp.Request.URL.String()),
+				)
 			}
 		case <-ctx.Done():
 			return
 		}
 	}
 }
 
-func (a *AnalyticsProcessor) Flush(ctx context.Context) error {
+func (a *AnalyticsProcessor) Flush(ctx context.Context) (*http.Response, error) {
 	a.store.mu.Lock()
 	defer a.store.mu.Unlock()
 	if len(a.store.data) == 0 {
-		return nil
+		return nil, nil
 	}
 	resp, err := a.client.R().SetContext(ctx).SetBody(a.store.data).Post(a.endpoint)
 	if err != nil {
-		return err
+		return nil, err
 	}
 	if !resp.IsSuccess() {
-		return fmt.Errorf("received unexpected response from server: %s", resp.Status())
+		return resp.RawResponse, fmt.Errorf("AnalyticsProcessor.Flush received error response %d %s", resp.StatusCode(), resp.Status())
 	}
-
-	// Clear the cache in case of success.
 	a.store.data = make(map[string]int)
-	return nil
+	return resp.RawResponse, nil
 }
 
 func (a *AnalyticsProcessor) TrackFeature(featureName string) {

analytics_test.go

@@ -3,6 +3,7 @@ package flagsmith
 import (
 	"context"
 	"io"
+	"log/slog"
 	"net/http"
 	"net/http/httptest"
 	"sync"
@@ -14,7 +15,6 @@ import (
 	"github.com/go-resty/resty/v2"
 )
 
-const BaseURL = "http://localhost:8000/api/v1/"
 const EnvironmentAPIKey = "test_key"
 
 func TestAnalytics(t *testing.T) {
@@ -43,7 +43,7 @@ func TestAnalytics(t *testing.T) {
 	client.SetHeader("X-Environment-Key", EnvironmentAPIKey)
 
 	// Now let's create the processor
-	processor := NewAnalyticsProcessor(context.Background(), client, server.URL+"/api/v1/", &analyticsTimer, createLogger())
+	processor := NewAnalyticsProcessor(context.Background(), client, server.URL+"/api/v1/", &analyticsTimer, slog.Default())
 
 	// and, track some features
 	processor.TrackFeature("feature_1")