feat: better error handling (allow to see the request body when request fail)

Stream29 · Stream29 · commit ba65ac7feb02 · 2025-05-06T17:51:12.000+08:00
diff --git a/src/main/kotlin/io/github/stream29/proxy/client/ChatSSE.kt b/src/main/kotlin/io/github/stream29/proxy/client/ChatSSE.kt
@@ -29,7 +29,8 @@ suspend fun createStreamingChatCompletion(
             append(HttpHeaders.Authorization, "Bearer $apiKey")
         }
     }
-    val channel: ByteReadChannel = statement.body()
+    val channel = runCatching { statement.body<ByteReadChannel>() }
+        .getOrElse { return flow { throw it } }
     return flow {
         while (currentCoroutineContext().isActive && !channel.isClosedForRead) {
             val line = channel.readUTF8Line()

Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,8 @@ suspend fun createStreamingChatCompletion(`
`29`	`29`	`append(HttpHeaders.Authorization, "Bearer $apiKey")`
`30`	`30`	`}`
`31`	`31`	`}`
`32`		`- val channel: ByteReadChannel = statement.body()`
	`32`	`+ val channel = runCatching { statement.body<ByteReadChannel>() }`
	`33`	`+ .getOrElse { return flow { throw it } }`
`33`	`34`	`return flow {`
`34`	`35`	`while (currentCoroutineContext().isActive && !channel.isClosedForRead) {`
`35`	`36`	`val line = channel.readUTF8Line()`