main_test.go

package main

import (
	"encoding/base64"
	"fmt"
	"strings"
	"testing"
)

// Running without arguments should return an error message.
func TestMainWithoutArgs(t *testing.T) {
	args := []string{}
	msg := driverMain(args)
	if msg.Status != retStatFailure {
		t.Error()
	}
	if msg.Message != retMsgInsufficientArgs {
		t.Error()
	}

	args = []string{"/path/to/binary"}
	msg = driverMain(args)
	if msg.Status != retStatFailure {
		t.Error()
	}
	if msg.Message != retMsgInsufficientArgs {
		t.Error()
	}
}

// There is nothing to init at this point. Should return a sucess message.
func TestInit(t *testing.T) {
	args := []string{"/path/to/binary", "init"}
	msg := driverMain(args)
	if msg.Status != retStatSuccess {
		t.Error()
	}
	if msg.Capabilities.Attach {
		t.Error()
	}
	if msg.Capabilities.FSGroup {
		t.Error()
	}
	if msg.Capabilities.SupportsMetrics {
		t.Error()
	}
}

func TestUnsupportedOperation(t *testing.T) {
	args := []string{"/path/to/binary", "i_do_not_exist"}
	msg := driverMain(args)
	if msg.Status != retStatNotSupported {
		t.Error()
	}
	if !strings.HasPrefix(msg.Message, retMsgUnsupportedOperation) {
		t.Error()
	}
}

func TestUnmountCmd(t *testing.T) {

	args := []string{"/path/to/binary", "unmount", "/mnt/point"}
	mountCmd := createUmountCmd(args)
	if mountCmd == nil {
		t.Error()
	}

	if mountCmd.Args[0] != "umount" {
		t.Error()
	}
	if mountCmd.Args[1] != "/mnt/point" {
		t.Error()
	}
}

// Teste with all possible arguments
func TestMountCmdComplete(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "ZG9tYWluMTIz",
	  "kubernetes.io/secret/username": "dXNlcjEyMw==",
	  "kubernetes.io/secret/password": "cGFzczEyMw==",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,rw,domain=domain123,username=user123,password=pass123,domain=Foo",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdComplete len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdComplete[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}

}

// Simplest test, without any of:
// * fsGroup
// * Opts
// * Credentials
func TestMountCmdSimplest(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/serviceAccount.name": "default",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"//fooserver123/test",
		"/mnt/point",
	}
	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdSimplest len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdSimplest[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdWithoutCredentials(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,rw,domain=Foo",
		"//fooserver123/test",
		"/mnt/point",
	}
	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdWithoutCredentials len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdWithoutCredentials[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdFsGroupLegacy(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/fsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "ZG9tYWluMTIz",
	  "kubernetes.io/secret/username": "dXNlcjEyMw==",
	  "kubernetes.io/secret/password": "cGFzczEyMw==",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,rw,domain=domain123,username=user123,password=pass123,domain=Foo",
		"//fooserver123/test",
		"/mnt/point",
	}
	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdWithoutCredentials len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdWithoutCredentials[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdWithoutFsGroup(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "ZG9tYWluMTIz",
	  "kubernetes.io/secret/username": "dXNlcjEyMw==",
	  "kubernetes.io/secret/password": "cGFzczEyMw==",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"rw,domain=domain123,username=user123,password=pass123,domain=Foo",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdWithoutFsGroup len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdWithoutFsGroup[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdInvalidCredendialDomain(t *testing.T) {

	// recover from panic, which is a good sign here
	defer func() {
		recover()
	}()

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "INVALID_BASE64",
	  "kubernetes.io/secret/username": "dXNlcjEyMw==",
	  "kubernetes.io/secret/password": "cGFzczEyMw==",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	createMountCmd(args)
	t.Error("Invalid base64 did not cause panic")
}

func TestMountCmdInvalidCredendialUser(t *testing.T) {

	// recover from panic, which is a good sign here
	defer func() {
		recover()
	}()

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "ZG9tYWluMTIz",
	  "kubernetes.io/secret/username": "INVALID_BASE64",
	  "kubernetes.io/secret/password": "cGFzczEyMw==",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	createMountCmd(args)
	t.Error("Invalid base64 did not cause panic")
}

func TestMountCmdInvalidCredendialPassword(t *testing.T) {

	// recover from panic, which is a good sign here
	defer func() {
		recover()
	}()

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "ZG9tYWluMTIz",
	  "kubernetes.io/secret/username": "dXNlcjEyMw==",
	  "kubernetes.io/secret/password": "INVALID_BASE64",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	createMountCmd(args)
	t.Error("Invalid base64 did not cause panic")
}

func TestMountCmdWithoutReadWrite(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "ZG9tYWluMTIz",
	  "kubernetes.io/secret/username": "dXNlcjEyMw==",
	  "kubernetes.io/secret/password": "cGFzczEyMw==",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,domain=domain123,username=user123,password=pass123,domain=Foo",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdWithoutReadWrite len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdWithoutReadWrite[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdNoCredentialsAndNoOpts(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/readwrite": "rw",
	  "kubernetes.io/serviceAccount.name": "default",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,rw",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdNoCredentialsAndNoOpts len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdNoCredentialsAndNoOpts[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdNoReadWrite(t *testing.T) {

	jsonArgs := `{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "ZG9tYWluMTIz",
	  "kubernetes.io/secret/username": "dXNlcjEyMw==",
	  "kubernetes.io/secret/password": "cGFzczEyMw==",
	  "opts": "domain=Foo",
	  "server": "fooserver123",
	  "share": "/test"
	}`

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,domain=domain123,username=user123,password=pass123,domain=Foo",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdNoReadWrite len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdNoReadWrite[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdNewline(t *testing.T) {

	jsonArgs := fmt.Sprintf(`{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "%s",
	  "kubernetes.io/secret/username": "%s",
	  "kubernetes.io/secret/password": "%s",
	  "server": "fooserver123",
	  "share": "/test"
	}`,
		base64.StdEncoding.EncodeToString([]byte("domain123\n")),
		base64.StdEncoding.EncodeToString([]byte("user123\n")),
		base64.StdEncoding.EncodeToString([]byte("pass123\n")),
	)

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,domain=domain123,username=user123,password=pass123",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdNoReadWrite len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdNoReadWrite[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestMountCmdReturn(t *testing.T) {

	jsonArgs := fmt.Sprintf(`{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "%s",
	  "kubernetes.io/secret/username": "%s",
	  "kubernetes.io/secret/password": "%s",
	  "server": "fooserver123",
	  "share": "/test"
	}`,
		base64.StdEncoding.EncodeToString([]byte("domain123\n\r")),
		base64.StdEncoding.EncodeToString([]byte("user123\n\r")),
		base64.StdEncoding.EncodeToString([]byte("pass123\n\r")),
	)

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,domain=domain123,username=user123,password=pass123",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestMountCmdNoReadWrite len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestMountCmdNoReadWrite[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestPassEnvOption(t *testing.T) {

	jsonArgs := fmt.Sprintf(`{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "%s",
	  "kubernetes.io/secret/username": "%s",
	  "kubernetes.io/secret/password": "%s",
	  "server": "fooserver123",
	  "share": "/test",
	  "passwdMethod": "env"
	}`,
		base64.StdEncoding.EncodeToString([]byte("domain123\n\r")),
		base64.StdEncoding.EncodeToString([]byte("user123\n\r")),
		base64.StdEncoding.EncodeToString([]byte("pass123\n\r")),
	)

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	mountCmd := createMountCmd(args)
	if mountCmd == nil {
		t.Error("Mount command wasn't created")
	}

	expected := []string{
		"mount",
		"-t",
		"cifs",
		"-o",
		"uid=33,gid=33,domain=domain123,username=user123",
		"//fooserver123/test",
		"/mnt/point",
	}

	if len(mountCmd.Env) < 1 {
		t.Error("TestPassEnvOption env variables expected")
	}
	
	found := false
	for _,s := range mountCmd.Env {
		if s == "PASSWD=pass123" {
			found = true
			break
		}
	}
	if !found {
		t.Error("TestPassEnvOption env variable expected PASSWD=pass123")
	}

	if len(mountCmd.Args) != len(expected) {
		t.Errorf("TestPassEnvOption len: expected %d, actual %d", len(mountCmd.Args), len(expected))
	}

	for idx := range expected {
		if mountCmd.Args[idx] != expected[idx] {
			t.Errorf("TestPassEnvOption[%d]: expected %s, actual %s", idx, expected[idx], mountCmd.Args[idx])
		}
	}
}

func TestIncorrectJsonPayload(t *testing.T) {

	jsonArgs := fmt.Sprintf(`{
	  "kubernetes.io/mounterArgs.FsGroup": "33",
	  "kubernetes.io/fsType": "",
	  "kubernetes.io/pod.name": "nginx-deployment-549ddfb5fc-rnqk8",
	  "kubernetes.io/pod.namespace": "default",
	  "kubernetes.io/pod.uid": "bb6b2e46-c80d-4c86-920c-8e08736fa211",
	  "kubernetes.io/pvOrVolumeName": "test-volume",
	  "kubernetes.io/serviceAccount.name": "default",
	  "kubernetes.io/secret/domain": "%s",
	  "kubernetes.io/secret/username": "%s",
	  "kubernetes.io/secret/password": "%s",
	  "server": "fooserver123",
	  "share": "/test",
		"passwdMethod": 999
	}`,
		base64.StdEncoding.EncodeToString([]byte("domain123\n\r")),
		base64.StdEncoding.EncodeToString([]byte("user123\n\r")),
		base64.StdEncoding.EncodeToString([]byte("pass123\n\r")),
	)

	args := []string{"/path/to/binary", "mount", "/mnt/point", jsonArgs}
	msg := driverMain(args)
	
	expectedStatus := "Failure"
	expectedMessage := "Unexpected executing volume driver: Error interpreting mounter args"

	if msg.Status != expectedStatus {
		t.Errorf("TestIncorrectJsonPayload: expected status [%s] does not match [%s]", expectedStatus, msg.Status)
	}
	if !strings.Contains(msg.Message, expectedMessage) {
		t.Errorf("TestIncorrectJsonPayload: expected status [%s] does not match [%s]", expectedMessage, msg.Message)
	}
}