SmbConstants.DEFAULT_SHARING);

        byte[] data = "Hello World".getBytes();

        // When
        outputStream.write(data, 6, 5); // Write "World"

        // Then
        verify(mockTreeHandle, atLeastOnce()).send(any(Smb2WriteRequest.class), any());
    }

    @Test

            // Read remaining bytes
            byte[] remaining = new byte[20];
            int remainingBytes = stream.read(remaining);
            assertEquals(8, remainingBytes); // ", World!"
            assertEquals(", World!", new String(remaining, 0, remainingBytes, "UTF-8"));
        }
    }

    }

    @Test
    public void testGetContentAsStringWithCache() throws IOException {
        CurlResponse response = new CurlResponse();
        response.setEncoding("UTF-8");
        String testContent = "Hello, World!";
        byte[] data = testContent.getBytes("UTF-8");
        ContentCache cache = new ContentCache(data);
        response.setContentCache(cache);

        String content = response.getContentAsString();

        RequestData data = RequestDataBuilder.newRequestData().url(null).build();

        assertNull(data.getUrl());
    }

    public void test_realWorldUsageExample1() {
        // Real-world example: crawling a web page
        RequestData data = RequestDataBuilder.newRequestData().get().url("https://example.com/article/12345").weight(1.0f).build();

        assertNotNull(data);

            String originalString = "Hello World Test";
            byte[] allBytes = originalString.getBytes(StandardCharsets.UTF_16LE);
            int partialLength = "Hello World".getBytes(StandardCharsets.UTF_16LE).length;

            // When
            String result = Strings.fromUNIBytes(allBytes, 0, partialLength);

            // Then
            assertEquals("Hello World", result, "Should decode partial byte array correctly");

     *
     * @param searchEngineClient the search engine client to use for deletion
     * @param docList the list of new documents to check against
     * @return the number of old documents that were deleted
     */
    protected long deleteOldDocuments(final SearchEngineClient searchEngineClient, final DocList docList) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();

            assertEquals(8192, response.getChunkBytesWritten());
            assertEquals(40960, response.getTotalBytesWritten());
        }

        @Test
        @DisplayName("Should work with real-world values")
        void testRealWorldValues() throws SMBProtocolDecodingException {
            // Typical server response after copying chunks
            byte[] buffer = createValidCopyChunkResponse(16, // 16 chunks written

            TimeZone.setDefault(original);
        }
    }

    @Test
    void testStringReadWriteASCII() throws UnsupportedEncodingException {
        smb.useUnicode = false;
        String testString = "Hello World";
        byte[] buffer = new byte[testString.length() + 1];
        int len = smb.writeString(testString, buffer, 0);
        assertEquals(testString.length() + 1, len);
        String readString = smb.readString(buffer, 0);

        // Perform the renewal
        boolean renewed = wrapper.renewCredentials("locationHint", null);

        // Verify that renew() was called and credentials were updated
        assertTrue(renewed, "renewCredentials should return true when renewable credentials are renewed");

    int NT_STATUS_PATH_NOT_COVERED = 0xC0000257;
    /** The IO operation on the reparse point failed */
    int NT_STATUS_IO_REPARSE_TAG_NOT_HANDLED = 0xC0000279;
    /** No more files were found matching the file specification */
    int NT_STATUS_NO_MORE_FILES = 0x80000006;

    /** Array of all NT status codes defined in this interface */