Merge branch 'master' into CHA-1630

Acconut · web-flow · commit 13755ffd3b6a · 2025-12-19T13:42:35.000+01:00
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -17,7 +17,7 @@ jobs:
       max-parallel: 3
       fail-fast: false
       matrix:
-        goVer: ['1.22', '1.23', '1.24']
+        goVer: ['1.23', '1.24', '1.25']
     steps:
       - uses: actions/checkout@v4
 
diff --git a/.github/workflows/lint.yml b/.github/workflows/lint.yml
@@ -19,7 +19,7 @@ jobs:
       - name: Setup Go
         uses: actions/setup-go@v5
         with:
-          go-version: "1.22"
+          go-version: "1.25"
 
       - name: Tidy
         run: go mod tidy -v && git diff --no-patch --exit-code || { git status;  echo 'Unchecked diff, did you forget go mod tidy again?' ; false ; };
diff --git a/.github/workflows/reviewdog.yml b/.github/workflows/reviewdog.yml
@@ -20,7 +20,7 @@ jobs:
       - name: Setup Go
         uses: actions/setup-go@v5
         with:
-          go-version: '1.22'
+          go-version: '1.25'
 
       - name: Install golangci-lint
         run: make install-golangci
diff --git a/.github/workflows/scheduled_test.yml b/.github/workflows/scheduled_test.yml
@@ -14,7 +14,7 @@ jobs:
 
       - uses: actions/setup-go@v3
         with:
-          go-version: "1.22"
+          go-version: "1.25"
 
       - name: Run tests
         env:
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,14 @@
 
 All notable changes to this project will be documented in this file. See [standard-version](https://github.com/conventional-changelog/standard-version) for commit guidelines.
 
+## [8.0.0](https://github.com/GetStream/stream-chat-go/compare/v7.15.1...v8.0.0) (2025-12-19)
+
+
+### Features
+
+* Fix QueryReminders to use filter parameter instead of filter_conditions ([#360](https://github.com/GetStream/stream-chat-go/issues/360)) ([d00843e](https://github.com/GetStream/stream-chat-go/commit/d00843eff6fc2067b9671e609c6c0f2a15140194))
+* support option to mark messages unread by message timestamp ([#358](https://github.com/GetStream/stream-chat-go/issues/358)) ([6cb57a2](https://github.com/GetStream/stream-chat-go/commit/6cb57a2c06727ab867182c88841cf27f749a769a))
+
 ### [7.15.1](https://github.com/GetStream/stream-chat-go/compare/v7.14.2...v7.15.1) (2025-11-12)
 
 
diff --git a/README.md b/README.md
@@ -1,7 +1,7 @@
 # Official Go SDK for [Stream Chat](https://getstream.io/chat/)
 
 [![build](https://github.com/GetStream/stream-chat-go/workflows/build/badge.svg)](https://github.com/GetStream/stream-chat-go/actions)
-[![godoc](https://pkg.go.dev/badge/GetStream/stream-chat-go)](https://pkg.go.dev/github.com/GetStream/stream-chat-go/v7?tab=doc)
+[![godoc](https://pkg.go.dev/badge/GetStream/stream-chat-go)](https://pkg.go.dev/github.com/GetStream/stream-chat-go/v8?tab=doc)
 
 <p align="center">
     <img src="./assets/logo.svg" width="50%" height="50%">
@@ -28,7 +28,7 @@ For the client-side integrations (web and mobile) have a look at the JavaScript,
 ## ⚙️ Installation
 
 ```shell
-go get github.com/GetStream/stream-chat-go/v7
+go get github.com/GetStream/stream-chat-go/v8
 ```
 
 ## ✨ Getting started
@@ -39,7 +39,7 @@ package main
 import (
 	"os"
 
-	stream "github.com/GetStream/stream-chat-go/v7"
+	stream "github.com/GetStream/stream-chat-go/v8"
 )
 
 var APIKey = os.Getenv("STREAM_KEY")
diff --git a/channel.go b/channel.go
@@ -70,6 +70,7 @@ func (m *ChannelMember) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(m.ExtraData, *m)
+	flattenExtraData(m.ExtraData)
 	return nil
 }
 
@@ -144,6 +145,7 @@ func (ch *Channel) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(ch.ExtraData, *ch)
+	flattenExtraData(ch.ExtraData)
 	return nil
 }
 
@@ -191,6 +193,7 @@ func (c *ChannelRequest) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(c.ExtraData, *c)
+	flattenExtraData(c.ExtraData)
 	return nil
 }
 
diff --git a/event.go b/event.go
@@ -108,6 +108,7 @@ func (e *Event) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(e.ExtraData, *e)
+	flattenExtraData(e.ExtraData)
 	return nil
 }
 
@@ -161,6 +162,7 @@ func (e *UserCustomEvent) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(e.ExtraData, *e)
+	flattenExtraData(e.ExtraData)
 	return nil
 }
 
diff --git a/go.mod b/go.mod
@@ -1,6 +1,6 @@
-module github.com/GetStream/stream-chat-go/v7
+module github.com/GetStream/stream-chat-go/v8
 
-go 1.22
+go 1.23
 
 require (
 	github.com/golang-jwt/jwt/v4 v4.5.1
diff --git a/json.go b/json.go
@@ -27,6 +27,22 @@ func removeFromMap(m map[string]interface{}, obj interface{}) {
 	}
 }
 
+// flattenExtraData flattens the nested "extra_data" key if it exists.
+// The API may return custom fields nested under an "extra_data" key,
+// which should be flattened to the root level of the ExtraData map.
+func flattenExtraData(m map[string]interface{}) {
+	if extraData, ok := m["extra_data"]; ok {
+		if extraDataMap, ok := extraData.(map[string]interface{}); ok {
+			// Copy all fields from nested extra_data to root level
+			for k, v := range extraDataMap {
+				m[k] = v
+			}
+			// Remove the nested extra_data key
+			delete(m, "extra_data")
+		}
+	}
+}
+
 func addToMapAndMarshal(m map[string]interface{}, obj interface{}) ([]byte, error) {
 	m2 := copyMap(m)
 
diff --git a/json_test.go b/json_test.go
@@ -16,10 +16,8 @@ func randomExtraData(in interface{}) {
 	}
 	f := v.FieldByName("ExtraData")
 	f.Set(reflect.ValueOf(map[string]interface{}{
-		"extra_data": map[string]interface{}{
-			"mystring": randomString(10),
-			"mybool":   rand.Float64() < 0.5,
-		},
+		"mystring":    randomString(10),
+		"mybool":      rand.Float64() < 0.5,
 		"data":        "custom",
 		"custom_data": "really_custom",
 		"extra": map[string]interface{}{
@@ -69,3 +67,65 @@ func TestJSON(t *testing.T) {
 	var r, r2 Reaction
 	testInvariantJSON(t, &r, &r2)
 }
+
+// TestFlattenExtraData tests the flattenExtraData function directly
+func TestFlattenExtraData(t *testing.T) {
+	t.Run("Flatten nested extra_data", func(t *testing.T) {
+		m := map[string]interface{}{
+			"field1": "value1",
+			"extra_data": map[string]interface{}{
+				"custom_field": "custom_value",
+				"another_field": 123,
+			},
+		}
+
+		flattenExtraData(m)
+
+		// Fields should be flattened
+		require.Equal(t, "custom_value", m["custom_field"])
+		require.Equal(t, 123, m["another_field"])
+		require.Equal(t, "value1", m["field1"])
+		// The nested "extra_data" key should not exist
+		require.NotContains(t, m, "extra_data")
+	})
+
+	t.Run("No extra_data key", func(t *testing.T) {
+		m := map[string]interface{}{
+			"field1": "value1",
+			"field2": 123,
+		}
+
+		flattenExtraData(m)
+
+		// Map should be unchanged
+		require.Equal(t, "value1", m["field1"])
+		require.Equal(t, 123, m["field2"])
+		require.Len(t, m, 2)
+	})
+
+	t.Run("extra_data is not a map", func(t *testing.T) {
+		m := map[string]interface{}{
+			"field1":     "value1",
+			"extra_data": "not_a_map",
+		}
+
+		flattenExtraData(m)
+
+		// extra_data should remain unchanged if it's not a map
+		require.Equal(t, "not_a_map", m["extra_data"])
+		require.Equal(t, "value1", m["field1"])
+	})
+
+	t.Run("Empty extra_data map", func(t *testing.T) {
+		m := map[string]interface{}{
+			"field1":     "value1",
+			"extra_data": map[string]interface{}{},
+		}
+
+		flattenExtraData(m)
+
+		// Empty extra_data should be removed
+		require.NotContains(t, m, "extra_data")
+		require.Equal(t, "value1", m["field1"])
+	})
+}
diff --git a/message.go b/message.go
@@ -85,6 +85,7 @@ func (m *Message) UnmarshalJSON(data []byte) error {
 		return err
 	}
 	removeFromMap(m.ExtraData, *m)
+	flattenExtraData(m.ExtraData)
 	return nil
 }
 
@@ -168,6 +169,7 @@ func (s *messageRequestMessage) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(s.ExtraData, *s)
+	flattenExtraData(s.ExtraData)
 	return nil
 }
 
@@ -206,6 +208,7 @@ func (a *Attachment) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(a.ExtraData, *a)
+	flattenExtraData(a.ExtraData)
 	return nil
 }
 
diff --git a/message_history.go b/message_history.go
@@ -45,6 +45,7 @@ func (m *MessageHistoryEntry) UnmarshalJSON(data []byte) error {
 		return err
 	}
 	removeFromMap(m.ExtraData, *m)
+	flattenExtraData(m.ExtraData)
 	return nil
 }
 
diff --git a/reaction.go b/reaction.go
@@ -32,6 +32,7 @@ func (s *Reaction) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(s.ExtraData, *s)
+	flattenExtraData(s.ExtraData)
 	return nil
 }
 
diff --git a/reminders_unit_test.go b/reminders_unit_test.go
@@ -7,7 +7,7 @@ import (
 	"testing"
 	"time"
 
-	stream_chat "github.com/GetStream/stream-chat-go/v7"
+	stream_chat "github.com/GetStream/stream-chat-go/v8"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
diff --git a/user.go b/user.go
@@ -87,6 +87,7 @@ func (u *User) UnmarshalJSON(data []byte) error {
 	}
 
 	removeFromMap(u.ExtraData, *u)
+	flattenExtraData(u.ExtraData)
 	return nil
 }
 
diff --git a/version.go b/version.go
@@ -5,9 +5,9 @@ import (
 )
 
 const (
-	versionMajor = 7
-	versionMinor = 15
-	versionPatch = 1
+	versionMajor = 8
+	versionMinor = 0
+	versionPatch = 0
 )
 
 // Version returns the version of the library.

Original file line number	Diff line number	Diff line change
`@@ -70,6 +70,7 @@ func (m *ChannelMember) UnmarshalJSON(data []byte) error {`
`70`	`70`	`}`
`71`	`71`
`72`	`72`	`removeFromMap(m.ExtraData, *m)`
	`73`	`+ flattenExtraData(m.ExtraData)`
`73`	`74`	`return nil`
`74`	`75`	`}`
`75`	`76`
`@@ -144,6 +145,7 @@ func (ch *Channel) UnmarshalJSON(data []byte) error {`
`144`	`145`	`}`
`145`	`146`
`146`	`147`	`removeFromMap(ch.ExtraData, *ch)`
	`148`	`+ flattenExtraData(ch.ExtraData)`
`147`	`149`	`return nil`
`148`	`150`	`}`
`149`	`151`
`@@ -191,6 +193,7 @@ func (c *ChannelRequest) UnmarshalJSON(data []byte) error {`
`191`	`193`	`}`
`192`	`194`
`193`	`195`	`removeFromMap(c.ExtraData, *c)`
	`196`	`+ flattenExtraData(c.ExtraData)`
`194`	`197`	`return nil`
`195`	`198`	`}`
`196`	`199`
Original file line number	Diff line number	Diff line change
`@@ -108,6 +108,7 @@ func (e *Event) UnmarshalJSON(data []byte) error {`
`108`	`108`	`}`
`109`	`109`
`110`	`110`	`removeFromMap(e.ExtraData, *e)`
	`111`	`+ flattenExtraData(e.ExtraData)`
`111`	`112`	`return nil`
`112`	`113`	`}`
`113`	`114`
`@@ -161,6 +162,7 @@ func (e *UserCustomEvent) UnmarshalJSON(data []byte) error {`
`161`	`162`	`}`
`162`	`163`
`163`	`164`	`removeFromMap(e.ExtraData, *e)`
	`165`	`+ flattenExtraData(e.ExtraData)`
`164`	`166`	`return nil`
`165`	`167`	`}`
`166`	`168`