SSE_ENVELOPE_FIELDS = new HashSet<>(Arrays.asList("event", "data", "id", "retry"));
+
+ private SseEventParser() {
+ // Utility class
+ }
+
+ /**
+ * Parse an SSE event using event-level discrimination.
+ *
+ * Constructs the full SSE envelope object with event, data, id, and retry fields,
+ * then deserializes it to the target union type.
+ *
+ * @param eventType The SSE event type (from event: field)
+ * @param data The SSE data content (from data: field)
+ * @param id The SSE event ID (from id: field), may be null
+ * @param retry The SSE retry value (from retry: field), may be null
+ * @param unionClass The target union class
+ * @param discriminatorProperty The property name used for discrimination (e.g., "event")
+ * @param The target type
+ * @return The deserialized object
+ */
+ public static T parseEventLevelUnion(
+ String eventType,
+ String data,
+ String id,
+ Long retry,
+ Class unionClass,
+ String discriminatorProperty) {
+ try {
+ // Determine if data should be parsed as JSON based on the variant's expected type
+ Object parsedData = parseDataForVariant(eventType, data, unionClass, discriminatorProperty);
+
+ // Construct the SSE envelope object
+ Map envelope = new HashMap<>();
+ envelope.put(discriminatorProperty, eventType);
+ envelope.put("data", parsedData);
+ if (id != null) {
+ envelope.put("id", id);
+ }
+ if (retry != null) {
+ envelope.put("retry", retry);
+ }
+
+ // Serialize to JSON and deserialize to target type
+ String envelopeJson = ObjectMappers.JSON_MAPPER.writeValueAsString(envelope);
+ return ObjectMappers.JSON_MAPPER.readValue(envelopeJson, unionClass);
+ } catch (Exception e) {
+ throw new RuntimeException("Failed to parse SSE event with event-level discrimination", e);
+ }
+ }
+
+ /**
+ * Parse an SSE event using data-level discrimination.
+ *
+ * Simply parses the data field as JSON and deserializes it to the target type.
+ * Jackson's polymorphic deserialization handles the discrimination automatically.
+ *
+ * @param data The SSE data content (from data: field)
+ * @param valueType The target type
+ * @param The target type
+ * @return The deserialized object
+ */
+ public static T parseDataLevelUnion(String data, Class valueType) {
+ try {
+ return ObjectMappers.JSON_MAPPER.readValue(data, valueType);
+ } catch (Exception e) {
+ throw new RuntimeException("Failed to parse SSE data with data-level discrimination", e);
+ }
+ }
+
+ /**
+ * Determines if the given discriminator property indicates event-level discrimination.
+ * Event-level discrimination occurs when the discriminator is an SSE envelope field.
+ *
+ * @param discriminatorProperty The discriminator property name
+ * @return true if event-level discrimination, false otherwise
+ */
+ public static boolean isEventLevelDiscrimination(String discriminatorProperty) {
+ return SSE_ENVELOPE_FIELDS.contains(discriminatorProperty);
+ }
+
+ /**
+ * Attempts to find the discriminator property from the union class's Jackson annotations.
+ *
+ * @param unionClass The union class to inspect
+ * @return The discriminator property name, or empty if not found
+ */
+ public static Optional findDiscriminatorProperty(Class unionClass) {
+ try {
+ // Look for JsonTypeInfo on the class itself
+ JsonTypeInfo typeInfo = unionClass.getAnnotation(JsonTypeInfo.class);
+ if (typeInfo != null && !typeInfo.property().isEmpty()) {
+ return Optional.of(typeInfo.property());
+ }
+
+ // Look for inner Value interface with JsonTypeInfo
+ for (Class innerClass : unionClass.getDeclaredClasses()) {
+ typeInfo = innerClass.getAnnotation(JsonTypeInfo.class);
+ if (typeInfo != null && !typeInfo.property().isEmpty()) {
+ return Optional.of(typeInfo.property());
+ }
+ }
+ } catch (Exception e) {
+ // Ignore reflection errors
+ }
+ return Optional.empty();
+ }
+
+ /**
+ * Parse the data field based on what the matching variant expects.
+ * If the variant expects a String for its data field, returns the raw string.
+ * Otherwise, parses the data as JSON.
+ */
+ private static Object parseDataForVariant(
+ String eventType,
+ String data,
+ Class unionClass,
+ String discriminatorProperty) {
+ if (data == null || data.isEmpty()) {
+ return data;
+ }
+
+ try {
+ // Try to find the variant class that matches this event type
+ Class variantClass = findVariantClass(unionClass, eventType, discriminatorProperty);
+ if (variantClass != null) {
+ // Check if the variant expects a String for the data field
+ Field dataField = findField(variantClass, "data");
+ if (dataField != null && String.class.equals(dataField.getType())) {
+ // Variant expects String - return raw data
+ return data;
+ }
+ }
+
+ // Try to parse as JSON
+ return ObjectMappers.JSON_MAPPER.readValue(data, new TypeReference>() {});
+ } catch (Exception e) {
+ // If JSON parsing fails, return as string
+ return data;
+ }
+ }
+
+ /**
+ * Find the variant class that matches the given discriminator value.
+ */
+ private static Class findVariantClass(Class unionClass, String discriminatorValue, String discriminatorProperty) {
+ try {
+ // Look for JsonSubTypes annotation
+ JsonSubTypes subTypes = findJsonSubTypes(unionClass);
+ if (subTypes == null) {
+ return null;
+ }
+
+ for (JsonSubTypes.Type subType : subTypes.value()) {
+ JsonTypeName typeName = subType.value().getAnnotation(JsonTypeName.class);
+ if (typeName != null && typeName.value().equals(discriminatorValue)) {
+ return subType.value();
+ }
+ // Also check the name attribute of @JsonSubTypes.Type
+ if (subType.name().equals(discriminatorValue)) {
+ return subType.value();
+ }
+ }
+ } catch (Exception e) {
+ // Ignore reflection errors
+ }
+ return null;
+ }
+
+ /**
+ * Find JsonSubTypes annotation on the class or its inner classes.
+ */
+ private static JsonSubTypes findJsonSubTypes(Class unionClass) {
+ // Check the class itself
+ JsonSubTypes subTypes = unionClass.getAnnotation(JsonSubTypes.class);
+ if (subTypes != null) {
+ return subTypes;
+ }
+
+ // Check inner classes (for Fern-style unions with inner Value interface)
+ for (Class innerClass : unionClass.getDeclaredClasses()) {
+ subTypes = innerClass.getAnnotation(JsonSubTypes.class);
+ if (subTypes != null) {
+ return subTypes;
+ }
+ }
+ return null;
+ }
+
+ /**
+ * Find a field by name in a class, including private fields.
+ */
+ private static Field findField(Class clazz, String fieldName) {
+ try {
+ return clazz.getDeclaredField(fieldName);
+ } catch (NoSuchFieldException e) {
+ // Check superclass
+ Class superClass = clazz.getSuperclass();
+ if (superClass != null && superClass != Object.class) {
+ return findField(superClass, fieldName);
+ }
+ return null;
+ }
+ }
+}
diff --git a/src/main/java/com/langfuse/client/core/Stream.java b/src/main/java/com/langfuse/client/core/Stream.java
index fbccca5..319d33d 100644
--- a/src/main/java/com/langfuse/client/core/Stream.java
+++ b/src/main/java/com/langfuse/client/core/Stream.java
@@ -4,9 +4,11 @@
package com.langfuse.client.core;
+import java.io.Closeable;
+import java.io.IOException;
+import java.io.Reader;
import java.util.Iterator;
import java.util.NoSuchElementException;
-import java.io.Reader;
import java.util.Scanner;
/**
@@ -15,18 +17,30 @@
*
* {@code Stream} assumes that data is being pushed to the provided {@link Reader} asynchronously and utilizes a
* {@code Scanner} to block during iteration if the next object is not available.
+ * Iterable stream for parsing JSON and Server-Sent Events (SSE) data.
+ * Supports both newline-delimited JSON and SSE with optional stream termination.
*
* @param The type of objects in the stream.
*/
-public final class Stream implements Iterable {
- /**
- * The {@link Class} of the objects in the stream.
- */
+public final class Stream implements Iterable, Closeable {
+
+ private static final String NEWLINE = "\n";
+ private static final String DATA_PREFIX = "data:";
+
+ public enum StreamType {
+ JSON,
+ SSE,
+ SSE_EVENT_DISCRIMINATED
+ }
+
private final Class valueType;
- /**
- * The {@link Scanner} used for reading from the input stream and blocking when needed during iteration.
- */
private final Scanner scanner;
+ private final StreamType streamType;
+ private final String messageTerminator;
+ private final String streamTerminator;
+ private final Reader sseReader;
+ private final String discriminatorProperty;
+ private boolean isClosed = false;
/**
* Constructs a new {@code Stream} with the specified value type, reader, and delimiter.
@@ -36,8 +50,98 @@ public final class Stream implements Iterable {
* @param delimiter The delimiter used to separate elements in the stream.
*/
public Stream(Class valueType, Reader reader, String delimiter) {
+ this.valueType = valueType;
this.scanner = new Scanner(reader).useDelimiter(delimiter);
+ this.streamType = StreamType.JSON;
+ this.messageTerminator = delimiter;
+ this.streamTerminator = null;
+ this.sseReader = null;
+ this.discriminatorProperty = null;
+ }
+
+ private Stream(Class valueType, StreamType type, Reader reader, String terminator) {
+ this(valueType, type, reader, terminator, null);
+ }
+
+ private Stream(Class valueType, StreamType type, Reader reader, String terminator, String discriminatorProperty) {
this.valueType = valueType;
+ this.streamType = type;
+ this.discriminatorProperty = discriminatorProperty;
+ if (type == StreamType.JSON) {
+ this.scanner = new Scanner(reader).useDelimiter(terminator);
+ this.messageTerminator = terminator;
+ this.streamTerminator = null;
+ this.sseReader = null;
+ } else {
+ this.scanner = null;
+ this.messageTerminator = NEWLINE;
+ this.streamTerminator = terminator;
+ this.sseReader = reader;
+ }
+ }
+
+ public static Stream fromJson(Class valueType, Reader reader, String delimiter) {
+ return new Stream<>(valueType, reader, delimiter);
+ }
+
+ public static Stream fromJson(Class valueType, Reader reader) {
+ return new Stream<>(valueType, reader, NEWLINE);
+ }
+
+ public static Stream fromSse(Class valueType, Reader sseReader) {
+ return new Stream<>(valueType, StreamType.SSE, sseReader, null);
+ }
+
+ public static Stream fromSse(Class valueType, Reader sseReader, String streamTerminator) {
+ return new Stream<>(valueType, StreamType.SSE, sseReader, streamTerminator);
+ }
+
+ /**
+ * Creates a stream from SSE data with event-level discrimination support.
+ * Use this when the SSE payload is a discriminated union where the discriminator
+ * is an SSE envelope field (e.g., 'event').
+ *
+ * @param valueType The class of the objects in the stream.
+ * @param sseReader The reader that provides the SSE data.
+ * @param discriminatorProperty The property name used for discrimination (e.g., "event").
+ * @param The type of objects in the stream.
+ * @return A new Stream instance configured for SSE with event-level discrimination.
+ */
+ public static Stream fromSseWithEventDiscrimination(
+ Class valueType, Reader sseReader, String discriminatorProperty) {
+ return new Stream<>(valueType, StreamType.SSE_EVENT_DISCRIMINATED, sseReader, null, discriminatorProperty);
+ }
+
+ /**
+ * Creates a stream from SSE data with event-level discrimination support and a stream terminator.
+ *
+ * @param valueType The class of the objects in the stream.
+ * @param sseReader The reader that provides the SSE data.
+ * @param discriminatorProperty The property name used for discrimination (e.g., "event").
+ * @param streamTerminator The terminator string that signals end of stream (e.g., "[DONE]").
+ * @param The type of objects in the stream.
+ * @return A new Stream instance configured for SSE with event-level discrimination.
+ */
+ public static Stream fromSseWithEventDiscrimination(
+ Class valueType, Reader sseReader, String discriminatorProperty, String streamTerminator) {
+ return new Stream<>(valueType, StreamType.SSE_EVENT_DISCRIMINATED, sseReader, streamTerminator, discriminatorProperty);
+ }
+
+ @Override
+ public void close() throws IOException {
+ if (!isClosed) {
+ isClosed = true;
+ if (scanner != null) {
+ scanner.close();
+ }
+ if (sseReader != null) {
+ sseReader.close();
+ }
+ }
+ }
+
+ private boolean isStreamClosed() {
+ return isClosed;
}
/**
@@ -48,51 +152,360 @@ public Stream(Class valueType, Reader reader, String delimiter) {
*/
@Override
public Iterator iterator() {
- return new Iterator() {
- /**
- * Returns {@code true} if there are more elements in the stream.
- *
- * Will block and wait for input if the stream has not ended and the next object is not yet available.
- *
- * @return {@code true} if there are more elements, {@code false} otherwise.
- */
- @Override
- public boolean hasNext() {
- return scanner.hasNext();
- }
-
- /**
- * Returns the next element in the stream.
- *
- * Will block and wait for input if the stream has not ended and the next object is not yet available.
- *
- * @return The next element in the stream.
- * @throws NoSuchElementException If there are no more elements in the stream.
- */
- @Override
- public T next() {
- if (!scanner.hasNext()) {
- throw new NoSuchElementException();
- } else {
+ switch (streamType) {
+ case SSE:
+ return new SSEIterator();
+ case SSE_EVENT_DISCRIMINATED:
+ return new SSEEventDiscriminatedIterator();
+ case JSON:
+ default:
+ return new JsonIterator();
+ }
+ }
+
+ private final class JsonIterator implements Iterator {
+
+ /**
+ * Returns {@code true} if there are more elements in the stream.
+ *
+ * Will block and wait for input if the stream has not ended and the next object is not yet available.
+ *
+ * @return {@code true} if there are more elements, {@code false} otherwise.
+ */
+ @Override
+ public boolean hasNext() {
+ if (isStreamClosed()) {
+ return false;
+ }
+ return scanner.hasNext();
+ }
+
+ /**
+ * Returns the next element in the stream.
+ *
+ * Will block and wait for input if the stream has not ended and the next object is not yet available.
+ *
+ * @return The next element in the stream.
+ * @throws NoSuchElementException If there are no more elements in the stream.
+ */
+ @Override
+ public T next() {
+ if (isStreamClosed()) {
+ throw new NoSuchElementException("Stream is closed");
+ }
+
+ if (!scanner.hasNext()) {
+ throw new NoSuchElementException();
+ } else {
+ try {
+ T parsedResponse =
+ ObjectMappers.JSON_MAPPER.readValue(scanner.next().trim(), valueType);
+ return parsedResponse;
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+
+ @Override
+ public void remove() {
+ throw new UnsupportedOperationException();
+ }
+ }
+
+ private final class SSEIterator implements Iterator {
+ private Scanner sseScanner;
+ private T nextItem;
+ private boolean hasNextItem = false;
+ private boolean endOfStream = false;
+ private StringBuilder eventDataBuffer = new StringBuilder();
+ private String currentEventType = null;
+
+ private SSEIterator() {
+ if (sseReader != null && !isStreamClosed()) {
+ this.sseScanner = new Scanner(sseReader);
+ } else {
+ this.endOfStream = true;
+ }
+ }
+
+ @Override
+ public boolean hasNext() {
+ if (isStreamClosed() || endOfStream) {
+ return false;
+ }
+
+ if (hasNextItem) {
+ return true;
+ }
+
+ return readNextMessage();
+ }
+
+ @Override
+ public T next() {
+ if (!hasNext()) {
+ throw new NoSuchElementException("No more elements in stream");
+ }
+
+ T result = nextItem;
+ nextItem = null;
+ hasNextItem = false;
+ return result;
+ }
+
+ @Override
+ public void remove() {
+ throw new UnsupportedOperationException();
+ }
+
+ private boolean readNextMessage() {
+ if (sseScanner == null || isStreamClosed()) {
+ endOfStream = true;
+ return false;
+ }
+
+ try {
+ while (sseScanner.hasNextLine()) {
+ String line = sseScanner.nextLine();
+
+ if (line.trim().isEmpty()) {
+ if (eventDataBuffer.length() > 0) {
+ try {
+ nextItem = ObjectMappers.JSON_MAPPER.readValue(
+ eventDataBuffer.toString(), valueType);
+ hasNextItem = true;
+ eventDataBuffer.setLength(0);
+ currentEventType = null;
+ return true;
+ } catch (Exception parseEx) {
+ System.err.println("Failed to parse SSE event: " + parseEx.getMessage());
+ eventDataBuffer.setLength(0);
+ currentEventType = null;
+ continue;
+ }
+ }
+ continue;
+ }
+
+ if (line.startsWith(DATA_PREFIX)) {
+ String dataContent = line.substring(DATA_PREFIX.length());
+ if (dataContent.startsWith(" ")) {
+ dataContent = dataContent.substring(1);
+ }
+
+ if (eventDataBuffer.length() == 0 && streamTerminator != null && dataContent.trim().equals(streamTerminator)) {
+ endOfStream = true;
+ return false;
+ }
+
+ if (eventDataBuffer.length() > 0) {
+ eventDataBuffer.append('\n');
+ }
+ eventDataBuffer.append(dataContent);
+ } else if (line.startsWith("event:")) {
+ String eventValue = line.length() > 6 ? line.substring(6) : "";
+ if (eventValue.startsWith(" ")) {
+ eventValue = eventValue.substring(1);
+ }
+ currentEventType = eventValue;
+ } else if (line.startsWith("id:")) {
+ // Event ID field (ignored)
+ } else if (line.startsWith("retry:")) {
+ // Retry field (ignored)
+ } else if (line.startsWith(":")) {
+ // Comment line (ignored)
+ }
+ }
+
+ if (eventDataBuffer.length() > 0) {
try {
- T parsedResponse =
- ObjectMappers.JSON_MAPPER.readValue(scanner.next().trim(), valueType);
- return parsedResponse;
- } catch (Exception e) {
- throw new RuntimeException(e);
+ nextItem = ObjectMappers.JSON_MAPPER.readValue(
+ eventDataBuffer.toString(), valueType);
+ hasNextItem = true;
+ eventDataBuffer.setLength(0);
+ currentEventType = null;
+ return true;
+ } catch (Exception parseEx) {
+ System.err.println("Failed to parse final SSE event: " + parseEx.getMessage());
+ eventDataBuffer.setLength(0);
+ currentEventType = null;
}
}
+
+ endOfStream = true;
+ return false;
+
+ } catch (Exception e) {
+ System.err.println("Failed to parse SSE stream: " + e.getMessage());
+ endOfStream = true;
+ return false;
+ }
+ }
+
+ }
+
+ /**
+ * Iterator for SSE streams with event-level discrimination.
+ * Uses SseEventParser to construct the full SSE envelope for Jackson deserialization.
+ */
+ private final class SSEEventDiscriminatedIterator implements Iterator {
+ private Scanner sseScanner;
+ private T nextItem;
+ private boolean hasNextItem = false;
+ private boolean endOfStream = false;
+ private StringBuilder eventDataBuffer = new StringBuilder();
+ private String currentEventType = null;
+ private String currentEventId = null;
+ private Long currentRetry = null;
+
+ private SSEEventDiscriminatedIterator() {
+ if (sseReader != null && !isStreamClosed()) {
+ this.sseScanner = new Scanner(sseReader);
+ } else {
+ this.endOfStream = true;
+ }
+ }
+
+ @Override
+ public boolean hasNext() {
+ if (isStreamClosed() || endOfStream) {
+ return false;
+ }
+
+ if (hasNextItem) {
+ return true;
+ }
+
+ return readNextMessage();
+ }
+
+ @Override
+ public T next() {
+ if (!hasNext()) {
+ throw new NoSuchElementException("No more elements in stream");
}
- /**
- * Removing elements from {@code Stream} is not supported.
- *
- * @throws UnsupportedOperationException Always, as removal is not supported.
- */
- @Override
- public void remove() {
- throw new UnsupportedOperationException();
+ T result = nextItem;
+ nextItem = null;
+ hasNextItem = false;
+ return result;
+ }
+
+ @Override
+ public void remove() {
+ throw new UnsupportedOperationException();
+ }
+
+ private boolean readNextMessage() {
+ if (sseScanner == null || isStreamClosed()) {
+ endOfStream = true;
+ return false;
}
- };
+
+ try {
+ while (sseScanner.hasNextLine()) {
+ String line = sseScanner.nextLine();
+
+ if (line.trim().isEmpty()) {
+ if (eventDataBuffer.length() > 0 || currentEventType != null) {
+ try {
+ // Use SseEventParser for event-level discrimination
+ nextItem = SseEventParser.parseEventLevelUnion(
+ currentEventType,
+ eventDataBuffer.toString(),
+ currentEventId,
+ currentRetry,
+ valueType,
+ discriminatorProperty);
+ hasNextItem = true;
+ resetEventState();
+ return true;
+ } catch (Exception parseEx) {
+ System.err.println("Failed to parse SSE event: " + parseEx.getMessage());
+ resetEventState();
+ continue;
+ }
+ }
+ continue;
+ }
+
+ if (line.startsWith(DATA_PREFIX)) {
+ String dataContent = line.substring(DATA_PREFIX.length());
+ if (dataContent.startsWith(" ")) {
+ dataContent = dataContent.substring(1);
+ }
+
+ if (eventDataBuffer.length() == 0 && streamTerminator != null && dataContent.trim().equals(streamTerminator)) {
+ endOfStream = true;
+ return false;
+ }
+
+ if (eventDataBuffer.length() > 0) {
+ eventDataBuffer.append('\n');
+ }
+ eventDataBuffer.append(dataContent);
+ } else if (line.startsWith("event:")) {
+ String eventValue = line.length() > 6 ? line.substring(6) : "";
+ if (eventValue.startsWith(" ")) {
+ eventValue = eventValue.substring(1);
+ }
+ currentEventType = eventValue;
+ } else if (line.startsWith("id:")) {
+ String idValue = line.length() > 3 ? line.substring(3) : "";
+ if (idValue.startsWith(" ")) {
+ idValue = idValue.substring(1);
+ }
+ currentEventId = idValue;
+ } else if (line.startsWith("retry:")) {
+ String retryValue = line.length() > 6 ? line.substring(6) : "";
+ if (retryValue.startsWith(" ")) {
+ retryValue = retryValue.substring(1);
+ }
+ try {
+ currentRetry = Long.parseLong(retryValue.trim());
+ } catch (NumberFormatException e) {
+ // Ignore invalid retry values
+ }
+ } else if (line.startsWith(":")) {
+ // Comment line (ignored)
+ }
+ }
+
+ // Handle any remaining buffered data at end of stream
+ if (eventDataBuffer.length() > 0 || currentEventType != null) {
+ try {
+ nextItem = SseEventParser.parseEventLevelUnion(
+ currentEventType,
+ eventDataBuffer.toString(),
+ currentEventId,
+ currentRetry,
+ valueType,
+ discriminatorProperty);
+ hasNextItem = true;
+ resetEventState();
+ return true;
+ } catch (Exception parseEx) {
+ System.err.println("Failed to parse final SSE event: " + parseEx.getMessage());
+ resetEventState();
+ }
+ }
+
+ endOfStream = true;
+ return false;
+
+ } catch (Exception e) {
+ System.err.println("Failed to parse SSE stream: " + e.getMessage());
+ endOfStream = true;
+ return false;
+ }
+ }
+
+ private void resetEventState() {
+ eventDataBuffer.setLength(0);
+ currentEventType = null;
+ currentEventId = null;
+ currentRetry = null;
+ }
}
-}
\ No newline at end of file
+}
diff --git a/src/main/java/com/langfuse/client/resources/annotationqueues/AnnotationQueuesClient.java b/src/main/java/com/langfuse/client/resources/annotationqueues/AnnotationQueuesClient.java
index db6eb50..e3027de 100644
--- a/src/main/java/com/langfuse/client/resources/annotationqueues/AnnotationQueuesClient.java
+++ b/src/main/java/com/langfuse/client/resources/annotationqueues/AnnotationQueuesClient.java
@@ -4,24 +4,9 @@
package com.langfuse.client.resources.annotationqueues;
-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.MediaTypes;
-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.RequestBody;
-import okhttp3.Response;
-import okhttp3.ResponseBody;
import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueueItemsRequest;
import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueuesRequest;
import com.langfuse.client.resources.annotationqueues.types.AnnotationQueue;
@@ -35,31 +20,43 @@
import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueueItems;
import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueues;
import com.langfuse.client.resources.annotationqueues.types.UpdateAnnotationQueueItemRequest;
-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;
public class AnnotationQueuesClient {
protected final ClientOptions clientOptions;
+ private final RawAnnotationQueuesClient rawClient;
+
public AnnotationQueuesClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
+ this.rawClient = new RawAnnotationQueuesClient(clientOptions);
+ }
+
+ /**
+ * Get responses with HTTP metadata like headers
+ */
+ public RawAnnotationQueuesClient withRawResponse() {
+ return this.rawClient;
}
/**
* Get all annotation queues
*/
public PaginatedAnnotationQueues listQueues() {
- return listQueues(GetAnnotationQueuesRequest.builder().build());
+ return this.rawClient.listQueues().body();
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public PaginatedAnnotationQueues listQueues(RequestOptions requestOptions) {
+ return this.rawClient.listQueues(requestOptions).body();
}
/**
* Get all annotation queues
*/
public PaginatedAnnotationQueues listQueues(GetAnnotationQueuesRequest request) {
- return listQueues(request,null);
+ return this.rawClient.listQueues(request).body();
}
/**
@@ -67,593 +64,175 @@ public PaginatedAnnotationQueues listQueues(GetAnnotationQueuesRequest request)
*/
public PaginatedAnnotationQueues listQueues(GetAnnotationQueuesRequest request,
RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues");if (request.getPage().isPresent()) {
- QueryStringMapper.addQueryParameter(httpUrl, "page", request.getPage().get().toString(), false);
- }
- if (request.getLimit().isPresent()) {
- QueryStringMapper.addQueryParameter(httpUrl, "limit", request.getLimit().get().toString(), 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(), PaginatedAnnotationQueues.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);
- }
- }
-
- /**
- * Create an annotation queue
- */
- public AnnotationQueue createQueue(CreateAnnotationQueueRequest request) {
- return createQueue(request,null);
- }
-
- /**
- * Create an annotation queue
- */
- public AnnotationQueue createQueue(CreateAnnotationQueueRequest request,
- RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .build();
- RequestBody body;
- try {
- body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
- }
- catch(JsonProcessingException e) {
- throw new LangfuseClientException("Failed to serialize request", e);
- }
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("POST", body)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), AnnotationQueue.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);
- }
- }
-
- /**
- * Get an annotation queue by ID
- */
- public AnnotationQueue getQueue(String queueId) {
- return getQueue(queueId,null);
- }
-
- /**
- * Get an annotation queue by ID
- */
- public AnnotationQueue getQueue(String queueId, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .build();
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("GET", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), AnnotationQueue.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);
- }
- }
-
- /**
- * Get items for a specific annotation queue
- */
- public PaginatedAnnotationQueueItems listQueueItems(String queueId) {
- return listQueueItems(queueId,GetAnnotationQueueItemsRequest.builder().build());
- }
-
- /**
- * Get items for a specific annotation queue
- */
- public PaginatedAnnotationQueueItems listQueueItems(String queueId,
- GetAnnotationQueueItemsRequest request) {
- return listQueueItems(queueId,request,null);
- }
-
- /**
- * Get items for a specific annotation queue
- */
- public PaginatedAnnotationQueueItems listQueueItems(String queueId,
- GetAnnotationQueueItemsRequest request, RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .addPathSegments("items");if (request.getStatus().isPresent()) {
- QueryStringMapper.addQueryParameter(httpUrl, "status", request.getStatus().get().toString(), false);
- }
- if (request.getPage().isPresent()) {
- QueryStringMapper.addQueryParameter(httpUrl, "page", request.getPage().get().toString(), false);
- }
- if (request.getLimit().isPresent()) {
- QueryStringMapper.addQueryParameter(httpUrl, "limit", request.getLimit().get().toString(), 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(), PaginatedAnnotationQueueItems.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);
- }
- }
-
- /**
- * Get a specific item from an annotation queue
- */
- public AnnotationQueueItem getQueueItem(String queueId, String itemId) {
- return getQueueItem(queueId,itemId,null);
- }
-
- /**
- * Get a specific item from an annotation queue
- */
- public AnnotationQueueItem getQueueItem(String queueId, String itemId,
- RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .addPathSegments("items")
- .addPathSegment(itemId)
- .build();
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("GET", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), AnnotationQueueItem.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);
- }
- }
-
- /**
- * Add an item to an annotation queue
- */
- public AnnotationQueueItem createQueueItem(String queueId,
- CreateAnnotationQueueItemRequest request) {
- return createQueueItem(queueId,request,null);
- }
-
- /**
- * Add an item to an annotation queue
- */
- public AnnotationQueueItem createQueueItem(String queueId,
- CreateAnnotationQueueItemRequest request, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .addPathSegments("items")
- .build();
- RequestBody body;
- try {
- body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
- }
- catch(JsonProcessingException e) {
- throw new LangfuseClientException("Failed to serialize request", e);
- }
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("POST", body)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), AnnotationQueueItem.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);
- }
- }
-
- /**
- * Update an annotation queue item
- */
- public AnnotationQueueItem updateQueueItem(String queueId, String itemId) {
- return updateQueueItem(queueId,itemId,UpdateAnnotationQueueItemRequest.builder().build());
- }
-
- /**
- * Update an annotation queue item
- */
- public AnnotationQueueItem updateQueueItem(String queueId, String itemId,
- UpdateAnnotationQueueItemRequest request) {
- return updateQueueItem(queueId,itemId,request,null);
- }
-
- /**
- * Update an annotation queue item
- */
- public AnnotationQueueItem updateQueueItem(String queueId, String itemId,
- UpdateAnnotationQueueItemRequest request, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .addPathSegments("items")
- .addPathSegment(itemId)
- .build();
- RequestBody body;
- try {
- body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
- }
- catch(JsonProcessingException e) {
- throw new LangfuseClientException("Failed to serialize request", e);
- }
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("PATCH", body)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), AnnotationQueueItem.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);
- }
- }
-
- /**
- * Remove an item from an annotation queue
- */
- public DeleteAnnotationQueueItemResponse deleteQueueItem(String queueId, String itemId) {
- return deleteQueueItem(queueId,itemId,null);
- }
-
- /**
- * Remove an item from an annotation queue
- */
- public DeleteAnnotationQueueItemResponse deleteQueueItem(String queueId, String itemId,
- RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .addPathSegments("items")
- .addPathSegment(itemId)
- .build();
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("DELETE", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), DeleteAnnotationQueueItemResponse.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);
- }
- }
-
- /**
- * Create an assignment for a user to an annotation queue
- */
- public CreateAnnotationQueueAssignmentResponse createQueueAssignment(String queueId,
- AnnotationQueueAssignmentRequest request) {
- return createQueueAssignment(queueId,request,null);
- }
-
- /**
- * Create an assignment for a user to an annotation queue
- */
- public CreateAnnotationQueueAssignmentResponse createQueueAssignment(String queueId,
- AnnotationQueueAssignmentRequest request, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .addPathSegments("assignments")
- .build();
- RequestBody body;
- try {
- body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
- }
- catch(JsonProcessingException e) {
- throw new LangfuseClientException("Failed to serialize request", e);
- }
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("POST", body)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), CreateAnnotationQueueAssignmentResponse.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);
- }
- }
-
- /**
- * Delete an assignment for a user to an annotation queue
- */
- public DeleteAnnotationQueueAssignmentResponse deleteQueueAssignment(String queueId,
- AnnotationQueueAssignmentRequest request) {
- return deleteQueueAssignment(queueId,request,null);
- }
-
- /**
- * Delete an assignment for a user to an annotation queue
- */
- public DeleteAnnotationQueueAssignmentResponse deleteQueueAssignment(String queueId,
- AnnotationQueueAssignmentRequest request, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
- .addPathSegments("api/public")
- .addPathSegments("annotation-queues")
- .addPathSegment(queueId)
- .addPathSegments("assignments")
- .build();
- RequestBody body;
- try {
- body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
- }
- catch(JsonProcessingException e) {
- throw new LangfuseClientException("Failed to serialize request", e);
- }
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("DELETE", body)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json")
- .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(), DeleteAnnotationQueueAssignmentResponse.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);
- }
- }
- }
+ return this.rawClient.listQueues(request, requestOptions).body();
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public AnnotationQueue createQueue(CreateAnnotationQueueRequest request) {
+ return this.rawClient.createQueue(request).body();
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public AnnotationQueue createQueue(CreateAnnotationQueueRequest request,
+ RequestOptions requestOptions) {
+ return this.rawClient.createQueue(request, requestOptions).body();
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public AnnotationQueue getQueue(String queueId) {
+ return this.rawClient.getQueue(queueId).body();
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public AnnotationQueue getQueue(String queueId, RequestOptions requestOptions) {
+ return this.rawClient.getQueue(queueId, requestOptions).body();
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public PaginatedAnnotationQueueItems listQueueItems(String queueId) {
+ return this.rawClient.listQueueItems(queueId).body();
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public PaginatedAnnotationQueueItems listQueueItems(String queueId,
+ RequestOptions requestOptions) {
+ return this.rawClient.listQueueItems(queueId, requestOptions).body();
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public PaginatedAnnotationQueueItems listQueueItems(String queueId,
+ GetAnnotationQueueItemsRequest request) {
+ return this.rawClient.listQueueItems(queueId, request).body();
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public PaginatedAnnotationQueueItems listQueueItems(String queueId,
+ GetAnnotationQueueItemsRequest request, RequestOptions requestOptions) {
+ return this.rawClient.listQueueItems(queueId, request, requestOptions).body();
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public AnnotationQueueItem getQueueItem(String queueId, String itemId) {
+ return this.rawClient.getQueueItem(queueId, itemId).body();
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public AnnotationQueueItem getQueueItem(String queueId, String itemId,
+ RequestOptions requestOptions) {
+ return this.rawClient.getQueueItem(queueId, itemId, requestOptions).body();
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public AnnotationQueueItem createQueueItem(String queueId,
+ CreateAnnotationQueueItemRequest request) {
+ return this.rawClient.createQueueItem(queueId, request).body();
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public AnnotationQueueItem createQueueItem(String queueId,
+ CreateAnnotationQueueItemRequest request, RequestOptions requestOptions) {
+ return this.rawClient.createQueueItem(queueId, request, requestOptions).body();
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public AnnotationQueueItem updateQueueItem(String queueId, String itemId) {
+ return this.rawClient.updateQueueItem(queueId, itemId).body();
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public AnnotationQueueItem updateQueueItem(String queueId, String itemId,
+ RequestOptions requestOptions) {
+ return this.rawClient.updateQueueItem(queueId, itemId, requestOptions).body();
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public AnnotationQueueItem updateQueueItem(String queueId, String itemId,
+ UpdateAnnotationQueueItemRequest request) {
+ return this.rawClient.updateQueueItem(queueId, itemId, request).body();
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public AnnotationQueueItem updateQueueItem(String queueId, String itemId,
+ UpdateAnnotationQueueItemRequest request, RequestOptions requestOptions) {
+ return this.rawClient.updateQueueItem(queueId, itemId, request, requestOptions).body();
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public DeleteAnnotationQueueItemResponse deleteQueueItem(String queueId, String itemId) {
+ return this.rawClient.deleteQueueItem(queueId, itemId).body();
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public DeleteAnnotationQueueItemResponse deleteQueueItem(String queueId, String itemId,
+ RequestOptions requestOptions) {
+ return this.rawClient.deleteQueueItem(queueId, itemId, requestOptions).body();
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public CreateAnnotationQueueAssignmentResponse createQueueAssignment(String queueId,
+ AnnotationQueueAssignmentRequest request) {
+ return this.rawClient.createQueueAssignment(queueId, request).body();
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public CreateAnnotationQueueAssignmentResponse createQueueAssignment(String queueId,
+ AnnotationQueueAssignmentRequest request, RequestOptions requestOptions) {
+ return this.rawClient.createQueueAssignment(queueId, request, requestOptions).body();
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public DeleteAnnotationQueueAssignmentResponse deleteQueueAssignment(String queueId,
+ AnnotationQueueAssignmentRequest request) {
+ return this.rawClient.deleteQueueAssignment(queueId, request).body();
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public DeleteAnnotationQueueAssignmentResponse deleteQueueAssignment(String queueId,
+ AnnotationQueueAssignmentRequest request, RequestOptions requestOptions) {
+ return this.rawClient.deleteQueueAssignment(queueId, request, requestOptions).body();
+ }
+}
diff --git a/src/main/java/com/langfuse/client/resources/annotationqueues/AsyncAnnotationQueuesClient.java b/src/main/java/com/langfuse/client/resources/annotationqueues/AsyncAnnotationQueuesClient.java
new file mode 100644
index 0000000..0f88d14
--- /dev/null
+++ b/src/main/java/com/langfuse/client/resources/annotationqueues/AsyncAnnotationQueuesClient.java
@@ -0,0 +1,242 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+
+package com.langfuse.client.resources.annotationqueues;
+
+import com.langfuse.client.core.ClientOptions;
+import com.langfuse.client.core.RequestOptions;
+import java.lang.String;
+import java.util.concurrent.CompletableFuture;
+import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueueItemsRequest;
+import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueuesRequest;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueue;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueueAssignmentRequest;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueueItem;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueAssignmentResponse;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueItemRequest;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueRequest;
+import com.langfuse.client.resources.annotationqueues.types.DeleteAnnotationQueueAssignmentResponse;
+import com.langfuse.client.resources.annotationqueues.types.DeleteAnnotationQueueItemResponse;
+import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueueItems;
+import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueues;
+import com.langfuse.client.resources.annotationqueues.types.UpdateAnnotationQueueItemRequest;
+
+public class AsyncAnnotationQueuesClient {
+ protected final ClientOptions clientOptions;
+
+ private final AsyncRawAnnotationQueuesClient rawClient;
+
+ public AsyncAnnotationQueuesClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ this.rawClient = new AsyncRawAnnotationQueuesClient(clientOptions);
+ }
+
+ /**
+ * Get responses with HTTP metadata like headers
+ */
+ public AsyncRawAnnotationQueuesClient withRawResponse() {
+ return this.rawClient;
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture listQueues() {
+ return this.rawClient.listQueues().thenApply(response -> response.body());
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture listQueues(RequestOptions requestOptions) {
+ return this.rawClient.listQueues(requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture listQueues(
+ GetAnnotationQueuesRequest request) {
+ return this.rawClient.listQueues(request).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture listQueues(GetAnnotationQueuesRequest request,
+ RequestOptions requestOptions) {
+ return this.rawClient.listQueues(request, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public CompletableFuture createQueue(CreateAnnotationQueueRequest request) {
+ return this.rawClient.createQueue(request).thenApply(response -> response.body());
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public CompletableFuture createQueue(CreateAnnotationQueueRequest request,
+ RequestOptions requestOptions) {
+ return this.rawClient.createQueue(request, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public CompletableFuture getQueue(String queueId) {
+ return this.rawClient.getQueue(queueId).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public CompletableFuture getQueue(String queueId,
+ RequestOptions requestOptions) {
+ return this.rawClient.getQueue(queueId, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture listQueueItems(String queueId) {
+ return this.rawClient.listQueueItems(queueId).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture listQueueItems(String queueId,
+ RequestOptions requestOptions) {
+ return this.rawClient.listQueueItems(queueId, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture listQueueItems(String queueId,
+ GetAnnotationQueueItemsRequest request) {
+ return this.rawClient.listQueueItems(queueId, request).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture listQueueItems(String queueId,
+ GetAnnotationQueueItemsRequest request, RequestOptions requestOptions) {
+ return this.rawClient.listQueueItems(queueId, request, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public CompletableFuture getQueueItem(String queueId, String itemId) {
+ return this.rawClient.getQueueItem(queueId, itemId).thenApply(response -> response.body());
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public CompletableFuture getQueueItem(String queueId, String itemId,
+ RequestOptions requestOptions) {
+ return this.rawClient.getQueueItem(queueId, itemId, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public CompletableFuture createQueueItem(String queueId,
+ CreateAnnotationQueueItemRequest request) {
+ return this.rawClient.createQueueItem(queueId, request).thenApply(response -> response.body());
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public CompletableFuture createQueueItem(String queueId,
+ CreateAnnotationQueueItemRequest request, RequestOptions requestOptions) {
+ return this.rawClient.createQueueItem(queueId, request, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture updateQueueItem(String queueId, String itemId) {
+ return this.rawClient.updateQueueItem(queueId, itemId).thenApply(response -> response.body());
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture updateQueueItem(String queueId, String itemId,
+ RequestOptions requestOptions) {
+ return this.rawClient.updateQueueItem(queueId, itemId, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture updateQueueItem(String queueId, String itemId,
+ UpdateAnnotationQueueItemRequest request) {
+ return this.rawClient.updateQueueItem(queueId, itemId, request).thenApply(response -> response.body());
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture updateQueueItem(String queueId, String itemId,
+ UpdateAnnotationQueueItemRequest request, RequestOptions requestOptions) {
+ return this.rawClient.updateQueueItem(queueId, itemId, request, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public CompletableFuture deleteQueueItem(String queueId,
+ String itemId) {
+ return this.rawClient.deleteQueueItem(queueId, itemId).thenApply(response -> response.body());
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public CompletableFuture deleteQueueItem(String queueId,
+ String itemId, RequestOptions requestOptions) {
+ return this.rawClient.deleteQueueItem(queueId, itemId, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public CompletableFuture createQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request) {
+ return this.rawClient.createQueueAssignment(queueId, request).thenApply(response -> response.body());
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public CompletableFuture createQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request, RequestOptions requestOptions) {
+ return this.rawClient.createQueueAssignment(queueId, request, requestOptions).thenApply(response -> response.body());
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public CompletableFuture deleteQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request) {
+ return this.rawClient.deleteQueueAssignment(queueId, request).thenApply(response -> response.body());
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public CompletableFuture deleteQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request, RequestOptions requestOptions) {
+ return this.rawClient.deleteQueueAssignment(queueId, request, requestOptions).thenApply(response -> response.body());
+ }
+}
diff --git a/src/main/java/com/langfuse/client/resources/annotationqueues/AsyncRawAnnotationQueuesClient.java b/src/main/java/com/langfuse/client/resources/annotationqueues/AsyncRawAnnotationQueuesClient.java
new file mode 100644
index 0000000..f2637e9
--- /dev/null
+++ b/src/main/java/com/langfuse/client/resources/annotationqueues/AsyncRawAnnotationQueuesClient.java
@@ -0,0 +1,920 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+
+package com.langfuse.client.resources.annotationqueues;
+
+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.LangfuseClientHttpResponse;
+import com.langfuse.client.core.MediaTypes;
+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.Override;
+import java.lang.String;
+import java.util.concurrent.CompletableFuture;
+import okhttp3.Call;
+import okhttp3.Callback;
+import okhttp3.Headers;
+import okhttp3.HttpUrl;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
+import org.jetbrains.annotations.NotNull;
+import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueueItemsRequest;
+import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueuesRequest;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueue;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueueAssignmentRequest;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueueItem;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueAssignmentResponse;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueItemRequest;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueRequest;
+import com.langfuse.client.resources.annotationqueues.types.DeleteAnnotationQueueAssignmentResponse;
+import com.langfuse.client.resources.annotationqueues.types.DeleteAnnotationQueueItemResponse;
+import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueueItems;
+import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueues;
+import com.langfuse.client.resources.annotationqueues.types.UpdateAnnotationQueueItemRequest;
+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;
+
+public class AsyncRawAnnotationQueuesClient {
+ protected final ClientOptions clientOptions;
+
+ public AsyncRawAnnotationQueuesClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture> listQueues() {
+ return listQueues(GetAnnotationQueuesRequest.builder().build());
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture> listQueues(
+ RequestOptions requestOptions) {
+ return listQueues(GetAnnotationQueuesRequest.builder().build(),requestOptions);
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture> listQueues(
+ GetAnnotationQueuesRequest request) {
+ return listQueues(request,null);
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public CompletableFuture> listQueues(
+ GetAnnotationQueuesRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues");if (request.getPage().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "page", request.getPage().get(), false);
+ }
+ if (request.getLimit().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "limit", request.getLimit().get(), false);
+ }
+ if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json");
+ Request okhttpRequest = _requestBuilder.build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, PaginatedAnnotationQueues.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public CompletableFuture> createQueue(
+ CreateAnnotationQueueRequest request) {
+ return createQueue(request,null);
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public CompletableFuture> createQueue(
+ CreateAnnotationQueueRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueue.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public CompletableFuture> getQueue(
+ String queueId) {
+ return getQueue(queueId,null);
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public CompletableFuture> getQueue(String queueId,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueue.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture> listQueueItems(
+ String queueId) {
+ return listQueueItems(queueId,GetAnnotationQueueItemsRequest.builder().build());
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture> listQueueItems(
+ String queueId, RequestOptions requestOptions) {
+ return listQueueItems(queueId,GetAnnotationQueueItemsRequest.builder().build(),requestOptions);
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture> listQueueItems(
+ String queueId, GetAnnotationQueueItemsRequest request) {
+ return listQueueItems(queueId,request,null);
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public CompletableFuture> listQueueItems(
+ String queueId, GetAnnotationQueueItemsRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items");if (request.getStatus().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "status", request.getStatus().get(), false);
+ }
+ if (request.getPage().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "page", request.getPage().get(), false);
+ }
+ if (request.getLimit().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "limit", request.getLimit().get(), false);
+ }
+ if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json");
+ Request okhttpRequest = _requestBuilder.build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, PaginatedAnnotationQueueItems.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public CompletableFuture> getQueueItem(
+ String queueId, String itemId) {
+ return getQueueItem(queueId,itemId,null);
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public CompletableFuture> getQueueItem(
+ String queueId, String itemId, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items")
+ .addPathSegment(itemId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueueItem.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public CompletableFuture> createQueueItem(
+ String queueId, CreateAnnotationQueueItemRequest request) {
+ return createQueueItem(queueId,request,null);
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public CompletableFuture> createQueueItem(
+ String queueId, CreateAnnotationQueueItemRequest request,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueueItem.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture> updateQueueItem(
+ String queueId, String itemId) {
+ return updateQueueItem(queueId,itemId,UpdateAnnotationQueueItemRequest.builder().build());
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture> updateQueueItem(
+ String queueId, String itemId, RequestOptions requestOptions) {
+ return updateQueueItem(queueId,itemId,UpdateAnnotationQueueItemRequest.builder().build(),requestOptions);
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture> updateQueueItem(
+ String queueId, String itemId, UpdateAnnotationQueueItemRequest request) {
+ return updateQueueItem(queueId,itemId,request,null);
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public CompletableFuture> updateQueueItem(
+ String queueId, String itemId, UpdateAnnotationQueueItemRequest request,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items")
+ .addPathSegment(itemId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("PATCH", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueueItem.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public CompletableFuture> deleteQueueItem(
+ String queueId, String itemId) {
+ return deleteQueueItem(queueId,itemId,null);
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public CompletableFuture> deleteQueueItem(
+ String queueId, String itemId, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items")
+ .addPathSegment(itemId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("DELETE", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, DeleteAnnotationQueueItemResponse.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public CompletableFuture> createQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request) {
+ return createQueueAssignment(queueId,request,null);
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public CompletableFuture> createQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("assignments");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, CreateAnnotationQueueAssignmentResponse.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public CompletableFuture> deleteQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request) {
+ return deleteQueueAssignment(queueId,request,null);
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public CompletableFuture> deleteQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("assignments");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("DELETE", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ CompletableFuture> future = new CompletableFuture<>();
+ client.newCall(okhttpRequest).enqueue(new Callback() {
+ @Override
+ public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
+ try (ResponseBody responseBody = response.body()) {
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ future.complete(new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, DeleteAnnotationQueueAssignmentResponse.class), response));
+ return;
+ }
+ try {
+ switch (response.code()) {
+ case 400:future.completeExceptionally(new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 401:future.completeExceptionally(new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 403:future.completeExceptionally(new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 404:future.completeExceptionally(new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ case 405:future.completeExceptionally(new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response));
+ return;
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ }
+ catch (IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new LangfuseClientException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+ }
diff --git a/src/main/java/com/langfuse/client/resources/annotationqueues/RawAnnotationQueuesClient.java b/src/main/java/com/langfuse/client/resources/annotationqueues/RawAnnotationQueuesClient.java
new file mode 100644
index 0000000..7cf9212
--- /dev/null
+++ b/src/main/java/com/langfuse/client/resources/annotationqueues/RawAnnotationQueuesClient.java
@@ -0,0 +1,733 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+
+package com.langfuse.client.resources.annotationqueues;
+
+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.LangfuseClientHttpResponse;
+import com.langfuse.client.core.MediaTypes;
+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.RequestBody;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
+import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueueItemsRequest;
+import com.langfuse.client.resources.annotationqueues.requests.GetAnnotationQueuesRequest;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueue;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueueAssignmentRequest;
+import com.langfuse.client.resources.annotationqueues.types.AnnotationQueueItem;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueAssignmentResponse;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueItemRequest;
+import com.langfuse.client.resources.annotationqueues.types.CreateAnnotationQueueRequest;
+import com.langfuse.client.resources.annotationqueues.types.DeleteAnnotationQueueAssignmentResponse;
+import com.langfuse.client.resources.annotationqueues.types.DeleteAnnotationQueueItemResponse;
+import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueueItems;
+import com.langfuse.client.resources.annotationqueues.types.PaginatedAnnotationQueues;
+import com.langfuse.client.resources.annotationqueues.types.UpdateAnnotationQueueItemRequest;
+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;
+
+public class RawAnnotationQueuesClient {
+ protected final ClientOptions clientOptions;
+
+ public RawAnnotationQueuesClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public LangfuseClientHttpResponse listQueues() {
+ return listQueues(GetAnnotationQueuesRequest.builder().build());
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public LangfuseClientHttpResponse listQueues(
+ RequestOptions requestOptions) {
+ return listQueues(GetAnnotationQueuesRequest.builder().build(),requestOptions);
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public LangfuseClientHttpResponse listQueues(
+ GetAnnotationQueuesRequest request) {
+ return listQueues(request,null);
+ }
+
+ /**
+ * Get all annotation queues
+ */
+ public LangfuseClientHttpResponse listQueues(
+ GetAnnotationQueuesRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues");if (request.getPage().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "page", request.getPage().get(), false);
+ }
+ if (request.getLimit().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "limit", request.getLimit().get(), false);
+ }
+ if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, PaginatedAnnotationQueues.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public LangfuseClientHttpResponse createQueue(
+ CreateAnnotationQueueRequest request) {
+ return createQueue(request,null);
+ }
+
+ /**
+ * Create an annotation queue
+ */
+ public LangfuseClientHttpResponse createQueue(
+ CreateAnnotationQueueRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueue.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public LangfuseClientHttpResponse getQueue(String queueId) {
+ return getQueue(queueId,null);
+ }
+
+ /**
+ * Get an annotation queue by ID
+ */
+ public LangfuseClientHttpResponse getQueue(String queueId,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueue.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public LangfuseClientHttpResponse listQueueItems(
+ String queueId) {
+ return listQueueItems(queueId,GetAnnotationQueueItemsRequest.builder().build());
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public LangfuseClientHttpResponse listQueueItems(
+ String queueId, RequestOptions requestOptions) {
+ return listQueueItems(queueId,GetAnnotationQueueItemsRequest.builder().build(),requestOptions);
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public LangfuseClientHttpResponse listQueueItems(
+ String queueId, GetAnnotationQueueItemsRequest request) {
+ return listQueueItems(queueId,request,null);
+ }
+
+ /**
+ * Get items for a specific annotation queue
+ */
+ public LangfuseClientHttpResponse listQueueItems(
+ String queueId, GetAnnotationQueueItemsRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items");if (request.getStatus().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "status", request.getStatus().get(), false);
+ }
+ if (request.getPage().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "page", request.getPage().get(), false);
+ }
+ if (request.getLimit().isPresent()) {
+ QueryStringMapper.addQueryParameter(httpUrl, "limit", request.getLimit().get(), false);
+ }
+ if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, PaginatedAnnotationQueueItems.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public LangfuseClientHttpResponse getQueueItem(String queueId,
+ String itemId) {
+ return getQueueItem(queueId,itemId,null);
+ }
+
+ /**
+ * Get a specific item from an annotation queue
+ */
+ public LangfuseClientHttpResponse getQueueItem(String queueId,
+ String itemId, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items")
+ .addPathSegment(itemId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("GET", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueueItem.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public LangfuseClientHttpResponse createQueueItem(String queueId,
+ CreateAnnotationQueueItemRequest request) {
+ return createQueueItem(queueId,request,null);
+ }
+
+ /**
+ * Add an item to an annotation queue
+ */
+ public LangfuseClientHttpResponse createQueueItem(String queueId,
+ CreateAnnotationQueueItemRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueueItem.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public LangfuseClientHttpResponse updateQueueItem(String queueId,
+ String itemId) {
+ return updateQueueItem(queueId,itemId,UpdateAnnotationQueueItemRequest.builder().build());
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public LangfuseClientHttpResponse updateQueueItem(String queueId,
+ String itemId, RequestOptions requestOptions) {
+ return updateQueueItem(queueId,itemId,UpdateAnnotationQueueItemRequest.builder().build(),requestOptions);
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public LangfuseClientHttpResponse updateQueueItem(String queueId,
+ String itemId, UpdateAnnotationQueueItemRequest request) {
+ return updateQueueItem(queueId,itemId,request,null);
+ }
+
+ /**
+ * Update an annotation queue item
+ */
+ public LangfuseClientHttpResponse updateQueueItem(String queueId,
+ String itemId, UpdateAnnotationQueueItemRequest request,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items")
+ .addPathSegment(itemId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("PATCH", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, AnnotationQueueItem.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public LangfuseClientHttpResponse deleteQueueItem(
+ String queueId, String itemId) {
+ return deleteQueueItem(queueId,itemId,null);
+ }
+
+ /**
+ * Remove an item from an annotation queue
+ */
+ public LangfuseClientHttpResponse deleteQueueItem(
+ String queueId, String itemId, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("items")
+ .addPathSegment(itemId);if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("DELETE", null)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, DeleteAnnotationQueueItemResponse.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public LangfuseClientHttpResponse createQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request) {
+ return createQueueAssignment(queueId,request,null);
+ }
+
+ /**
+ * Create an assignment for a user to an annotation queue
+ */
+ public LangfuseClientHttpResponse createQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("assignments");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, CreateAnnotationQueueAssignmentResponse.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public LangfuseClientHttpResponse deleteQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request) {
+ return deleteQueueAssignment(queueId,request,null);
+ }
+
+ /**
+ * Delete an assignment for a user to an annotation queue
+ */
+ public LangfuseClientHttpResponse deleteQueueAssignment(
+ String queueId, AnnotationQueueAssignmentRequest request,
+ RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()).newBuilder()
+ .addPathSegments("api/public")
+ .addPathSegments("annotation-queues")
+ .addPathSegment(queueId)
+ .addPathSegments("assignments");if (requestOptions != null) {
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
+ } );
+ }
+ RequestBody body;
+ try {
+ body = RequestBody.create(ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ }
+ catch(JsonProcessingException e) {
+ throw new LangfuseClientException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl.build())
+ .method("DELETE", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .addHeader("Accept", "application/json")
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new LangfuseClientHttpResponse<>(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, DeleteAnnotationQueueAssignmentResponse.class), response);
+ }
+ try {
+ switch (response.code()) {
+ case 400:throw new Error(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 401:throw new UnauthorizedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 403:throw new AccessDeniedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 404:throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ case 405:throw new MethodNotAllowedError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class), response);
+ }
+ }
+ catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new LangfuseClientApiException("Error with status code " + response.code(), response.code(), errorBody, response);
+ }
+ catch (IOException e) {
+ throw new LangfuseClientException("Network error executing HTTP request", e);
+ }
+ }
+ }
diff --git a/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueueItemsRequest.java b/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueueItemsRequest.java
index 6ffba05..2fe5562 100644
--- a/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueueItemsRequest.java
+++ b/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueueItemsRequest.java
@@ -119,6 +119,9 @@ public Builder from(GetAnnotationQueueItemsRequest other) {
return this;
}
+ /**
+ * Filter by status
+ */
@JsonSetter(
value = "status",
nulls = Nulls.SKIP
@@ -133,6 +136,9 @@ public Builder status(AnnotationQueueStatus status) {
return this;
}
+ /**
+ * page number, starts at 1
+ */
@JsonSetter(
value = "page",
nulls = Nulls.SKIP
@@ -147,6 +153,9 @@ public Builder page(Integer page) {
return this;
}
+ /**
+ * limit of items per page
+ */
@JsonSetter(
value = "limit",
nulls = Nulls.SKIP
@@ -164,5 +173,15 @@ public Builder limit(Integer limit) {
public GetAnnotationQueueItemsRequest build() {
return new GetAnnotationQueueItemsRequest(status, page, limit, additionalProperties);
}
+
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueuesRequest.java b/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueuesRequest.java
index 725b191..1d123ad 100644
--- a/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueuesRequest.java
+++ b/src/main/java/com/langfuse/client/resources/annotationqueues/requests/GetAnnotationQueuesRequest.java
@@ -104,6 +104,9 @@ public Builder from(GetAnnotationQueuesRequest other) {
return this;
}
+ /**
+ * page number, starts at 1
+ */
@JsonSetter(
value = "page",
nulls = Nulls.SKIP
@@ -118,6 +121,9 @@ public Builder page(Integer page) {
return this;
}
+ /**
+ * limit of items per page
+ */
@JsonSetter(
value = "limit",
nulls = Nulls.SKIP
@@ -135,5 +141,15 @@ public Builder limit(Integer limit) {
public GetAnnotationQueuesRequest build() {
return new GetAnnotationQueuesRequest(page, limit, additionalProperties);
}
+
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/langfuse/client/resources/annotationqueues/types/AnnotationQueue.java b/src/main/java/com/langfuse/client/resources/annotationqueues/types/AnnotationQueue.java
index 6fed5b4..87a7fdb 100644
--- a/src/main/java/com/langfuse/client/resources/annotationqueues/types/AnnotationQueue.java
+++ b/src/main/java/com/langfuse/client/resources/annotationqueues/types/AnnotationQueue.java
@@ -135,6 +135,10 @@ public interface UpdatedAtStage {
public interface _FinalStage {
AnnotationQueue build();
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
_FinalStage description(Optional description);
_FinalStage description(String description);
@@ -209,7 +213,9 @@ public _FinalStage updatedAt(@NotNull OffsetDateTime updatedAt) {
@java.lang.Override
public _FinalStage addAllScoreConfigIds(List