Copy events and log log_event failures

logger.go

@@ -2,6 +2,7 @@
 
 import (
 	"fmt"
+	"net/http/httputil"
 	"strconv"
 	"sync"
 	"time"
@@ -23,7 +24,7 @@
 	Time               int64               `json:"time"`
 }
 
 type diagnosticsEvent struct {
 	EventName string                 `json:"eventName"`
 	Metadata  map[string]interface{} `json:"metadata"`
 	Time      int64                  `json:"time"`
@@ -205,7 +206,6 @@
 }
 
 func (l *logger) flush(closing bool) {
-	l.logDiagnosticsEvents(l.diagnostics)
 	l.mu.Lock()
 	defer l.mu.Unlock()
 
@@ -220,10 +220,13 @@
 		return
 	}
 
+	eventsCopy := make([]interface{}, len(l.events))
+	copy(eventsCopy, l.events)
+
 	if closing {
-		l.sendEvents(l.events)
+		l.sendEvents(eventsCopy)
 	} else {
-		go l.sendEvents(l.events)
+		go l.sendEvents(eventsCopy)
 	}
 
 	l.events = make([]interface{}, 0)
@@ -234,17 +237,29 @@
 		Events:          events,
 		StatsigMetadata: l.transport.metadata,
 	}
-	var res logEventResponse
-	_, _ = l.transport.retryablePostRequest("/log_event", input, &res, maxRetries)
+	var result logEventResponse
+	global.Logger().Log(fmt.Sprintf("logging %d events\n", len(events)), nil)
+	res, err := l.transport.retryablePostRequest("/log_event", input, &result, maxRetries)
+
+	if err != nil {
+		global.Logger().LogError(err)
+	}
+
+	respDump, err := httputil.DumpResponse(res, true)
+	if err != nil {
+		global.Logger().LogError(err)
+	}
+
+	global.Logger().Log(fmt.Sprintf("log_event response:\n%s", string(respDump)), nil)
 }
 
 func (l *logger) logDiagnosticsEvents(d *diagnostics) {
 	l.logDiagnosticsEvent(d.initDiagnostics)
 	l.logDiagnosticsEvent(d.syncDiagnostics)
 	l.logDiagnosticsEvent(d.apiDiagnostics)
 }
 
 func (l *logger) logDiagnosticsEvent(d *diagnosticsBase) {
 	if l.options.StatsigLoggerOptions.DisableInitDiagnostics && d.context == InitializeContext {
 		return
 	}

logger_test.go

@@ -10,6 +10,14 @@ import (
 )
 
 func TestLog(t *testing.T) {
+	InitializeGlobalOutputLogger(OutputLoggerOptions{
+		LogCallback: func(message string, err error) {
+			t.Log(message)
+			t.Log(err)
+		},
+		DisableInitDiagnostics: false,
+		DisableSyncDiagnostics: true,
+	})
 	testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) {}))
 	defer testServer.Close()
 	opt := &Options{
@@ -92,4 +100,6 @@ func TestLog(t *testing.T) {
 	if evt3.Time/1000 < nowSecond-2 || evt3.Time/1000 > nowSecond+2 {
 		t.Errorf("Config exposure event time not set correctly.")
 	}
+
+	logger.flush(true)
 }