added basic tests

providers/sfmesh/sfmesh_test.go

@@ -0,0 +1,68 @@
+package sfmesh
+
+import (
+	"errors"
+	"os"
+	"testing"
+
+	"k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func setEnvVars() {
+	os.Setenv("AZURE_SUBSCRIPTION_ID", "fake")
+	os.Setenv("AZURE_TENANT_ID", "fake")
+	os.Setenv("AZURE_CLIENT_ID", "fake")
+	os.Setenv("AZURE_CLIENT_SECRET", "fake")
+	os.Setenv("REGION", "fake")
+	os.Setenv("RESOURCE_GROUP", "fake")
+}
+
+func Test_podToMeshApp(t *testing.T) {
+	setEnvVars()
+
+	pod := &v1.Pod{}
+	pod.ObjectMeta = metav1.ObjectMeta{
+		Name: "test-pod",
+	}
+	pod.Spec = v1.PodSpec{
+		Containers: []v1.Container{
+			{
+				Name:  "testcontainer",
+				Image: "nginx",
+				Ports: []v1.ContainerPort{
+					{
+						Name:          "http",
+						ContainerPort: 80,
+					},
+				},
+			},
+		},
+	}
+
+	provider, err := NewSFMeshProvider(nil, "testnode", "Linux", "6.6.6.6", 80)
+	if err != nil {
+		t.Error(err.Error())
+	}
+
+	_, err = provider.getMeshApplication(pod)
+	if err != nil {
+		t.Error(err.Error())
+	}
+}
+
+func Test_meshStateToPodCondition(t *testing.T) {
+	setEnvVars()
+
+	meshStateSucceeded := "Succeeded"
+
+	provider, err := NewSFMeshProvider(nil, "testnode", "Linux", "6.6.6.6", 80)
+	if err != nil {
+		t.Error(err.Error())
+	}
+
+	phase := provider.appStateToPodPhase(meshStateSucceeded)
+	if phase != v1.PodRunning {
+		t.Error(errors.New("PodRunning phase expected"))
+	}
+}