*/
    @Test
    void testParseAuthDataPacWithInvalidToken() {
        // GIVEN an invalid token for AUTH_DATA_PAC
        byte[] invalidToken = "invalid-pac-token".getBytes();

        // WHEN parsing the auth data
        // THEN a PACDecodingException should be thrown
        assertThrows(PACDecodingException.class, () -> {

            try {
                domain = DEFAULT_DOMAIN.getBytes(UNI_ENCODING);
            } catch (final IOException ex) {}
        }
        final int domainLength = domain.length;
        byte[] server = {};
        try {
            final String host = NbtAddress.getLocalHost().getHostName();
            if (host != null) {
                try {
                    server = host.getBytes(UNI_ENCODING);

    /**
     * Constructs a pipe wait request without timeout.
     *
     * @param name the pipe name to wait for
     */
    public FsctlPipeWaitRequest(final String name) {
        this.nameBytes = name.getBytes(StandardCharsets.UTF_16LE);
        this.timeoutSpecified = false;
        this.timeout = 0;
    }

    /**
     * Constructs a pipe wait request with timeout.
     *
     * @param name the pipe name to wait for

        return Stream.of(Arguments.of(new byte[0], ""), Arguments.of(new byte[] { (byte) 0x41 }, "QQ=="), // "A"
                Arguments.of(new byte[] { (byte) 0x41, (byte) 0x42 }, "QUI="), // "AB"
                Arguments.of("Man".getBytes(), "TWFu"), // 3 bytes, no padding
                Arguments.of(new byte[] { (byte) 0x00, (byte) 0x00, (byte) 0x00 }, "AAAA"), // all zeros

                    } catch (IOException e) {
                        throw new IORuntimeException(e);
                    }
                } else if (url.contains("plugin/repo2")) {
                    try (InputStream is = ResourceUtil.getResourceAsStream(url)) {
                        return new String(InputStreamUtil.getBytes(is), Constants.UTF_8);

        System.arraycopy("short".getBytes(), 0, buffer, 0, 5);
        buffer[5] = 0; // Null terminator
        String result = smb.readString(buffer, 0, 5, false);
        assertEquals("short", result);
    }

    @Test
    void testReadStringWithMaxLengthExceeded() {
        smb.useUnicode = false;
        byte[] buffer = "a very long string that exceeds max length".getBytes();

  private boolean outputStreamOpened;
  private boolean outputStreamClosed;

  public TestByteSink(TestOption... options) {
    this.options = ImmutableSet.copyOf(options);
  }

  byte[] getBytes() {
    return bytes.toByteArray();
  }

  @Override
  public boolean wasStreamOpened() {
    return outputStreamOpened;
  }

  @Override
  public boolean wasStreamClosed() {

            ByteBuffer bb = ByteBuffer.wrap(dst).order(ByteOrder.LITTLE_ENDIAN);
            assertEquals(maxReferralLevel, bb.getShort());

            // Verify path encoding (UTF-16LE)
            byte[] pathBytes = path.getBytes(StandardCharsets.UTF_16LE);
            byte[] encodedPath = new byte[pathBytes.length];
            bb.get(encodedPath);
            assertArrayEquals(pathBytes, encodedPath);

            // Verify null terminator

  private final TestByteSource byteSource;

  public TestCharSource(String content, TestOption... options) {
    this.byteSource = new TestByteSource(content.getBytes(UTF_8), options);
  }

  @Override
  public boolean wasStreamOpened() {
    return byteSource.wasStreamOpened();
  }

  @Override
  public boolean wasStreamClosed() {

            assertEquals(200, responseData.getHttpStatusCode());
            assertEquals(baseUrl + "file1.txt", responseData.getUrl());
            assertEquals("file1", new String(InputStreamUtil.getBytes(responseData.getResponseBody())));
            assertEquals(5, responseData.getContentLength());
        }
        try (final ResponseData responseData = smbClient.doGet(baseUrl + "dir1/file2.txt")) {