Code gen responses latest

sdk/openai/azure-ai-openai/src/main/java/com/azure/ai/openai/implementation/OpenAIUtils.java

@@ -4,7 +4,7 @@
 package com.azure.ai.openai.implementation;
 
 import com.azure.ai.openai.OpenAIServiceVersion;
-import com.azure.ai.openai.responses.AzureOpenAIServiceVersion;
+import com.azure.ai.openai.responses.AzureResponsesServiceVersion;
 import com.azure.core.http.rest.RequestOptions;
 
 /**
@@ -33,7 +33,7 @@ public static void addAzureVersionToRequestOptions(String endpoint, RequestOptio
      * Add the version query parameter to the request options if the service is not Azure OpenAI service.
      */
     public static void addAzureVersionToRequestOptions(String endpoint, RequestOptions requestOptions,
-                                                       AzureOpenAIServiceVersion serviceVersion) {
+                                                       AzureResponsesServiceVersion serviceVersion) {
         if (useAzureOpenAIService(endpoint)) {
             requestOptions.addQueryParam("api-version", serviceVersion.getVersion());
         }

sdk/openai/azure-ai-openai/src/main/java/com/azure/ai/openai/responses/AzureOpenAIServiceVersion.java → sdk/openai/azure-ai-openai/src/main/java/com/azure/ai/openai/responses/AzureResponsesServiceVersion.java

@@ -7,9 +7,9 @@
 import com.azure.core.util.ServiceVersion;
 
 /**
- * Service version of AzureOpenAIClient.
+ * Service version of AzureResponsesClient.
  */
-public enum AzureOpenAIServiceVersion implements ServiceVersion {
+public enum AzureResponsesServiceVersion implements ServiceVersion {
     /**
      * Enum value 2024-02-15-preview.
      */
@@ -57,7 +57,7 @@ public enum AzureOpenAIServiceVersion implements ServiceVersion {
 
     private final String version;
 
-    AzureOpenAIServiceVersion(String version) {
+    AzureResponsesServiceVersion(String version) {
         this.version = version;
     }
 
@@ -72,9 +72,9 @@ public String getVersion() {
     /**
      * Gets the latest service version supported by this client library.
      * 
-     * @return The latest {@link AzureOpenAIServiceVersion}.
+     * @return The latest {@link AzureResponsesServiceVersion}.
      */
-    public static AzureOpenAIServiceVersion getLatest() {
+    public static AzureResponsesServiceVersion getLatest() {
         return V2025_01_01_PREVIEW;
     }
 }

sdk/openai/azure-ai-openai/src/main/java/com/azure/ai/openai/responses/AzureOpenAIAsyncClient.java → sdk/openai/azure-ai-openai/src/main/java/com/azure/ai/openai/responses/ResponsesAsyncClient.java

@@ -3,7 +3,7 @@
 // Code generated by Microsoft (R) TypeSpec Code Generator.
 package com.azure.ai.openai.responses;
 
-import com.azure.ai.openai.responses.implementation.AzureResponsesImpl;
+import com.azure.ai.openai.responses.implementation.ResponsesClientImpl;
 import com.azure.ai.openai.responses.implementation.streaming.OpenAIServerSentEvents;
 import com.azure.ai.openai.responses.models.CreateResponseRequestAccept;
 import com.azure.ai.openai.responses.models.CreateResponsesRequest;
@@ -24,31 +24,29 @@
 import com.azure.core.http.rest.Response;
 import com.azure.core.util.BinaryData;
 import com.azure.core.util.FluxUtil;
-
 import java.nio.ByteBuffer;
 import java.util.List;
 import java.util.Objects;
 import java.util.stream.Collectors;
-
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 /**
- * Initializes a new instance of the asynchronous AzureOpenAIClient type.
+ * Initializes a new instance of the asynchronous ResponsesClient type.
  */
-@ServiceClient(builder = AzureOpenAIClientBuilder.class, isAsync = true)
-public final class AzureOpenAIAsyncClient {
+@ServiceClient(builder = ResponsesClientBuilder.class, isAsync = true)
+public final class ResponsesAsyncClient {
 
     @Generated
-    private final AzureResponsesImpl serviceClient;
+    private final ResponsesClientImpl serviceClient;
 
     /**
-     * Initializes an instance of AzureOpenAIAsyncClient class.
+     * Initializes an instance of ResponsesAsyncClient class.
      *
      * @param serviceClient the service client implementation.
      */
     @Generated
-    AzureOpenAIAsyncClient(AzureResponsesImpl serviceClient) {
+    ResponsesAsyncClient(ResponsesClientImpl serviceClient) {
         this.serviceClient = serviceClient;
     }
 
@@ -69,7 +67,8 @@ public final class AzureOpenAIAsyncClient {
      *     }
      *     input (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     previous_response_id: String (Optional)
@@ -100,7 +99,8 @@ public final class AzureOpenAIAsyncClient {
      *     previous_response_id: String (Required)
      *     output (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     error (Required): {
@@ -172,7 +172,8 @@ public Mono<Response<BinaryData>> createResponseWithResponse(String accept, Bina
      *     previous_response_id: String (Required)
      *     output (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     error (Required): {
@@ -229,7 +230,8 @@ public Mono<Response<BinaryData>> getResponseWithResponse(String responseId, Req
      *     object: String (Required)
      *     data (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     first_id: String (Required)
@@ -376,9 +378,7 @@ private Mono<ResponsesResponse> createResponse(CreateResponseRequestAccept accep
     public Mono<ResponsesResponse> createResponse(CreateResponsesRequest requestBody, RequestOptions requestOptions) {
         requestBody.setStream(false);
         return createResponseWithResponse(CreateResponseRequestAccept.APPLICATION_JSON.toString(),
-                BinaryData.fromObject(requestBody),
-                requestOptions)
-                .flatMap(FluxUtil::toMono)
+            BinaryData.fromObject(requestBody), requestOptions).flatMap(FluxUtil::toMono)
                 .map(protocolMethodData -> protocolMethodData.toObject(ResponsesResponse.class));
     }
 
@@ -396,12 +396,11 @@ public Mono<ResponsesResponse> createResponse(CreateResponsesRequest requestBody
      * @return the response body on successful completion of {@link Mono}.
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
-    public Flux<ResponsesResponseStreamEvent> createResponseStream(CreateResponsesRequest requestBody, RequestOptions requestOptions) {
+    public Flux<ResponsesResponseStreamEvent> createResponseStream(CreateResponsesRequest requestBody,
+        RequestOptions requestOptions) {
         requestBody.setStream(true);
         Flux<ByteBuffer> response = createResponseWithResponse(CreateResponseRequestAccept.TEXT_EVENT_STREAM.toString(),
-                BinaryData.fromObject(requestBody),
-                requestOptions).flatMapMany(it -> it.getValue().toFluxByteBuffer());
-
+            BinaryData.fromObject(requestBody), requestOptions).flatMapMany(it -> it.getValue().toFluxByteBuffer());
         return new OpenAIServerSentEvents(response).getEvents();
     }
 }

sdk/openai/azure-ai-openai/src/main/java/com/azure/ai/openai/responses/AzureOpenAIClient.java → sdk/openai/azure-ai-openai/src/main/java/com/azure/ai/openai/responses/ResponsesClient.java

@@ -3,7 +3,9 @@
 // Code generated by Microsoft (R) TypeSpec Code Generator.
 package com.azure.ai.openai.responses;
 
-import com.azure.ai.openai.responses.implementation.AzureResponsesImpl;
+import static com.azure.ai.openai.implementation.OpenAIUtils.addAzureVersionToRequestOptions;
+
+import com.azure.ai.openai.responses.implementation.ResponsesClientImpl;
 import com.azure.ai.openai.responses.implementation.streaming.OpenAIServerSentEvents;
 import com.azure.ai.openai.responses.models.CreateResponseRequestAccept;
 import com.azure.ai.openai.responses.models.CreateResponsesRequest;
@@ -24,38 +26,35 @@
 import com.azure.core.http.rest.Response;
 import com.azure.core.util.BinaryData;
 import com.azure.core.util.IterableStream;
-import reactor.core.publisher.Flux;
-
 import java.nio.ByteBuffer;
 import java.util.List;
 import java.util.Objects;
 import java.util.stream.Collectors;
-
-import static com.azure.ai.openai.implementation.OpenAIUtils.addAzureVersionToRequestOptions;
+import reactor.core.publisher.Flux;
 
 /**
- * Initializes a new instance of the synchronous AzureOpenAIClient type.
+ * Initializes a new instance of the synchronous ResponsesClient type.
  */
-@ServiceClient(builder = AzureOpenAIClientBuilder.class)
-public final class AzureOpenAIClient {
+@ServiceClient(builder = ResponsesClientBuilder.class)
+public final class ResponsesClient {
 
     @Generated
-    private final AzureResponsesImpl serviceClient;
+    private final ResponsesClientImpl serviceClient;
 
     /**
-     * Initializes an instance of AzureOpenAIClient class.
+     * Initializes an instance of ResponsesClient class.
      *
      * @param serviceClient the service client implementation.
      */
     @Generated
-    AzureOpenAIClient(AzureResponsesImpl serviceClient) {
+    ResponsesClient(ResponsesClientImpl serviceClient) {
         this.serviceClient = serviceClient;
     }
 
     /**
      * Creates a model response.
      * <p><strong>Request Body Schema</strong></p>
-     * 
+     *
      * <pre>
      * {@code
      * {
@@ -69,7 +68,8 @@ public final class AzureOpenAIClient {
      *     }
      *     input (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     previous_response_id: String (Optional)
@@ -86,9 +86,9 @@ public final class AzureOpenAIClient {
      * }
      * }
      * </pre>
-     * 
+     *
      * <p><strong>Response Body Schema</strong></p>
-     * 
+     *
      * <pre>
      * {@code
      * {
@@ -100,7 +100,8 @@ public final class AzureOpenAIClient {
      *     previous_response_id: String (Required)
      *     output (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     error (Required): {
@@ -160,7 +161,7 @@ public Response<BinaryData> createResponseWithResponse(String accept, BinaryData
      * </table>
      * You can add these to a request with {@link RequestOptions#addQueryParam}
      * <p><strong>Response Body Schema</strong></p>
-     * 
+     *
      * <pre>
      * {@code
      * {
@@ -172,7 +173,8 @@ public Response<BinaryData> createResponseWithResponse(String accept, BinaryData
      *     previous_response_id: String (Required)
      *     output (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     error (Required): {
@@ -222,14 +224,15 @@ public Response<BinaryData> getResponseWithResponse(String responseId, RequestOp
     /**
      * Returns a list of input items for a given response.
      * <p><strong>Response Body Schema</strong></p>
-     * 
+     *
      * <pre>
      * {@code
      * {
      *     object: String (Required)
      *     data (Required): [
      *          (Required){
-     *             type: String(message/function_call/function_call_output/file_search_call/file_search_call_response/code_interpreter_call/code_interpreter_call_response/computer_call/computer_call_output) (Required)
+     *             type: String(message/function_call/function_call_output/computer_call/computer_call_output/file_search_call/web_search_call/code_interpreter_call) (Required)
+     *             id: String (Required)
      *         }
      *     ]
      *     first_id: String (Required)
@@ -370,7 +373,7 @@ private ResponsesResponse createResponse(CreateResponseRequestAccept accept, Cre
     public ResponsesResponse createResponse(CreateResponsesRequest requestBody, RequestOptions requestOptions) {
         requestBody.setStream(false);
         return createResponseWithResponse(CreateResponseRequestAccept.APPLICATION_JSON.toString(),
-                BinaryData.fromObject(requestBody), requestOptions).getValue().toObject(ResponsesResponse.class);
+            BinaryData.fromObject(requestBody), requestOptions).getValue().toObject(ResponsesResponse.class);
     }
 
     /**
@@ -390,7 +393,7 @@ public ResponsesResponse createResponse(CreateResponsesRequest requestBody) {
         requestBody.setStream(false);
         RequestOptions requestOptions = new RequestOptions();
         return createResponseWithResponse(CreateResponseRequestAccept.APPLICATION_JSON.toString(),
-                BinaryData.fromObject(requestBody), requestOptions).getValue().toObject(ResponsesResponse.class);
+            BinaryData.fromObject(requestBody), requestOptions).getValue().toObject(ResponsesResponse.class);
     }
 
     /**
@@ -406,11 +409,11 @@ public ResponsesResponse createResponse(CreateResponsesRequest requestBody) {
      * @return the response.
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
-    public IterableStream<ResponsesResponseStreamEvent> createResponseStreaming(CreateResponsesRequest requestBody, RequestOptions requestOptions) {
+    public IterableStream<ResponsesResponseStreamEvent> createResponseStreaming(CreateResponsesRequest requestBody,
+        RequestOptions requestOptions) {
         requestBody.setStream(true);
         Flux<ByteBuffer> events = createResponseWithResponse(CreateResponseRequestAccept.TEXT_EVENT_STREAM.toString(),
-                BinaryData.fromObject(requestBody), requestOptions).getValue().toFluxByteBuffer();
-
+            BinaryData.fromObject(requestBody), requestOptions).getValue().toFluxByteBuffer();
         OpenAIServerSentEvents eventsProcessor = new OpenAIServerSentEvents(events);
         return new IterableStream<>(eventsProcessor.getEvents());
     }
@@ -432,8 +435,7 @@ public IterableStream<ResponsesResponseStreamEvent> createResponseStreaming(Crea
         RequestOptions requestOptions = new RequestOptions();
         requestBody.setStream(true);
         Flux<ByteBuffer> events = createResponseWithResponse(CreateResponseRequestAccept.TEXT_EVENT_STREAM.toString(),
-                BinaryData.fromObject(requestBody), requestOptions).getValue().toFluxByteBuffer();
-
+            BinaryData.fromObject(requestBody), requestOptions).getValue().toFluxByteBuffer();
         OpenAIServerSentEvents eventsProcessor = new OpenAIServerSentEvents(events);
         return new IterableStream<>(eventsProcessor.getEvents());
     }