Make redis cache update synchronous and stabilize websocket test

Author: devblac

adapters/redis/storage.go

@@ -169,15 +169,10 @@ func (s *Store) GetState(ctx context.Context, userID core.UserID) (core.UserStat
 		return core.UserState{}, err
 	}
 
-	// Update cache asynchronously (don't block the response)
-	go func() {
-		ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
-		defer cancel()
-		if err := s.updateStateCache(ctx, userID, state); err != nil {
-			// Cache update failures are not critical, just log them
-			// We don't fail the main operation for cache issues
-		}
-	}()
+	// Update cache (best-effort); keep it synchronous for determinism.
+	ctxCache, cancel := context.WithTimeout(context.Background(), 1*time.Second)
+	defer cancel()
+	_ = s.updateStateCache(ctxCache, userID, state)
 
 	return state, nil
 }

adapters/websocket/adapter_test.go

@@ -25,10 +25,13 @@ func TestHandlerStreamsEvents(t *testing.T) {
 	}
 	defer conn.Close()
 
+	// ensure subscriber goroutine is ready
+	time.Sleep(10 * time.Millisecond)
+
 	ev := core.NewPointsAdded("alice", core.MetricXP, 5, 5)
 	hub.Broadcast(context.Background(), ev)
 
-	_ = conn.SetReadDeadline(time.Now().Add(time.Second))
+	_ = conn.SetReadDeadline(time.Now().Add(2 * time.Second))
 	_, msg, err := conn.ReadMessage()
 	if err != nil {
 		t.Fatalf("read message: %v", err)