WiP: gcp/tests

Signed-off-by: Beraldo Leal <[email protected]>

src/cloud-api-adaptor/test/e2e/gcp_common.go

@@ -0,0 +1,71 @@
+// (C) Copyright Confidential Containers Contributors
+// SPDX-License-Identifier: Apache-2.0
+
+package e2e
+
+import (
+	"testing"
+	"time"
+
+	pv "github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/test/provisioner/gcp"
+)
+
+// GCPAssert implements the CloudAssert interface.
+type GCPAssert struct {
+	Vpc *pv.GCPVPC
+}
+
+func NewGCPAssert() GCPAssert {
+	return GCPAssert{
+		Vpc: pv.GCPProps.GcpVPC,
+	}
+}
+
+func (aa GCPAssert) DefaultTimeout() time.Duration {
+	return 1 * time.Minute
+}
+
+func (aa GCPAssert) HasPodVM(t *testing.T, id string) {
+	// // The `id` parameter is not the instance ID but rather the pod's name, so
+	// // it will need to scan all running pods on the subnet to find one that
+	// // starts with the prefix.
+	// podvmPrefix := "podvm-" + id
+
+	// describeInstances, err := aa.Vpc.Client.DescribeInstances(context.TODO(),
+	// 	&ec2.DescribeInstancesInput{
+	// 		Filters: []ec2types.Filter{
+	// 			{
+	// 				Name:   aws.String("subnet-id"),
+	// 				Values: []string{aa.Vpc.SubnetId},
+	// 			},
+	// 		},
+	// 	})
+	// if err != nil {
+	// 	t.Errorf("Podvm name=%s not found: %v", id, err)
+	// }
+
+	// found := false
+	// for _, reservation := range describeInstances.Reservations {
+	// 	for _, instance := range reservation.Instances {
+	// 		// Code == 48 (terminated)
+	// 		// Some podvm from previous tests might be on terminated stage
+	// 		// so let's ignore them.
+	// 		if instance.State.Code != aws.Int32(48) {
+	// 			for _, tag := range instance.Tags {
+	// 				if *tag.Key == "Name" &&
+	// 					strings.HasPrefix(*tag.Value, podvmPrefix) {
+	// 					found = true
+	// 				}
+	// 			}
+	// 		}
+	// 	}
+	// }
+
+	// if !found {
+	// 	t.Errorf("Podvm name=%s not found", id)
+	// }
+}
+
+func (aa GCPAssert) GetInstanceType(t *testing.T, podName string) (string, error) {
+	return "", nil
+}

src/cloud-api-adaptor/test/e2e/gcp_test.go

@@ -0,0 +1,105 @@
+//go:build gcp
+
+// (C) Copyright Confidential Containers Contributors
+// SPDX-License-Identifier: Apache-2.0
+
+package e2e
+
+import (
+	"testing"
+	// pv "github.com/confidential-containers/cloud-api-adaptor/src/cloud-api-adaptor/test/provisioner/gcp"
+)
+
+func TestGCPCreateSimplePod(t *testing.T) {
+	assert := GCPAssert{}
+	DoTestCreateSimplePod(t, testEnv, assert)
+}
+
+func TestGCPCreatePodWithConfigMap(t *testing.T) {
+	t.Skip("Test not passing")
+	assert := NewGCPAssert()
+
+	DoTestCreatePodWithConfigMap(t, testEnv, assert)
+}
+
+func TestGCPCreatePodWithSecret(t *testing.T) {
+	t.Skip("Test not passing")
+	assert := NewGCPAssert()
+
+	DoTestCreatePodWithSecret(t, testEnv, assert)
+}
+
+// func TestAwsCreatePeerPodContainerWithExternalIPAccess(t *testing.T) {
+// 	t.Skip("Test not passing")
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodContainerWithExternalIPAccess(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodWithJob(t *testing.T) {
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodWithJob(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodAndCheckUserLogs(t *testing.T) {
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodAndCheckUserLogs(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodAndCheckWorkDirLogs(t *testing.T) {
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodAndCheckWorkDirLogs(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodAndCheckEnvVariableLogsWithImageOnly(t *testing.T) {
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodAndCheckEnvVariableLogsWithImageOnly(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodAndCheckEnvVariableLogsWithDeploymentOnly(t *testing.T) {
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodAndCheckEnvVariableLogsWithDeploymentOnly(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodAndCheckEnvVariableLogsWithImageAndDeployment(t *testing.T) {
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodAndCheckEnvVariableLogsWithImageAndDeployment(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodWithLargeImage(t *testing.T) {
+// 	assert := NewAWSAssert()
+//
+// 	DoTestCreatePeerPodWithLargeImage(t, testEnv, assert)
+// }
+//
+// func TestAwsCreatePeerPodWithPVC(t *testing.T) {
+// 	t.Skip("To be implemented")
+// }
+//
+// func TestAwsCreatePeerPodWithAuthenticatedImagewithValidCredentials(t *testing.T) {
+// 	t.Skip("To be implemented")
+// }
+//
+// func TestAwsCreatePeerPodWithAuthenticatedImageWithInvalidCredentials(t *testing.T) {
+// 	t.Skip("To be implemented")
+// }
+//
+// func TestAwsCreatePeerPodWithAuthenticatedImageWithoutCredentials(t *testing.T) {
+// 	t.Skip("To be implemented")
+// }
+//
+// func TestAwsDeletePod(t *testing.T) {
+// 	assert := NewAWSAssert()
+// 	DoTestDeleteSimplePod(t, testEnv, assert)
+// }
+//
+// func TestAwsCreateNginxDeployment(t *testing.T) {
+// 	assert := NewAWSAssert()
+// 	DoTestNginxDeployment(t, testEnv, assert)
+// }