@Test
    @DisplayName("Test decode operation")
    void testDecode() {
        byte[] buffer = new byte[1024];
        // Fill with basic SMB header structure
        System.arraycopy(new byte[] { (byte) 0xFF, 'S', 'M', 'B' }, 0, buffer, 0, 4);
        buffer[4] = 1; // wordCount
        buffer[7] = 0; // byteCount low
        buffer[8] = 0; // byteCount high

        assertDoesNotThrow(() -> response.decode(buffer, 0));

    @Test
    @DisplayName("Test setCommand with various SMB command codes")
    void testSetCommandWithVariousCodes() {
        // Test common SMB command codes
        int[] commandCodes = { 0x00, 0x72, 0x73, 0x74, 0x75, 0xFF };

        for (int command : commandCodes) {
            doNothing().when(messageBlock).setCommand(command);
            when(messageBlock.getCommand()).thenReturn(command);

        char[] plaintext = "SecureData".toCharArray();
        byte[] encrypted = storage.encryptCredentials(plaintext);

        // Tamper with the encrypted data
        encrypted[encrypted.length - 1] ^= 0xFF;

        // Should throw exception due to authentication tag failure
        assertThrows(GeneralSecurityException.class, () -> {
            storage.decryptCredentials(encrypted);

    /** Maximum buffer size for IO operations */
    protected int maximumBufferSize = 0x10000;
    /** Maximum buffer size for SMB transaction operations */
    protected int transactionBufferSize = 0xFFFF - 512;
    /** Number of buffers to keep in cache */
    protected int bufferCacheSize = 16;
    /** Maximum size for list operations */
    protected int smbListSize = 65435;

        byte[] buffer = new byte[256];
        // Fill with non-zero values first
        for (int i = 0; i < buffer.length; i++) {
            buffer[i] = (byte) 0xFF;
        }

        // When
        request.writeBytesWireFormat(buffer, 10);

        // Then - verify reserved field is zero
        assertEquals(0, SMBUtil.readInt2(buffer, 12));
    }

        // Given
        byte[] buffer = new byte[256];
        // Fill buffer with test pattern
        for (int i = 0; i < buffer.length; i++) {
            buffer[i] = (byte) (i & 0xFF);
        }
        byte[] originalBuffer = buffer.clone();

        // When
        int bytesWritten = response.writeBytesWireFormat(buffer, 10);

        // Then
        assertEquals(0, bytesWritten);

        when(resp.getErrorCode()).thenReturn(0x10B);
        when(resp.getNotifyInformation()).thenReturn(new ArrayList<>());
        setupSmb1(resp, 42);
        SmbWatchHandleImpl sut = new SmbWatchHandleImpl(handle, 0xFF, false);

        List<FileNotifyInformation> result = sut.watch();

        assertNotNull(result);
        verify(handle, times(1)).markClosed();

	{" ", []rune{32}, false},
	{"ABC", []rune{65, 66, 67}, false},
	{"abc", []rune{97, 98, 99}, false},
	{"\u65e5\u672c\u8a9e", []rune{26085, 26412, 35486}, false},
	{"ab\x80c", []rune{97, 98, 0xFFFD, 99}, true},
	{"ab\xc0c", []rune{97, 98, 0xFFFD, 99}, true},
}

func TestRunes(t *testing.T) {
	for _, tt := range RunesTests {
		tin := []byte(tt.in)
		a := Runes(tin)
		if !slices.Equal(a, tt.out) {

        @DisplayName("Should handle large buffer decoding")
        void testLargeBufferDecode() throws SMBProtocolDecodingException {
            byte[] largeBuffer = new byte[65536];
            Arrays.fill(largeBuffer, (byte) 0xFF);

            TestCreateContextResponse response = new TestCreateContextResponse("LARGE_BUFFER_TEST".getBytes(StandardCharsets.UTF_8));

            int result = response.decode(largeBuffer, 1000, 5000);

    public void validateSmbHeader(int protocolId, int structureSize, int command) throws SmbException {
        totalValidations.incrementAndGet();

        // Check SMB1 signature
        if (protocolId == 0x424D53FF) { // 0xFF 'S' 'M' 'B'
            // SMB1
            if (structureSize < 32 || structureSize > 65535) {
                failedValidations.incrementAndGet();