chore: Modify conversation examples

Signed-off-by: Javier Aliaga <javier@diagrid.io>

Author: javier-aliaga

examples/src/main/java/io/dapr/examples/conversation/AssistantMessageDemo.java

@@ -108,9 +108,10 @@ public static void main(String[] args) {
       // Process and display the response
       if (response != null && response.getOutputs() != null && !response.getOutputs().isEmpty()) {
         ConversationResultAlpha2 result = response.getOutputs().get(0);
+        UsageUtils.printUsage(result);
+
         if (result.getChoices() != null && !result.getChoices().isEmpty()) {
           ConversationResultChoices choice = result.getChoices().get(0);
-
           if (choice.getMessage() != null && choice.getMessage().getContent() != null) {
             System.out.printf("Assistant Response: %s%n", choice.getMessage().getContent());
           }

examples/src/main/java/io/dapr/examples/conversation/ToolsCallDemo.java

@@ -80,6 +80,8 @@ public static void main(String[] args) {
       // Process and display the response
       if (response != null && response.getOutputs() != null && !response.getOutputs().isEmpty()) {
         ConversationResultAlpha2 result = response.getOutputs().get(0);
+        UsageUtils.printUsage(result);
+
         if (result.getChoices() != null && !result.getChoices().isEmpty()) {
           ConversationResultChoices choice = result.getChoices().get(0);
 

examples/src/main/java/io/dapr/examples/conversation/UsageUtils.java

@@ -0,0 +1,83 @@
+/*
+ * Copyright 2026 The Dapr Authors
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package io.dapr.examples.conversation;
+
+import io.dapr.client.domain.ConversationResultAlpha2;
+import io.dapr.client.domain.ConversationResultCompletionUsage;
+import org.springframework.util.StringUtils;
+
+public class UsageUtils {
+  static void printUsage(ConversationResultAlpha2 result) {
+    if (!StringUtils.hasText(result.getModel())){
+      return;
+    }
+
+  System.out.printf("Conversation model : %s\n", result.getModel());
+    var usage = result.getUsage();
+    printUsage(usage);
+
+    printCompletionDetails(usage);
+    printPromptDetails(usage);
+
+  }
+
+  private static void printUsage(ConversationResultCompletionUsage usage) {
+    System.out.println("Token Usage Details:");
+    System.out.printf("  Completion tokens: %d\n", usage.getCompletionTokens());
+    System.out.printf("  Prompt tokens: %d\n", usage.getPromptTokens());
+    System.out.printf("  Total tokens: %d\n", usage.getTotalTokens());
+    System.out.println();
+  }
+
+  private static void printPromptDetails(ConversationResultCompletionUsage usage) {
+    var completionDetails = usage.getCompletionTokenDetails();
+
+    // Display completion token breakdown if available
+    System.out.println("Prompt Token Details:");
+    if (completionDetails.getReasoningTokens() > 0) {
+      System.out.printf("  Reasoning tokens: %d\n", completionDetails.getReasoningTokens());
+    }
+    if (completionDetails.getAudioTokens() > 0) {
+      System.out.printf("  Audio tokens: %d\n", completionDetails.getAudioTokens());
+    }
+    System.out.println();
+  }
+
+  private static void printCompletionDetails(ConversationResultCompletionUsage usage) {
+    // Print detailed token usage information
+    var completionDetails = usage.getCompletionTokenDetails();
+
+    System.out.println("Completion Token Details:");
+    // If audio tokens are available, display them
+    if ( completionDetails.getAudioTokens() > 0) {
+      System.out.printf("  Audio tokens: %d\n", completionDetails.getAudioTokens());
+    }
+
+    // Display completion token breakdown if available
+    if (completionDetails.getReasoningTokens() > 0) {
+      System.out.printf("  Reasoning tokens: %d\n", completionDetails.getReasoningTokens());
+    }
+
+    // Display completion token breakdown if available
+    if (completionDetails.getAcceptedPredictionTokens() > 0) {
+      System.out.printf("  Accepted prediction tokens: %d\n", completionDetails.getAcceptedPredictionTokens());
+    }
+
+    // Display completion token breakdown if available
+    if (completionDetails.getRejectedPredictionTokens() > 0) {
+      System.out.printf("  Rejected prediction tokens: %d\n", completionDetails.getRejectedPredictionTokens());
+    }
+    System.out.println();
+  }
+}

examples/src/main/java/io/dapr/examples/conversation/UserMessageDemo.java

@@ -22,12 +22,9 @@
 import io.dapr.client.domain.ConversationResultAlpha2;
 import io.dapr.client.domain.ConversationResultChoices;
 import io.dapr.client.domain.UserMessage;
-import io.dapr.config.Properties;
-import io.dapr.config.Property;
 import reactor.core.publisher.Mono;
 
 import java.util.List;
-import java.util.Map;
 
 public class UserMessageDemo {
   /**
@@ -46,18 +43,44 @@ public static void main(String[] args) {
       // Create conversation input with the user message
       ConversationInputAlpha2 daprConversationInput = new ConversationInputAlpha2(List.of(userMessage));
 
+      // Define the JSON schema for the response format
+      String responseSchema = """
+          {
+            "type": "object",
+            "properties": {
+              "greeting": {
+                "type": "string",
+                "description": "A friendly greeting response"
+              },
+              "phone_number_detected": {
+                "type": "boolean",
+                "description": "Whether a phone number was detected in the input"
+              },
+              "detected_number": {
+                "type": "string",
+                "description": "The phone number that was detected, if any"
+              }
+            },
+            "required": ["greeting", "phone_number_detected"],
+            "additionalProperties": false
+          }
+          """;
+
+
       // Component name is the name provided in the metadata block of the conversation.yaml file.
       Mono<ConversationResponseAlpha2> responseMono = client.converseAlpha2(new ConversationRequestAlpha2("echo",
               List.of(daprConversationInput))
               .setContextId("contextId")
               .setScrubPii(true)
-              .setTemperature(1.1d));
+          .setTemperature(1.1d).setResponseFormat(responseSchema));
 
       ConversationResponseAlpha2 response = responseMono.block();
 
       // Extract and print the conversation result
       if (response != null && response.getOutputs() != null && !response.getOutputs().isEmpty()) {
         ConversationResultAlpha2 result = response.getOutputs().get(0);
+        UsageUtils.printUsage(result);
+
         if (result.getChoices() != null && !result.getChoices().isEmpty()) {
           ConversationResultChoices choice = result.getChoices().get(0);
           if (choice.getMessage() != null && choice.getMessage().getContent() != null) {

sdk/pom.xml

@@ -37,6 +37,10 @@
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-databind</artifactId>
     </dependency>
+    <dependency>
+      <groupId>com.google.protobuf</groupId>
+      <artifactId>protobuf-java-util</artifactId>
+    </dependency>
     <dependency>
       <groupId>io.projectreactor</groupId>
       <artifactId>reactor-core</artifactId>

sdk/src/main/java/io/dapr/client/DaprClientImpl.java

@@ -1863,20 +1863,7 @@ private DaprAiProtos.ConversationRequestAlpha2 buildConversationRequestProto(Con
     }
 
     if (request.getResponseFormat() != null) {
-      Map<String, Value> responseParams = request.getResponseFormat()
-          .entrySet().stream()
-          .collect(Collectors.toMap(
-              Map.Entry::getKey,
-              e -> {
-                try {
-                  return ProtobufValueHelper.toProtobufValue(e.getValue());
-                } catch (IOException ex) {
-                  throw new RuntimeException(ex);
-                }
-              }
-          ));
-
-      builder.setResponseFormat(Struct.newBuilder().putAllFields(responseParams).build());
+      builder.setResponseFormat(request.getResponseFormat());
     }
 
     if (request.getPromptCacheRetention() != null) {

sdk/src/main/java/io/dapr/client/domain/ConversationRequestAlpha2.java

@@ -13,6 +13,9 @@
 
 package io.dapr.client.domain;
 
+import com.google.protobuf.Struct;
+import io.dapr.utils.ProtobufUtils;
+
 import java.time.Duration;
 import java.util.List;
 import java.util.Map;
@@ -32,7 +35,7 @@ public class ConversationRequestAlpha2 {
   private String toolChoice;
   private Map<String, Object> parameters;
   private Map<String, String> metadata;
-  private Map<String, Object> responseFormat;
+  private Struct responseFormat;
   private Duration promptCacheRetention;
 
   /**
@@ -210,19 +213,52 @@ public ConversationRequestAlpha2 setMetadata(Map<String, String> metadata) {
     return this;
   }
 
-  public Map<String, Object> getResponseFormat() {
+  /**
+   * Gets the response format in JSON-Schema format.
+   *
+   * @return the response format
+   */
+  public Struct getResponseFormat() {
     return responseFormat;
   }
 
-  public ConversationRequestAlpha2 setResponseFormat(Map<String, Object> responseFormat) {
+  /**
+   * Sets the response format in JSON-Schema format.
+   * Structured output described using a JSON Schema object.
+   * Use this when you want typed structured output.
+   * Supported by Deepseek, Google AI, Hugging Face, OpenAI, and Anthropic components
+   *
+   * @param responseFormat the response format to set
+   * @return the current instance of {@link ConversationRequestAlpha2}
+   */
+  public ConversationRequestAlpha2 setResponseFormat(Struct responseFormat) {
     this.responseFormat = responseFormat;
     return this;
   }
 
+  public ConversationRequestAlpha2 setResponseFormat(String responseFormat) {
+    this.responseFormat = ProtobufUtils.jsonToStruct(responseFormat);
+    return this;
+  }
+
+  /**
+   * retention duration for the prompt cache.
+   *
+   * @return the prompt cache retention duration
+   */
   public Duration getPromptCacheRetention() {
     return promptCacheRetention;
   }
 
+  /**
+   * Retention duration for the prompt cache.
+   * When set, enables extended prompt caching so cached prefixes stay active longer.
+   * With OpenAI, supports up to 24 hours.
+   * See [OpenAI prompt caching](https://platform.openai.com/docs/guides/prompt-caching#prompt-cache-retention).
+   *
+   * @param promptCacheRetention the prompt cache retention duration
+   * @return the current instance of {@link ConversationRequestAlpha2}
+   */
   public ConversationRequestAlpha2 setPromptCacheRetention(Duration promptCacheRetention) {
     this.promptCacheRetention = promptCacheRetention;
     return this;

sdk/src/main/java/io/dapr/utils/ProtobufUtils.java

@@ -0,0 +1,42 @@
+/*
+ * Copyright 2026 The Dapr Authors
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package io.dapr.utils;
+
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.Struct;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class ProtobufUtils {
+  private static final Logger log = LoggerFactory.getLogger(ProtobufUtils.class);
+
+  /**
+   * Converts a JSON string to a protobuf Struct.
+   *
+   * @param json JSON string.
+   * @return Protobuf Struct.
+   */
+  public static Struct jsonToStruct(String json) {
+    Struct.Builder builder = Struct.newBuilder();
+    try {
+      com.google.protobuf.util.JsonFormat.parser()
+          .ignoringUnknownFields() // optional
+          .merge(json, builder);
+    } catch (InvalidProtocolBufferException e) {
+      log.error("Failed to parse json to protobuf struct", e);
+      return builder.build();
+    }
+    return builder.build();
+  }
+}

sdk/src/test/java/io/dapr/client/DaprPreviewClientGrpcTest.java

@@ -45,7 +45,6 @@
 import io.dapr.client.domain.QueryStateRequest;
 import io.dapr.client.domain.QueryStateResponse;
 import io.dapr.client.domain.SystemMessage;
-import io.dapr.client.domain.TestData;
 import io.dapr.client.domain.ToolMessage;
 import io.dapr.client.domain.UnlockResponseStatus;
 import io.dapr.client.domain.UserMessage;
@@ -1065,9 +1064,9 @@ public void converseAlpha2ComplexRequestTest() {
     Map<String, Object> parameters = new HashMap<>();
     parameters.put("max_tokens", "1000");
 
-    var responseFormat = new HashMap<String, Object>();
-    responseFormat.put("temperature", 0.7);
-    responseFormat.put("data", new TestData("Peter", 40));
+    Struct responseFormat = Struct.newBuilder().putFields("type",
+        Value.newBuilder().setStringValue("text").build()).build();
+
     ConversationRequestAlpha2 request = new ConversationRequestAlpha2("openai", List.of(input));
     request.setContextId("test-context");
     request.setTemperature(0.7);
@@ -1166,10 +1165,8 @@ public void converseAlpha2ComplexRequestTest() {
     assertEquals("value1", capturedRequest.getMetadataMap().get("key1"));
     assertEquals(1, capturedRequest.getToolsCount());
     assertEquals("get_weather", capturedRequest.getTools(0).getFunction().getName());
-    assertEquals(Struct.newBuilder()
-            .putFields("temperature", Value.newBuilder().setNumberValue(0.7).build())
-            .putFields("data", Value.newBuilder().setStringValue("TestData{name='Peter', age=40}").build())
-            .build(),
+    assertEquals(Struct.newBuilder().putFields("type",
+            Value.newBuilder().setStringValue("text").build()).build(),
         capturedRequest.getResponseFormat());
     assertEquals(Duration.ofDays(1).getSeconds(), capturedRequest.getPromptCacheRetention().getSeconds());
     assertEquals(0, capturedRequest.getPromptCacheRetention().getNanos());