void testWriteBytesDoesNotOverflow() {
            byte[] buffer = new byte[100];
            // Fill buffer with known values
            for (int i = 0; i < buffer.length; i++) {
                buffer[i] = (byte) 0xFF;
            }

            int startIndex = 50;
            echoRequest.writeBytesWireFormat(buffer, startIndex);

            // Check bytes before written area are unchanged

        byte[] buffer = new byte[8];
        // numEntries = 2
        writeInt2(2, buffer, 0);
        // isEndOfSearch = false
        buffer[2] = 0x00;
        buffer[3] = 0x00;
        // eaErrorOffset = 3
        writeInt2(3, buffer, 4);
        // lastNameOffset = 4
        writeInt2(4, buffer, 6);

        int bytesRead = response.readParametersWireFormat(buffer, 0, buffer.length);

    }

    @Override
    protected int readBytesWireFormat(final byte[] buffer, int bufferIndex) throws SMBProtocolDecodingException {
        final int start = bufferIndex;

        // Validate minimum buffer size for SMB2 negotiate response
        if (buffer == null || buffer.length < bufferIndex + 65) {
            throw new SMBProtocolDecodingException("Buffer too small for SMB2 negotiate response (minimum 65 bytes required)");
        }

            this.cacheScope = DirectoryCacheScope.values()[scopeOrdinal];
            dataOffset += 4;
            
            this.maxCacheAge = readInt8(buffer, dataOffset);
            dataOffset += 8;
            
            int flags = readInt4(buffer, dataOffset);
            dataOffset += 4;
            
            this.notificationFilter = readInt4(buffer, dataOffset);
        }

        setFieldValue(response, "wordCount", 10);

        byte[] buffer = new byte[256];
        SMBUtil.writeInt2(fileAttribute, buffer, 0);
        SMBUtil.writeUTime(0, buffer, 2);
        SMBUtil.writeInt4(0, buffer, 6);

        response.readParameterWordsWireFormat(buffer, 0);

        assertEquals(fileAttribute, response.getAttributes());
    }

    @ParameterizedTest

        case SMB_QUERY_FS_SIZE_INFO -> readSmbQueryFSSizeInfoWireFormat(buffer, bufferIndex);
        case SMB_FS_FULL_SIZE_INFORMATION -> readFsFullSizeInformationWireFormat(buffer, bufferIndex);
        default -> 0;
        };
    }

    int readSmbInfoAllocationWireFormat(final byte[] buffer, int bufferIndex) {
        final int start = bufferIndex;

            buffer.append(ALPHABET.charAt(block >>> 6 & 0x3f));
            buffer.append(ALPHABET.charAt(block & 0x3f));
        }
        if (remainder == 0) {
            return buffer.toString();
        }
        if (remainder == 1) {
            block = (bytes[i] & 0xff) << 4;
            buffer.append(ALPHABET.charAt(block >>> 6));
            buffer.append(ALPHABET.charAt(block & 0x3f));
            buffer.append("==");

        byte[] buffer = new byte[20];
        // Mock data for SmbInfoAllocation
        // idFileSystem (4 bytes, skipped)
        writeInt4(100, buffer, 4); // sectPerAlloc
        writeInt4(1000, buffer, 8); // alloc
        writeInt4(500, buffer, 12); // free
        writeInt2(512, buffer, 16); // bytesPerSect

        int bytesRead = response.readDataWireFormat(buffer, 0, buffer.length);

            byte[] innerDigest = "inner_digest".getBytes();
            byte[] expectedOutput = "output_data".getBytes();
            byte[] buffer = new byte[expectedOutput.length + 10]; // Buffer with extra space

            when(mockMd5.digest()).thenReturn(innerDigest);
            when(mockMd5.digest(buffer, 0, expectedOutput.length)).thenAnswer(invocation -> {
                byte[] b = invocation.getArgument(0);

  private val minimumDeflateSize: Long,
) : Closeable {
  /** This holds outbound data for compression and masking. */
  private val messageBuffer = Buffer()

  /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
  private val sinkBuffer: Buffer = sink.buffer
  private var writerClosed = false

  /** Lazily initialized on first use. */
  private var messageDeflater: MessageDeflater? = null