package volumepathhandler

import (
	"fmt"
	"path/filepath"
	"testing"

	utilexec "k8s.io/utils/exec"
)

func createTestDevice(t *testing.T) string {
	executor := utilexec.New()
	backingFile := filepath.Join(t.TempDir(), "backingFile")

	out, err := executor.Command("fallocate", "-l", "1M", backingFile).CombinedOutput()
	if err != nil {
		t.Fatalf("failed to create backing file: %v, %v", err, string(out))
	}
	devicePath, err := makeLoopDevice(backingFile)
	if err != nil {
		t.Fatalf("failed to create loop device: %v", err)
	}
	t.Cleanup(func() {
		err := removeLoopDevice(devicePath)
		if err != nil {
			t.Errorf("failed to remove loop device: %v", err)
		}
	})
	return devicePath
}

func TestIsDeviceBindMountExist(t *testing.T) {
	devicePath := createTestDevice(t)

	handler := VolumePathHandler{}

	mapPath := t.TempDir()
	linkName := "link"
	err := mapBindMountDevice(handler, devicePath, mapPath, linkName)
	if err != nil {
		t.Fatalf("failed to map bind mount: %v", err)
	}
	t.Cleanup(func() {
		err := unmapBindMountDevice(handler, mapPath, linkName)
		if err != nil {
			t.Fatalf("failed to unmap bind mount: %v", err)
		}
	})

	linkPath := filepath.Join(mapPath, linkName)
	yes, err := handler.IsDeviceBindMountExist(linkPath)
	if err != nil {
		t.Fatalf("failed to check bind mount: %v", err)
	}
	if !yes {
		t.Fatalf("expected device bind mount")
	}
}