client.chatStream(request) -> Optional<StreamedChatResponse>client.chat(request) -> NonStreamedChatResponseclient.generateStream(request) -> Optional<GenerateStreamedResponse>client.generate(request) -> Generationclient.embed(request) -> EmbedResponseclient.rerank(request) -> RerankResponseclient.classify(request) -> ClassifyResponseclient.summarize(request) -> SummarizeResponseclient.tokenize(request) -> TokenizeResponseclient.detokenize(request) -> DetokenizeResponseclient.checkApiKey() -> CheckApiKeyResponseclient.v2.chatStream(request) -> Optional<V2ChatStreamResponse>client.v2.chat(request) -> V2ChatResponseclient.v2.embed(request) -> EmbedByTypeResponseclient.v2.rerank(request) -> V2RerankResponseclient.embedJobs.list() -> ListEmbedJobResponseclient.embedJobs.create(request) -> CreateEmbedJobResponseclient.embedJobs.get(id) -> EmbedJobclient.embedJobs.cancel(id)client.datasets.list() -> DatasetsListResponseclient.datasets.create(request) -> DatasetsCreateResponseclient.datasets.getUsage() -> DatasetsGetUsageResponseclient.datasets.get(id) -> DatasetsGetResponseclient.datasets.delete(id) -> Map<String, Object>client.connectors.list() -> ListConnectorsResponseclient.connectors.create(request) -> CreateConnectorResponseclient.connectors.get(id) -> GetConnectorResponseclient.connectors.delete(id) -> Map<String, Object>client.connectors.update(id, request) -> UpdateConnectorResponseclient.connectors.oAuthAuthorize(id) -> OAuthAuthorizeResponseclient.models.get(model) -> GetModelResponseclient.models.list() -> ListModelsResponseclient.finetuning.listFinetunedModels() -> ListFinetunedModelsResponseclient.finetuning.createFinetunedModel(request) -> CreateFinetunedModelResponseclient.finetuning.getFinetunedModel(id) -> GetFinetunedModelResponseclient.finetuning.deleteFinetunedModel(id) -> Map<String, Object>client.finetuning.updateFinetunedModel(id, request) -> UpdateFinetunedModelResponseclient.finetuning.listEvents(finetunedModelId) -> ListEventsResponseclient.finetuning.listTrainingStepMetrics(finetunedModelId) -> ListTrainingStepMetricsResponseTo learn how to use the Chat API and RAG follow our Text Generation guides.
- */ - public CompletableFutureTo learn how to use the Chat API and RAG follow our Text Generation guides.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat with Streaming API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat with Streaming API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFutureEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CompletableFutureEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CompletableFutureEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CompletableFutureexamples of text + label pairs as a reference.
- * Note: Fine-tuned models trained on classification examples don't require the examples parameter to be passed in explicitly.
- */
- public CompletableFutureexamples of text + label pairs as a reference.
- * Note: Fine-tuned models trained on classification examples don't require the examples parameter to be passed in explicitly.
- */
- public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates a summary in English for a given text.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates a summary in English for a given text.
- */ - public CompletableFuture{@code
- * @Override
- * protected void setAuthentication(ClientOptions.Builder builder) {
- * super.setAuthentication(builder); // Keep existing auth
- * builder.addHeader("X-API-Key", this.apiKey);
- * }
- * }
- */
- protected void setAuthentication(ClientOptions.Builder builder) {
- if (this.token != null) {
- builder.addHeader("Authorization", "Bearer " + this.token);
- }
- }
-
- /**
- * Override this method to add or modify custom headers.
- * This method is called during client options construction to set up custom headers defined in the API.
- *
- * @param builder The ClientOptions.Builder to configure
- *
- * Example:
- * {@code
- * @Override
- * protected void setCustomHeaders(ClientOptions.Builder builder) {
- * super.setCustomHeaders(builder); // Keep existing headers
- * builder.addHeader("X-Trace-ID", generateTraceId());
- * }
- * }
- */
- protected void setCustomHeaders(ClientOptions.Builder builder) {
- if (this.clientName != null) {
- builder.addHeader("X-Client-Name", this.clientName);
- }
- }
-
- /**
- * Sets the request timeout configuration.
- * Override this method to customize timeout behavior.
- *
- * @param builder The ClientOptions.Builder to configure
- */
- protected void setTimeouts(ClientOptions.Builder builder) {
- if (this.timeout.isPresent()) {
- builder.timeout(this.timeout.get());
- }
- }
-
- /**
- * Sets the retry configuration for failed requests.
- * Override this method to implement custom retry strategies.
- *
- * @param builder The ClientOptions.Builder to configure
- */
- protected void setRetries(ClientOptions.Builder builder) {
- if (this.maxRetries.isPresent()) {
- builder.maxRetries(this.maxRetries.get());
- }
- }
-
- /**
- * Sets the OkHttp client configuration.
- * Override this method to customize HTTP client behavior (interceptors, connection pools, etc).
- *
- * @param builder The ClientOptions.Builder to configure
- */
- protected void setHttpClient(ClientOptions.Builder builder) {
- if (this.httpClient != null) {
- builder.httpClient(this.httpClient);
- }
- }
-
- /**
- * Override this method to add any additional configuration to the client.
- * This method is called at the end of the configuration chain, allowing you to add
- * custom headers, modify settings, or perform any other client customization.
- *
- * @param builder The ClientOptions.Builder to configure
- *
- * Example:
- * {@code
- * @Override
- * protected void setAdditional(ClientOptions.Builder builder) {
- * builder.addHeader("X-Request-ID", () -> UUID.randomUUID().toString());
- * builder.addHeader("X-Client-Version", "1.0.0");
- * }
- * }
- */
- protected void setAdditional(ClientOptions.Builder builder) {}
-
- /**
- * Override this method to add custom validation logic before the client is built.
- * This method is called at the beginning of the build() method to ensure the configuration is valid.
- * Throw an exception to prevent client creation if validation fails.
- *
- * Example:
- * {@code
- * @Override
- * protected void validateConfiguration() {
- * super.validateConfiguration(); // Run parent validations
- * if (tenantId == null || tenantId.isEmpty()) {
- * throw new IllegalStateException("tenantId is required");
- * }
- * }
- * }
- */
- protected void validateConfiguration() {}
-
- public AsyncCohere build() {
- if (token == null) {
- throw new RuntimeException("Please provide token or set the CO_API_KEY environment variable.");
- }
- validateConfiguration();
- return new AsyncCohere(buildClientOptions());
- }
-}
diff --git a/src/main/java/com/cohere/api/AsyncRawCohere.java b/src/main/java/com/cohere/api/AsyncRawCohere.java
deleted file mode 100644
index c3728c4..0000000
--- a/src/main/java/com/cohere/api/AsyncRawCohere.java
+++ /dev/null
@@ -1,1694 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.cohere.api;
-
-import com.cohere.api.core.ClientOptions;
-import com.cohere.api.core.CohereApiException;
-import com.cohere.api.core.CohereException;
-import com.cohere.api.core.CohereHttpResponse;
-import com.cohere.api.core.MediaTypes;
-import com.cohere.api.core.ObjectMappers;
-import com.cohere.api.core.RequestOptions;
-import com.cohere.api.core.ResponseBodyReader;
-import com.cohere.api.core.Stream;
-import com.cohere.api.errors.BadRequestError;
-import com.cohere.api.errors.ClientClosedRequestError;
-import com.cohere.api.errors.ForbiddenError;
-import com.cohere.api.errors.GatewayTimeoutError;
-import com.cohere.api.errors.InternalServerError;
-import com.cohere.api.errors.InvalidTokenError;
-import com.cohere.api.errors.NotFoundError;
-import com.cohere.api.errors.NotImplementedError;
-import com.cohere.api.errors.ServiceUnavailableError;
-import com.cohere.api.errors.TooManyRequestsError;
-import com.cohere.api.errors.UnauthorizedError;
-import com.cohere.api.errors.UnprocessableEntityError;
-import com.cohere.api.requests.ChatRequest;
-import com.cohere.api.requests.ChatStreamRequest;
-import com.cohere.api.requests.ClassifyRequest;
-import com.cohere.api.requests.DetokenizeRequest;
-import com.cohere.api.requests.EmbedRequest;
-import com.cohere.api.requests.GenerateRequest;
-import com.cohere.api.requests.GenerateStreamRequest;
-import com.cohere.api.requests.RerankRequest;
-import com.cohere.api.requests.SummarizeRequest;
-import com.cohere.api.requests.TokenizeRequest;
-import com.cohere.api.types.CheckApiKeyResponse;
-import com.cohere.api.types.ClassifyResponse;
-import com.cohere.api.types.DetokenizeResponse;
-import com.cohere.api.types.EmbedResponse;
-import com.cohere.api.types.GenerateStreamedResponse;
-import com.cohere.api.types.Generation;
-import com.cohere.api.types.NonStreamedChatResponse;
-import com.cohere.api.types.RerankResponse;
-import com.cohere.api.types.StreamedChatResponse;
-import com.cohere.api.types.SummarizeResponse;
-import com.cohere.api.types.TokenizeResponse;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
-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 AsyncRawCohere {
- protected final ClientOptions clientOptions;
-
- public AsyncRawCohere(ClientOptions clientOptions) {
- this.clientOptions = clientOptions;
- }
-
- /**
- * Generates a streamed text response to a user message.
- * To learn how to use the Chat API and RAG follow our Text Generation guides.
- */ - public CompletableFutureTo learn how to use the Chat API and RAG follow our Text Generation guides.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat with Streaming API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat with Streaming API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CompletableFutureEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CompletableFutureEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CompletableFutureEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CompletableFutureexamples of text + label pairs as a reference.
- * Note: Fine-tuned models trained on classification examples don't require the examples parameter to be passed in explicitly.
- */
- public CompletableFutureexamples of text + label pairs as a reference.
- * Note: Fine-tuned models trained on classification examples don't require the examples parameter to be passed in explicitly.
- */
- public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates a summary in English for a given text.
- */ - public CompletableFuture<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates a summary in English for a given text.
- */ - public CompletableFutureTo learn how to use the Chat API and RAG follow our Text Generation guides.
*/ public IterableTo learn how to use the Chat API and RAG follow our Text Generation guides.
*/ public IterableIf you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
*/ public EmbedResponse embed() { - return this.rawClient.embed().body(); + return embed(EmbedRequest.builder().build()); } /** @@ -158,7 +635,7 @@ public EmbedResponse embed() { *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
*/ public EmbedResponse embed(EmbedRequest request) { - return this.rawClient.embed(request).body(); + return embed(request, null); } /** @@ -167,21 +644,167 @@ public EmbedResponse embed(EmbedRequest request) { *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
*/ public EmbedResponse embed(EmbedRequest request, RequestOptions requestOptions) { - return this.rawClient.embed(request, requestOptions).body(); + HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()) + .newBuilder() + .addPathSegments("v1/embed") + .build(); + RequestBody body; + try { + body = RequestBody.create( + ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON); + } catch (JsonProcessingException e) { + throw new CohereException("Failed to serialize request", e); + } + Request okhttpRequest = new Request.Builder() + .url(httpUrl) + .method("POST", body) + .headers(Headers.of(clientOptions.headers(requestOptions))) + .addHeader("Content-Type", "application/json") + .build(); + OkHttpClient client = clientOptions.httpClient(); + if (requestOptions != null && requestOptions.getTimeout().isPresent()) { + client = clientOptions.httpClientWithTimeout(requestOptions); + } + try (Response response = client.newCall(okhttpRequest).execute()) { + ResponseBody responseBody = response.body(); + if (response.isSuccessful()) { + return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), EmbedResponse.class); + } + String responseBodyString = responseBody != null ? responseBody.string() : "{}"; + try { + switch (response.code()) { + case 400: + throw new BadRequestError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 401: + throw new UnauthorizedError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 403: + throw new ForbiddenError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 404: + throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 422: + throw new UnprocessableEntityError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 429: + throw new TooManyRequestsError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 498: + throw new InvalidTokenError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 499: + throw new ClientClosedRequestError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 500: + throw new InternalServerError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 501: + throw new NotImplementedError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 503: + throw new ServiceUnavailableError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 504: + throw new GatewayTimeoutError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + } + } catch (JsonProcessingException ignored) { + // unable to map error response, throwing generic error + } + throw new CohereApiException( + "Error with status code " + response.code(), + response.code(), + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + } catch (IOException e) { + throw new CohereException("Network error executing HTTP request", e); + } } /** * This endpoint takes in a query and a list of texts and produces an ordered array with each text assigned a relevance score. */ public RerankResponse rerank(RerankRequest request) { - return this.rawClient.rerank(request).body(); + return rerank(request, null); } /** * This endpoint takes in a query and a list of texts and produces an ordered array with each text assigned a relevance score. */ public RerankResponse rerank(RerankRequest request, RequestOptions requestOptions) { - return this.rawClient.rerank(request, requestOptions).body(); + HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl()) + .newBuilder() + .addPathSegments("v1/rerank") + .build(); + RequestBody body; + try { + body = RequestBody.create( + ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON); + } catch (JsonProcessingException e) { + throw new CohereException("Failed to serialize request", e); + } + Request okhttpRequest = new Request.Builder() + .url(httpUrl) + .method("POST", body) + .headers(Headers.of(clientOptions.headers(requestOptions))) + .addHeader("Content-Type", "application/json") + .build(); + OkHttpClient client = clientOptions.httpClient(); + if (requestOptions != null && requestOptions.getTimeout().isPresent()) { + client = clientOptions.httpClientWithTimeout(requestOptions); + } + try (Response response = client.newCall(okhttpRequest).execute()) { + ResponseBody responseBody = response.body(); + if (response.isSuccessful()) { + return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), RerankResponse.class); + } + String responseBodyString = responseBody != null ? responseBody.string() : "{}"; + try { + switch (response.code()) { + case 400: + throw new BadRequestError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 401: + throw new UnauthorizedError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 403: + throw new ForbiddenError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 404: + throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 422: + throw new UnprocessableEntityError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 429: + throw new TooManyRequestsError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 498: + throw new InvalidTokenError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 499: + throw new ClientClosedRequestError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 500: + throw new InternalServerError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 501: + throw new NotImplementedError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 503: + throw new ServiceUnavailableError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + case 504: + throw new GatewayTimeoutError( + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + } + } catch (JsonProcessingException ignored) { + // unable to map error response, throwing generic error + } + throw new CohereApiException( + "Error with status code " + response.code(), + response.code(), + ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class)); + } catch (IOException e) { + throw new CohereException("Network error executing HTTP request", e); + } } /** @@ -189,7 +812,7 @@ public RerankResponse rerank(RerankRequest request, RequestOptions requestOption * Note: Fine-tuned models trained on classification examples don't require theexamples parameter to be passed in explicitly.
*/
public ClassifyResponse classify(ClassifyRequest request) {
- return this.rawClient.classify(request).body();
+ return classify(request, null);
}
/**
@@ -197,7 +820,80 @@ public ClassifyResponse classify(ClassifyRequest request) {
* Note: Fine-tuned models trained on classification examples don't require the examples parameter to be passed in explicitly.
*/
public ClassifyResponse classify(ClassifyRequest request, RequestOptions requestOptions) {
- return this.rawClient.classify(request, requestOptions).body();
+ HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v1/classify")
+ .build();
+ RequestBody body;
+ try {
+ body = RequestBody.create(
+ ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ } catch (JsonProcessingException e) {
+ throw new CohereException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl)
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ try (Response response = client.newCall(okhttpRequest).execute()) {
+ ResponseBody responseBody = response.body();
+ if (response.isSuccessful()) {
+ return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ClassifyResponse.class);
+ }
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ try {
+ switch (response.code()) {
+ case 400:
+ throw new BadRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 401:
+ throw new UnauthorizedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 403:
+ throw new ForbiddenError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 404:
+ throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 422:
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 429:
+ throw new TooManyRequestsError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 498:
+ throw new InvalidTokenError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 499:
+ throw new ClientClosedRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 500:
+ throw new InternalServerError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 501:
+ throw new NotImplementedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 503:
+ throw new ServiceUnavailableError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 504:
+ throw new GatewayTimeoutError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ throw new CohereApiException(
+ "Error with status code " + response.code(),
+ response.code(),
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ } catch (IOException e) {
+ throw new CohereException("Network error executing HTTP request", e);
+ }
}
/**
@@ -207,7 +903,7 @@ public ClassifyResponse classify(ClassifyRequest request, RequestOptions request
* Generates a summary in English for a given text.
*/
public SummarizeResponse summarize(SummarizeRequest request) {
- return this.rawClient.summarize(request).body();
+ return summarize(request, null);
}
/**
@@ -217,49 +913,334 @@ public SummarizeResponse summarize(SummarizeRequest request) {
* Generates a summary in English for a given text.
*/
public SummarizeResponse summarize(SummarizeRequest request, RequestOptions requestOptions) {
- return this.rawClient.summarize(request, requestOptions).body();
+ HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v1/summarize")
+ .build();
+ RequestBody body;
+ try {
+ body = RequestBody.create(
+ ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ } catch (JsonProcessingException e) {
+ throw new CohereException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl)
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ try (Response response = client.newCall(okhttpRequest).execute()) {
+ ResponseBody responseBody = response.body();
+ if (response.isSuccessful()) {
+ return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), SummarizeResponse.class);
+ }
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ try {
+ switch (response.code()) {
+ case 400:
+ throw new BadRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 401:
+ throw new UnauthorizedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 403:
+ throw new ForbiddenError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 404:
+ throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 422:
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 429:
+ throw new TooManyRequestsError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 498:
+ throw new InvalidTokenError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 499:
+ throw new ClientClosedRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 500:
+ throw new InternalServerError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 501:
+ throw new NotImplementedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 503:
+ throw new ServiceUnavailableError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 504:
+ throw new GatewayTimeoutError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ throw new CohereApiException(
+ "Error with status code " + response.code(),
+ response.code(),
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ } catch (IOException e) {
+ throw new CohereException("Network error executing HTTP request", e);
+ }
}
/**
* This endpoint splits input text into smaller units called tokens using byte-pair encoding (BPE). To learn more about tokenization and byte pair encoding, see the tokens page.
*/
public TokenizeResponse tokenize(TokenizeRequest request) {
- return this.rawClient.tokenize(request).body();
+ return tokenize(request, null);
}
/**
* This endpoint splits input text into smaller units called tokens using byte-pair encoding (BPE). To learn more about tokenization and byte pair encoding, see the tokens page.
*/
public TokenizeResponse tokenize(TokenizeRequest request, RequestOptions requestOptions) {
- return this.rawClient.tokenize(request, requestOptions).body();
+ HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v1/tokenize")
+ .build();
+ RequestBody body;
+ try {
+ body = RequestBody.create(
+ ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ } catch (JsonProcessingException e) {
+ throw new CohereException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl)
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ try (Response response = client.newCall(okhttpRequest).execute()) {
+ ResponseBody responseBody = response.body();
+ if (response.isSuccessful()) {
+ return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), TokenizeResponse.class);
+ }
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ try {
+ switch (response.code()) {
+ case 400:
+ throw new BadRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 401:
+ throw new UnauthorizedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 403:
+ throw new ForbiddenError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 404:
+ throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 422:
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 429:
+ throw new TooManyRequestsError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 498:
+ throw new InvalidTokenError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 499:
+ throw new ClientClosedRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 500:
+ throw new InternalServerError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 501:
+ throw new NotImplementedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 503:
+ throw new ServiceUnavailableError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 504:
+ throw new GatewayTimeoutError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ throw new CohereApiException(
+ "Error with status code " + response.code(),
+ response.code(),
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ } catch (IOException e) {
+ throw new CohereException("Network error executing HTTP request", e);
+ }
}
/**
* This endpoint takes tokens using byte-pair encoding and returns their text representation. To learn more about tokenization and byte pair encoding, see the tokens page.
*/
public DetokenizeResponse detokenize(DetokenizeRequest request) {
- return this.rawClient.detokenize(request).body();
+ return detokenize(request, null);
}
/**
* This endpoint takes tokens using byte-pair encoding and returns their text representation. To learn more about tokenization and byte pair encoding, see the tokens page.
*/
public DetokenizeResponse detokenize(DetokenizeRequest request, RequestOptions requestOptions) {
- return this.rawClient.detokenize(request, requestOptions).body();
+ HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v1/detokenize")
+ .build();
+ RequestBody body;
+ try {
+ body = RequestBody.create(
+ ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
+ } catch (JsonProcessingException e) {
+ throw new CohereException("Failed to serialize request", e);
+ }
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl)
+ .method("POST", body)
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ try (Response response = client.newCall(okhttpRequest).execute()) {
+ ResponseBody responseBody = response.body();
+ if (response.isSuccessful()) {
+ return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), DetokenizeResponse.class);
+ }
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ try {
+ switch (response.code()) {
+ case 400:
+ throw new BadRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 401:
+ throw new UnauthorizedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 403:
+ throw new ForbiddenError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 404:
+ throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 422:
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 429:
+ throw new TooManyRequestsError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 498:
+ throw new InvalidTokenError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 499:
+ throw new ClientClosedRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 500:
+ throw new InternalServerError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 501:
+ throw new NotImplementedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 503:
+ throw new ServiceUnavailableError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 504:
+ throw new GatewayTimeoutError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ throw new CohereApiException(
+ "Error with status code " + response.code(),
+ response.code(),
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ } catch (IOException e) {
+ throw new CohereException("Network error executing HTTP request", e);
+ }
}
/**
* Checks that the api key in the Authorization header is valid and active
*/
public CheckApiKeyResponse checkApiKey() {
- return this.rawClient.checkApiKey().body();
+ return checkApiKey(null);
}
/**
* Checks that the api key in the Authorization header is valid and active
*/
public CheckApiKeyResponse checkApiKey(RequestOptions requestOptions) {
- return this.rawClient.checkApiKey(requestOptions).body();
+ HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
+ .newBuilder()
+ .addPathSegments("v1/check-api-key")
+ .build();
+ Request okhttpRequest = new Request.Builder()
+ .url(httpUrl)
+ .method("POST", RequestBody.create("", null))
+ .headers(Headers.of(clientOptions.headers(requestOptions)))
+ .addHeader("Content-Type", "application/json")
+ .build();
+ OkHttpClient client = clientOptions.httpClient();
+ if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
+ client = clientOptions.httpClientWithTimeout(requestOptions);
+ }
+ try (Response response = client.newCall(okhttpRequest).execute()) {
+ ResponseBody responseBody = response.body();
+ if (response.isSuccessful()) {
+ return ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), CheckApiKeyResponse.class);
+ }
+ String responseBodyString = responseBody != null ? responseBody.string() : "{}";
+ try {
+ switch (response.code()) {
+ case 400:
+ throw new BadRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 401:
+ throw new UnauthorizedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 403:
+ throw new ForbiddenError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 404:
+ throw new NotFoundError(ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 422:
+ throw new UnprocessableEntityError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 429:
+ throw new TooManyRequestsError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 498:
+ throw new InvalidTokenError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 499:
+ throw new ClientClosedRequestError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 500:
+ throw new InternalServerError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 501:
+ throw new NotImplementedError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 503:
+ throw new ServiceUnavailableError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ case 504:
+ throw new GatewayTimeoutError(
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ }
+ } catch (JsonProcessingException ignored) {
+ // unable to map error response, throwing generic error
+ }
+ throw new CohereApiException(
+ "Error with status code " + response.code(),
+ response.code(),
+ ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class));
+ } catch (IOException e) {
+ throw new CohereException("Network error executing HTTP request", e);
+ }
}
public V2Client v2() {
diff --git a/src/main/java/com/cohere/api/CohereBuilder.java b/src/main/java/com/cohere/api/CohereBuilder.java
index 2050387..133039f 100644
--- a/src/main/java/com/cohere/api/CohereBuilder.java
+++ b/src/main/java/com/cohere/api/CohereBuilder.java
@@ -5,13 +5,9 @@
import com.cohere.api.core.ClientOptions;
import com.cohere.api.core.Environment;
-import java.util.Optional;
-import okhttp3.OkHttpClient;
-public class CohereBuilder {
- private Optional{@code
- * @Override
- * protected void setAuthentication(ClientOptions.Builder builder) {
- * super.setAuthentication(builder); // Keep existing auth
- * builder.addHeader("X-API-Key", this.apiKey);
- * }
- * }
- */
- protected void setAuthentication(ClientOptions.Builder builder) {
- if (this.token != null) {
- builder.addHeader("Authorization", "Bearer " + this.token);
- }
- }
-
- /**
- * Override this method to add or modify custom headers.
- * This method is called during client options construction to set up custom headers defined in the API.
- *
- * @param builder The ClientOptions.Builder to configure
- *
- * Example:
- * {@code
- * @Override
- * protected void setCustomHeaders(ClientOptions.Builder builder) {
- * super.setCustomHeaders(builder); // Keep existing headers
- * builder.addHeader("X-Trace-ID", generateTraceId());
- * }
- * }
- */
- protected void setCustomHeaders(ClientOptions.Builder builder) {
- if (this.clientName != null) {
- builder.addHeader("X-Client-Name", this.clientName);
- }
- }
-
- /**
- * Sets the request timeout configuration.
- * Override this method to customize timeout behavior.
- *
- * @param builder The ClientOptions.Builder to configure
- */
- protected void setTimeouts(ClientOptions.Builder builder) {
- if (this.timeout.isPresent()) {
- builder.timeout(this.timeout.get());
- }
- }
-
- /**
- * Sets the retry configuration for failed requests.
- * Override this method to implement custom retry strategies.
- *
- * @param builder The ClientOptions.Builder to configure
- */
- protected void setRetries(ClientOptions.Builder builder) {
- if (this.maxRetries.isPresent()) {
- builder.maxRetries(this.maxRetries.get());
- }
- }
-
- /**
- * Sets the OkHttp client configuration.
- * Override this method to customize HTTP client behavior (interceptors, connection pools, etc).
- *
- * @param builder The ClientOptions.Builder to configure
- */
- protected void setHttpClient(ClientOptions.Builder builder) {
- if (this.httpClient != null) {
- builder.httpClient(this.httpClient);
- }
- }
-
- /**
- * Override this method to add any additional configuration to the client.
- * This method is called at the end of the configuration chain, allowing you to add
- * custom headers, modify settings, or perform any other client customization.
- *
- * @param builder The ClientOptions.Builder to configure
- *
- * Example:
- * {@code
- * @Override
- * protected void setAdditional(ClientOptions.Builder builder) {
- * builder.addHeader("X-Request-ID", () -> UUID.randomUUID().toString());
- * builder.addHeader("X-Client-Version", "1.0.0");
- * }
- * }
- */
- protected void setAdditional(ClientOptions.Builder builder) {}
-
- /**
- * Override this method to add custom validation logic before the client is built.
- * This method is called at the beginning of the build() method to ensure the configuration is valid.
- * Throw an exception to prevent client creation if validation fails.
- *
- * Example:
- * {@code
- * @Override
- * protected void validateConfiguration() {
- * super.validateConfiguration(); // Run parent validations
- * if (tenantId == null || tenantId.isEmpty()) {
- * throw new IllegalStateException("tenantId is required");
- * }
- * }
- * }
- */
- protected void validateConfiguration() {}
-
public Cohere build() {
if (token == null) {
throw new RuntimeException("Please provide token or set the CO_API_KEY environment variable.");
}
- validateConfiguration();
- return new Cohere(buildClientOptions());
+ this.clientOptionsBuilder.addHeader("Authorization", "Bearer " + this.token);
+ if (clientName != null) {
+ this.clientOptionsBuilder.addHeader("X-Client-Name", this.clientName);
+ }
+ clientOptionsBuilder.environment(this.environment);
+ return new Cohere(clientOptionsBuilder.build());
}
}
diff --git a/src/main/java/com/cohere/api/RawCohere.java b/src/main/java/com/cohere/api/RawCohere.java
deleted file mode 100644
index 3f3ec4e..0000000
--- a/src/main/java/com/cohere/api/RawCohere.java
+++ /dev/null
@@ -1,1264 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.cohere.api;
-
-import com.cohere.api.core.ClientOptions;
-import com.cohere.api.core.CohereApiException;
-import com.cohere.api.core.CohereException;
-import com.cohere.api.core.CohereHttpResponse;
-import com.cohere.api.core.MediaTypes;
-import com.cohere.api.core.ObjectMappers;
-import com.cohere.api.core.RequestOptions;
-import com.cohere.api.core.ResponseBodyReader;
-import com.cohere.api.core.Stream;
-import com.cohere.api.errors.BadRequestError;
-import com.cohere.api.errors.ClientClosedRequestError;
-import com.cohere.api.errors.ForbiddenError;
-import com.cohere.api.errors.GatewayTimeoutError;
-import com.cohere.api.errors.InternalServerError;
-import com.cohere.api.errors.InvalidTokenError;
-import com.cohere.api.errors.NotFoundError;
-import com.cohere.api.errors.NotImplementedError;
-import com.cohere.api.errors.ServiceUnavailableError;
-import com.cohere.api.errors.TooManyRequestsError;
-import com.cohere.api.errors.UnauthorizedError;
-import com.cohere.api.errors.UnprocessableEntityError;
-import com.cohere.api.requests.ChatRequest;
-import com.cohere.api.requests.ChatStreamRequest;
-import com.cohere.api.requests.ClassifyRequest;
-import com.cohere.api.requests.DetokenizeRequest;
-import com.cohere.api.requests.EmbedRequest;
-import com.cohere.api.requests.GenerateRequest;
-import com.cohere.api.requests.GenerateStreamRequest;
-import com.cohere.api.requests.RerankRequest;
-import com.cohere.api.requests.SummarizeRequest;
-import com.cohere.api.requests.TokenizeRequest;
-import com.cohere.api.types.CheckApiKeyResponse;
-import com.cohere.api.types.ClassifyResponse;
-import com.cohere.api.types.DetokenizeResponse;
-import com.cohere.api.types.EmbedResponse;
-import com.cohere.api.types.GenerateStreamedResponse;
-import com.cohere.api.types.Generation;
-import com.cohere.api.types.NonStreamedChatResponse;
-import com.cohere.api.types.RerankResponse;
-import com.cohere.api.types.StreamedChatResponse;
-import com.cohere.api.types.SummarizeResponse;
-import com.cohere.api.types.TokenizeResponse;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
-import okhttp3.Headers;
-import okhttp3.HttpUrl;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import okhttp3.RequestBody;
-import okhttp3.Response;
-import okhttp3.ResponseBody;
-
-public class RawCohere {
- protected final ClientOptions clientOptions;
-
- public RawCohere(ClientOptions clientOptions) {
- this.clientOptions = clientOptions;
- }
-
- /**
- * Generates a streamed text response to a user message.
- * To learn how to use the Chat API and RAG follow our Text Generation guides.
- */ - public CohereHttpResponseTo learn how to use the Chat API and RAG follow our Text Generation guides.
- */ - public CohereHttpResponse<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat with Streaming API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CohereHttpResponse<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat with Streaming API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CohereHttpResponse<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CohereHttpResponse<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates realistic text conditioned on a given input.
- */ - public CohereHttpResponseEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CohereHttpResponseEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CohereHttpResponseEmbeddings can be used to create classifiers as well as empower semantic search. To learn more about embeddings, see the embedding page.
- *If you want to learn more how to use the embedding model, have a look at the Semantic Search Guide.
- */ - public CohereHttpResponseexamples of text + label pairs as a reference.
- * Note: Fine-tuned models trained on classification examples don't require the examples parameter to be passed in explicitly.
- */
- public CohereHttpResponseexamples of text + label pairs as a reference.
- * Note: Fine-tuned models trained on classification examples don't require the examples parameter to be passed in explicitly.
- */
- public CohereHttpResponse<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates a summary in English for a given text.
- */ - public CohereHttpResponse<Warning> - * This API is marked as "Legacy" and is no longer maintained. Follow the [migration guide](https://docs.cohere.com/docs/migrating-from-cogenerate-to-cochat) to start using the Chat API. - * </Warning> - * Generates a summary in English for a given text.
- */ - public CohereHttpResponse
* {@code Stream} assumes that data is being pushed to the provided {@link Reader} asynchronously and utilizes a
* {@code Scanner} to block during iteration if the next object is not available.
- * Iterable stream for parsing JSON and Server-Sent Events (SSE) data.
- * Supports both newline-delimited JSON and SSE with optional stream termination.
*
* @param
- * Will block and wait for input if the stream has not ended and the next object is not yet available.
- *
- * @return {@code true} if there are more elements, {@code false} otherwise.
- */
- @Override
- public boolean hasNext() {
- if (isStreamClosed()) {
- return false;
+ return new Iterator
+ * Will block and wait for input if the stream has not ended and the next object is not yet available.
+ *
+ * @return {@code true} if there are more elements, {@code false} otherwise.
+ */
+ @Override
+ public boolean hasNext() {
+ return scanner.hasNext();
}
- return scanner.hasNext();
- }
- /**
- * Returns the next element in the stream.
- *
- * Will block and wait for input if the stream has not ended and the next object is not yet available.
- *
- * @return The next element in the stream.
- * @throws NoSuchElementException If there are no more elements in the stream.
- */
- @Override
- public T next() {
- if (isStreamClosed()) {
- throw new NoSuchElementException("Stream is closed");
- }
-
- if (!scanner.hasNext()) {
- throw new NoSuchElementException();
- } else {
- try {
- T parsedResponse =
- ObjectMappers.JSON_MAPPER.readValue(scanner.next().trim(), valueType);
- return parsedResponse;
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
- }
-
- @Override
- public void remove() {
- throw new UnsupportedOperationException();
- }
- }
-
- private final class SSEIterator implements Iterator
+ * Will block and wait for input if the stream has not ended and the next object is not yet available.
+ *
+ * @return The next element in the stream.
+ * @throws NoSuchElementException If there are no more elements in the stream.
+ */
+ @Override
+ public T next() {
+ if (!scanner.hasNext()) {
+ throw new NoSuchElementException();
+ } else {
+ try {
+ T parsedResponse = ObjectMappers.JSON_MAPPER.readValue(
+ scanner.next().trim(), valueType);
+ return parsedResponse;
+ } catch (Exception e) {
+ throw new RuntimeException(e);
}
}
+ }
- endOfStream = true;
- return false;
-
- } catch (Exception e) {
- System.err.println("Failed to parse SSE stream: " + e.getMessage());
- endOfStream = true;
- return false;
+ /**
+ * Removing elements from {@code Stream} is not supported.
+ *
+ * @throws UnsupportedOperationException Always, as removal is not supported.
+ */
+ @Override
+ public void remove() {
+ throw new UnsupportedOperationException();
}
- }
+ };
}
}
diff --git a/src/main/java/com/cohere/api/errors/BadRequestError.java b/src/main/java/com/cohere/api/errors/BadRequestError.java
index 60abf96..6546e91 100644
--- a/src/main/java/com/cohere/api/errors/BadRequestError.java
+++ b/src/main/java/com/cohere/api/errors/BadRequestError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class BadRequestError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public BadRequestError(Object body) {
this.body = body;
}
- public BadRequestError(Object body, Response rawResponse) {
- super("BadRequestError", 400, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/ClientClosedRequestError.java b/src/main/java/com/cohere/api/errors/ClientClosedRequestError.java
index cc78e15..89a0fc4 100644
--- a/src/main/java/com/cohere/api/errors/ClientClosedRequestError.java
+++ b/src/main/java/com/cohere/api/errors/ClientClosedRequestError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class ClientClosedRequestError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public ClientClosedRequestError(Object body) {
this.body = body;
}
- public ClientClosedRequestError(Object body, Response rawResponse) {
- super("ClientClosedRequestError", 499, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/ForbiddenError.java b/src/main/java/com/cohere/api/errors/ForbiddenError.java
index a139acc..23c461b 100644
--- a/src/main/java/com/cohere/api/errors/ForbiddenError.java
+++ b/src/main/java/com/cohere/api/errors/ForbiddenError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class ForbiddenError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public ForbiddenError(Object body) {
this.body = body;
}
- public ForbiddenError(Object body, Response rawResponse) {
- super("ForbiddenError", 403, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/GatewayTimeoutError.java b/src/main/java/com/cohere/api/errors/GatewayTimeoutError.java
index 3e28c9d..bf513ef 100644
--- a/src/main/java/com/cohere/api/errors/GatewayTimeoutError.java
+++ b/src/main/java/com/cohere/api/errors/GatewayTimeoutError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class GatewayTimeoutError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public GatewayTimeoutError(Object body) {
this.body = body;
}
- public GatewayTimeoutError(Object body, Response rawResponse) {
- super("GatewayTimeoutError", 504, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/InternalServerError.java b/src/main/java/com/cohere/api/errors/InternalServerError.java
index 3e5fbdb..5a64c17 100644
--- a/src/main/java/com/cohere/api/errors/InternalServerError.java
+++ b/src/main/java/com/cohere/api/errors/InternalServerError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class InternalServerError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public InternalServerError(Object body) {
this.body = body;
}
- public InternalServerError(Object body, Response rawResponse) {
- super("InternalServerError", 500, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/InvalidTokenError.java b/src/main/java/com/cohere/api/errors/InvalidTokenError.java
index eb1caa1..b889d1b 100644
--- a/src/main/java/com/cohere/api/errors/InvalidTokenError.java
+++ b/src/main/java/com/cohere/api/errors/InvalidTokenError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class InvalidTokenError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public InvalidTokenError(Object body) {
this.body = body;
}
- public InvalidTokenError(Object body, Response rawResponse) {
- super("InvalidTokenError", 498, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/NotFoundError.java b/src/main/java/com/cohere/api/errors/NotFoundError.java
index 6ec9e4c..37f7e9d 100644
--- a/src/main/java/com/cohere/api/errors/NotFoundError.java
+++ b/src/main/java/com/cohere/api/errors/NotFoundError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class NotFoundError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public NotFoundError(Object body) {
this.body = body;
}
- public NotFoundError(Object body, Response rawResponse) {
- super("NotFoundError", 404, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/NotImplementedError.java b/src/main/java/com/cohere/api/errors/NotImplementedError.java
index dc436b9..7ada371 100644
--- a/src/main/java/com/cohere/api/errors/NotImplementedError.java
+++ b/src/main/java/com/cohere/api/errors/NotImplementedError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class NotImplementedError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public NotImplementedError(Object body) {
this.body = body;
}
- public NotImplementedError(Object body, Response rawResponse) {
- super("NotImplementedError", 501, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/ServiceUnavailableError.java b/src/main/java/com/cohere/api/errors/ServiceUnavailableError.java
index 95dbf3e..a615b11 100644
--- a/src/main/java/com/cohere/api/errors/ServiceUnavailableError.java
+++ b/src/main/java/com/cohere/api/errors/ServiceUnavailableError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class ServiceUnavailableError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public ServiceUnavailableError(Object body) {
this.body = body;
}
- public ServiceUnavailableError(Object body, Response rawResponse) {
- super("ServiceUnavailableError", 503, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/TooManyRequestsError.java b/src/main/java/com/cohere/api/errors/TooManyRequestsError.java
index bbff67a..d1f4f4b 100644
--- a/src/main/java/com/cohere/api/errors/TooManyRequestsError.java
+++ b/src/main/java/com/cohere/api/errors/TooManyRequestsError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class TooManyRequestsError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public TooManyRequestsError(Object body) {
this.body = body;
}
- public TooManyRequestsError(Object body, Response rawResponse) {
- super("TooManyRequestsError", 429, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/UnauthorizedError.java b/src/main/java/com/cohere/api/errors/UnauthorizedError.java
index cb6815d..6a3df32 100644
--- a/src/main/java/com/cohere/api/errors/UnauthorizedError.java
+++ b/src/main/java/com/cohere/api/errors/UnauthorizedError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class UnauthorizedError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public UnauthorizedError(Object body) {
this.body = body;
}
- public UnauthorizedError(Object body, Response rawResponse) {
- super("UnauthorizedError", 401, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/errors/UnprocessableEntityError.java b/src/main/java/com/cohere/api/errors/UnprocessableEntityError.java
index 83fa51f..96d95e1 100644
--- a/src/main/java/com/cohere/api/errors/UnprocessableEntityError.java
+++ b/src/main/java/com/cohere/api/errors/UnprocessableEntityError.java
@@ -4,7 +4,6 @@
package com.cohere.api.errors;
import com.cohere.api.core.CohereApiException;
-import okhttp3.Response;
public final class UnprocessableEntityError extends CohereApiException {
/**
@@ -17,11 +16,6 @@ public UnprocessableEntityError(Object body) {
this.body = body;
}
- public UnprocessableEntityError(Object body, Response rawResponse) {
- super("UnprocessableEntityError", 422, body, rawResponse);
- this.body = body;
- }
-
/**
* @return the body
*/
diff --git a/src/main/java/com/cohere/api/requests/ChatRequest.java b/src/main/java/com/cohere/api/requests/ChatRequest.java
index 5c4e8d7..4125d21 100644
--- a/src/main/java/com/cohere/api/requests/ChatRequest.java
+++ b/src/main/java/com/cohere/api/requests/ChatRequest.java
@@ -70,6 +70,10 @@ public final class ChatRequest {
private final Optional Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments When Text input for the model to respond to. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Pass text/event-stream to receive the streamed response as server-sent events. The default is The name of a compatible Cohere model or the ID of a fine-tuned model. Compatible Deployments: Cohere Platform, Private Deployments When specified, the default Cohere preamble will be replaced with the provided one. Preambles are a part of the prompt used to adjust the model's overall behavior and conversation style, and use the The Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments A list of previous messages between the user and the model, giving the model conversational context for responding to the user's Each item represents a single message in the chat history, excluding the current user turn. It has two properties: The chat_history parameter should not be used for Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments An alternative to Providing a Compatible Deployments: Cohere Platform Defaults to Dictates how the prompt will be constructed. With With With Compatible Deployments: Accepts When specified, the model's reply will be enriched with information found by querying each of the connectors (RAG). Compatible Deployments: Cohere Platform Defaults to When Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments A list of relevant documents that the model can cite to generate a more accurate reply. Each document is a string-string dictionary. Example: Keys and values from each document will be serialized to a string and passed to the model. The resulting generation will include citations that reference some of these documents. Some suggested keys are "text", "author", and "date". For better generation quality, it is recommended to keep the total word count of the strings in the dictionary to under 300 words. An An See 'Document Mode' in the guide for more information. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Defaults to Dictates the approach taken to generating citations as part of the RAG flow by allowing the user to specify whether they want Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Defaults to A non-negative float that tunes the degree of randomness in generation. Lower temperatures mean less random generations, and higher temperatures mean more random generations. Randomness can be further maximized by increasing the value of the Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments The maximum number of tokens the model will generate as part of the response. Note: Setting a low value may result in incomplete generations. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments The maximum number of input tokens to send to the model. If not specified, Input will be truncated according to the Compatible Deployments: Cohere Platform Ensures only the top Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Ensures that only the most likely tokens, with total probability mass of Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments If specified, the backend will make a best effort to sample tokens
- * deterministically, such that repeated requests with the same
- * seed and parameters should return the same result. However,
- * determinism cannot be totally guaranteed. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments A list of up to 5 strings that the model will use to stop generation. If the model generates a string that matches any of the strings in the list, it will stop generating tokens and return the generated text up to that point not including the stop sequence. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Defaults to Used to reduce repetitiveness of generated tokens. The higher the value, the stronger a penalty is applied to previously present tokens, proportional to how many times they have already appeared in the prompt or prior generation. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Defaults to Used to reduce repetitiveness of generated tokens. Similar to Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments A list of available tools (functions) that the model may suggest invoking before producing a text response. When Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments A list of results from invoking tools recommended by the model in the previous chat turn. Results are used to produce a text response and will be referenced in citations. When using Note: Note: Chat calls with Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Forces the chat to be single step. Defaults to Used to select the safety instruction inserted into the prompt. Defaults to Safety modes are not yet configurable in combination with Note: This parameter is only compatible newer Cohere models, starting with Command R 08-2024 and Command R+ 08-2024. Note: Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Text input for the model to respond to. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Text input for the model to respond to. Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Used to select the safety instruction inserted into the prompt. Defaults to Safety modes are not yet configurable in combination with Note: This parameter is only compatible newer Cohere models, starting with Command R 08-2024 and Command R+ 08-2024. Note: Compatible Deployments: Cohere Platform, Azure, AWS Sagemaker/Bedrock, Private Deployments Forces the chat to be single step. Defaults to prompt response field when this is enabled.
+ */
+ @JsonProperty("return_prompt")
+ public Optionaltools is passed (without tool_results), the text field in the response will be "" and the tool_calls field in the response will be populated with a list of tool calls that need to be made. If no calls need to be made, the tool_calls array will be empty.\n delimited events.SYSTEM role.SYSTEM role is also used for the contents of the optional chat_history= parameter. When used with the chat_history= parameter it adds content throughout a conversation. Conversely, when used with the preamble= parameter it adds content at the start of the conversation only.message.role and message. The role identifies the sender (CHATBOT, SYSTEM, or USER), while the message contains the text content.SYSTEM messages in most cases. Instead, to add a SYSTEM role message at the beginning of a conversation, the preamble parameter should be used.chat_history.conversation_id creates or resumes a persisted conversation with the specified ID. The ID can be any non empty string.AUTO when connectors are specified and OFF in all other cases.prompt_truncation set to "AUTO", some elements from chat_history and documents will be dropped in an attempt to construct a prompt that fits within the model's context length limit. During this process the order of the documents and chat history will be changed and ranked by relevance.prompt_truncation set to "AUTO_PRESERVE_ORDER", some elements from chat_history and documents will be dropped in an attempt to construct a prompt that fits within the model's context length limit. During this process the order of the documents and chat history will be preserved as they are inputted into the API.prompt_truncation set to "OFF", no elements will be dropped. If the sum of the inputs exceeds the model's context length limit, a TooManyTokens error will be returned.
- *
- */
_FinalStage promptTruncation(Optional{"id": "web-search"}, and/or the "id" for a custom connector, if you've created one.false.true, the response will only contain a list of generated search queries, but no search will take place, and no reply from the model to the user's message will be generated.
- * [
- * { "title": "Tall penguins", "text": "Emperor penguins are the tallest." },
- * { "title": "Penguin habitats", "text": "Emperor penguins only live in Antarctica." },
- * ]
- * id field (string) can be optionally supplied to identify the document in the citations. This field will not be passed to the model._excludes field (array of strings) can be optionally supplied to omit some key-value pairs from being shown to the model. The omitted fields will still show up in the citation object. The "_excludes" field will not be passed to the model."accurate"."accurate" results, "fast" results or no results.0.3.p parameter.max_input_tokens is the model's context length limit minus a small buffer.prompt_truncation parameter.k most likely tokens are considered for generation at each step.
- * Defaults to 0, min value of 0, max value of 500.p, are considered for generation at each step. If both k and p are enabled, p acts after k.
- * Defaults to 0.75. min value of 0.01, max value of 0.99.0.0, min value of 0.0, max value of 1.0.0.0, min value of 0.0, max value of 1.0.frequency_penalty, except that this penalty is applied equally to all tokens that have already appeared, regardless of their exact frequencies.tools is passed (without tool_results), the text field in the response will be "" and the tool_calls field in the response will be populated with a list of tool calls that need to be made. If no calls need to be made, the tool_calls array will be empty.tool_results, tools must be passed as well.
- * Each tool_result contains information about how it was invoked, as well as a list of outputs in the form of dictionaries.outputs must be a list of objects. If your tool returns a single object (eg {"status": 200}), make sure to wrap it in a list.
- * tool_results = [
- * {
- * "call": {
- * "name": <tool name>,
- * "parameters": {
- * <param name>: <param value>
- * }
- * },
- * "outputs": [{
- * <key>: <value>
- * }]
- * },
- * ...
- * ]
- * tool_results should not be included in the Chat history to avoid duplication of the message text.false.CONTEXTUAL.
- * When NONE is specified, the safety instruction will be omitted.tools, tool_results and documents parameters.command-r7b-12-2024 and newer models only support "CONTEXTUAL" and "STRICT" modes.CONTEXTUAL.
- * When NONE is specified, the safety instruction will be omitted.tools, tool_results and documents parameters.command-r7b-12-2024 and newer models only support "CONTEXTUAL" and "STRICT" modes.false.