feat(api): manual updates

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 88
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/openai%2Fopenai-b2a451656ca64d30d174391ebfd94806b4de3ab76dc55b92843cfb7f1a54ecb6.yml
-openapi_spec_hash: 27d9691b400f28c17ef063a1374048b0
-config_hash: e822d0c9082c8b312264403949243179
+configured_endpoints: 111
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/openai%2Fopenai-721e6ccaa72205ee14c71f8163129920464fb814b95d3df9567a9476bbd9b7fb.yml
+openapi_spec_hash: 2115413a21df8b5bf9e4552a74df4312
+config_hash: 9606bb315a193bfd8da0459040143242

openai-java-core/src/main/kotlin/com/openai/core/handlers/SseHandler.kt

@@ -134,9 +134,10 @@ private class SseState(
 }
 
 @JvmSynthetic
-internal inline fun <reified T> Handler<StreamResponse<SseMessage>>.mapJson():
-    Handler<StreamResponse<T>> =
+internal inline fun <reified T> Handler<StreamResponse<SseMessage>>.mapJson(
+    includeEventAndData: Boolean = false
+): Handler<StreamResponse<T>> =
     object : Handler<StreamResponse<T>> {
         override fun handle(response: HttpResponse): StreamResponse<T> =
-            this@mapJson.handle(response).map { it.json<T>() }
+            this@mapJson.handle(response).map { it.json<T>(includeEventAndData) }
     }

openai-java-core/src/main/kotlin/com/openai/core/http/SseMessage.kt

@@ -41,12 +41,21 @@ private constructor(
         fun build(): SseMessage = SseMessage(jsonMapper!!, event, data, id, retry)
     }
 
-    inline fun <reified T> json(): T =
+    inline fun <reified T> json(includeEventAndData: Boolean = false): T {
+        var jsonNode = jsonNode
+        if (includeEventAndData) {
+            val newJsonNode = jsonMapper.createObjectNode()
+            event?.let { newJsonNode.put("event", event) }
+            newJsonNode.replace("data", jsonNode)
+            jsonNode = newJsonNode
+        }
+
         try {
-            jsonMapper.readerFor(jacksonTypeRef<T>()).readValue(jsonNode)
+            return jsonMapper.readerFor(jacksonTypeRef<T>()).readValue(jsonNode)
         } catch (e: Exception) {
             throw OpenAIInvalidDataException("Error reading response", e)
         }
+    }
 
     private val jsonNode by lazy {
         try {