config) {
+ return config.map(Logger::from).orElse(DEFAULT);
+ }
+
+ private boolean shouldLog(LogLevel messageLevel) {
+ return !silent && level.getValue() <= messageLevel.getValue();
+ }
+
+ public boolean isDebug() {
+ return shouldLog(LogLevel.DEBUG);
+ }
+
+ public boolean isInfo() {
+ return shouldLog(LogLevel.INFO);
+ }
+
+ public boolean isWarn() {
+ return shouldLog(LogLevel.WARN);
+ }
+
+ public boolean isError() {
+ return shouldLog(LogLevel.ERROR);
+ }
+
+ public void debug(String message) {
+ if (isDebug()) {
+ logger.debug(message);
+ }
+ }
+
+ public void info(String message) {
+ if (isInfo()) {
+ logger.info(message);
+ }
+ }
+
+ public void warn(String message) {
+ if (isWarn()) {
+ logger.warn(message);
+ }
+ }
+
+ public void error(String message) {
+ if (isError()) {
+ logger.error(message);
+ }
+ }
+}
diff --git a/src/main/java/com/vital/api/core/LoggingInterceptor.java b/src/main/java/com/vital/api/core/LoggingInterceptor.java
new file mode 100644
index 00000000..a7896c89
--- /dev/null
+++ b/src/main/java/com/vital/api/core/LoggingInterceptor.java
@@ -0,0 +1,104 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.core;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+import okhttp3.Interceptor;
+import okhttp3.Request;
+import okhttp3.Response;
+
+/**
+ * OkHttp interceptor that logs HTTP requests and responses.
+ *
+ * Logs request method, URL, and headers (with sensitive values redacted) at debug level.
+ * Logs response status at debug level, and 4xx/5xx responses at error level.
+ * Does nothing if the logger is silent.
+ */
+public final class LoggingInterceptor implements Interceptor {
+
+ private static final Set SENSITIVE_HEADERS = new HashSet<>(Arrays.asList(
+ "authorization",
+ "www-authenticate",
+ "x-api-key",
+ "api-key",
+ "apikey",
+ "x-api-token",
+ "x-auth-token",
+ "auth-token",
+ "proxy-authenticate",
+ "proxy-authorization",
+ "cookie",
+ "set-cookie",
+ "x-csrf-token",
+ "x-xsrf-token",
+ "x-session-token",
+ "x-access-token"));
+
+ private final Logger logger;
+
+ public LoggingInterceptor(Logger logger) {
+ this.logger = logger;
+ }
+
+ @Override
+ public Response intercept(Chain chain) throws IOException {
+ Request request = chain.request();
+
+ if (logger.isDebug()) {
+ StringBuilder sb = new StringBuilder();
+ sb.append("HTTP Request: ").append(request.method()).append(" ").append(request.url());
+ sb.append(" headers={");
+ boolean first = true;
+ for (String name : request.headers().names()) {
+ if (!first) {
+ sb.append(", ");
+ }
+ sb.append(name).append("=");
+ if (SENSITIVE_HEADERS.contains(name.toLowerCase())) {
+ sb.append("[REDACTED]");
+ } else {
+ sb.append(request.header(name));
+ }
+ first = false;
+ }
+ sb.append("}");
+ sb.append(" has_body=").append(request.body() != null);
+ logger.debug(sb.toString());
+ }
+
+ Response response = chain.proceed(request);
+
+ if (logger.isDebug()) {
+ StringBuilder sb = new StringBuilder();
+ sb.append("HTTP Response: status=").append(response.code());
+ sb.append(" url=").append(response.request().url());
+ sb.append(" headers={");
+ boolean first = true;
+ for (String name : response.headers().names()) {
+ if (!first) {
+ sb.append(", ");
+ }
+ sb.append(name).append("=");
+ if (SENSITIVE_HEADERS.contains(name.toLowerCase())) {
+ sb.append("[REDACTED]");
+ } else {
+ sb.append(response.header(name));
+ }
+ first = false;
+ }
+ sb.append("}");
+ logger.debug(sb.toString());
+ }
+
+ if (response.code() >= 400 && logger.isError()) {
+ logger.error("HTTP Error: status=" + response.code() + " url="
+ + response.request().url());
+ }
+
+ return response;
+ }
+}
diff --git a/src/main/java/com/vital/api/core/SseEvent.java b/src/main/java/com/vital/api/core/SseEvent.java
new file mode 100644
index 00000000..779c1ec1
--- /dev/null
+++ b/src/main/java/com/vital/api/core/SseEvent.java
@@ -0,0 +1,114 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.core;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.Objects;
+import java.util.Optional;
+
+/**
+ * Represents a Server-Sent Event with all standard fields.
+ * Used for event-level discrimination where the discriminator is at the SSE envelope level.
+ *
+ * @param The type of the data field
+ */
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonIgnoreProperties(ignoreUnknown = true)
+public final class SseEvent {
+ private final String event;
+ private final T data;
+ private final String id;
+ private final Long retry;
+
+ private SseEvent(String event, T data, String id, Long retry) {
+ this.event = event;
+ this.data = data;
+ this.id = id;
+ this.retry = retry;
+ }
+
+ @JsonProperty("event")
+ public Optional getEvent() {
+ return Optional.ofNullable(event);
+ }
+
+ @JsonProperty("data")
+ public T getData() {
+ return data;
+ }
+
+ @JsonProperty("id")
+ public Optional getId() {
+ return Optional.ofNullable(id);
+ }
+
+ @JsonProperty("retry")
+ public Optional getRetry() {
+ return Optional.ofNullable(retry);
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) return true;
+ if (o == null || getClass() != o.getClass()) return false;
+ SseEvent sseEvent = (SseEvent) o;
+ return Objects.equals(event, sseEvent.event)
+ && Objects.equals(data, sseEvent.data)
+ && Objects.equals(id, sseEvent.id)
+ && Objects.equals(retry, sseEvent.retry);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(event, data, id, retry);
+ }
+
+ @Override
+ public String toString() {
+ return "SseEvent{" + "event='"
+ + event + '\'' + ", data="
+ + data + ", id='"
+ + id + '\'' + ", retry="
+ + retry + '}';
+ }
+
+ public static Builder builder() {
+ return new Builder<>();
+ }
+
+ public static final class Builder {
+ private String event;
+ private T data;
+ private String id;
+ private Long retry;
+
+ private Builder() {}
+
+ public Builder event(String event) {
+ this.event = event;
+ return this;
+ }
+
+ public Builder data(T data) {
+ this.data = data;
+ return this;
+ }
+
+ public Builder id(String id) {
+ this.id = id;
+ return this;
+ }
+
+ public Builder retry(Long retry) {
+ this.retry = retry;
+ return this;
+ }
+
+ public SseEvent build() {
+ return new SseEvent<>(event, data, id, retry);
+ }
+ }
+}
diff --git a/src/main/java/com/vital/api/core/SseEventParser.java b/src/main/java/com/vital/api/core/SseEventParser.java
new file mode 100644
index 00000000..b5b9a668
--- /dev/null
+++ b/src/main/java/com/vital/api/core/SseEventParser.java
@@ -0,0 +1,228 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.core;
+
+import com.fasterxml.jackson.annotation.JsonSubTypes;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.fasterxml.jackson.annotation.JsonTypeName;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.lang.reflect.Field;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
+
+/**
+ * Utility class for parsing Server-Sent Events with support for discriminated unions.
+ *
+ * Handles two discrimination patterns:
+ *
+ * - Data-level discrimination: The discriminator (e.g., 'type') is inside the JSON data payload.
+ * Jackson's polymorphic deserialization handles this automatically.
+ * - Event-level discrimination: The discriminator (e.g., 'event') is at the SSE envelope level.
+ * This requires constructing the full SSE envelope for Jackson to process.
+ *
+ */
+public final class SseEventParser {
+
+ private static final Set 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/vital/api/core/Stream.java b/src/main/java/com/vital/api/core/Stream.java
index 4895adc0..9e2322a0 100644
--- a/src/main/java/com/vital/api/core/Stream.java
+++ b/src/main/java/com/vital/api/core/Stream.java
@@ -28,7 +28,8 @@ public final class Stream implements Iterable, Closeable {
public enum StreamType {
JSON,
- SSE
+ SSE,
+ SSE_EVENT_DISCRIMINATED
}
private final Class valueType;
@@ -37,6 +38,7 @@ public enum StreamType {
private final String messageTerminator;
private final String streamTerminator;
private final Reader sseReader;
+ private final String discriminatorProperty;
private boolean isClosed = false;
/**
@@ -53,11 +55,18 @@ public Stream(Class valueType, Reader reader, String delimiter) {
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;
@@ -87,6 +96,38 @@ public static Stream fromSse(Class valueType, Reader sseReader, String
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) {
@@ -112,10 +153,14 @@ private boolean isStreamClosed() {
*/
@Override
public Iterator iterator() {
- if (streamType == StreamType.SSE) {
- return new SSEIterator();
- } else {
- return new JsonIterator();
+ switch (streamType) {
+ case SSE:
+ return new SSEIterator();
+ case SSE_EVENT_DISCRIMINATED:
+ return new SSEEventDiscriminatedIterator();
+ case JSON:
+ default:
+ return new JsonIterator();
}
}
@@ -299,4 +344,170 @@ private boolean readNextMessage() {
}
}
}
+
+ /**
+ * 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");
+ }
+
+ 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;
+ }
+ }
}
diff --git a/src/main/java/com/vital/api/resources/activity/AsyncRawActivityClient.java b/src/main/java/com/vital/api/resources/activity/AsyncRawActivityClient.java
index 4b9134e4..266e401a 100644
--- a/src/main/java/com/vital/api/resources/activity/AsyncRawActivityClient.java
+++ b/src/main/java/com/vital/api/resources/activity/AsyncRawActivityClient.java
@@ -62,8 +62,8 @@ public CompletableFuture> get(
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -142,8 +142,8 @@ public CompletableFuture> getRaw(
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/activity/RawActivityClient.java b/src/main/java/com/vital/api/resources/activity/RawActivityClient.java
index e6756af1..6091ac3c 100644
--- a/src/main/java/com/vital/api/resources/activity/RawActivityClient.java
+++ b/src/main/java/com/vital/api/resources/activity/RawActivityClient.java
@@ -58,8 +58,8 @@ public VitalHttpResponse get(
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -123,8 +123,8 @@ public VitalHttpResponse getRaw(
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRawRequest.java b/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRawRequest.java
index 9e4497fc..30e3e090 100644
--- a/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRawRequest.java
+++ b/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRawRequest.java
@@ -105,6 +105,10 @@ public interface StartDateStage {
public interface _FinalStage {
ActivityGetRawRequest build();
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
/**
* Provider oura/strava etc
*/
@@ -197,5 +201,17 @@ public _FinalStage provider(Optional provider) {
public ActivityGetRawRequest build() {
return new ActivityGetRawRequest(provider, startDate, endDate, additionalProperties);
}
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRequest.java b/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRequest.java
index b78b11a9..8d61887e 100644
--- a/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRequest.java
+++ b/src/main/java/com/vital/api/resources/activity/requests/ActivityGetRequest.java
@@ -105,6 +105,10 @@ public interface StartDateStage {
public interface _FinalStage {
ActivityGetRequest build();
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
/**
* Provider oura/strava etc
*/
@@ -197,5 +201,17 @@ public _FinalStage provider(Optional provider) {
public ActivityGetRequest build() {
return new ActivityGetRequest(provider, startDate, endDate, additionalProperties);
}
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/vital/api/resources/aggregate/AsyncRawAggregateClient.java b/src/main/java/com/vital/api/resources/aggregate/AsyncRawAggregateClient.java
index d0d64011..99d8979b 100644
--- a/src/main/java/com/vital/api/resources/aggregate/AsyncRawAggregateClient.java
+++ b/src/main/java/com/vital/api/resources/aggregate/AsyncRawAggregateClient.java
@@ -51,8 +51,8 @@ public CompletableFuture> queryOne(
.addPathSegment(userId)
.addPathSegments("query");
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
RequestBody body;
@@ -128,8 +128,8 @@ public CompletableFuture> getResultTableFor
.addPathSegment(queryIdOrSlug)
.addPathSegments("result_table");
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request okhttpRequest = new Request.Builder()
@@ -224,8 +224,8 @@ public CompletableFuture>
httpUrl, "limit", request.getLimit().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/aggregate/RawAggregateClient.java b/src/main/java/com/vital/api/resources/aggregate/RawAggregateClient.java
index 5d7ddd95..3ff55630 100644
--- a/src/main/java/com/vital/api/resources/aggregate/RawAggregateClient.java
+++ b/src/main/java/com/vital/api/resources/aggregate/RawAggregateClient.java
@@ -47,8 +47,8 @@ public VitalHttpResponse queryOne(
.addPathSegment(userId)
.addPathSegments("query");
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
RequestBody body;
@@ -107,8 +107,8 @@ public VitalHttpResponse getResultTableForContinuousQuery(
.addPathSegment(queryIdOrSlug)
.addPathSegments("result_table");
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request okhttpRequest = new Request.Builder()
@@ -187,8 +187,8 @@ public VitalHttpResponse getTaskHistoryForCo
httpUrl, "limit", request.getLimit().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/aggregate/requests/AggregateGetTaskHistoryForContinuousQueryRequest.java b/src/main/java/com/vital/api/resources/aggregate/requests/AggregateGetTaskHistoryForContinuousQueryRequest.java
index 0f809c5d..c4b1cd33 100644
--- a/src/main/java/com/vital/api/resources/aggregate/requests/AggregateGetTaskHistoryForContinuousQueryRequest.java
+++ b/src/main/java/com/vital/api/resources/aggregate/requests/AggregateGetTaskHistoryForContinuousQueryRequest.java
@@ -115,5 +115,15 @@ public Builder limit(Integer limit) {
public AggregateGetTaskHistoryForContinuousQueryRequest build() {
return new AggregateGetTaskHistoryForContinuousQueryRequest(nextCursor, 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/vital/api/resources/aggregate/requests/QueryBatch.java b/src/main/java/com/vital/api/resources/aggregate/requests/QueryBatch.java
index 0f7621ba..90bee5a9 100644
--- a/src/main/java/com/vital/api/resources/aggregate/requests/QueryBatch.java
+++ b/src/main/java/com/vital/api/resources/aggregate/requests/QueryBatch.java
@@ -104,6 +104,10 @@ public interface TimeframeStage {
public interface _FinalStage {
QueryBatch build();
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
_FinalStage queries(List queries);
_FinalStage addQueries(Query queries);
@@ -184,5 +188,17 @@ public _FinalStage queries(List queries) {
public QueryBatch build() {
return new QueryBatch(timeframe, queries, config, additionalProperties);
}
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/vital/api/resources/body/AsyncRawBodyClient.java b/src/main/java/com/vital/api/resources/body/AsyncRawBodyClient.java
index 79abb441..e9d9dbd5 100644
--- a/src/main/java/com/vital/api/resources/body/AsyncRawBodyClient.java
+++ b/src/main/java/com/vital/api/resources/body/AsyncRawBodyClient.java
@@ -62,8 +62,8 @@ public CompletableFuture> get(
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -142,8 +142,8 @@ public CompletableFuture> getRaw(
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/body/RawBodyClient.java b/src/main/java/com/vital/api/resources/body/RawBodyClient.java
index d1a71e72..49355a29 100644
--- a/src/main/java/com/vital/api/resources/body/RawBodyClient.java
+++ b/src/main/java/com/vital/api/resources/body/RawBodyClient.java
@@ -58,8 +58,8 @@ public VitalHttpResponse get(
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -121,8 +121,8 @@ public VitalHttpResponse getRaw(String userId, BodyGetRawRequest reques
httpUrl, "end_date", request.getEndDate().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/body/requests/BodyGetRawRequest.java b/src/main/java/com/vital/api/resources/body/requests/BodyGetRawRequest.java
index 2db1dc34..0d6d4564 100644
--- a/src/main/java/com/vital/api/resources/body/requests/BodyGetRawRequest.java
+++ b/src/main/java/com/vital/api/resources/body/requests/BodyGetRawRequest.java
@@ -105,6 +105,10 @@ public interface StartDateStage {
public interface _FinalStage {
BodyGetRawRequest build();
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
/**
* Provider oura/strava etc
*/
@@ -197,5 +201,17 @@ public _FinalStage provider(Optional provider) {
public BodyGetRawRequest build() {
return new BodyGetRawRequest(provider, startDate, endDate, additionalProperties);
}
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/vital/api/resources/body/requests/BodyGetRequest.java b/src/main/java/com/vital/api/resources/body/requests/BodyGetRequest.java
index 7f4a4f41..04164618 100644
--- a/src/main/java/com/vital/api/resources/body/requests/BodyGetRequest.java
+++ b/src/main/java/com/vital/api/resources/body/requests/BodyGetRequest.java
@@ -105,6 +105,10 @@ public interface StartDateStage {
public interface _FinalStage {
BodyGetRequest build();
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
/**
* Provider oura/strava etc
*/
@@ -197,5 +201,17 @@ public _FinalStage provider(Optional provider) {
public BodyGetRequest build() {
return new BodyGetRequest(provider, startDate, endDate, additionalProperties);
}
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/vital/api/resources/compendium/AsyncCompendiumClient.java b/src/main/java/com/vital/api/resources/compendium/AsyncCompendiumClient.java
new file mode 100644
index 00000000..0e75e63f
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/AsyncCompendiumClient.java
@@ -0,0 +1,48 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium;
+
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.resources.compendium.requests.ConvertCompendiumBody;
+import com.vital.api.resources.compendium.requests.SearchCompendiumBody;
+import com.vital.api.types.ConvertCompendiumResponse;
+import com.vital.api.types.SearchCompendiumResponse;
+import java.util.concurrent.CompletableFuture;
+
+public class AsyncCompendiumClient {
+ protected final ClientOptions clientOptions;
+
+ private final AsyncRawCompendiumClient rawClient;
+
+ public AsyncCompendiumClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ this.rawClient = new AsyncRawCompendiumClient(clientOptions);
+ }
+
+ /**
+ * Get responses with HTTP metadata like headers
+ */
+ public AsyncRawCompendiumClient withRawResponse() {
+ return this.rawClient;
+ }
+
+ public CompletableFuture search(SearchCompendiumBody request) {
+ return this.rawClient.search(request).thenApply(response -> response.body());
+ }
+
+ public CompletableFuture search(
+ SearchCompendiumBody request, RequestOptions requestOptions) {
+ return this.rawClient.search(request, requestOptions).thenApply(response -> response.body());
+ }
+
+ public CompletableFuture convert(ConvertCompendiumBody request) {
+ return this.rawClient.convert(request).thenApply(response -> response.body());
+ }
+
+ public CompletableFuture convert(
+ ConvertCompendiumBody request, RequestOptions requestOptions) {
+ return this.rawClient.convert(request, requestOptions).thenApply(response -> response.body());
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/compendium/AsyncRawCompendiumClient.java b/src/main/java/com/vital/api/resources/compendium/AsyncRawCompendiumClient.java
new file mode 100644
index 00000000..88c10891
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/AsyncRawCompendiumClient.java
@@ -0,0 +1,191 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.vital.api.core.ApiError;
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.MediaTypes;
+import com.vital.api.core.ObjectMappers;
+import com.vital.api.core.QueryStringMapper;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.core.VitalException;
+import com.vital.api.core.VitalHttpResponse;
+import com.vital.api.errors.UnprocessableEntityError;
+import com.vital.api.resources.compendium.requests.ConvertCompendiumBody;
+import com.vital.api.resources.compendium.requests.SearchCompendiumBody;
+import com.vital.api.types.ConvertCompendiumResponse;
+import com.vital.api.types.HttpValidationError;
+import com.vital.api.types.SearchCompendiumResponse;
+import java.io.IOException;
+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;
+
+public class AsyncRawCompendiumClient {
+ protected final ClientOptions clientOptions;
+
+ public AsyncRawCompendiumClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ }
+
+ public CompletableFuture> search(SearchCompendiumBody request) {
+ return search(request, null);
+ }
+
+ public CompletableFuture> search(
+ SearchCompendiumBody request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v3/compendium/search");
+ if (request.getTeamId().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "team_id", request.getTeamId().get(), false);
+ }
+ 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 (Exception e) {
+ throw new RuntimeException(e);
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .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);
+ }
+ 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 VitalHttpResponse<>(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, SearchCompendiumResponse.class),
+ response));
+ return;
+ }
+ try {
+ if (response.code() == 422) {
+ future.completeExceptionally(new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, HttpValidationError.class),
+ response));
+ return;
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new ApiError(
+ "Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ } catch (IOException e) {
+ future.completeExceptionally(new VitalException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new VitalException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+
+ public CompletableFuture> convert(ConvertCompendiumBody request) {
+ return convert(request, null);
+ }
+
+ public CompletableFuture> convert(
+ ConvertCompendiumBody request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v3/compendium/convert");
+ if (request.getTeamId().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "team_id", request.getTeamId().get(), false);
+ }
+ 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 (Exception e) {
+ throw new RuntimeException(e);
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .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);
+ }
+ 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 VitalHttpResponse<>(
+ ObjectMappers.JSON_MAPPER.readValue(
+ responseBodyString, ConvertCompendiumResponse.class),
+ response));
+ return;
+ }
+ try {
+ if (response.code() == 422) {
+ future.completeExceptionally(new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, HttpValidationError.class),
+ response));
+ return;
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new ApiError(
+ "Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ } catch (IOException e) {
+ future.completeExceptionally(new VitalException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new VitalException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/compendium/CompendiumClient.java b/src/main/java/com/vital/api/resources/compendium/CompendiumClient.java
new file mode 100644
index 00000000..c0dbdf25
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/CompendiumClient.java
@@ -0,0 +1,45 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium;
+
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.resources.compendium.requests.ConvertCompendiumBody;
+import com.vital.api.resources.compendium.requests.SearchCompendiumBody;
+import com.vital.api.types.ConvertCompendiumResponse;
+import com.vital.api.types.SearchCompendiumResponse;
+
+public class CompendiumClient {
+ protected final ClientOptions clientOptions;
+
+ private final RawCompendiumClient rawClient;
+
+ public CompendiumClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ this.rawClient = new RawCompendiumClient(clientOptions);
+ }
+
+ /**
+ * Get responses with HTTP metadata like headers
+ */
+ public RawCompendiumClient withRawResponse() {
+ return this.rawClient;
+ }
+
+ public SearchCompendiumResponse search(SearchCompendiumBody request) {
+ return this.rawClient.search(request).body();
+ }
+
+ public SearchCompendiumResponse search(SearchCompendiumBody request, RequestOptions requestOptions) {
+ return this.rawClient.search(request, requestOptions).body();
+ }
+
+ public ConvertCompendiumResponse convert(ConvertCompendiumBody request) {
+ return this.rawClient.convert(request).body();
+ }
+
+ public ConvertCompendiumResponse convert(ConvertCompendiumBody request, RequestOptions requestOptions) {
+ return this.rawClient.convert(request, requestOptions).body();
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/compendium/RawCompendiumClient.java b/src/main/java/com/vital/api/resources/compendium/RawCompendiumClient.java
new file mode 100644
index 00000000..422adc62
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/RawCompendiumClient.java
@@ -0,0 +1,156 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.vital.api.core.ApiError;
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.MediaTypes;
+import com.vital.api.core.ObjectMappers;
+import com.vital.api.core.QueryStringMapper;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.core.VitalException;
+import com.vital.api.core.VitalHttpResponse;
+import com.vital.api.errors.UnprocessableEntityError;
+import com.vital.api.resources.compendium.requests.ConvertCompendiumBody;
+import com.vital.api.resources.compendium.requests.SearchCompendiumBody;
+import com.vital.api.types.ConvertCompendiumResponse;
+import com.vital.api.types.HttpValidationError;
+import com.vital.api.types.SearchCompendiumResponse;
+import java.io.IOException;
+import okhttp3.Headers;
+import okhttp3.HttpUrl;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
+
+public class RawCompendiumClient {
+ protected final ClientOptions clientOptions;
+
+ public RawCompendiumClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ }
+
+ public VitalHttpResponse search(SearchCompendiumBody request) {
+ return search(request, null);
+ }
+
+ public VitalHttpResponse search(
+ SearchCompendiumBody request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v3/compendium/search");
+ if (request.getTeamId().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "team_id", request.getTeamId().get(), false);
+ }
+ 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 (Exception e) {
+ throw new RuntimeException(e);
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new VitalHttpResponse<>(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, SearchCompendiumResponse.class),
+ response);
+ }
+ try {
+ if (response.code() == 422) {
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, HttpValidationError.class),
+ response);
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new ApiError("Error with status code " + response.code(), response.code(), errorBody, response);
+ } catch (IOException e) {
+ throw new VitalException("Network error executing HTTP request", e);
+ }
+ }
+
+ public VitalHttpResponse convert(ConvertCompendiumBody request) {
+ return convert(request, null);
+ }
+
+ public VitalHttpResponse convert(
+ ConvertCompendiumBody request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v3/compendium/convert");
+ if (request.getTeamId().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "team_id", request.getTeamId().get(), false);
+ }
+ 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 (Exception e) {
+ throw new RuntimeException(e);
+ }
+ Request.Builder _requestBuilder = new Request.Builder()
+ .url(httpUrl.build())
+ .method("POST", body)
+ .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();
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ if (response.isSuccessful()) {
+ return new VitalHttpResponse<>(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, ConvertCompendiumResponse.class),
+ response);
+ }
+ try {
+ if (response.code() == 422) {
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, HttpValidationError.class),
+ response);
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new ApiError("Error with status code " + response.code(), response.code(), errorBody, response);
+ } catch (IOException e) {
+ throw new VitalException("Network error executing HTTP request", e);
+ }
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/compendium/requests/ConvertCompendiumBody.java b/src/main/java/com/vital/api/resources/compendium/requests/ConvertCompendiumBody.java
new file mode 100644
index 00000000..2a667a5a
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/requests/ConvertCompendiumBody.java
@@ -0,0 +1,245 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium.requests;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSetter;
+import com.fasterxml.jackson.annotation.Nulls;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.vital.api.core.ObjectMappers;
+import com.vital.api.resources.compendium.types.CompendiumConvertRequestTeamId;
+import com.vital.api.types.CompendiumSearchLabs;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+import org.jetbrains.annotations.NotNull;
+
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonDeserialize(builder = ConvertCompendiumBody.Builder.class)
+public final class ConvertCompendiumBody {
+ private final Optional teamId;
+
+ private final Optional labTestId;
+
+ private final Optional> providerIds;
+
+ private final CompendiumSearchLabs targetLab;
+
+ private final Optional limit;
+
+ private final Map additionalProperties;
+
+ private ConvertCompendiumBody(
+ Optional teamId,
+ Optional labTestId,
+ Optional> providerIds,
+ CompendiumSearchLabs targetLab,
+ Optional limit,
+ Map additionalProperties) {
+ this.teamId = teamId;
+ this.labTestId = labTestId;
+ this.providerIds = providerIds;
+ this.targetLab = targetLab;
+ this.limit = limit;
+ this.additionalProperties = additionalProperties;
+ }
+
+ @JsonProperty("team_id")
+ public Optional getTeamId() {
+ return teamId;
+ }
+
+ @JsonProperty("lab_test_id")
+ public Optional getLabTestId() {
+ return labTestId;
+ }
+
+ @JsonProperty("provider_ids")
+ public Optional> getProviderIds() {
+ return providerIds;
+ }
+
+ @JsonProperty("target_lab")
+ public CompendiumSearchLabs getTargetLab() {
+ return targetLab;
+ }
+
+ @JsonProperty("limit")
+ public Optional getLimit() {
+ return limit;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ if (this == other) return true;
+ return other instanceof ConvertCompendiumBody && equalTo((ConvertCompendiumBody) other);
+ }
+
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ private boolean equalTo(ConvertCompendiumBody other) {
+ return teamId.equals(other.teamId)
+ && labTestId.equals(other.labTestId)
+ && providerIds.equals(other.providerIds)
+ && targetLab.equals(other.targetLab)
+ && limit.equals(other.limit);
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return Objects.hash(this.teamId, this.labTestId, this.providerIds, this.targetLab, this.limit);
+ }
+
+ @java.lang.Override
+ public String toString() {
+ return ObjectMappers.stringify(this);
+ }
+
+ public static TargetLabStage builder() {
+ return new Builder();
+ }
+
+ public interface TargetLabStage {
+ _FinalStage targetLab(@NotNull CompendiumSearchLabs targetLab);
+
+ Builder from(ConvertCompendiumBody other);
+ }
+
+ public interface _FinalStage {
+ ConvertCompendiumBody build();
+
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
+ _FinalStage teamId(Optional teamId);
+
+ _FinalStage teamId(CompendiumConvertRequestTeamId teamId);
+
+ _FinalStage labTestId(Optional labTestId);
+
+ _FinalStage labTestId(String labTestId);
+
+ _FinalStage providerIds(Optional> providerIds);
+
+ _FinalStage providerIds(List providerIds);
+
+ _FinalStage limit(Optional limit);
+
+ _FinalStage limit(Integer limit);
+ }
+
+ @JsonIgnoreProperties(ignoreUnknown = true)
+ public static final class Builder implements TargetLabStage, _FinalStage {
+ private CompendiumSearchLabs targetLab;
+
+ private Optional limit = Optional.empty();
+
+ private Optional> providerIds = Optional.empty();
+
+ private Optional labTestId = Optional.empty();
+
+ private Optional teamId = Optional.empty();
+
+ @JsonAnySetter
+ private Map additionalProperties = new HashMap<>();
+
+ private Builder() {}
+
+ @java.lang.Override
+ public Builder from(ConvertCompendiumBody other) {
+ teamId(other.getTeamId());
+ labTestId(other.getLabTestId());
+ providerIds(other.getProviderIds());
+ targetLab(other.getTargetLab());
+ limit(other.getLimit());
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter("target_lab")
+ public _FinalStage targetLab(@NotNull CompendiumSearchLabs targetLab) {
+ this.targetLab = Objects.requireNonNull(targetLab, "targetLab must not be null");
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage limit(Integer limit) {
+ this.limit = Optional.ofNullable(limit);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "limit", nulls = Nulls.SKIP)
+ public _FinalStage limit(Optional limit) {
+ this.limit = limit;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage providerIds(List providerIds) {
+ this.providerIds = Optional.ofNullable(providerIds);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "provider_ids", nulls = Nulls.SKIP)
+ public _FinalStage providerIds(Optional> providerIds) {
+ this.providerIds = providerIds;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage labTestId(String labTestId) {
+ this.labTestId = Optional.ofNullable(labTestId);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "lab_test_id", nulls = Nulls.SKIP)
+ public _FinalStage labTestId(Optional labTestId) {
+ this.labTestId = labTestId;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage teamId(CompendiumConvertRequestTeamId teamId) {
+ this.teamId = Optional.ofNullable(teamId);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "team_id", nulls = Nulls.SKIP)
+ public _FinalStage teamId(Optional teamId) {
+ this.teamId = teamId;
+ return this;
+ }
+
+ @java.lang.Override
+ public ConvertCompendiumBody build() {
+ return new ConvertCompendiumBody(teamId, labTestId, providerIds, targetLab, limit, additionalProperties);
+ }
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/compendium/requests/SearchCompendiumBody.java b/src/main/java/com/vital/api/resources/compendium/requests/SearchCompendiumBody.java
new file mode 100644
index 00000000..75610c75
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/requests/SearchCompendiumBody.java
@@ -0,0 +1,308 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium.requests;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSetter;
+import com.fasterxml.jackson.annotation.Nulls;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.vital.api.core.ObjectMappers;
+import com.vital.api.resources.compendium.types.CompendiumSearchRequestTeamId;
+import com.vital.api.types.CompendiumSearchLabs;
+import com.vital.api.types.SearchMode;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+import org.jetbrains.annotations.NotNull;
+
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonDeserialize(builder = SearchCompendiumBody.Builder.class)
+public final class SearchCompendiumBody {
+ private final Optional teamId;
+
+ private final SearchMode mode;
+
+ private final Optional query;
+
+ private final Optional loincSetHash;
+
+ private final Optional> labs;
+
+ private final Optional includeRelated;
+
+ private final Optional limit;
+
+ private final Map additionalProperties;
+
+ private SearchCompendiumBody(
+ Optional teamId,
+ SearchMode mode,
+ Optional query,
+ Optional loincSetHash,
+ Optional> labs,
+ Optional includeRelated,
+ Optional limit,
+ Map additionalProperties) {
+ this.teamId = teamId;
+ this.mode = mode;
+ this.query = query;
+ this.loincSetHash = loincSetHash;
+ this.labs = labs;
+ this.includeRelated = includeRelated;
+ this.limit = limit;
+ this.additionalProperties = additionalProperties;
+ }
+
+ @JsonProperty("team_id")
+ public Optional getTeamId() {
+ return teamId;
+ }
+
+ @JsonProperty("mode")
+ public SearchMode getMode() {
+ return mode;
+ }
+
+ @JsonProperty("query")
+ public Optional getQuery() {
+ return query;
+ }
+
+ @JsonProperty("loinc_set_hash")
+ public Optional getLoincSetHash() {
+ return loincSetHash;
+ }
+
+ @JsonProperty("labs")
+ public Optional> getLabs() {
+ return labs;
+ }
+
+ @JsonProperty("include_related")
+ public Optional getIncludeRelated() {
+ return includeRelated;
+ }
+
+ @JsonProperty("limit")
+ public Optional getLimit() {
+ return limit;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ if (this == other) return true;
+ return other instanceof SearchCompendiumBody && equalTo((SearchCompendiumBody) other);
+ }
+
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ private boolean equalTo(SearchCompendiumBody other) {
+ return teamId.equals(other.teamId)
+ && mode.equals(other.mode)
+ && query.equals(other.query)
+ && loincSetHash.equals(other.loincSetHash)
+ && labs.equals(other.labs)
+ && includeRelated.equals(other.includeRelated)
+ && limit.equals(other.limit);
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return Objects.hash(
+ this.teamId, this.mode, this.query, this.loincSetHash, this.labs, this.includeRelated, this.limit);
+ }
+
+ @java.lang.Override
+ public String toString() {
+ return ObjectMappers.stringify(this);
+ }
+
+ public static ModeStage builder() {
+ return new Builder();
+ }
+
+ public interface ModeStage {
+ _FinalStage mode(@NotNull SearchMode mode);
+
+ Builder from(SearchCompendiumBody other);
+ }
+
+ public interface _FinalStage {
+ SearchCompendiumBody build();
+
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
+ _FinalStage teamId(Optional teamId);
+
+ _FinalStage teamId(CompendiumSearchRequestTeamId teamId);
+
+ _FinalStage query(Optional query);
+
+ _FinalStage query(String query);
+
+ _FinalStage loincSetHash(Optional loincSetHash);
+
+ _FinalStage loincSetHash(String loincSetHash);
+
+ _FinalStage labs(Optional> labs);
+
+ _FinalStage labs(List labs);
+
+ _FinalStage includeRelated(Optional includeRelated);
+
+ _FinalStage includeRelated(Boolean includeRelated);
+
+ _FinalStage limit(Optional limit);
+
+ _FinalStage limit(Integer limit);
+ }
+
+ @JsonIgnoreProperties(ignoreUnknown = true)
+ public static final class Builder implements ModeStage, _FinalStage {
+ private SearchMode mode;
+
+ private Optional limit = Optional.empty();
+
+ private Optional includeRelated = Optional.empty();
+
+ private Optional> labs = Optional.empty();
+
+ private Optional loincSetHash = Optional.empty();
+
+ private Optional query = Optional.empty();
+
+ private Optional teamId = Optional.empty();
+
+ @JsonAnySetter
+ private Map additionalProperties = new HashMap<>();
+
+ private Builder() {}
+
+ @java.lang.Override
+ public Builder from(SearchCompendiumBody other) {
+ teamId(other.getTeamId());
+ mode(other.getMode());
+ query(other.getQuery());
+ loincSetHash(other.getLoincSetHash());
+ labs(other.getLabs());
+ includeRelated(other.getIncludeRelated());
+ limit(other.getLimit());
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter("mode")
+ public _FinalStage mode(@NotNull SearchMode mode) {
+ this.mode = Objects.requireNonNull(mode, "mode must not be null");
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage limit(Integer limit) {
+ this.limit = Optional.ofNullable(limit);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "limit", nulls = Nulls.SKIP)
+ public _FinalStage limit(Optional limit) {
+ this.limit = limit;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage includeRelated(Boolean includeRelated) {
+ this.includeRelated = Optional.ofNullable(includeRelated);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "include_related", nulls = Nulls.SKIP)
+ public _FinalStage includeRelated(Optional includeRelated) {
+ this.includeRelated = includeRelated;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage labs(List labs) {
+ this.labs = Optional.ofNullable(labs);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "labs", nulls = Nulls.SKIP)
+ public _FinalStage labs(Optional> labs) {
+ this.labs = labs;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage loincSetHash(String loincSetHash) {
+ this.loincSetHash = Optional.ofNullable(loincSetHash);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "loinc_set_hash", nulls = Nulls.SKIP)
+ public _FinalStage loincSetHash(Optional loincSetHash) {
+ this.loincSetHash = loincSetHash;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage query(String query) {
+ this.query = Optional.ofNullable(query);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "query", nulls = Nulls.SKIP)
+ public _FinalStage query(Optional query) {
+ this.query = query;
+ return this;
+ }
+
+ @java.lang.Override
+ public _FinalStage teamId(CompendiumSearchRequestTeamId teamId) {
+ this.teamId = Optional.ofNullable(teamId);
+ return this;
+ }
+
+ @java.lang.Override
+ @JsonSetter(value = "team_id", nulls = Nulls.SKIP)
+ public _FinalStage teamId(Optional teamId) {
+ this.teamId = teamId;
+ return this;
+ }
+
+ @java.lang.Override
+ public SearchCompendiumBody build() {
+ return new SearchCompendiumBody(
+ teamId, mode, query, loincSetHash, labs, includeRelated, limit, additionalProperties);
+ }
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/compendium/types/CompendiumConvertRequestTeamId.java b/src/main/java/com/vital/api/resources/compendium/types/CompendiumConvertRequestTeamId.java
new file mode 100644
index 00000000..2d488097
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/types/CompendiumConvertRequestTeamId.java
@@ -0,0 +1,22 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium.types;
+
+import com.fasterxml.jackson.annotation.JsonValue;
+
+public enum CompendiumConvertRequestTeamId {
+ INFER_FROM_CONTEXT("infer_from_context");
+
+ private final String value;
+
+ CompendiumConvertRequestTeamId(String value) {
+ this.value = value;
+ }
+
+ @JsonValue
+ @java.lang.Override
+ public String toString() {
+ return this.value;
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/compendium/types/CompendiumSearchRequestTeamId.java b/src/main/java/com/vital/api/resources/compendium/types/CompendiumSearchRequestTeamId.java
new file mode 100644
index 00000000..8eac1ab5
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/compendium/types/CompendiumSearchRequestTeamId.java
@@ -0,0 +1,22 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.compendium.types;
+
+import com.fasterxml.jackson.annotation.JsonValue;
+
+public enum CompendiumSearchRequestTeamId {
+ INFER_FROM_CONTEXT("infer_from_context");
+
+ private final String value;
+
+ CompendiumSearchRequestTeamId(String value) {
+ this.value = value;
+ }
+
+ @JsonValue
+ @java.lang.Override
+ public String toString() {
+ return this.value;
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/devices/AsyncRawDevicesClient.java b/src/main/java/com/vital/api/resources/devices/AsyncRawDevicesClient.java
index a72d0e4e..73ccab03 100644
--- a/src/main/java/com/vital/api/resources/devices/AsyncRawDevicesClient.java
+++ b/src/main/java/com/vital/api/resources/devices/AsyncRawDevicesClient.java
@@ -70,8 +70,8 @@ public CompletableFuture> getRaw(
httpUrl, "provider", request.getProvider().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/devices/RawDevicesClient.java b/src/main/java/com/vital/api/resources/devices/RawDevicesClient.java
index 73cd7f81..dba48635 100644
--- a/src/main/java/com/vital/api/resources/devices/RawDevicesClient.java
+++ b/src/main/java/com/vital/api/resources/devices/RawDevicesClient.java
@@ -66,8 +66,8 @@ public VitalHttpResponse getRaw(
httpUrl, "provider", request.getProvider().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/devices/requests/DevicesGetRawRequest.java b/src/main/java/com/vital/api/resources/devices/requests/DevicesGetRawRequest.java
index 3c52d6da..53ba15b3 100644
--- a/src/main/java/com/vital/api/resources/devices/requests/DevicesGetRawRequest.java
+++ b/src/main/java/com/vital/api/resources/devices/requests/DevicesGetRawRequest.java
@@ -97,5 +97,15 @@ public Builder provider(String provider) {
public DevicesGetRawRequest build() {
return new DevicesGetRawRequest(provider, 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/vital/api/resources/electrocardiogram/AsyncRawElectrocardiogramClient.java b/src/main/java/com/vital/api/resources/electrocardiogram/AsyncRawElectrocardiogramClient.java
index 72d81049..863f8413 100644
--- a/src/main/java/com/vital/api/resources/electrocardiogram/AsyncRawElectrocardiogramClient.java
+++ b/src/main/java/com/vital/api/resources/electrocardiogram/AsyncRawElectrocardiogramClient.java
@@ -61,8 +61,8 @@ public CompletableFuture {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/electrocardiogram/RawElectrocardiogramClient.java b/src/main/java/com/vital/api/resources/electrocardiogram/RawElectrocardiogramClient.java
index 3942c4f6..23d95b3d 100644
--- a/src/main/java/com/vital/api/resources/electrocardiogram/RawElectrocardiogramClient.java
+++ b/src/main/java/com/vital/api/resources/electrocardiogram/RawElectrocardiogramClient.java
@@ -57,8 +57,8 @@ public VitalHttpResponse get(
httpUrl, "provider", request.getProvider().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/electrocardiogram/requests/ElectrocardiogramGetRequest.java b/src/main/java/com/vital/api/resources/electrocardiogram/requests/ElectrocardiogramGetRequest.java
index 67611287..473f3b31 100644
--- a/src/main/java/com/vital/api/resources/electrocardiogram/requests/ElectrocardiogramGetRequest.java
+++ b/src/main/java/com/vital/api/resources/electrocardiogram/requests/ElectrocardiogramGetRequest.java
@@ -96,6 +96,10 @@ public interface StartDateStage {
public interface _FinalStage {
ElectrocardiogramGetRequest build();
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
+
_FinalStage endDate(Optional endDate);
_FinalStage endDate(String endDate);
@@ -173,5 +177,17 @@ public _FinalStage endDate(Optional endDate) {
public ElectrocardiogramGetRequest build() {
return new ElectrocardiogramGetRequest(startDate, endDate, provider, additionalProperties);
}
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/vital/api/resources/insurance/AsyncRawInsuranceClient.java b/src/main/java/com/vital/api/resources/insurance/AsyncRawInsuranceClient.java
index 7b9bcea8..83a1dcbc 100644
--- a/src/main/java/com/vital/api/resources/insurance/AsyncRawInsuranceClient.java
+++ b/src/main/java/com/vital/api/resources/insurance/AsyncRawInsuranceClient.java
@@ -74,8 +74,8 @@ public CompletableFuture
httpUrl, "provider_payor_id", request.getProviderPayorId().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -149,8 +149,8 @@ public CompletableFuture {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
RequestBody body;
@@ -225,8 +225,8 @@ public CompletableFuture {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/insurance/RawInsuranceClient.java b/src/main/java/com/vital/api/resources/insurance/RawInsuranceClient.java
index 6a48afba..0dda36d2 100644
--- a/src/main/java/com/vital/api/resources/insurance/RawInsuranceClient.java
+++ b/src/main/java/com/vital/api/resources/insurance/RawInsuranceClient.java
@@ -69,8 +69,8 @@ public VitalHttpResponse> searchGetPayorIn
httpUrl, "provider_payor_id", request.getProviderPayorId().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -128,8 +128,8 @@ public VitalHttpResponse> search
.newBuilder()
.addPathSegments("v3/insurance/search/payor");
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
RequestBody body;
@@ -188,8 +188,8 @@ public VitalHttpResponse> searchDiagnosis
.addPathSegments("v3/insurance/search/diagnosis");
QueryStringMapper.addQueryParameter(httpUrl, "diagnosis_query", request.getDiagnosisQuery(), false);
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchDiagnosisRequest.java b/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchDiagnosisRequest.java
index 3bf079f3..d9892132 100644
--- a/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchDiagnosisRequest.java
+++ b/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchDiagnosisRequest.java
@@ -70,6 +70,10 @@ public interface DiagnosisQueryStage {
public interface _FinalStage {
InsuranceSearchDiagnosisRequest build();
+
+ _FinalStage additionalProperty(String key, Object value);
+
+ _FinalStage additionalProperties(Map additionalProperties);
}
@JsonIgnoreProperties(ignoreUnknown = true)
@@ -98,5 +102,17 @@ public _FinalStage diagnosisQuery(@NotNull String diagnosisQuery) {
public InsuranceSearchDiagnosisRequest build() {
return new InsuranceSearchDiagnosisRequest(diagnosisQuery, additionalProperties);
}
+
+ @java.lang.Override
+ public Builder additionalProperty(String key, Object value) {
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ @java.lang.Override
+ public Builder additionalProperties(Map additionalProperties) {
+ this.additionalProperties.putAll(additionalProperties);
+ return this;
+ }
}
}
diff --git a/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchGetPayorInfoRequest.java b/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchGetPayorInfoRequest.java
index 12672a7e..dfa3fd4f 100644
--- a/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchGetPayorInfoRequest.java
+++ b/src/main/java/com/vital/api/resources/insurance/requests/InsuranceSearchGetPayorInfoRequest.java
@@ -144,5 +144,15 @@ public InsuranceSearchGetPayorInfoRequest build() {
return new InsuranceSearchGetPayorInfoRequest(
insuranceName, provider, providerPayorId, 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/vital/api/resources/insurance/requests/PayorSearchRequest.java b/src/main/java/com/vital/api/resources/insurance/requests/PayorSearchRequest.java
index a255a7cd..be25041a 100644
--- a/src/main/java/com/vital/api/resources/insurance/requests/PayorSearchRequest.java
+++ b/src/main/java/com/vital/api/resources/insurance/requests/PayorSearchRequest.java
@@ -142,5 +142,15 @@ public Builder providerId(String providerId) {
public PayorSearchRequest build() {
return new PayorSearchRequest(insuranceName, provider, providerId, 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/vital/api/resources/introspect/AsyncRawIntrospectClient.java b/src/main/java/com/vital/api/resources/introspect/AsyncRawIntrospectClient.java
index e67ca0c1..3ce7c53c 100644
--- a/src/main/java/com/vital/api/resources/introspect/AsyncRawIntrospectClient.java
+++ b/src/main/java/com/vital/api/resources/introspect/AsyncRawIntrospectClient.java
@@ -75,8 +75,8 @@ public CompletableFuture> getUserResour
httpUrl, "next_cursor", request.getNextCursor().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -170,8 +170,8 @@ public CompletableFuture> getUser
httpUrl, "next_cursor", request.getNextCursor().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/introspect/RawIntrospectClient.java b/src/main/java/com/vital/api/resources/introspect/RawIntrospectClient.java
index d871d3cd..cbf495a7 100644
--- a/src/main/java/com/vital/api/resources/introspect/RawIntrospectClient.java
+++ b/src/main/java/com/vital/api/resources/introspect/RawIntrospectClient.java
@@ -70,8 +70,8 @@ public VitalHttpResponse getUserResources(
httpUrl, "next_cursor", request.getNextCursor().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
@@ -148,8 +148,8 @@ public VitalHttpResponse getUserHistoricalPulls(
httpUrl, "next_cursor", request.getNextCursor().get(), false);
}
if (requestOptions != null) {
- requestOptions.getQueryParameters().forEach((key, value) -> {
- httpUrl.addQueryParameter(key, value);
+ requestOptions.getQueryParameters().forEach((_key, _value) -> {
+ httpUrl.addQueryParameter(_key, _value);
});
}
Request.Builder _requestBuilder = new Request.Builder()
diff --git a/src/main/java/com/vital/api/resources/introspect/requests/IntrospectGetUserHistoricalPullsRequest.java b/src/main/java/com/vital/api/resources/introspect/requests/IntrospectGetUserHistoricalPullsRequest.java
index 5325cb5d..688b9f3d 100644
--- a/src/main/java/com/vital/api/resources/introspect/requests/IntrospectGetUserHistoricalPullsRequest.java
+++ b/src/main/java/com/vital/api/resources/introspect/requests/IntrospectGetUserHistoricalPullsRequest.java
@@ -204,5 +204,15 @@ public IntrospectGetUserHistoricalPullsRequest build() {
return new IntrospectGetUserHistoricalPullsRequest(
userId, provider, userLimit, cursor, nextCursor, 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/vital/api/resources/introspect/requests/IntrospectGetUserResourcesRequest.java b/src/main/java/com/vital/api/resources/introspect/requests/IntrospectGetUserResourcesRequest.java
index e61fd2ff..d6c72b49 100644
--- a/src/main/java/com/vital/api/resources/introspect/requests/IntrospectGetUserResourcesRequest.java
+++ b/src/main/java/com/vital/api/resources/introspect/requests/IntrospectGetUserResourcesRequest.java
@@ -203,5 +203,15 @@ public IntrospectGetUserResourcesRequest build() {
return new IntrospectGetUserResourcesRequest(
userId, provider, userLimit, cursor, nextCursor, 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/vital/api/resources/labaccount/AsyncLabAccountClient.java b/src/main/java/com/vital/api/resources/labaccount/AsyncLabAccountClient.java
new file mode 100644
index 00000000..96997140
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/labaccount/AsyncLabAccountClient.java
@@ -0,0 +1,46 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.labaccount;
+
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.resources.labaccount.requests.LabAccountGetTeamLabAccountsRequest;
+import com.vital.api.types.GetTeamLabAccountsResponse;
+import java.util.concurrent.CompletableFuture;
+
+public class AsyncLabAccountClient {
+ protected final ClientOptions clientOptions;
+
+ private final AsyncRawLabAccountClient rawClient;
+
+ public AsyncLabAccountClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ this.rawClient = new AsyncRawLabAccountClient(clientOptions);
+ }
+
+ /**
+ * Get responses with HTTP metadata like headers
+ */
+ public AsyncRawLabAccountClient withRawResponse() {
+ return this.rawClient;
+ }
+
+ public CompletableFuture getTeamLabAccounts() {
+ return this.rawClient.getTeamLabAccounts().thenApply(response -> response.body());
+ }
+
+ public CompletableFuture getTeamLabAccounts(RequestOptions requestOptions) {
+ return this.rawClient.getTeamLabAccounts(requestOptions).thenApply(response -> response.body());
+ }
+
+ public CompletableFuture getTeamLabAccounts(
+ LabAccountGetTeamLabAccountsRequest request) {
+ return this.rawClient.getTeamLabAccounts(request).thenApply(response -> response.body());
+ }
+
+ public CompletableFuture getTeamLabAccounts(
+ LabAccountGetTeamLabAccountsRequest request, RequestOptions requestOptions) {
+ return this.rawClient.getTeamLabAccounts(request, requestOptions).thenApply(response -> response.body());
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/labaccount/AsyncRawLabAccountClient.java b/src/main/java/com/vital/api/resources/labaccount/AsyncRawLabAccountClient.java
new file mode 100644
index 00000000..374a1013
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/labaccount/AsyncRawLabAccountClient.java
@@ -0,0 +1,118 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.labaccount;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.vital.api.core.ApiError;
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.ObjectMappers;
+import com.vital.api.core.QueryStringMapper;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.core.VitalException;
+import com.vital.api.core.VitalHttpResponse;
+import com.vital.api.errors.UnprocessableEntityError;
+import com.vital.api.resources.labaccount.requests.LabAccountGetTeamLabAccountsRequest;
+import com.vital.api.types.GetTeamLabAccountsResponse;
+import com.vital.api.types.HttpValidationError;
+import java.io.IOException;
+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.Response;
+import okhttp3.ResponseBody;
+import org.jetbrains.annotations.NotNull;
+
+public class AsyncRawLabAccountClient {
+ protected final ClientOptions clientOptions;
+
+ public AsyncRawLabAccountClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ }
+
+ public CompletableFuture> getTeamLabAccounts() {
+ return getTeamLabAccounts(LabAccountGetTeamLabAccountsRequest.builder().build());
+ }
+
+ public CompletableFuture> getTeamLabAccounts(
+ RequestOptions requestOptions) {
+ return getTeamLabAccounts(LabAccountGetTeamLabAccountsRequest.builder().build(), requestOptions);
+ }
+
+ public CompletableFuture> getTeamLabAccounts(
+ LabAccountGetTeamLabAccountsRequest request) {
+ return getTeamLabAccounts(request, null);
+ }
+
+ public CompletableFuture> getTeamLabAccounts(
+ LabAccountGetTeamLabAccountsRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v3/lab_test/lab_account");
+ if (request.getLabAccountId().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "lab_account_id", request.getLabAccountId().get(), false);
+ }
+ if (request.getStatus().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "status", request.getStatus().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 VitalHttpResponse<>(
+ ObjectMappers.JSON_MAPPER.readValue(
+ responseBodyString, GetTeamLabAccountsResponse.class),
+ response));
+ return;
+ }
+ try {
+ if (response.code() == 422) {
+ future.completeExceptionally(new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, HttpValidationError.class),
+ response));
+ return;
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ future.completeExceptionally(new ApiError(
+ "Error with status code " + response.code(), response.code(), errorBody, response));
+ return;
+ } catch (IOException e) {
+ future.completeExceptionally(new VitalException("Network error executing HTTP request", e));
+ }
+ }
+
+ @Override
+ public void onFailure(@NotNull Call call, @NotNull IOException e) {
+ future.completeExceptionally(new VitalException("Network error executing HTTP request", e));
+ }
+ });
+ return future;
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/labaccount/LabAccountClient.java b/src/main/java/com/vital/api/resources/labaccount/LabAccountClient.java
new file mode 100644
index 00000000..e20ebf31
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/labaccount/LabAccountClient.java
@@ -0,0 +1,44 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.labaccount;
+
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.resources.labaccount.requests.LabAccountGetTeamLabAccountsRequest;
+import com.vital.api.types.GetTeamLabAccountsResponse;
+
+public class LabAccountClient {
+ protected final ClientOptions clientOptions;
+
+ private final RawLabAccountClient rawClient;
+
+ public LabAccountClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ this.rawClient = new RawLabAccountClient(clientOptions);
+ }
+
+ /**
+ * Get responses with HTTP metadata like headers
+ */
+ public RawLabAccountClient withRawResponse() {
+ return this.rawClient;
+ }
+
+ public GetTeamLabAccountsResponse getTeamLabAccounts() {
+ return this.rawClient.getTeamLabAccounts().body();
+ }
+
+ public GetTeamLabAccountsResponse getTeamLabAccounts(RequestOptions requestOptions) {
+ return this.rawClient.getTeamLabAccounts(requestOptions).body();
+ }
+
+ public GetTeamLabAccountsResponse getTeamLabAccounts(LabAccountGetTeamLabAccountsRequest request) {
+ return this.rawClient.getTeamLabAccounts(request).body();
+ }
+
+ public GetTeamLabAccountsResponse getTeamLabAccounts(
+ LabAccountGetTeamLabAccountsRequest request, RequestOptions requestOptions) {
+ return this.rawClient.getTeamLabAccounts(request, requestOptions).body();
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/labaccount/RawLabAccountClient.java b/src/main/java/com/vital/api/resources/labaccount/RawLabAccountClient.java
new file mode 100644
index 00000000..2c8d8828
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/labaccount/RawLabAccountClient.java
@@ -0,0 +1,97 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.labaccount;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.vital.api.core.ApiError;
+import com.vital.api.core.ClientOptions;
+import com.vital.api.core.ObjectMappers;
+import com.vital.api.core.QueryStringMapper;
+import com.vital.api.core.RequestOptions;
+import com.vital.api.core.VitalException;
+import com.vital.api.core.VitalHttpResponse;
+import com.vital.api.errors.UnprocessableEntityError;
+import com.vital.api.resources.labaccount.requests.LabAccountGetTeamLabAccountsRequest;
+import com.vital.api.types.GetTeamLabAccountsResponse;
+import com.vital.api.types.HttpValidationError;
+import java.io.IOException;
+import okhttp3.Headers;
+import okhttp3.HttpUrl;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
+
+public class RawLabAccountClient {
+ protected final ClientOptions clientOptions;
+
+ public RawLabAccountClient(ClientOptions clientOptions) {
+ this.clientOptions = clientOptions;
+ }
+
+ public VitalHttpResponse getTeamLabAccounts() {
+ return getTeamLabAccounts(LabAccountGetTeamLabAccountsRequest.builder().build());
+ }
+
+ public VitalHttpResponse getTeamLabAccounts(RequestOptions requestOptions) {
+ return getTeamLabAccounts(LabAccountGetTeamLabAccountsRequest.builder().build(), requestOptions);
+ }
+
+ public VitalHttpResponse getTeamLabAccounts(
+ LabAccountGetTeamLabAccountsRequest request) {
+ return getTeamLabAccounts(request, null);
+ }
+
+ public VitalHttpResponse getTeamLabAccounts(
+ LabAccountGetTeamLabAccountsRequest request, RequestOptions requestOptions) {
+ HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v3/lab_test/lab_account");
+ if (request.getLabAccountId().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "lab_account_id", request.getLabAccountId().get(), false);
+ }
+ if (request.getStatus().isPresent()) {
+ QueryStringMapper.addQueryParameter(
+ httpUrl, "status", request.getStatus().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 VitalHttpResponse<>(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, GetTeamLabAccountsResponse.class),
+ response);
+ }
+ try {
+ if (response.code() == 422) {
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, HttpValidationError.class),
+ response);
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ Object errorBody = ObjectMappers.parseErrorBody(responseBodyString);
+ throw new ApiError("Error with status code " + response.code(), response.code(), errorBody, response);
+ } catch (IOException e) {
+ throw new VitalException("Network error executing HTTP request", e);
+ }
+ }
+}
diff --git a/src/main/java/com/vital/api/resources/labaccount/requests/LabAccountGetTeamLabAccountsRequest.java b/src/main/java/com/vital/api/resources/labaccount/requests/LabAccountGetTeamLabAccountsRequest.java
new file mode 100644
index 00000000..0aa9060d
--- /dev/null
+++ b/src/main/java/com/vital/api/resources/labaccount/requests/LabAccountGetTeamLabAccountsRequest.java
@@ -0,0 +1,132 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.vital.api.resources.labaccount.requests;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSetter;
+import com.fasterxml.jackson.annotation.Nulls;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.vital.api.core.ObjectMappers;
+import com.vital.api.types.LabAccountStatus;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonDeserialize(builder = LabAccountGetTeamLabAccountsRequest.Builder.class)
+public final class LabAccountGetTeamLabAccountsRequest {
+ private final Optional labAccountId;
+
+ private final Optional status;
+
+ private final Map additionalProperties;
+
+ private LabAccountGetTeamLabAccountsRequest(
+ Optional labAccountId,
+ Optional status,
+ Map additionalProperties) {
+ this.labAccountId = labAccountId;
+ this.status = status;
+ this.additionalProperties = additionalProperties;
+ }
+
+ @JsonProperty("lab_account_id")
+ public Optional getLabAccountId() {
+ return labAccountId;
+ }
+
+ @JsonProperty("status")
+ public Optional getStatus() {
+ return status;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ if (this == other) return true;
+ return other instanceof LabAccountGetTeamLabAccountsRequest
+ && equalTo((LabAccountGetTeamLabAccountsRequest) other);
+ }
+
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ private boolean equalTo(LabAccountGetTeamLabAccountsRequest other) {
+ return labAccountId.equals(other.labAccountId) && status.equals(other.status);
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return Objects.hash(this.labAccountId, this.status);
+ }
+
+ @java.lang.Override
+ public String toString() {
+ return ObjectMappers.stringify(this);
+ }
+
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ @JsonIgnoreProperties(ignoreUnknown = true)
+ public static final class Builder {
+ private Optional labAccountId = Optional.empty();
+
+ private Optional status = Optional.empty();
+
+ @JsonAnySetter
+ private Map additionalProperties = new HashMap<>();
+
+ private Builder() {}
+
+ public Builder from(LabAccountGetTeamLabAccountsRequest other) {
+ labAccountId(other.getLabAccountId());
+ status(other.getStatus());
+ return this;
+ }
+
+ @JsonSetter(value = "lab_account_id", nulls = Nulls.SKIP)
+ public Builder labAccountId(Optional labAccountId) {
+ this.labAccountId = labAccountId;
+ return this;
+ }
+
+ public Builder labAccountId(String labAccountId) {
+ this.labAccountId = Optional.ofNullable(labAccountId);
+ return this;
+ }
+
+ @JsonSetter(value = "status", nulls = Nulls.SKIP)
+ public Builder status(Optional status) {
+ this.status = status;
+ return this;
+ }
+
+ public Builder status(LabAccountStatus status) {
+ this.status = Optional.ofNullable(status);
+ return this;
+ }
+
+ public LabAccountGetTeamLabAccountsRequest build() {
+ return new LabAccountGetTeamLabAccountsRequest(labAccountId, status, 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/vital/api/resources/labreport/AsyncLabReportClient.java b/src/main/java/com/vital/api/resources/labreport/AsyncLabReportClient.java
index 90ccb111..bf6ee534 100644
--- a/src/main/java/com/vital/api/resources/labreport/AsyncLabReportClient.java
+++ b/src/main/java/com/vital/api/resources/labreport/AsyncLabReportClient.java
@@ -8,9 +8,7 @@
import com.vital.api.resources.labreport.requests.BodyCreateLabReportParserJob;
import com.vital.api.types.ParsingJob;
import java.io.File;
-import java.io.InputStream;
import java.util.concurrent.CompletableFuture;
-import okhttp3.MediaType;
public class AsyncLabReportClient {
protected final ClientOptions clientOptions;
@@ -30,7 +28,7 @@ public AsyncRawLabReportClient withRawResponse() {
}
/**
- * Creates a parse job, uploads the file to provider, persists the job row,
+ * Creates a parse job, uploads the file(s) to provider, persists the job row,
* and starts the ParseLabReport. Returns a generated job_id.
*/
public CompletableFuture parserCreateJob(File file, BodyCreateLabReportParserJob request) {
@@ -38,7 +36,7 @@ public CompletableFuture parserCreateJob(File file, BodyCreateLabRep
}
/**
- * Creates a parse job, uploads the file to provider, persists the job row,
+ * Creates a parse job, uploads the file(s) to provider, persists the job row,
* and starts the ParseLabReport. Returns a generated job_id.
*/
public CompletableFuture parserCreateJob(
@@ -46,26 +44,6 @@ public CompletableFuture parserCreateJob(
return this.rawClient.parserCreateJob(file, request, requestOptions).thenApply(response -> response.body());
}
- public CompletableFuture parserCreateJob(InputStream stream, String filename) {
- return this.rawClient.parserCreateJob(stream, filename).thenApply(response -> response.body());
- }
-
- public CompletableFuture parserCreateJob(InputStream stream, String filename, MediaType mediaType) {
- return this.rawClient.parserCreateJob(stream, filename, mediaType).thenApply(response -> response.body());
- }
-
- public CompletableFuture parserCreateJob(
- InputStream stream, String filename, RequestOptions requestOptions) {
- return this.rawClient.parserCreateJob(stream, filename, requestOptions).thenApply(response -> response.body());
- }
-
- public CompletableFuture parserCreateJob(
- InputStream stream, String filename, MediaType mediaType, RequestOptions requestOptions) {
- return this.rawClient
- .parserCreateJob(stream, filename, mediaType, requestOptions)
- .thenApply(response -> response.body());
- }
-
/**
* Retrieves the parse job status and stored result if completed.
* Returns:
diff --git a/src/main/java/com/vital/api/resources/labreport/AsyncRawLabReportClient.java b/src/main/java/com/vital/api/resources/labreport/AsyncRawLabReportClient.java
index a8cf6294..a16e681d 100644
--- a/src/main/java/com/vital/api/resources/labreport/AsyncRawLabReportClient.java
+++ b/src/main/java/com/vital/api/resources/labreport/AsyncRawLabReportClient.java
@@ -6,7 +6,6 @@
import com.fasterxml.jackson.core.JsonProcessingException;
import com.vital.api.core.ApiError;
import com.vital.api.core.ClientOptions;
-import com.vital.api.core.FileStream;
import com.vital.api.core.ObjectMappers;
import com.vital.api.core.RequestOptions;
import com.vital.api.core.VitalException;
@@ -17,7 +16,6 @@
import com.vital.api.types.ParsingJob;
import java.io.File;
import java.io.IOException;
-import java.io.InputStream;
import java.nio.file.Files;
import java.util.concurrent.CompletableFuture;
import okhttp3.Call;
@@ -41,7 +39,7 @@ public AsyncRawLabReportClient(ClientOptions clientOptions) {
}
/**
- * Creates a parse job, uploads the file to provider, persists the job row,
+ * Creates a parse job, uploads the file(s) to provider, persists the job row,
* and starts the ParseLabReport. Returns a generated job_id.
*/
public CompletableFuture> parserCreateJob(
@@ -50,7 +48,7 @@ public CompletableFuture