Setup sanity and integration test CI

Author: chewong

Gopkg.lock

@@ -32,15 +32,15 @@ verify:
 
 .PHONY: unit-test
 unit-test:
-	go test -covermode=count -coverprofile=profile.cov ./pkg/...
+	go test -covermode=count -coverprofile=profile.cov ./pkg/... ./test/utils/credentials
 
 .PHONY: sanity-test
-sanity-test:
-	test/sanity/run-tests-all-clouds.sh
+sanity-test: blobfuse
+	go test -v -timeout=30m ./test/sanity
 
 .PHONY: integration-test
-integration-test:
-	test/integration/run-tests-all-clouds.sh
+integration-test: blobfuse
+	go test -v -timeout=30m ./test/integration
 
 .PHONY: e2e-test
 e2e-test:

Makefile

@@ -0,0 +1,108 @@
+/*
+Copyright 2019 The Kubernetes Authors.
+
+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 integration
+
+import (
+	"context"
+	"log"
+	"os"
+	"os/exec"
+	"strings"
+	"testing"
+
+	"github.com/kubernetes-sigs/blobfuse-csi-driver/test/utils/azure"
+	"github.com/kubernetes-sigs/blobfuse-csi-driver/test/utils/credentials"
+	"github.com/kubernetes-sigs/blobfuse-csi-driver/test/utils/testutil"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestIntegrationOnAzurePublicCloud(t *testing.T) {
+	// Test on AzurePublicCloud
+	creds, err := credentials.CreateAzureCredentialFile(false)
+	defer func() {
+		err := credentials.DeleteAzureCredentialFile()
+		assert.NoError(t, err)
+	}()
+	assert.NoError(t, err)
+	assert.NotNil(t, creds)
+
+	testIntegration(t, creds)
+}
+
+func TestIntegrationOnAzureChinaCloud(t *testing.T) {
+	if testutil.IsRunningInProw() {
+		t.Skipf("Skipping integration test on Azure China Cloud because Prow only tests on Azure Public Cloud at the moment")
+	}
+
+	// Test on AzureChinaCloud
+	creds, err := credentials.CreateAzureCredentialFile(true)
+	defer func() {
+		err := credentials.DeleteAzureCredentialFile()
+		assert.NoError(t, err)
+	}()
+
+	if err != nil {
+		// Skip the test if Azure China Cloud credentials are not supplied
+		t.Skipf("Skipping integration test on Azure China Cloud due to the following error %v", err)
+	}
+	assert.NotNil(t, creds)
+	testIntegration(t, creds)
+}
+
+func testIntegration(t *testing.T, creds *credentials.Credentials) {
+	os.Setenv("AZURE_CREDENTIAL_FILE", credentials.TempAzureCredentialFilePath)
+
+	azureClient, err := azure.GetClient(creds.Cloud, creds.SubscriptionID, creds.AADClientID, creds.TenantID, creds.AADClientSecret)
+	assert.NoError(t, err)
+
+	ctx := context.Background()
+	// Create an empty resource group for integration test
+	log.Printf("Creating resource group %s in %s", creds.ResourceGroup, creds.Cloud)
+	_, err = azureClient.EnsureResourceGroup(ctx, creds.ResourceGroup, creds.Location, nil)
+	assert.NoError(t, err)
+	defer func() {
+		// Only delete resource group the test created
+		if strings.HasPrefix(creds.ResourceGroup, credentials.ResourceGroupPrefix) {
+			log.Printf("Deleting resource group %s", creds.ResourceGroup)
+			err := azureClient.DeleteResourceGroup(ctx, creds.ResourceGroup)
+			assert.NoError(t, err)
+		}
+	}()
+
+	// Execute the script from project root
+	err = os.Chdir("../..")
+	assert.NoError(t, err)
+	// Change directory back to test/integration in preparation for next test
+	defer func() {
+		err := os.Chdir("test/integration")
+		assert.NoError(t, err)
+	}()
+
+	cwd, err := os.Getwd()
+	assert.NoError(t, err)
+	assert.True(t, strings.HasSuffix(cwd, "blobfuse-csi-driver"))
+
+	// Pass in resource group name, storage account name and cloud type
+	cmd := exec.Command("./test/integration/run-tests-all-clouds.sh", creds.ResourceGroup, creds.Cloud)
+	cmd.Dir = cwd
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	if err := cmd.Run(); err != nil {
+		t.Fatalf("Integration test failed %v", err)
+	}
+}