feat: update client to 3.143.0 compatibility

Author: Steffen911

README.md

@@ -79,4 +79,5 @@ To publish to Maven Central, you need to configure the following secrets in your
 3. Generate the new client code using `npx fern-api generate --api server`.
 4. Manually set the `package` across all files to `com.langfuse.client`.
 5. Overwrite `this.clientOptionsBuilder.addHeader("Authorization", "Bearer " + encodedToken);` to `Basic` in LangfuseClientBuilder.java.
-6. Commit the changes in langfuse-java and push them to the repository.
+6. Adjust Javadoc strings with HTML properties as the apidocs package does not support them.
+7. Commit the changes in langfuse-java and push them to the repository.

src/main/java/com/langfuse/client/LangfuseClient.java

@@ -18,8 +18,10 @@
 import com.langfuse.client.resources.llmconnections.LlmConnectionsClient;
 import com.langfuse.client.resources.media.MediaClient;
 import com.langfuse.client.resources.metrics.MetricsClient;
+import com.langfuse.client.resources.metricsv2.MetricsV2Client;
 import com.langfuse.client.resources.models.ModelsClient;
 import com.langfuse.client.resources.observations.ObservationsClient;
+import com.langfuse.client.resources.observationsv2.ObservationsV2Client;
 import com.langfuse.client.resources.opentelemetry.OpentelemetryClient;
 import com.langfuse.client.resources.organizations.OrganizationsClient;
 import com.langfuse.client.resources.projects.ProjectsClient;
@@ -55,10 +57,14 @@ public class LangfuseClient {
 
   protected final Supplier<MediaClient> mediaClient;
 
+  protected final Supplier<MetricsV2Client> metricsV2Client;
+
   protected final Supplier<MetricsClient> metricsClient;
 
   protected final Supplier<ModelsClient> modelsClient;
 
+  protected final Supplier<ObservationsV2Client> observationsV2Client;
+
   protected final Supplier<ObservationsClient> observationsClient;
 
   protected final Supplier<OpentelemetryClient> opentelemetryClient;
@@ -95,8 +101,10 @@ public LangfuseClient(ClientOptions clientOptions) {
     this.ingestionClient = Suppliers.memoize(() -> new IngestionClient(clientOptions));
     this.llmConnectionsClient = Suppliers.memoize(() -> new LlmConnectionsClient(clientOptions));
     this.mediaClient = Suppliers.memoize(() -> new MediaClient(clientOptions));
+    this.metricsV2Client = Suppliers.memoize(() -> new MetricsV2Client(clientOptions));
     this.metricsClient = Suppliers.memoize(() -> new MetricsClient(clientOptions));
     this.modelsClient = Suppliers.memoize(() -> new ModelsClient(clientOptions));
+    this.observationsV2Client = Suppliers.memoize(() -> new ObservationsV2Client(clientOptions));
     this.observationsClient = Suppliers.memoize(() -> new ObservationsClient(clientOptions));
     this.opentelemetryClient = Suppliers.memoize(() -> new OpentelemetryClient(clientOptions));
     this.organizationsClient = Suppliers.memoize(() -> new OrganizationsClient(clientOptions));
@@ -151,6 +159,10 @@ public MediaClient media() {
     return this.mediaClient.get();
   }
 
+  public MetricsV2Client metricsV2() {
+    return this.metricsV2Client.get();
+  }
+
   public MetricsClient metrics() {
     return this.metricsClient.get();
   }
@@ -159,6 +171,10 @@ public ModelsClient models() {
     return this.modelsClient.get();
   }
 
+  public ObservationsV2Client observationsV2() {
+    return this.observationsV2Client.get();
+  }
+
   public ObservationsClient observations() {
     return this.observationsClient.get();
   }

src/main/java/com/langfuse/client/core/ClientOptions.java

@@ -27,7 +27,7 @@ private ClientOptions(Environment environment, Map<String, String> headers,
     this.environment = environment;
     this.headers = new HashMap<>();
     this.headers.putAll(headers);
-    this.headers.putAll(new HashMap<String,String>() {{put("X-Fern-Language", "JAVA");put("X-Fern-SDK-Name", "com.langfuse.fern:langfuse-sdk");put("X-Fern-SDK-Version", "0.0.2565");}});
+    this.headers.putAll(new HashMap<String,String>() {{put("X-Fern-Language", "JAVA");put("X-Fern-SDK-Name", "com.langfuse.fern:langfuse-sdk");put("X-Fern-SDK-Version", "0.0.2841");}});
     this.headerSuppliers = headerSuppliers;
     this.httpClient = httpClient;
     this.timeout = timeout;

src/main/java/com/langfuse/client/resources/commons/types/ScoreConfig.java

@@ -39,7 +39,7 @@ public final class ScoreConfig {
 
   private final String projectId;
 
-  private final ScoreDataType dataType;
+  private final ScoreConfigDataType dataType;
 
   private final boolean isArchived;
 
@@ -54,7 +54,7 @@ public final class ScoreConfig {
   private final Map<String, Object> additionalProperties;
 
   private ScoreConfig(String id, String name, OffsetDateTime createdAt, OffsetDateTime updatedAt,
-      String projectId, ScoreDataType dataType, boolean isArchived, Optional<Double> minValue,
+      String projectId, ScoreConfigDataType dataType, boolean isArchived, Optional<Double> minValue,
       Optional<Double> maxValue, Optional<List<ConfigCategory>> categories,
       Optional<String> description, Map<String, Object> additionalProperties) {
     this.id = id;
@@ -97,7 +97,7 @@ public String getProjectId() {
   }
 
   @JsonProperty("dataType")
-  public ScoreDataType getDataType() {
+  public ScoreConfigDataType getDataType() {
     return dataType;
   }
 
@@ -190,7 +190,7 @@ public interface ProjectIdStage {
   }
 
   public interface DataTypeStage {
-    IsArchivedStage dataType(@NotNull ScoreDataType dataType);
+    IsArchivedStage dataType(@NotNull ScoreConfigDataType dataType);
   }
 
   public interface IsArchivedStage {
@@ -231,7 +231,7 @@ public static final class Builder implements IdStage, NameStage, CreatedAtStage,
 
     private String projectId;
 
-    private ScoreDataType dataType;
+    private ScoreConfigDataType dataType;
 
     private boolean isArchived;
 
@@ -302,7 +302,7 @@ public DataTypeStage projectId(@NotNull String projectId) {
 
     @java.lang.Override
     @JsonSetter("dataType")
-    public IsArchivedStage dataType(@NotNull ScoreDataType dataType) {
+    public IsArchivedStage dataType(@NotNull ScoreConfigDataType dataType) {
       this.dataType = Objects.requireNonNull(dataType, "dataType must not be null");
       return this;
     }

src/main/java/com/langfuse/client/resources/commons/types/ScoreConfigDataType.java

@@ -0,0 +1,28 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+
+package com.langfuse.client.resources.commons.types;
+
+import com.fasterxml.jackson.annotation.JsonValue;
+import java.lang.String;
+
+public enum ScoreConfigDataType {
+  NUMERIC("NUMERIC"),
+
+  BOOLEAN("BOOLEAN"),
+
+  CATEGORICAL("CATEGORICAL");
+
+  private final String value;
+
+  ScoreConfigDataType(String value) {
+    this.value = value;
+  }
+
+  @JsonValue
+  @java.lang.Override
+  public String toString() {
+    return this.value;
+  }
+}

src/main/java/com/langfuse/client/resources/commons/types/ScoreDataType.java

@@ -12,7 +12,9 @@ public enum ScoreDataType {
 
   BOOLEAN("BOOLEAN"),
 
-  CATEGORICAL("CATEGORICAL");
+  CATEGORICAL("CATEGORICAL"),
+
+  CORRECTION("CORRECTION");
 
   private final String value;
 

src/main/java/com/langfuse/client/resources/ingestion/types/ScoreBody.java

@@ -102,6 +102,9 @@ public Optional<String> getDatasetRunId() {
     return datasetRunId;
   }
 
+  /**
+   * @return The name of the score. Always overrides &quot;output&quot; for correction scores.
+   */
   @JsonProperty("name")
   public String getName() {
     return name;
@@ -295,6 +298,10 @@ public Builder from(ScoreBody other) {
       return this;
     }
 
+    /**
+     * <p>The name of the score. Always overrides &quot;output&quot; for correction scores.</p>
+     * @return Reference to {@code this} so that method calls can be chained together.
+     */
     @java.lang.Override
     @JsonSetter("name")
     public ValueStage name(@NotNull String name) {

src/main/java/com/langfuse/client/resources/metrics/MetricsClient.java

@@ -37,6 +37,7 @@ public MetricsClient(ClientOptions clientOptions) {
 
   /**
    * Get metrics from the Langfuse project using a query object.
+   * <p>Consider using the <a href="/api-reference#tag/metricsv2/GET/api/public/v2/metrics">v2 metrics endpoint</a> for better performance.</p>
    * <p>For more details, see the <a href="https://langfuse.com/docs/metrics/features/metrics-api">Metrics API documentation</a>.</p>
    */
   public MetricsResponse metrics(GetMetricsRequest request) {
@@ -45,6 +46,7 @@ public MetricsResponse metrics(GetMetricsRequest request) {
 
   /**
    * Get metrics from the Langfuse project using a query object.
+   * <p>Consider using the <a href="/api-reference#tag/metricsv2/GET/api/public/v2/metrics">v2 metrics endpoint</a> for better performance.</p>
    * <p>For more details, see the <a href="https://langfuse.com/docs/metrics/features/metrics-api">Metrics API documentation</a>.</p>
    */
   public MetricsResponse metrics(GetMetricsRequest request, RequestOptions requestOptions) {

src/main/java/com/langfuse/client/resources/metricsv2/MetricsV2Client.java

@@ -0,0 +1,87 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+
+package com.langfuse.client.resources.metricsv2;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.langfuse.client.core.ClientOptions;
+import com.langfuse.client.core.LangfuseClientApiException;
+import com.langfuse.client.core.LangfuseClientException;
+import com.langfuse.client.core.ObjectMappers;
+import com.langfuse.client.core.QueryStringMapper;
+import com.langfuse.client.core.RequestOptions;
+import java.io.IOException;
+import java.lang.Object;
+import java.lang.String;
+import okhttp3.Headers;
+import okhttp3.HttpUrl;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
+import com.langfuse.client.resources.commons.errors.AccessDeniedError;
+import com.langfuse.client.resources.commons.errors.Error;
+import com.langfuse.client.resources.commons.errors.MethodNotAllowedError;
+import com.langfuse.client.resources.commons.errors.NotFoundError;
+import com.langfuse.client.resources.commons.errors.UnauthorizedError;
+import com.langfuse.client.resources.metricsv2.requests.GetMetricsV2Request;
+import com.langfuse.client.resources.metricsv2.types.MetricsV2Response;
+
+public class MetricsV2Client {
+  protected final ClientOptions clientOptions;
+
+  public MetricsV2Client(ClientOptions clientOptions) {
+    this.clientOptions = clientOptions;
+  }
+
+  /**
+   * Get metrics from the Langfuse project using a query object. V2 endpoint with optimized performance.
+   */
+  public MetricsV2Response metrics(GetMetricsV2Request request) {
+    return metrics(request,null);
+  }
+
+  /**
+   * Get metrics from the Langfuse project using a query object. V2 endpoint with optimized performance.
+   */
+  public MetricsV2Response metrics(GetMetricsV2Request request, RequestOptions requestOptions) {
+    HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+      .addPathSegments("api/public")
+      .addPathSegments("v2/metrics");QueryStringMapper.addQueryParameter(httpUrl, "query", request.getQuery(), false);
+      Request.Builder _requestBuilder = new Request.Builder()
+        .url(httpUrl.build())
+        .method("GET", null)
+        .headers(Headers.of(clientOptions.headers(requestOptions)))
+        .addHeader("Content-Type", "application/json")
+        .addHeader("Accept", "application/json");
+      Request okhttpRequest = _requestBuilder.build();
+      OkHttpClient client = clientOptions.httpClient();
+      if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+        client = clientOptions.httpClientWithTimeout(requestOptions);
+      }
+      try (Response response = client.newCall(okhttpRequest).execute()) {
+        ResponseBody responseBody = response.body();
+        if (response.isSuccessful()) {
+          return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), MetricsV2Response.class);
+        }
+        String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+        try {
+          switch (response.code()) {
+            case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+            case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+            case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+            case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+            case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+          }
+        }
+        catch (JsonProcessingException ignored) {
+          // unable to map error response, throwing generic error
+        }
+        throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+      }
+      catch (IOException e) {
+        throw new LangfuseClientException("Network error executing HTTP request", e);
+      }
+    }
+  }