test: enable csi-proxy.exe in workflow and enable windows unit tests

Signed-off-by: Mayank Shah <[email protected]>

.github/workflows/windows.yml

@@ -25,4 +25,13 @@ jobs:
           go build -a -o _output/azurediskplugin.exe ./pkg/azurediskplugin
       - name: Run Windows Unit Tests
         run: |
+          # start the CSI Proxy before running tests on windows
+          Start-Job -Name CSIProxy -ScriptBlock {
+            Invoke-WebRequest https://kubernetesartifacts.azureedge.net/csi-proxy/v0.2.1/binaries/csi-proxy.tar.gz -OutFile csi-proxy.tar.gz;
+            tar -xvf csi-proxy.tar.gz
+            .\bin\csi-proxy.exe --kubelet-csi-plugins-path $pwd --kubelet-pod-path $pwd
+          };
+          Start-Sleep -Seconds 30;
+          Write-Output "getting named pipes"
+          [System.IO.Directory]::GetFiles("\\.\\pipe\\")
           go test -v -race ./pkg/...

pkg/azuredisk/azure_test.go

@@ -20,8 +20,8 @@ import (
 	"fmt"
 	"io/ioutil"
 	"os"
-	"reflect"
 	"runtime"
+	"sigs.k8s.io/azuredisk-csi-driver/test/utils/testutil"
 	"testing"
 )
 
@@ -32,6 +32,7 @@ func skipIfTestingOnWindows(t *testing.T) {
 }
 
 func TestGetCloudProvider(t *testing.T) {
+	// skip on Windows for now as it gets very flaky
 	skipIfTestingOnWindows(t)
 	fakeCredFile := "fake-cred-file.json"
 	fakeKubeConfig := "fake-kube-config"

pkg/azuredisk/azuredisk_test.go

@@ -588,6 +588,7 @@ func TestIsAvailabilityZone(t *testing.T) {
 }
 
 func TestIsCorruptedDir(t *testing.T) {
+	// skip for now, due to issues related to admin privileges on Windows
 	skipIfTestingOnWindows(t)
 	existingMountPath, err := ioutil.TempDir(os.TempDir(), "csi-mount-test")
 	if err != nil {

pkg/azuredisk/fake_mounter.go

@@ -18,6 +18,9 @@ package azuredisk
 
 import (
 	"fmt"
+	testingexec "k8s.io/utils/exec/testing"
+	"runtime"
+	"sigs.k8s.io/azuredisk-csi-driver/pkg/mounter"
 	"strings"
 
 	"k8s.io/utils/mount"
@@ -59,3 +62,13 @@ func (f *fakeMounter) IsLikelyNotMountPoint(file string) (bool, error) {
 	}
 	return true, nil
 }
+
+func NewFakeMounter() (*mount.SafeFormatAndMount, error) {
+	if runtime.GOOS == "windows" {
+		return mounter.NewSafeMounter()
+	}
+	return &mount.SafeFormatAndMount{
+		Interface: &fakeMounter{},
+		Exec:      &testingexec.FakeExec{ExactOrder: true},
+	}, nil
+}

pkg/azuredisk/fake_mounter_test.go

@@ -19,12 +19,16 @@ package azuredisk
 import (
 	"fmt"
 	"reflect"
+	"sigs.k8s.io/azuredisk-csi-driver/test/utils/testutil"
 	"testing"
 
 	"k8s.io/utils/mount"
 )
 
 func TestMount(t *testing.T) {
+	targetTest := testutil.GetWorkDirPath("target_test", t)
+	sourceTest := testutil.GetWorkDirPath("source_test", t)
+
 	tests := []struct {
 		desc        string
 		source      string
@@ -65,6 +69,9 @@ func TestMount(t *testing.T) {
 }
 
 func TestMountSensitive(t *testing.T) {
+	targetTest := testutil.GetWorkDirPath("target_test", t)
+	sourceTest := testutil.GetWorkDirPath("source_test", t)
+
 	tests := []struct {
 		desc        string
 		source      string
@@ -105,6 +112,8 @@ func TestMountSensitive(t *testing.T) {
 }
 
 func TestIsLikelyNotMountPoint(t *testing.T) {
+	targetTest := testutil.GetWorkDirPath("target_test", t)
+
 	tests := []struct {
 		desc        string
 		file        string