fix: Update GCF compute tests (GoogleCloudPlatform#7698)

averikitsch · web-flow · commit 9203e0022ba9 · 2023-02-28T08:30:21.000-08:00
* Update GCF compute tests

* lint

* add exception

* Use UUID

* Update AutoLabelInstanceTest.java
diff --git a/functions/v2/label-compute-instance/src/test/java/functions/AutoLabelInstanceTest.java b/functions/v2/label-compute-instance/src/test/java/functions/AutoLabelInstanceTest.java
@@ -18,13 +18,29 @@
 
 import static com.google.common.truth.Truth.assertThat;
 
+import com.google.api.gax.longrunning.OperationFuture;
+import com.google.cloud.compute.v1.AttachedDisk;
+import com.google.cloud.compute.v1.AttachedDisk.Type;
+import com.google.cloud.compute.v1.AttachedDiskInitializeParams;
+import com.google.cloud.compute.v1.DeleteInstanceRequest;
+import com.google.cloud.compute.v1.InsertInstanceRequest;
+import com.google.cloud.compute.v1.Instance;
+import com.google.cloud.compute.v1.InstancesClient;
+import com.google.cloud.compute.v1.NetworkInterface;
+import com.google.cloud.compute.v1.Operation;
 import com.google.common.testing.TestLogHandler;
 import com.google.gson.Gson;
 import com.google.gson.JsonObject;
 import io.cloudevents.CloudEvent;
 import io.cloudevents.core.builder.CloudEventBuilder;
+import java.io.IOException;
 import java.net.URI;
+import java.util.UUID;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
 import java.util.logging.Logger;
+import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -37,13 +53,26 @@ public class AutoLabelInstanceTest {
 
   private static final String PROJECT_ID = System.getenv("GOOGLE_CLOUD_PROJECT");
   private static final String ZONE = "us-central1-a";
-  private static final String INSTANCE = "lite1";
+  private static final String INSTANCE = "gcf-test" + UUID.randomUUID().toString();
+  private static final int TIMEOUT = 3;
 
   @BeforeClass
-  public static void beforeClass() {
+  public static void beforeClass()
+      throws IOException, InterruptedException, ExecutionException, TimeoutException {
+    assertThat(PROJECT_ID).isNotNull();
+    try {
+      createInstance(PROJECT_ID, ZONE, INSTANCE);
+    } catch (Exception e) {
+      System.out.println("VM already exists: " + e);
+    }
     logger.addHandler(logHandler);
   }
 
+  @AfterClass
+  public static void cleanup() throws Exception {
+    deleteInstance(PROJECT_ID, ZONE, INSTANCE);
+  }
+
   @Test
   public void functionsAutoLabelInstance() throws Exception {
     // Build a CloudEvent Log Entry
@@ -81,4 +110,90 @@ public void functionsAutoLabelInstance() throws Exception {
                 "test-gmail-com", INSTANCE))
         .isEqualTo(logHandler.getStoredLogRecords().get(0).getMessage());
   }
+
+  public static void createInstance(String project, String zone, String instanceName)
+      throws IOException, InterruptedException, ExecutionException, TimeoutException {
+    String machineType = String.format("zones/%s/machineTypes/n1-standard-1", zone);
+    String sourceImage = "projects/debian-cloud/global/images/family/debian-11";
+    long diskSizeGb = 10L;
+    String networkName = "default";
+
+    try (InstancesClient instancesClient = InstancesClient.create()) {
+      // Instance creation requires at least one persistent disk and one network interface.
+      AttachedDisk disk =
+          AttachedDisk.newBuilder()
+              .setBoot(true)
+              .setAutoDelete(true)
+              .setType(Type.PERSISTENT.toString())
+              .setDeviceName("disk-1")
+              .setInitializeParams(
+                  AttachedDiskInitializeParams.newBuilder()
+                      .setSourceImage(sourceImage)
+                      .setDiskSizeGb(diskSizeGb)
+                      .build())
+              .build();
+
+      // Use the network interface provided in the networkName argument.
+      NetworkInterface networkInterface =
+          NetworkInterface.newBuilder().setName(networkName).build();
+
+      // Bind `instanceName`, `machineType`, `disk`, and `networkInterface` to an instance.
+      Instance instanceResource =
+          Instance.newBuilder()
+              .setName(instanceName)
+              .setMachineType(machineType)
+              .addDisks(disk)
+              .addNetworkInterfaces(networkInterface)
+              .build();
+
+      System.out.printf("Creating instance: %s at %s %n", instanceName, zone);
+
+      // Insert the instance in the specified project and zone.
+      InsertInstanceRequest insertInstanceRequest =
+          InsertInstanceRequest.newBuilder()
+              .setProject(project)
+              .setZone(zone)
+              .setInstanceResource(instanceResource)
+              .build();
+
+      OperationFuture<Operation, Operation> operation =
+          instancesClient.insertAsync(insertInstanceRequest);
+
+      // Wait for the operation to complete.
+      Operation response = operation.get(TIMEOUT, TimeUnit.MINUTES);
+
+      if (response.hasError()) {
+        System.out.println("Instance creation failed ! ! " + response);
+        return;
+      }
+      System.out.println("Operation Status: " + response.getStatus());
+    }
+  }
+
+  public static void deleteInstance(String project, String zone, String instanceName)
+      throws IOException, InterruptedException, ExecutionException, TimeoutException {
+    try (InstancesClient instancesClient = InstancesClient.create()) {
+
+      System.out.printf("Deleting instance: %s ", instanceName);
+
+      // Describe which instance is to be deleted.
+      DeleteInstanceRequest deleteInstanceRequest =
+          DeleteInstanceRequest.newBuilder()
+              .setProject(project)
+              .setZone(zone)
+              .setInstance(instanceName)
+              .build();
+
+      OperationFuture<Operation, Operation> operation =
+          instancesClient.deleteAsync(deleteInstanceRequest);
+      // Wait for the operation to complete.
+      Operation response = operation.get(TIMEOUT, TimeUnit.MINUTES);
+
+      if (response.hasError()) {
+        System.out.println("Instance deletion failed ! ! " + response);
+        return;
+      }
+      System.out.println("Operation Status: " + response.getStatus());
+    }
+  }
 }
