samples: migrate code from googleapis/java-dialogflow

dialogflow/snippets/pom.xml

@@ -0,0 +1,69 @@
+<?xml version='1.0' encoding='UTF-8'?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <groupId>com.example.dialogflow</groupId>
+  <artifactId>dialogflow-snippets</artifactId>
+  <packaging>jar</packaging>
+  <name>Google Dialogflow API Snippets</name>
+  <url>https://github.com/GoogleCloudPlatform/java-docs-samples/tree/main/dialogflow</url>
+
+  <!--
+    The parent pom defines common style checks and testing strategies for our samples.
+    Removing or replacing it should not affect the execution of the samples in anyway.
+  -->
+  <parent>
+    <groupId>com.google.cloud.samples</groupId>
+    <artifactId>shared-configuration</artifactId>
+    <version>1.2.0</version>
+  </parent>
+
+  <properties>
+    <maven.compiler.target>1.8</maven.compiler.target>
+    <maven.compiler.source>1.8</maven.compiler.source>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+
+
+  <!-- [START dialogflow_install_with_bom] -->
+  <dependencyManagement>
+    <dependencies>
+      <dependency>
+        <groupId>com.google.cloud</groupId>
+        <artifactId>libraries-bom</artifactId>
+        <version>26.1.3</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
+    </dependencies>
+  </dependencyManagement>
+
+  <dependencies>
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-dialogflow</artifactId>
+    </dependency>
+    <!-- [END dialogflow_install_with_bom] -->
+
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-core</artifactId>
+      <version>2.8.20</version>
+      <scope>test</scope>
+      <classifier>tests</classifier>
+    </dependency>
+
+
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.13.2</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.google.truth</groupId>
+      <artifactId>truth</artifactId>
+      <version>1.1.3</version>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>

dialogflow/snippets/src/main/dialogflow/Example.java

@@ -0,0 +1,72 @@
+/*
+ * Copyright 2021 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 dialogflow;
+
+// [START dialogflow_webhook]
+
+// TODO: add GSON dependency to Pom file
+// (https://mvnrepository.com/artifact/com.google.code.gson/gson/2.8.5)
+// TODO: Uncomment the line bellow before running cloud function
+// package com.example;
+
+import com.google.cloud.functions.HttpFunction;
+import com.google.cloud.functions.HttpRequest;
+import com.google.cloud.functions.HttpResponse;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+import java.io.BufferedWriter;
+
+public class Example implements HttpFunction {
+
+  public void service(HttpRequest request, HttpResponse response) throws Exception {
+    JsonParser parser = new JsonParser();
+    Gson gson = new GsonBuilder().create();
+
+    JsonObject job = gson.fromJson(request.getReader(), JsonObject.class);
+    String str =
+        job.getAsJsonObject("queryResult")
+            .getAsJsonObject("intent")
+            .getAsJsonPrimitive("displayName")
+            .toString();
+    JsonObject o = null;
+    String a = '"' + "Default Welcome Intent" + '"';
+    String b = '"' + "get-agent-name" + '"';
+    String responseText = "";
+
+    if (str.equals(a)) {
+      responseText = '"' + "Hello from a Java GCF Webhook" + '"';
+    } else if (str.equals(b)) {
+      responseText = '"' + "My name is Flowhook" + '"';
+    } else {
+      responseText = '"' + "Sorry I didn't get that" + '"';
+    }
+
+    o =
+        parser
+            .parse(
+                "{\"fulfillmentMessages\": [ { \"text\": { \"text\": [ "
+                    + responseText
+                    + " ] } } ] }")
+            .getAsJsonObject();
+
+    BufferedWriter writer = response.getWriter();
+    writer.write(o.toString());
+  }
+}
+// [END dialogflow_webhook]

dialogflow/snippets/src/main/dialogflow/SetAgent.java

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2021 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 dialogflow;
+
+// [START dialogflow_es_create_agent]
+
+import com.google.cloud.dialogflow.v2.Agent;
+import com.google.cloud.dialogflow.v2.Agent.Builder;
+import com.google.cloud.dialogflow.v2.AgentsClient;
+import com.google.cloud.dialogflow.v2.AgentsSettings;
+import java.io.IOException;
+
+public class SetAgent {
+
+  public static void main(String[] args) throws IOException {
+    String projectId = "my-project-id";
+
+    // The display name will set the name of your agent
+    String displayName = "my-display-name";
+
+    setAgent(projectId, displayName);
+  }
+
+  public static Agent setAgent(String parent, String displayName) throws IOException {
+
+    AgentsSettings agentsSettings = AgentsSettings.newBuilder().build();
+    try (AgentsClient client = AgentsClient.create(agentsSettings)) {
+      // Set the details of the Agent to create
+      Builder build = Agent.newBuilder();
+
+      build.setDefaultLanguageCode("en");
+      build.setDisplayName(displayName);
+
+      Agent agent = build.build();
+
+      // Make API request to create agent
+      Agent response = client.setAgent(agent);
+      System.out.println(response);
+      return response;
+    }
+  }
+}
+// [END dialogflow_es_create_agent]

dialogflow/snippets/src/main/java/com/example/dialogflow/DetectIntentAudio.java

@@ -0,0 +1,95 @@
+/*
+ * Copyright 2018 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 com.example.dialogflow;
+
+// [START dialogflow_detect_intent_audio]
+
+import com.google.api.gax.rpc.ApiException;
+import com.google.cloud.dialogflow.v2.AudioEncoding;
+import com.google.cloud.dialogflow.v2.DetectIntentRequest;
+import com.google.cloud.dialogflow.v2.DetectIntentResponse;
+import com.google.cloud.dialogflow.v2.InputAudioConfig;
+import com.google.cloud.dialogflow.v2.QueryInput;
+import com.google.cloud.dialogflow.v2.QueryResult;
+import com.google.cloud.dialogflow.v2.SessionName;
+import com.google.cloud.dialogflow.v2.SessionsClient;
+import com.google.protobuf.ByteString;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+
+public class DetectIntentAudio {
+
+  // DialogFlow API Detect Intent sample with audio files.
+  public static QueryResult detectIntentAudio(
+      String projectId, String audioFilePath, String sessionId, String languageCode)
+      throws IOException, ApiException {
+    // Instantiates a client
+    try (SessionsClient sessionsClient = SessionsClient.create()) {
+      // Set the session name using the sessionId (UUID) and projectID (my-project-id)
+      SessionName session = SessionName.of(projectId, sessionId);
+      System.out.println("Session Path: " + session.toString());
+
+      // Note: hard coding audioEncoding and sampleRateHertz for simplicity.
+      // Audio encoding of the audio content sent in the query request.
+      AudioEncoding audioEncoding = AudioEncoding.AUDIO_ENCODING_LINEAR_16;
+      int sampleRateHertz = 16000;
+
+      // Instructs the speech recognizer how to process the audio content.
+      InputAudioConfig inputAudioConfig =
+          InputAudioConfig.newBuilder()
+              .setAudioEncoding(
+                  audioEncoding) // audioEncoding = AudioEncoding.AUDIO_ENCODING_LINEAR_16
+              .setLanguageCode(languageCode) // languageCode = "en-US"
+              .setSampleRateHertz(sampleRateHertz) // sampleRateHertz = 16000
+              .build();
+
+      // Build the query with the InputAudioConfig
+      QueryInput queryInput = QueryInput.newBuilder().setAudioConfig(inputAudioConfig).build();
+
+      // Read the bytes from the audio file
+      byte[] inputAudio = Files.readAllBytes(Paths.get(audioFilePath));
+
+      // Build the DetectIntentRequest
+      DetectIntentRequest request =
+          DetectIntentRequest.newBuilder()
+              .setSession(session.toString())
+              .setQueryInput(queryInput)
+              .setInputAudio(ByteString.copyFrom(inputAudio))
+              .build();
+
+      // Performs the detect intent request
+      DetectIntentResponse response = sessionsClient.detectIntent(request);
+
+      // Display the query result
+      QueryResult queryResult = response.getQueryResult();
+      System.out.println("====================");
+      System.out.format("Query Text: '%s'\n", queryResult.getQueryText());
+      System.out.format(
+          "Detected Intent: %s (confidence: %f)\n",
+          queryResult.getIntent().getDisplayName(), queryResult.getIntentDetectionConfidence());
+      System.out.format(
+          "Fulfillment Text: '%s'\n",
+          queryResult.getFulfillmentMessagesCount() > 0
+              ? queryResult.getFulfillmentMessages(0).getText()
+              : "Triggered Default Fallback Intent");
+
+      return queryResult;
+    }
+  }
+}
+// [END dialogflow_detect_intent_audio]

dialogflow/snippets/src/main/java/com/example/dialogflow/DetectIntentKnowledge.java

@@ -0,0 +1,101 @@
+/*
+ * Copyright 2018 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 com.example.dialogflow;
+
+// [START dialogflow_detect_intent_knowledge]
+
+import com.google.api.gax.rpc.ApiException;
+import com.google.cloud.dialogflow.v2beta1.DetectIntentRequest;
+import com.google.cloud.dialogflow.v2beta1.DetectIntentResponse;
+import com.google.cloud.dialogflow.v2beta1.KnowledgeAnswers;
+import com.google.cloud.dialogflow.v2beta1.KnowledgeAnswers.Answer;
+import com.google.cloud.dialogflow.v2beta1.QueryInput;
+import com.google.cloud.dialogflow.v2beta1.QueryParameters;
+import com.google.cloud.dialogflow.v2beta1.QueryResult;
+import com.google.cloud.dialogflow.v2beta1.SessionName;
+import com.google.cloud.dialogflow.v2beta1.SessionsClient;
+import com.google.cloud.dialogflow.v2beta1.TextInput;
+import com.google.common.collect.Maps;
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+
+public class DetectIntentKnowledge {
+
+  // DialogFlow API Detect Intent sample with querying knowledge connector.
+  public static Map<String, KnowledgeAnswers> detectIntentKnowledge(
+      String projectId,
+      String knowledgeBaseName,
+      String sessionId,
+      String languageCode,
+      List<String> texts)
+      throws IOException, ApiException {
+    // Instantiates a client
+    Map<String, KnowledgeAnswers> allKnowledgeAnswers = Maps.newHashMap();
+    try (SessionsClient sessionsClient = SessionsClient.create()) {
+      // Set the session name using the sessionId (UUID) and projectID (my-project-id)
+      SessionName session = SessionName.of(projectId, sessionId);
+      System.out.println("Session Path: " + session.toString());
+
+      // Detect intents for each text input
+      for (String text : texts) {
+        // Set the text and language code (en-US) for the query
+        TextInput.Builder textInput =
+            TextInput.newBuilder().setText(text).setLanguageCode(languageCode);
+        // Build the query with the TextInput
+        QueryInput queryInput = QueryInput.newBuilder().setText(textInput).build();
+
+        QueryParameters queryParameters =
+            QueryParameters.newBuilder().addKnowledgeBaseNames(knowledgeBaseName).build();
+
+        DetectIntentRequest detectIntentRequest =
+            DetectIntentRequest.newBuilder()
+                .setSession(session.toString())
+                .setQueryInput(queryInput)
+                .setQueryParams(queryParameters)
+                .build();
+        // Performs the detect intent request
+        DetectIntentResponse response = sessionsClient.detectIntent(detectIntentRequest);
+
+        // Display the query result
+        QueryResult queryResult = response.getQueryResult();
+
+        System.out.format("Knowledge results:\n");
+        System.out.format("====================\n");
+        System.out.format("Query Text: '%s'\n", queryResult.getQueryText());
+        System.out.format(
+            "Detected Intent: %s (confidence: %f)\n",
+            queryResult.getIntent().getDisplayName(), queryResult.getIntentDetectionConfidence());
+        System.out.format(
+            "Fulfillment Text: '%s'\n",
+            queryResult.getFulfillmentMessagesCount() > 0
+                ? queryResult.getFulfillmentMessages(0).getText()
+                : "Triggered Default Fallback Intent");
+        KnowledgeAnswers knowledgeAnswers = queryResult.getKnowledgeAnswers();
+        for (Answer answer : knowledgeAnswers.getAnswersList()) {
+          System.out.format(" - Answer: '%s'\n", answer.getAnswer());
+          System.out.format(" - Confidence: '%s'\n", answer.getMatchConfidence());
+        }
+
+        KnowledgeAnswers answers = queryResult.getKnowledgeAnswers();
+        allKnowledgeAnswers.put(text, answers);
+      }
+    }
+    return allKnowledgeAnswers;
+  }
+}
+// [END dialogflow_detect_intent_knowledge]