samples: Add tests to Cloud Tasks Samples (#1459)

* Add tests

* Update license

* Update README

* Update for testing purposes

* Update queue location

* Fix test styling

* Library version

* Update service account

* Fix service account

Author: averikitsch

tasks/snippets/src/main/java/com/example/task/CreateHttpTask.java

@@ -26,24 +26,24 @@
 import java.nio.charset.Charset;
 
 public class CreateHttpTask {
-
-  public static void main(String[] args) throws Exception {
-    String projectId = System.getenv("PROJECT_ID");
-    String queueName = System.getenv("QUEUE_ID");
-    String location = System.getenv("LOCATION_ID");
-    String url = System.getenv("URL");
+  /**
+   * Create a task with a HTTP target using the Cloud Tasks client.
+   *
+   * @param projectId the Id of the project.
+   * @param queueId the name of your Queue.
+   * @param locationId the GCP region of your queue.
+   * @throws Exception on Cloud Tasks Client errors.
+   */
+  public static void createTask(String projectId, String locationId, String queueId)
+      throws Exception {
 
     // Instantiates a client.
     try (CloudTasksClient client = CloudTasksClient.create()) {
-      // Variables provided by the system variables.
-      // projectId = "my-project-id";
-      // queueName = "my-queue";
-      // location = "us-central1";
-      // url = "https://example.com/taskhandler";
-      String payload = "hello";
+      String url = "https://example.com/taskhandler";
+      String payload = "Hello, World!";
 
       // Construct the fully qualified queue name.
-      String queuePath = QueueName.of(projectId, location, queueName).toString();
+      String queuePath = QueueName.of(projectId, locationId, queueId).toString();
 
       // Construct the task body.
       Task.Builder taskBuilder =

tasks/snippets/src/main/java/com/example/task/CreateHttpTaskWithToken.java

@@ -27,29 +27,32 @@
 import java.nio.charset.Charset;
 
 public class CreateHttpTaskWithToken {
-
-  public static void main(String[] args) throws Exception {
-    String projectId = System.getenv("PROJECT_ID");
-    String queueName = System.getenv("QUEUE_ID");
-    String location = System.getenv("LOCATION_ID");
-    String url = System.getenv("URL");
+  /**
+   * Create a task with a HTTP target and authorization token using the Cloud Tasks client.
+   *
+   * @param projectId the Id of the project.
+   * @param queueId the name of your Queue.
+   * @param locationId the GCP region of your queue.
+   * @param serviceAccountEmail your Cloud IAM service account
+   * @throws Exception on Cloud Tasks Client errors.
+   */
+  public static void createTask(
+      String projectId, String locationId, String queueId, String serviceAccountEmail)
+      throws Exception {
 
     // Instantiates a client.
     try (CloudTasksClient client = CloudTasksClient.create()) {
-      // Variables provided by the system variables.
-      // projectId = "my-project-id";
-      // queueName = "my-queue";
-      // location = "us-central1";
-      // url = "https://example.com/taskhandler";
-      String payload = "hello";
+      String url =
+          "https://example.com/taskhandler"; // The full url path that the request will be sent to
+      String payload = "Hello, World!"; // The task HTTP request body
 
       // Construct the fully qualified queue name.
-      String queuePath = QueueName.of(projectId, location, queueName).toString();
+      String queuePath = QueueName.of(projectId, locationId, queueId).toString();
 
       // Add your service account email to construct the OIDC token.
       // in order to add an authentication header to the request.
       OidcToken.Builder oidcTokenBuilder =
-          OidcToken.newBuilder().setServiceAccountEmail("<SERVICE_ACCOUNT_EMAIL>");
+          OidcToken.newBuilder().setServiceAccountEmail(serviceAccountEmail);
 
       // Construct the task body.
       Task.Builder taskBuilder =

tasks/snippets/src/test/java/com/example/task/CreateHttpTaskIT.java

@@ -0,0 +1,67 @@
+/*
+ * Copyright 2019 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.task;
+
+import static com.google.common.truth.Truth.assertThat;
+
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.Timeout;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
+
+/** Tests for creating Tasks with HTTP targets. */
+@RunWith(JUnit4.class)
+public class CreateHttpTaskIT {
+  private static final String PROJECT_ID = "java-docs-samples-testing";
+  private static final String LOCATION_ID = "us-east1";
+  private static final String QUEUE_ID = "default";
+  private static final String EMAIL =
+      "java-docs-samples-testing@java-docs-samples-testing.iam.gserviceaccount.com";
+  private ByteArrayOutputStream bout;
+  private PrintStream out;
+
+  @Before
+  public void setUp() {
+    bout = new ByteArrayOutputStream();
+    out = new PrintStream(bout);
+    System.setOut(out);
+  }
+
+  @After
+  public void tearDown() {
+    System.setOut(null);
+  }
+
+  @Test
+  public void testCreateHttpTask() throws Exception {
+    CreateHttpTask.createTask(PROJECT_ID, LOCATION_ID, QUEUE_ID);
+    String got = bout.toString();
+    assertThat(got).contains("Task created:");
+  }
+
+  @Test
+  public void testCreateHttpTaskWithToken() throws Exception {
+    CreateHttpTaskWithToken.createTask(PROJECT_ID, LOCATION_ID, QUEUE_ID, EMAIL);
+    String got = bout.toString();
+    assertThat(got).contains("Task created:");
+  }
+}