}

    @Test
    void testStreamReading() throws IOException {
        // Test stream reading functionality
        Path testFile = tempDir.resolve("test.txt");
        String content = "test content";
        Files.writeString(testFile, content);

        Source source = Sources.fromPath(testFile);
        try (InputStream inputStream = source.openStream()) {
            String readContent = new String(inputStream.readAllBytes());

    }

    // Test FilePurgeVisitor
    public void test_FilePurgeVisitor() throws IOException {
        // Create a test file
        File testFile = new File(tempDir, "_1/_2/test.png");
        testFile.getParentFile().mkdirs();
        testFile.createNewFile();
        testFile.setLastModified(System.currentTimeMillis() - 2000L);

        // Since FilePurgeVisitor is an inner class and we can't directly test it,

    if (testFileUrl == null) {
      throw new RuntimeException("unable to locate testdata directory");
    }

    if (testFileUrl.getProtocol().equals("file")) {
      try {
        File testFile = new File(testFileUrl.toURI());
        testDir = testFile.getParentFile(); // the testdata directory
      } catch (Exception ignore) {
        // probably URISyntaxException or IllegalArgumentException

        tree.connectionState = 2; // Connected state
        tree.tid = 123;

        // Create real request and response objects since they're not interfaces
        ServerMessageBlock request = new SmbComOpenAndX("testfile.txt", 0x01, 0, null);
        ServerMessageBlock response = new SmbComOpenAndXResponse();

        // Execute send
        tree.send(request, response);

        // Verify session.send was called and tid was set

    }

    @Test
    @DisplayName("Test decode with replaceIfExists true")
    void testDecodeWithReplaceIfExistsTrue() throws SMBProtocolDecodingException {
        String originalFileName = "testfile.txt";
        byte[] nameBytes = originalFileName.getBytes(StandardCharsets.UTF_16LE);

        byte[] buffer = new byte[100];
        buffer[0] = 1; // replaceIfExists = true
        // Skip 7 reserved bytes (1-7)

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

public class SmbComQueryInformationTest {

    private static final String TEST_FILE_NAME = "testFile.txt";
    private SmbComQueryInformation smbComQueryInformation;

    @BeforeEach
    public void setUp() {
        smbComQueryInformation = new SmbComQueryInformation(TEST_FILE_NAME);
    }

    @Test

	"time"
)

type testError struct{ error }

type fileOps []any // []T where T is (string | int64)

// testFile is an io.ReadWriteSeeker where the IO operations performed
// on it must match the list of operations in ops.
type testFile struct {
	ops fileOps
	pos int64
}

func (f *testFile) Read(b []byte) (int, error) {
	if len(b) == 0 {
		return 0, nil
	}
	if len(f.ops) == 0 {
		return 0, io.EOF
	}

        byte[] buffer = createValidNotificationBuffer("testfile.txt", FileNotifyInformation.FILE_ACTION_ADDED);

        FileNotifyInformationImpl info = new FileNotifyInformationImpl(buffer, 0, buffer.length);

        assertNotNull(info);
        assertEquals(FileNotifyInformation.FILE_ACTION_ADDED, info.getAction());
        assertEquals("testfile.txt", info.getFileName());
    }

    @Test

package cmd

import (
	"io"
	"testing"
)

func testBitrotReaderWriterAlgo(t *testing.T, bitrotAlgo BitrotAlgorithm) {
	tmpDir := t.TempDir()

	volume := "testvol"
	filePath := "testfile"

	disk, err := newLocalXLStorage(tmpDir)
	if err != nil {
		t.Fatal(err)
	}

	disk.MakeVol(t.Context(), volume)

	writer := newBitrotWriter(disk, "", volume, filePath, 35, bitrotAlgo, 10)

    void testGetName() throws SMBProtocolDecodingException {
        // Prepare test data
        byte[] buffer = createValidBuffer("testfile.txt", "TEST~1.TXT", true);

        // Decode
        fileBothDirectoryInfo.decode(buffer, 0, buffer.length);

        // Verify
        assertEquals("testfile.txt", fileBothDirectoryInfo.getName());
    }

    @Test
    @DisplayName("Test getType returns TYPE_FILESYSTEM")