Adjust version to 9.0.0. Fix some flaky tests.

Author: KGronek-Pubnub

.pubnub.yml

@@ -1,8 +1,8 @@
 ---
-version: 8.2.1
+version: 9.0.0
 changelog:
   - date: 2026-06-08
-    version: 8.2.1
+    version: 9.0.0
     changes:
       - type: improvement
         text: "Bump minimum supported Go version to 1.25. **BREAKING CHANGE**."
@@ -837,7 +837,7 @@ sdks:
             distribution-type: package
             distribution-repository: GitHub
             package-name: Go
-            location: https://github.com/pubnub/go/releases/tag/8.2.1
+            location: https://github.com/pubnub/go/releases/tag/9.0.0
             requires:
               -
                 name: "Go"

CHANGELOG.md

@@ -1,4 +1,4 @@
-## 8.2.1
+## 9.0.0
 June 08 2026
 
 #### Modified

pubnub.go

@@ -18,7 +18,7 @@ import (
 // Default constants
 const (
 	// Version :the version of the SDK
-	Version = "8.2.1"
+	Version = "9.0.0"
 	// MaxSequence for publish messages
 	MaxSequence = 65535
 )

tests/e2e/objectsV2_test.go

@@ -63,13 +63,18 @@ func TestObjectsV2ChannelMetadataSetUpdateGetRemove(t *testing.T) {
 		a.Equal(channelType, res.Data.Type)
 	}
 
-	getRes, st, err := pn.GetChannelMetadata().Include(incl).Channel(id).Execute()
-	a.Nil(err)
-	a.Equal(200, st.StatusCode)
-	if getRes != nil {
-		a.Equal(statusUpdated, getRes.Data.Status)
-		a.Equal(channelType, getRes.Data.Type)
-	}
+	// PubNub Objects v2 GET is eventually consistent against SetChannelMetadata writes
+	// (CI hits a stale replica intermittently). Poll until the updated status propagates
+	// to the read path before asserting on it; without this the assertion sees the
+	// previous status ("active" instead of "inactive") and the test fails non-deterministically.
+	getRes := eventually(t, 10*time.Second, 250*time.Millisecond,
+		fmt.Sprintf("channel %s status update propagates to GetChannelMetadata", id),
+		func() (*pubnub.PNGetChannelMetadataResponse, bool) {
+			r, _, e := pn.GetChannelMetadata().Include(incl).Channel(id).Execute()
+			return r, e == nil && r != nil && r.Data.Status == statusUpdated
+		})
+	a.Equal(statusUpdated, getRes.Data.Status)
+	a.Equal(channelType, getRes.Data.Type)
 
 }
 
@@ -378,15 +383,17 @@ func TestObjectsV2ChannelMetadataETagConditionalUpdate(t *testing.T) {
 	a.NotEmpty(res.Data.ETag)
 	initialETag := res.Data.ETag
 
-	// Step 2: Get metadata to verify ETag
-	getRes, st, err := pn.GetChannelMetadata().
-		Include(incl).
-		Channel(id).
-		Execute()
-
-	a.Nil(err)
-	a.Equal(200, st.StatusCode)
-	a.NotNil(getRes)
+	// Step 2: Get metadata to verify ETag.
+	// PubNub Objects v2 is eventually consistent against just-created objects, so CI
+	// regularly observes the GET hitting a replica that hasn't seen the Set yet and
+	// returning 404. Poll until the just-created object becomes visible with the
+	// expected ETag, otherwise the next line panics dereferencing getRes.Data.
+	getRes := eventually(t, 10*time.Second, 250*time.Millisecond,
+		fmt.Sprintf("channel %s metadata visible to GET after Set (initial ETag)", id),
+		func() (*pubnub.PNGetChannelMetadataResponse, bool) {
+			r, _, e := pn.GetChannelMetadata().Include(incl).Channel(id).Execute()
+			return r, e == nil && r != nil && r.Data.ETag == initialETag
+		})
 	a.Equal(initialETag, getRes.Data.ETag)
 
 	// Step 3: Try to update with incorrect ETag - should fail with 412
@@ -403,16 +410,17 @@ func TestObjectsV2ChannelMetadataETagConditionalUpdate(t *testing.T) {
 	a.Equal(412, st.StatusCode)
 	a.Equal(pubnub.PNPreconditionFailedCategory, st.Category)
 
-	// Step 4: Verify data was NOT changed
-	getRes, st, err = pn.GetChannelMetadata().
-		Include(incl).
-		Channel(id).
-		Execute()
-
-	a.Nil(err)
-	a.Equal(200, st.StatusCode)
-	a.Equal(initialName, getRes.Data.Name) // Should still be initial name
-	a.Equal(initialETag, getRes.Data.ETag) // ETag unchanged
+	// Step 4: Verify data was NOT changed. Step 3's 412 means the write was rejected on
+	// the primary, but a subsequent GET can still hit a different replica that's lagging;
+	// poll until any replica we hit confirms the initial state is intact.
+	getRes = eventually(t, 10*time.Second, 250*time.Millisecond,
+		fmt.Sprintf("channel %s metadata still shows initial state after failed conditional update", id),
+		func() (*pubnub.PNGetChannelMetadataResponse, bool) {
+			r, _, e := pn.GetChannelMetadata().Include(incl).Channel(id).Execute()
+			return r, e == nil && r != nil && r.Data.Name == initialName && r.Data.ETag == initialETag
+		})
+	a.Equal(initialName, getRes.Data.Name)
+	a.Equal(initialETag, getRes.Data.ETag)
 
 	// Step 5: Update with correct ETag - should succeed
 	res, st, err = pn.SetChannelMetadata().
@@ -429,14 +437,14 @@ func TestObjectsV2ChannelMetadataETagConditionalUpdate(t *testing.T) {
 	a.NotEqual(initialETag, res.Data.ETag) // ETag should change after update
 	newETag := res.Data.ETag
 
-	// Step 6: Verify the update was successful
-	getRes, st, err = pn.GetChannelMetadata().
-		Include(incl).
-		Channel(id).
-		Execute()
-
-	a.Nil(err)
-	a.Equal(200, st.StatusCode)
+	// Step 6: Verify the update was successful. Same read-after-write story as Step 2;
+	// poll until the update is visible everywhere we land.
+	getRes = eventually(t, 10*time.Second, 250*time.Millisecond,
+		fmt.Sprintf("channel %s metadata update propagates to GET (new ETag)", id),
+		func() (*pubnub.PNGetChannelMetadataResponse, bool) {
+			r, _, e := pn.GetChannelMetadata().Include(incl).Channel(id).Execute()
+			return r, e == nil && r != nil && r.Data.Name == updatedName && r.Data.ETag == newETag
+		})
 	a.Equal(updatedName, getRes.Data.Name)
 	a.Equal(newETag, getRes.Data.ETag)
 }