release: 0.1.0-alpha.54 (#212)

* chore: add UnionUnmarshaler for responses that are interfaces (#211)

* fix(streaming): correctly decode assistant events

* release: 0.1.0-alpha.54

---------

Co-authored-by: stainless-app[bot] <142633134+stainless-app[bot]@users.noreply.github.com>
Co-authored-by: Robert Craigie <[email protected]>

Author: stainless-app[bot]

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.1.0-alpha.53"
+  ".": "0.1.0-alpha.54"
 }

CHANGELOG.md

@@ -1,5 +1,18 @@
 # Changelog
 
+## 0.1.0-alpha.54 (2025-02-05)
+
+Full Changelog: [v0.1.0-alpha.53...v0.1.0-alpha.54](https://github.com/openai/openai-go/compare/v0.1.0-alpha.53...v0.1.0-alpha.54)
+
+### Bug Fixes
+
+* **streaming:** correctly decode assistant events ([38ded46](https://github.com/openai/openai-go/commit/38ded4694480071a768eb4d2790ba4552e001506))
+
+
+### Chores
+
+* add UnionUnmarshaler for responses that are interfaces ([#211](https://github.com/openai/openai-go/issues/211)) ([185d848](https://github.com/openai/openai-go/commit/185d848cd3e9efb48f7468acc06a8b78f3a7b785))
+
 ## 0.1.0-alpha.53 (2025-02-05)
 
 Full Changelog: [v0.1.0-alpha.52...v0.1.0-alpha.53](https://github.com/openai/openai-go/compare/v0.1.0-alpha.52...v0.1.0-alpha.53)

README.md

@@ -25,7 +25,7 @@ Or to pin the version:
 <!-- x-release-please-start-version -->
 
 ```sh
-go get -u 'github.com/openai/[email protected].53'
+go get -u 'github.com/openai/[email protected].54'
 ```
 
 <!-- x-release-please-end -->

internal/apijson/registry.go

@@ -29,3 +29,13 @@ func RegisterUnion(typ reflect.Type, discriminator string, variants ...UnionVari
 		unionVariants[variant.Type] = typ
 	}
 }
+
+// Useful to wrap a union type to force it to use [apijson.UnmarshalJSON] since you cannot define an
+// UnmarshalJSON function on the interface itself.
+type UnionUnmarshaler[T any] struct {
+	Value T
+}
+
+func (c *UnionUnmarshaler[T]) UnmarshalJSON(buf []byte) error {
+	return UnmarshalRoot(buf, &c.Value)
+}

internal/version.go

@@ -2,4 +2,4 @@
 
 package internal
 
-const PackageVersion = "0.1.0-alpha.53" // x-release-please-version
+const PackageVersion = "0.1.0-alpha.54" // x-release-please-version

packages/ssestream/ssestream.go

@@ -158,16 +158,29 @@ func (s *Stream[T]) Next() bool {
 			continue
 		}
 
-		ep := gjson.GetBytes(s.decoder.Event().Data, "error")
-		if ep.Exists() {
-			s.err = fmt.Errorf("received error while streaming: %s", ep.String())
-			return false
-		}
-		s.err = json.Unmarshal(s.decoder.Event().Data, &s.cur)
-		if s.err != nil {
-			return false
+		if s.decoder.Event().Type == "" {
+			ep := gjson.GetBytes(s.decoder.Event().Data, "error")
+			if ep.Exists() {
+				s.err = fmt.Errorf("received error while streaming: %s", ep.String())
+				return false
+			}
+			s.err = json.Unmarshal(s.decoder.Event().Data, &s.cur)
+			if s.err != nil {
+				return false
+			}
+			return true
+		} else {
+			ep := gjson.GetBytes(s.decoder.Event().Data, "error")
+			if ep.Exists() {
+				s.err = fmt.Errorf("received error while streaming: %s", ep.String())
+				return false
+			}
+			s.err = json.Unmarshal([]byte(fmt.Sprintf(`{ "event": %q, "data": %s }`, s.decoder.Event().Type, s.decoder.Event().Data)), &s.cur)
+			if s.err != nil {
+				return false
+			}
+			return true
 		}
-		return true
 	}
 
 	return false