docs(samples): add try blocks to clean up resources in samples and sample tests

samples/snippets/src/main/java/dialogflow/cx/ConfigureWebhookToSetFormParametersAsOptionalOrRequired.java

@@ -57,9 +57,6 @@ public void service(HttpRequest request, HttpResponse response) throws Exception
     Gson gson = new GsonBuilder().setPrettyPrinting().create();
     String jsonResponseObject = gson.toJson(webhookResponse);
 
-    System.out.println("Response Object: \n");
-    System.out.println(jsonResponseObject.toString());
-
     /* {
      *   "page_info": {
      *     "form_info": {

samples/snippets/src/main/java/dialogflow/cx/CreateAgent.java

@@ -39,6 +39,9 @@ public static Agent createAgent(String parent, String displayName) throws IOExce
     String apiEndpoint = "global-dialogflow.googleapis.com:443";
 
     AgentsSettings agentsSettings = AgentsSettings.newBuilder().setEndpoint(apiEndpoint).build();
+    // Note: close() needs to be called on the AgentsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (AgentsClient client = AgentsClient.create(agentsSettings)) {
       // Set the details of the Agent to create
       Builder build = Agent.newBuilder();

samples/snippets/src/main/java/dialogflow/cx/CreateFlow.java

@@ -50,7 +50,10 @@ public static Flow createFlow(
     }
     FlowsSettings flowsSettings = flowsSettingsBuilder.build();
 
-    // Instantiates a client
+    // Instantiates a client.
+    // Note: close() needs to be called on the FlowsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (FlowsClient flowsClient = FlowsClient.create(flowsSettings)) {
       // Set the project agent name using the projectID (my-project-id), locationID (global), and
       // agentID (UUID).

samples/snippets/src/main/java/dialogflow/cx/CreateIntent.java

@@ -48,6 +48,9 @@ public static Intent createIntent(
     IntentsSettings intentsSettings = intentsSettingsBuilder.build();
 
     // Instantiates a client
+    // Note: close() needs to be called on the IntentsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (IntentsClient intentsClient = IntentsClient.create(intentsSettings)) {
       // Set the project agent name using the projectID (my-project-id), locationID (global), and
       // agentID (UUID).

samples/snippets/src/main/java/dialogflow/cx/CreatePage.java

@@ -52,6 +52,9 @@ public static Page createPage(
     PagesSettings pagesSettings = pagesSettingsBuilder.build();
 
     // Instantiates a client
+    // Note: close() needs to be called on the PagesClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (PagesClient pagesClient = PagesClient.create(pagesSettings)) {
       // Set the flow name using the projectID (my-project-id), locationID (global), agentID (UUID)
       // and flowID (UUID).

samples/snippets/src/main/java/dialogflow/cx/CreateSimplePage.java

@@ -59,6 +59,9 @@ public static Page createPage(
         .setPage(pageBuilder);
 
     // Make API request to create page
+    // Note: close() needs to be called on the PagesClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (PagesClient client = PagesClient.create()) {
       response = client.createPage(createRequestBuilder.build());
       System.out.println("Successfully created page!");

samples/snippets/src/main/java/dialogflow/cx/DeletePage.java

@@ -40,6 +40,10 @@ public static void main(String[] args) throws IOException {
   public static void deletePage(
       String projectId, String agentId, String flowId, String pageId, String location)
       throws IOException {
+
+    // Note: close() needs to be called on the PagesClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (PagesClient client = PagesClient.create()) {
       Builder deleteRequestBuilder = DeletePageRequest.newBuilder();
 

samples/snippets/src/main/java/dialogflow/cx/DetectIntent.java

@@ -52,7 +52,11 @@ public static Map<String, QueryResult> detectIntent(
     SessionsSettings sessionsSettings = sessionsSettingsBuilder.build();
 
     Map<String, QueryResult> queryResults = Maps.newHashMap();
-    // Instantiates a client
+    // Instantiates a client.
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       // Set the session name using the projectID (my-project-id), locationID (global), agentID
       // (UUID), and sessionId (UUID).

samples/snippets/src/main/java/dialogflow/cx/DetectIntentAudioInput.java

@@ -76,6 +76,10 @@ public static void detectIntent(
 
     // Instantiates a client by setting the session name.
     // Format:`projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session =
           SessionName.ofProjectLocationAgentSessionName(projectId, locationId, agentId, sessionId);

samples/snippets/src/main/java/dialogflow/cx/DetectIntentDisableWebhook.java

@@ -68,6 +68,10 @@ public static Map<String, QueryResult> detectIntent(
 
     // Instantiates a client by setting the session name.
     // Format:`projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session =
           SessionName.ofProjectLocationAgentSessionName(projectId, locationId, agentId, sessionId);

samples/snippets/src/main/java/dialogflow/cx/DetectIntentEventInput.java

@@ -62,6 +62,10 @@ public static void detectIntent(
 
     // Instantiates a client by setting the session name.
     // Format:`projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session =
           SessionName.ofProjectLocationAgentSessionName(projectId, locationId, agentId, sessionId);

samples/snippets/src/main/java/dialogflow/cx/DetectIntentIntentInput.java

@@ -62,6 +62,10 @@ public static void detectIntent(
 
     // Instantiates a client by setting the session name.
     // Format:`projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session =
           SessionName.ofProjectLocationAgentSessionName(projectId, locationId, agentId, sessionId);

samples/snippets/src/main/java/dialogflow/cx/DetectIntentSentimentAnalysis.java

@@ -68,6 +68,10 @@ public static Map<String, QueryResult> detectIntent(
 
     // Instantiates a client by setting the session name.
     // Format:`projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session =
           SessionName.ofProjectLocationAgentSessionName(projectId, locationId, agentId, sessionId);

samples/snippets/src/main/java/dialogflow/cx/DetectIntentStream.java

@@ -56,6 +56,10 @@ public static void detectIntentStream(
     // Instantiates a client by setting the session name.
     // Format: `projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
     // Using the same `sessionId` between requests allows continuation of the conversation.
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session = SessionName.of(projectId, locationId, agentId, sessionId);
 

samples/snippets/src/main/java/dialogflow/cx/DetectIntentStreamingPartialResponse.java

@@ -56,6 +56,10 @@ public static void detectIntentStreamingPartialResponse(
     // Instantiates a client by setting the session name.
     // Format:`projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
     // Using the same `sessionId` between requests allows continuation of the conversation.
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session = SessionName.of(projectId, locationId, agentId, sessionId);
 

samples/snippets/src/main/java/dialogflow/cx/DetectIntentSynthesizeTextToSpeechOutput.java

@@ -71,6 +71,10 @@ public static void detectIntent(
 
     // Instantiates a client by setting the session name.
     // Format:`projects/<ProjectID>/locations/<LocationID>/agents/<AgentID>/sessions/<SessionID>`
+
+    // Note: close() needs to be called on the SessionsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (SessionsClient sessionsClient = SessionsClient.create(sessionsSettings)) {
       SessionName session =
           SessionName.ofProjectLocationAgentSessionName(projectId, locationId, agentId, sessionId);

samples/snippets/src/main/java/dialogflow/cx/ExportAgent.java

@@ -47,6 +47,9 @@ public static void exportAgent(String projectId, String agentId, String location
     String apiEndpoint = String.format("%s-dialogflow.googleapis.com:443", location);
 
     AgentsSettings agentsSettings = AgentsSettings.newBuilder().setEndpoint(apiEndpoint).build();
+    // Note: close() needs to be called on the AgentsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (AgentsClient agentsClient = AgentsClient.create(agentsSettings)) {
       ExportAgentRequest request =
           ExportAgentRequest.newBuilder()

samples/snippets/src/main/java/dialogflow/cx/ListPages.java

@@ -39,23 +39,22 @@ public static void main(String[] args) throws IOException {
   // Lists all pages from the provided parameters
   public static void listPages(String projectId, String agentId, String flowId, String location)
       throws IOException {
-    PagesClient client = PagesClient.create();
-    Builder listRequestBuilder = ListPagesRequest.newBuilder();
-
-    listRequestBuilder.setParent(
-        "projects/"
-            + projectId
-            + "/locations/"
-            + location
-            + "/agents/"
-            + agentId
-            + "/flows/"
-            + flowId);
-    listRequestBuilder.setLanguageCode("en");
-
-    // Make API request to list all pages in the project
-    for (Page element : client.listPages(listRequestBuilder.build()).iterateAll()) {
-      System.out.println(element);
+    // Note: close() needs to be called on the PagesClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
+    try (PagesClient client = PagesClient.create()) {
+      Builder listRequestBuilder = ListPagesRequest.newBuilder();
+
+      String parentPath =
+          String.format(
+              "projects/%s/locations/%s/agents/%s/flows/%s", projectId, location, agentId, flowId);
+      listRequestBuilder.setParent(parentPath);
+      listRequestBuilder.setLanguageCode("en");
+
+      // Make API request to list all pages in the project
+      for (Page element : client.listPages(listRequestBuilder.build()).iterateAll()) {
+        System.out.println(element);
+      }
     }
   }
   // [END dialogflow_cx_list_pages]

samples/snippets/src/main/java/dialogflow/cx/ListTestCaseResults.java

@@ -57,10 +57,14 @@ public static void listTestCaseResults(
         TestCasesSettings.newBuilder()
             .setEndpoint(location + "-dialogflow.googleapis.com:443")
             .build();
-    TestCasesClient client = TestCasesClient.create(testCasesSettings);
 
-    for (TestCaseResult element : client.listTestCaseResults(req.build()).iterateAll()) {
-      System.out.println(element);
+    // Note: close() needs to be called on the TestCasesClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
+    try (TestCasesClient client = TestCasesClient.create(testCasesSettings)) {
+      for (TestCaseResult element : client.listTestCaseResults(req.build()).iterateAll()) {
+        System.out.println(element);
+      }
     }
   }
 }

samples/snippets/src/main/java/dialogflow/cx/ListTrainingPhrases.java

@@ -38,6 +38,10 @@ public static void main(String[] args) throws IOException {
   // DialogFlow API List Training Phrases sample.
   public static void listTrainingPhrases(
       String projectId, String location, String agentId, String intentId) throws IOException {
+
+    // Note: close() needs to be called on the IntentsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (IntentsClient client = IntentsClient.create()) {
       // Set the intent name
       IntentName name = IntentName.of(projectId, location, agentId, intentId);

samples/snippets/src/main/java/dialogflow/cx/UpdateIntent.java

@@ -41,6 +41,10 @@ public static void main(String[] args) throws IOException {
   public static void updateIntent(
       String projectId, String agentId, String intentId, String location, String displayName)
       throws IOException {
+
+    // Note: close() needs to be called on the IntentsClient object to clean up resources
+    // such as threads. In the example below, try-with-resources is used,
+    // which automatically calls close().
     try (IntentsClient client = IntentsClient.create()) {
       String intentPath =
           "projects/"

samples/snippets/src/main/java/dialogflow/cx/WebhookConfigureSessionParameters.java

@@ -49,9 +49,6 @@ public void service(HttpRequest request, HttpResponse response) throws Exception
     Gson gson = new GsonBuilder().setPrettyPrinting().create();
     String jsonResponseObject = gson.toJson(webhookResponse);
 
-    System.out.println("Session Parameter Info: \n");
-    System.out.println(jsonResponseObject.toString());
-
     /** { "session_info": { "parameters": { "order_number": "12345" } } } */
     BufferedWriter writer = response.getWriter();
     // Sends the webhookResponseObject

samples/snippets/src/main/java/dialogflow/cx/WebhookValidateFormParameter.java

@@ -65,8 +65,6 @@ public void service(HttpRequest request, HttpResponse response) throws Exception
     Gson gson = new GsonBuilder().setPrettyPrinting().create();
     String jsonResponseObject = gson.toJson(webhookResponse);
 
-    System.out.println("Response Object: \n");
-    System.out.println(jsonResponseObject.toString());
     /**
      * { "page_info": { "form_info": { "parameter_info": [ { "display_name": "order_number",
      * "required": "true", "state": "INVALID", "value": "123" } ] } }, "session_info": {

samples/snippets/src/test/java/dialogflow/cx/ConfigureWebhookToSetFormParametersAsOptionalOrRequiredIT.java

@@ -65,7 +65,9 @@ public void beforeTest() throws IOException {
   public void helloHttp_bodyParamsPost() throws IOException, Exception {
 
     FulfillmentInfo fulfillmentInfo =
-        FulfillmentInfo.newBuilder().setTag("configure-session-parameters").build();
+        FulfillmentInfo.newBuilder()
+            .setTag("configure-form-parameters-optional-or-parameter")
+            .build();
 
     WebhookRequest webhookRequest =
         WebhookRequest.newBuilder().setFulfillmentInfo(fulfillmentInfo).build();
@@ -94,5 +96,6 @@ public void helloHttp_bodyParamsPost() throws IOException, Exception {
     String expectedResponse = gson.toJson(webhookResponse);
 
     assertThat(responseOut.toString()).isEqualTo(expectedResponse);
+    Thread.sleep(200);
   }
 }

samples/snippets/src/test/java/dialogflow/cx/CreateAgentIT.java

@@ -48,12 +48,12 @@ public void tearDown() throws IOException, InterruptedException {
     String apiEndpoint = "global-dialogflow.googleapis.com:443";
 
     AgentsSettings agentsSettings = AgentsSettings.newBuilder().setEndpoint(apiEndpoint).build();
-    AgentsClient client = AgentsClient.create(agentsSettings);
+    try (AgentsClient client = AgentsClient.create(agentsSettings)) {
+      client.deleteAgent(CreateAgentIT.agentPath);
 
-    client.deleteAgent(CreateAgentIT.agentPath);
-
-    // Small delay to prevent reaching quota limit of requests per minute
-    Thread.sleep(250);
+      // Small delay to prevent reaching quota limit of requests per minute
+      Thread.sleep(250);
+    }
   }
 
   @Test