feat(api): update via SDK Studio (#40)

Author: stainless-app[bot]

.devcontainer/Dockerfile

@@ -1,14 +1,14 @@
 # syntax=docker/dockerfile:1
 FROM debian:bookworm-slim
 
-RUN apt-get update && apt-get install -y \
+RUN apt-get update && apt-get install -y --no-install-recommends \
   libxkbcommon0 \
   ca-certificates \
   ca-certificates-java \
   make \
   curl \
   git \
-  openjdk-17-jdk \
+  openjdk-17-jdk-headless \
   unzip \
   libc++1 \
   vim \

README.md

@@ -77,16 +77,17 @@ import com.openlayer.api.models.InferencePipelineDataStreamResponse;
 import java.util.List;
 
 InferencePipelineDataStreamParams params = InferencePipelineDataStreamParams.builder()
-    .rows(List.of(InferencePipelineDataStreamParams.Row.builder().build()))
+    .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e")
     .config(InferencePipelineDataStreamParams.Config.ofLlmData(InferencePipelineDataStreamParams.Config.LlmData.builder()
         .outputColumnName("output")
         .costColumnName("cost")
         .inputVariableNames(List.of("user_query"))
         .numOfTokenColumnName("tokens")
         .timestampColumnName("timestamp")
         .build()))
+    .row(List.of(InferencePipelineDataStreamParams.Row.builder().build()))
     .build();
-InferencePipelineDataStreamResponse inferencePipelineDataStreamResponse = client.inferencePipelines().data().stream(params);
+InferencePipelineDataStreamResponse response = client.inferencePipelines().data().stream(params);
 ```
 
 ---
@@ -118,7 +119,7 @@ InferencePipelineDataStreamParams params = InferencePipelineDataStreamParams.bui
 When receiving a response, the Openlayer Java SDK will deserialize it into instances of the typed model classes. In rare cases, the API may return a response property that doesn't match the expected Java type. If you directly access the mistaken property, the SDK will throw an unchecked `OpenlayerInvalidDataException` at runtime. If you would prefer to check in advance that that response is completely well-typed, call `.validate()` on the returned model.
 
 ```java
-InferencePipelineDataStreamResponse inferencePipelineDataStreamResponse = client.inferencePipelines().data().stream().validate();
+InferencePipelineDataStreamResponse response = client.inferencePipelines().data().stream().validate();
 ```
 
 ### Response properties as JSON
@@ -148,7 +149,7 @@ if (field.isMissing()) {
 Sometimes, the server response may include additional properties that are not yet available in this library's types. You can access them using the model's `_additionalProperties` method:
 
 ```java
-JsonValue secret = inferencePipelineDataStreamResponse._additionalProperties().get("secret_field");
+JsonValue secret = projectCreateResponse._additionalProperties().get("secret_field");
 ```
 
 ---

buildSrc/src/main/kotlin/openlayer.java.gradle.kts

@@ -19,6 +19,7 @@ configure<SpotlessExtension> {
         importOrder()
         removeUnusedImports()
         palantirJavaFormat()
+        toggleOffOn()
     }
 }
 

buildSrc/src/main/kotlin/openlayer.kotlin.gradle.kts

@@ -16,6 +16,7 @@ kotlin {
 configure<SpotlessExtension> {
     kotlin {
         ktfmt().kotlinlangStyle()
+        toggleOffOn()
     }
 }
 

openlayer-java-client-okhttp/src/main/kotlin/com/openlayer/api/client/okhttp/OkHttpClient.kt

@@ -66,7 +66,6 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
         request.body?.run { future.whenComplete { _, _ -> close() } }
 
         val call = getClient(requestOptions).newCall(request.toRequest())
-
         call.enqueue(
             object : Callback {
                 override fun onResponse(call: Call, response: Response) {
@@ -90,7 +89,7 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
 
     private fun HttpRequest.toRequest(): Request {
         var body: RequestBody? = body?.toRequestBody()
-        // OkHttpClient always requires a request body for PUT and POST methods
+        // OkHttpClient always requires a request body for PUT and POST methods.
         if (body == null && (method == HttpMethod.PUT || method == HttpMethod.POST)) {
             body = "".toRequestBody()
         }
@@ -118,43 +117,27 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
         val length = contentLength()
 
         return object : RequestBody() {
-            override fun contentType(): MediaType? {
-                return mediaType
-            }
+            override fun contentType(): MediaType? = mediaType
 
-            override fun contentLength(): Long {
-                return length
-            }
+            override fun contentLength(): Long = length
 
-            override fun isOneShot(): Boolean {
-                return !repeatable()
-            }
+            override fun isOneShot(): Boolean = !repeatable()
 
-            override fun writeTo(sink: BufferedSink) {
-                writeTo(sink.outputStream())
-            }
+            override fun writeTo(sink: BufferedSink) = writeTo(sink.outputStream())
         }
     }
 
     private fun Response.toResponse(): HttpResponse {
         val headers = headers.toHeaders()
 
         return object : HttpResponse {
-            override fun statusCode(): Int {
-                return code
-            }
+            override fun statusCode(): Int = code
 
-            override fun headers(): ListMultimap<String, String> {
-                return headers
-            }
+            override fun headers(): ListMultimap<String, String> = headers
 
-            override fun body(): InputStream {
-                return body!!.byteStream()
-            }
+            override fun body(): InputStream = body!!.byteStream()
 
-            override fun close() {
-                body!!.close()
-            }
+            override fun close() = body!!.close()
         }
     }
 
@@ -163,9 +146,7 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
             MultimapBuilder.treeKeys(String.CASE_INSENSITIVE_ORDER)
                 .arrayListValues()
                 .build<String, String>()
-
         forEach { pair -> headers.put(pair.first, pair.second) }
-
         return headers
     }
 
@@ -176,7 +157,7 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
     class Builder {
 
         private var baseUrl: HttpUrl? = null
-        // default timeout is 1 minute
+        // The default timeout is 1 minute.
         private var timeout: Duration = Duration.ofSeconds(60)
         private var proxy: Proxy? = null
 
@@ -186,8 +167,8 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
 
         fun proxy(proxy: Proxy?) = apply { this.proxy = proxy }
 
-        fun build(): OkHttpClient {
-            return OkHttpClient(
+        fun build(): OkHttpClient =
+            OkHttpClient(
                 okhttp3.OkHttpClient.Builder()
                     .connectTimeout(timeout)
                     .readTimeout(timeout)
@@ -197,6 +178,5 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
                     .build(),
                 checkNotNull(baseUrl) { "`baseUrl` is required but was not set" },
             )
-        }
     }
 }

openlayer-java-client-okhttp/src/main/kotlin/com/openlayer/api/client/okhttp/OpenlayerOkHttpClient.kt

@@ -23,7 +23,7 @@ class OpenlayerOkHttpClient private constructor() {
 
         private var clientOptions: ClientOptions.Builder = ClientOptions.builder()
         private var baseUrl: String = ClientOptions.PRODUCTION_URL
-        // default timeout for client is 1 minute
+        // The default timeout for the client is 1 minute.
         private var timeout: Duration = Duration.ofSeconds(60)
         private var proxy: Proxy? = null
 
@@ -66,8 +66,8 @@ class OpenlayerOkHttpClient private constructor() {
 
         fun fromEnv() = apply { clientOptions.fromEnv() }
 
-        fun build(): OpenlayerClient {
-            return OpenlayerClientImpl(
+        fun build(): OpenlayerClient =
+            OpenlayerClientImpl(
                 clientOptions
                     .httpClient(
                         OkHttpClient.builder()
@@ -78,6 +78,5 @@ class OpenlayerOkHttpClient private constructor() {
                     )
                     .build()
             )
-        }
     }
 }

openlayer-java-client-okhttp/src/main/kotlin/com/openlayer/api/client/okhttp/OpenlayerOkHttpClientAsync.kt

@@ -23,7 +23,7 @@ class OpenlayerOkHttpClientAsync private constructor() {
 
         private var clientOptions: ClientOptions.Builder = ClientOptions.builder()
         private var baseUrl: String = ClientOptions.PRODUCTION_URL
-        // default timeout for client is 1 minute
+        // The default timeout for the client is 1 minute.
         private var timeout: Duration = Duration.ofSeconds(60)
         private var proxy: Proxy? = null
 
@@ -66,8 +66,8 @@ class OpenlayerOkHttpClientAsync private constructor() {
 
         fun fromEnv() = apply { clientOptions.fromEnv() }
 
-        fun build(): OpenlayerClientAsync {
-            return OpenlayerClientAsyncImpl(
+        fun build(): OpenlayerClientAsync =
+            OpenlayerClientAsyncImpl(
                 clientOptions
                     .httpClient(
                         OkHttpClient.builder()
@@ -78,6 +78,5 @@ class OpenlayerOkHttpClientAsync private constructor() {
                     )
                     .build()
             )
-        }
     }
 }

openlayer-java-core/src/main/kotlin/com/openlayer/api/client/OpenlayerClient.kt

@@ -1,7 +1,5 @@
 // File generated from our OpenAPI spec by Stainless.
 
-@file:Suppress("OVERLOADS_INTERFACE") // See https://youtrack.jetbrains.com/issue/KT-36102
-
 package com.openlayer.api.client
 
 import com.openlayer.api.models.*

openlayer-java-core/src/main/kotlin/com/openlayer/api/client/OpenlayerClientAsync.kt

@@ -1,7 +1,5 @@
 // File generated from our OpenAPI spec by Stainless.
 
-@file:Suppress("OVERLOADS_INTERFACE") // See https://youtrack.jetbrains.com/issue/KT-36102
-
 package com.openlayer.api.client
 
 import com.openlayer.api.models.*

openlayer-java-core/src/main/kotlin/com/openlayer/api/client/OpenlayerClientAsyncImpl.kt

@@ -3,30 +3,41 @@
 package com.openlayer.api.client
 
 import com.openlayer.api.core.ClientOptions
-import com.openlayer.api.core.http.HttpResponse.Handler
-import com.openlayer.api.errors.OpenlayerError
+import com.openlayer.api.core.getPackageVersion
 import com.openlayer.api.models.*
 import com.openlayer.api.services.async.*
-import com.openlayer.api.services.errorHandler
 
 class OpenlayerClientAsyncImpl
 constructor(
     private val clientOptions: ClientOptions,
 ) : OpenlayerClientAsync {
 
-    private val errorHandler: Handler<OpenlayerError> = errorHandler(clientOptions.jsonMapper)
+    private val clientOptionsWithUserAgent =
+        if (clientOptions.headers.containsKey("User-Agent")) clientOptions
+        else
+            clientOptions
+                .toBuilder()
+                .putHeader("User-Agent", "${javaClass.simpleName}/Java ${getPackageVersion()}")
+                .build()
 
+    // Pass the original clientOptions so that this client sets its own User-Agent.
     private val sync: OpenlayerClient by lazy { OpenlayerClientImpl(clientOptions) }
 
-    private val projects: ProjectServiceAsync by lazy { ProjectServiceAsyncImpl(clientOptions) }
+    private val projects: ProjectServiceAsync by lazy {
+        ProjectServiceAsyncImpl(clientOptionsWithUserAgent)
+    }
 
-    private val commits: CommitServiceAsync by lazy { CommitServiceAsyncImpl(clientOptions) }
+    private val commits: CommitServiceAsync by lazy {
+        CommitServiceAsyncImpl(clientOptionsWithUserAgent)
+    }
 
     private val inferencePipelines: InferencePipelineServiceAsync by lazy {
-        InferencePipelineServiceAsyncImpl(clientOptions)
+        InferencePipelineServiceAsyncImpl(clientOptionsWithUserAgent)
     }
 
-    private val storage: StorageServiceAsync by lazy { StorageServiceAsyncImpl(clientOptions) }
+    private val storage: StorageServiceAsync by lazy {
+        StorageServiceAsyncImpl(clientOptionsWithUserAgent)
+    }
 
     override fun sync(): OpenlayerClient = sync
 

openlayer-java-core/src/main/kotlin/com/openlayer/api/client/OpenlayerClientImpl.kt

@@ -3,30 +3,35 @@
 package com.openlayer.api.client
 
 import com.openlayer.api.core.ClientOptions
-import com.openlayer.api.core.http.HttpResponse.Handler
-import com.openlayer.api.errors.OpenlayerError
+import com.openlayer.api.core.getPackageVersion
 import com.openlayer.api.models.*
 import com.openlayer.api.services.blocking.*
-import com.openlayer.api.services.errorHandler
 
 class OpenlayerClientImpl
 constructor(
     private val clientOptions: ClientOptions,
 ) : OpenlayerClient {
 
-    private val errorHandler: Handler<OpenlayerError> = errorHandler(clientOptions.jsonMapper)
+    private val clientOptionsWithUserAgent =
+        if (clientOptions.headers.containsKey("User-Agent")) clientOptions
+        else
+            clientOptions
+                .toBuilder()
+                .putHeader("User-Agent", "${javaClass.simpleName}/Java ${getPackageVersion()}")
+                .build()
 
+    // Pass the original clientOptions so that this client sets its own User-Agent.
     private val async: OpenlayerClientAsync by lazy { OpenlayerClientAsyncImpl(clientOptions) }
 
-    private val projects: ProjectService by lazy { ProjectServiceImpl(clientOptions) }
+    private val projects: ProjectService by lazy { ProjectServiceImpl(clientOptionsWithUserAgent) }
 
-    private val commits: CommitService by lazy { CommitServiceImpl(clientOptions) }
+    private val commits: CommitService by lazy { CommitServiceImpl(clientOptionsWithUserAgent) }
 
     private val inferencePipelines: InferencePipelineService by lazy {
-        InferencePipelineServiceImpl(clientOptions)
+        InferencePipelineServiceImpl(clientOptionsWithUserAgent)
     }
 
-    private val storage: StorageService by lazy { StorageServiceImpl(clientOptions) }
+    private val storage: StorageService by lazy { StorageServiceImpl(clientOptionsWithUserAgent) }
 
     override fun async(): OpenlayerClientAsync = async