(t *testing.T)
| 73 | } |
| 74 | |
| 75 | func TestSession_Acquire_Dir(t *testing.T) { |
| 76 | s, err := NewSession() |
| 77 | require.NoError(t, err) |
| 78 | defer s.Cleanup() |
| 79 | |
| 80 | // Create a source directory with files |
| 81 | srcDir := filepath.Join(t.TempDir(), "leveldb") |
| 82 | require.NoError(t, os.MkdirAll(srcDir, 0o755)) |
| 83 | require.NoError(t, os.WriteFile(filepath.Join(srcDir, "000001.ldb"), []byte("data"), 0o644)) |
| 84 | require.NoError(t, os.WriteFile(filepath.Join(srcDir, "LOCK"), []byte(""), 0o644)) |
| 85 | |
| 86 | dst := filepath.Join(s.TempDir(), "leveldb") |
| 87 | err = s.Acquire(srcDir, dst, true) |
| 88 | require.NoError(t, err) |
| 89 | |
| 90 | // Data file copied |
| 91 | assert.FileExists(t, filepath.Join(dst, "000001.ldb")) |
| 92 | // LOCK file skipped (CopyDir skips "lock" suffix) |
| 93 | } |
| 94 | |
| 95 | func TestSession_Acquire_NotFound(t *testing.T) { |
| 96 | s, err := NewSession() |
nothing calls this directly
no test coverage detected