fix(requestOptions): request options headers override previous values (#353)

Author: aallam

CHANGELOG.md

@@ -6,6 +6,7 @@
 
 ### Fixed
 - **chat**: enhance flow cancel capability (#333)
+- **config**: request options headers override previous values (#353)
 
 ## 3.7.2
 > Published 28 Apr 2024

openai-client/src/commonMain/kotlin/com.aallam.openai.client/internal/extension/HttpRequestBuilder.kt

@@ -9,7 +9,10 @@ import io.ktor.client.request.*
  */
 internal fun HttpRequestBuilder.requestOptions(requestOptions: RequestOptions? = null) {
     if (requestOptions == null) return
-    requestOptions.headers.forEach { (key, value) -> headers.append(key, value) }
+    requestOptions.headers.forEach { (key, value) ->
+        if (headers.contains(key)) headers.remove(key)
+        headers[key] = value
+    }
     requestOptions.urlParameters.forEach { (key, value) -> url.parameters.append(key, value) }
     requestOptions.timeout?.let { timeout ->
         timeout {

openai-client/src/commonTest/kotlin/com/aallam/openai/client/misc/TestRequestOptions.kt

@@ -32,4 +32,31 @@ class TestRequestOptions {
         client.models(requestOptions = requestOptions)
         assertEquals(requestHeaders?.get(key), requestOptions.headers[key])
     }
+
+    @Test
+    fun testOverride() = runTest {
+        val key = "OpenAI-Beta"
+        val requestOptions = RequestOptions(
+            headers = mapOf(key to "assistants=v0"),
+        )
+        var requestHeaders: Map<String, String>? = null
+        val client = OpenAI(
+            token = token,
+            headers = mapOf(key to "assistants=v3"),
+            httpClientConfig = {
+                install("RequestInterceptor") {
+                    requestPipeline.intercept(HttpRequestPipeline.Before) {
+                        requestHeaders = context.headers.entries().associate { it.key to it.value.first() }
+                    }
+                }
+            }
+        )
+
+        try {
+            client.assistants(requestOptions = requestOptions)
+        } catch (e: Exception) {
+            // skip
+        }
+        assertEquals(requestHeaders?.get(key), requestOptions.headers[key])
+    }
 }