feat(genai): add live samples (1)

genai/snippets/pom.xml

@@ -51,17 +51,13 @@
         <dependency>
             <groupId>com.google.genai</groupId>
             <artifactId>google-genai</artifactId>
-            <version>1.23.0</version>
+            <version>1.25.0</version>
         </dependency>
         <dependency>
             <groupId>com.google.cloud</groupId>
             <artifactId>google-cloud-storage</artifactId>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>com.google.cloud</groupId>
-            <artifactId>google-cloud-storage</artifactId>
-        </dependency>
         <dependency>
             <artifactId>junit</artifactId>
             <groupId>junit</groupId>

genai/snippets/src/main/java/genai/live/LiveCodeExecWithTxt.java

@@ -0,0 +1,117 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * 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 genai.live;
+
+// [START googlegenaisdk_live_code_exec_with_txt]
+
+import static com.google.genai.types.Modality.Known.TEXT;
+
+import com.google.genai.AsyncSession;
+import com.google.genai.Client;
+import com.google.genai.types.Content;
+import com.google.genai.types.LiveConnectConfig;
+import com.google.genai.types.LiveSendClientContentParameters;
+import com.google.genai.types.LiveServerContent;
+import com.google.genai.types.LiveServerMessage;
+import com.google.genai.types.Part;
+import com.google.genai.types.Tool;
+import com.google.genai.types.ToolCodeExecution;
+import java.util.concurrent.CompletableFuture;
+
+public class LiveCodeExecWithTxt {
+
+  public static void main(String[] args) {
+    // TODO(developer): Replace these variables before running the sample.
+    String modelId = "gemini-2.0-flash-live-preview-04-09";
+    generateContent(modelId);
+  }
+
+  // Shows how to generate content with the Code Execution tool and a text input.
+  public static void generateContent(String modelId) {
+    // Client Initialization. Once created, it can be reused for multiple requests.
+    try (Client client = Client.builder().location("us-central1").vertexAI(true).build()) {
+
+      // Connects to the live server.
+      CompletableFuture<AsyncSession> sessionFuture =
+          client.async.live.connect(
+              modelId,
+              LiveConnectConfig.builder()
+                  .responseModalities(TEXT)
+                  .tools(Tool.builder().codeExecution(ToolCodeExecution.builder().build()).build())
+                  .build());
+
+      // Sends and receives messages from the server.
+      sessionFuture
+          .thenCompose(
+              session -> {
+                // A future that completes when the server signals the end of its turn.
+                CompletableFuture<Void> turnComplete = new CompletableFuture<>();
+                // Starts receiving messages from the live server.
+                session.receive(message -> handleLiveServerMessage(message, turnComplete));
+                // Sends content to the server and waits for the turn to complete.
+                return sendContent(session)
+                    .thenCompose(unused -> turnComplete)
+                    .thenCompose(unused -> session.close());
+              })
+          .join();
+
+      // Example output:
+      // > Compute the largest prime palindrome under 100000
+      // text: Okay, I need
+      // text:  to find the largest prime palindrome less than 100000...
+      // code: ExecutableCode{code=Optional[def is_prime(n):...
+      // result: CodeExecutionResult{outcome=Optional[OUTCOME_OK],
+      // output=Optional[largest_prime_palindrome=98689...
+      // The model is done generating.
+    }
+  }
+
+  // Sends content to the server.
+  private static CompletableFuture<Void> sendContent(AsyncSession session) {
+    String textInput = "Compute the largest prime palindrome under 100000";
+    System.out.printf("> %s\n", textInput);
+    return session.sendClientContent(
+        LiveSendClientContentParameters.builder()
+            .turns(Content.builder().role("user").parts(Part.fromText(textInput)).build())
+            .turnComplete(true)
+            .build());
+  }
+
+  // Prints response messages from the server and signals `turnComplete` when the server is done.
+  private static void handleLiveServerMessage(
+      LiveServerMessage message, CompletableFuture<Void> turnComplete) {
+    message
+        .serverContent()
+        .flatMap(LiveServerContent::modelTurn)
+        .flatMap(Content::parts)
+        .ifPresent(
+            parts ->
+                parts.forEach(
+                    part -> {
+                      part.text().ifPresent(text -> System.out.println("text: " + text));
+                      part.executableCode().ifPresent(code -> System.out.println("code: " + code));
+                      part.codeExecutionResult()
+                          .ifPresent(result -> System.out.println("result: " + result));
+                    }));
+
+    if (message.serverContent().flatMap(LiveServerContent::turnComplete).orElse(false)) {
+      System.out.println("The model is done generating.");
+      turnComplete.complete(null);
+    }
+  }
+}
+// [END googlegenaisdk_live_code_exec_with_txt]

genai/snippets/src/main/java/genai/live/LiveGroundGoogSearchWithTxt.java

@@ -0,0 +1,110 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * 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 genai.live;
+
+// [START googlegenaisdk_live_ground_googsearch_with_txt]
+
+import static com.google.genai.types.Modality.Known.TEXT;
+
+import com.google.genai.AsyncSession;
+import com.google.genai.Client;
+import com.google.genai.types.Content;
+import com.google.genai.types.GoogleSearch;
+import com.google.genai.types.LiveConnectConfig;
+import com.google.genai.types.LiveSendClientContentParameters;
+import com.google.genai.types.LiveServerContent;
+import com.google.genai.types.LiveServerMessage;
+import com.google.genai.types.Part;
+import com.google.genai.types.Tool;
+import java.util.concurrent.CompletableFuture;
+
+public class LiveGroundGoogSearchWithTxt {
+
+  public static void main(String[] args) {
+    // TODO(developer): Replace these variables before running the sample.
+    String modelId = "gemini-2.0-flash-live-preview-04-09";
+    generateContent(modelId);
+  }
+
+  // Shows how to generate content with the Google Search tool and a text input.
+  public static void generateContent(String modelId) {
+    // Client Initialization. Once created, it can be reused for multiple requests.
+    try (Client client = Client.builder().location("us-central1").vertexAI(true).build()) {
+
+      // Connects to the live server.
+      CompletableFuture<AsyncSession> sessionFuture =
+          client.async.live.connect(
+              modelId,
+              LiveConnectConfig.builder()
+                  .responseModalities(TEXT)
+                  .tools(Tool.builder().googleSearch(GoogleSearch.builder().build()).build())
+                  .build());
+
+      // Sends and receives messages from the server.
+      sessionFuture
+          .thenCompose(
+              session -> {
+                // A future that completes when the server signals the end of its turn.
+                CompletableFuture<Void> turnComplete = new CompletableFuture<>();
+                // Starts receiving messages from the live server.
+                session.receive(message -> handleLiveServerMessage(message, turnComplete));
+                // Sends content to the server and waits for the turn to complete.
+                return sendContent(session)
+                    .thenCompose(unused -> turnComplete)
+                    .thenCompose(unused -> session.close());
+              })
+          .join();
+      // Example response:
+      // > When did the last Brazil vs. Argentina soccer match happen?
+      // Output: The last Brazil vs
+      // Output: . Argentina soccer match was on March 25, 2025
+      // Output: , a World Cup Qualifying match that Argentina won 4-1. Quite a game.
+      // The model is done generating.
+    }
+  }
+
+  // Sends content to the live server.
+  private static CompletableFuture<Void> sendContent(AsyncSession session) {
+    String textInput = "When did the last Brazil vs. Argentina soccer match happen?";
+    System.out.printf("> %s\n", textInput);
+    return session.sendClientContent(
+        LiveSendClientContentParameters.builder()
+            .turns(Content.builder().role("user").parts(Part.fromText(textInput)).build())
+            .turnComplete(true)
+            .build());
+  }
+
+  // Prints response messages from the server and signals `turnComplete` when the server is done.
+  private static void handleLiveServerMessage(
+      LiveServerMessage message, CompletableFuture<Void> turnComplete) {
+    message
+        .serverContent()
+        .flatMap(LiveServerContent::modelTurn)
+        .flatMap(Content::parts)
+        .ifPresent(
+            parts ->
+                parts.forEach(
+                    part ->
+                        part.text().ifPresent(text -> System.out.println("Output: " + text))));
+
+    if (message.serverContent().flatMap(LiveServerContent::turnComplete).orElse(false)) {
+      System.out.println("The model is done generating.");
+      turnComplete.complete(null);
+    }
+  }
+}
+// [END googlegenaisdk_live_ground_googsearch_with_txt]

genai/snippets/src/main/java/genai/live/LiveTranscribeWithAudio.java

@@ -0,0 +1,119 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * 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 genai.live;
+
+// [START googlegenaisdk_live_transcribe_with_audio]
+
+import static com.google.genai.types.Modality.Known.AUDIO;
+
+import com.google.genai.AsyncSession;
+import com.google.genai.Client;
+import com.google.genai.types.AudioTranscriptionConfig;
+import com.google.genai.types.Content;
+import com.google.genai.types.LiveConnectConfig;
+import com.google.genai.types.LiveSendClientContentParameters;
+import com.google.genai.types.LiveServerContent;
+import com.google.genai.types.LiveServerMessage;
+import com.google.genai.types.Part;
+import com.google.genai.types.Transcription;
+import java.util.concurrent.CompletableFuture;
+
+public class LiveTranscribeWithAudio {
+
+  public static void main(String[] args) {
+    // TODO(developer): Replace these variables before running the sample.
+    String modelId = "gemini-live-2.5-flash-preview-native-audio";
+    generateContent(modelId);
+  }
+
+  // Shows how to transcribe audio
+  public static void generateContent(String modelId) {
+    // Client Initialization. Once created, it can be reused for multiple requests.
+    try (Client client = Client.builder().location("us-central1").vertexAI(true).build()) {
+
+      // Connects to the live server.
+      CompletableFuture<AsyncSession> sessionFuture =
+          client.async.live.connect(
+              modelId,
+              LiveConnectConfig.builder()
+                  .responseModalities(AUDIO)
+                  .inputAudioTranscription(AudioTranscriptionConfig.builder().build())
+                  .outputAudioTranscription(AudioTranscriptionConfig.builder().build())
+                  .build());
+
+      // Sends and receives messages from the live server.
+      sessionFuture
+          .thenCompose(
+              session -> {
+                // A future that completes when the server signals the end of its turn.
+                CompletableFuture<Void> turnComplete = new CompletableFuture<>();
+                // Starts receiving messages from the live server.
+                session.receive(message -> handleLiveServerMessage(message, turnComplete));
+                // Sends content to the server and waits for the turn to complete.
+                return sendContent(session)
+                    .thenCompose(unused -> turnComplete)
+                    .thenCompose(unused -> session.close());
+              })
+          .join();
+      // Example output:
+      // > Hello? Gemini, are you there?
+      // Output transcript: Yes, I'm here
+      // Output transcript: How can I help you today?
+      // ...
+      // The model is done generating.
+    }
+  }
+
+  // Sends content to the live server.
+  private static CompletableFuture<Void> sendContent(AsyncSession session) {
+    String textInput = "Hello? Gemini, are you there?";
+    System.out.printf("> %s\n", textInput);
+    return session.sendClientContent(
+        LiveSendClientContentParameters.builder()
+            .turns(Content.builder().role("user").parts(Part.fromText(textInput)).build())
+            .turnComplete(true)
+            .build());
+  }
+
+  // Prints response messages from the server and signals `turnComplete` when the server is done.
+  private static void handleLiveServerMessage(
+      LiveServerMessage message, CompletableFuture<Void> turnComplete) {
+
+    if (message.serverContent().isPresent()) {
+      LiveServerContent serverContent = message.serverContent().get();
+      serverContent
+          .modelTurn()
+          .ifPresent(modelTurn -> System.out.println("Model turn: " + modelTurn.parts()));
+
+      serverContent
+          .inputTranscription()
+          .flatMap(Transcription::text)
+          .ifPresent(text -> System.out.println("Input transcript: " + text));
+
+      serverContent
+          .outputTranscription()
+          .flatMap(Transcription::text)
+          .ifPresent(text -> System.out.println("Output transcript: " + text));
+
+      if (serverContent.turnComplete().orElse(false)) {
+        System.out.println("The model is done generating.");
+        turnComplete.complete(null);
+      }
+    }
+  }
+}
+// [END googlegenaisdk_live_transcribe_with_audio]