)
    return CertificateAdapters.subjectPublicKeyInfo.toDer(subjectPublicKeyInfo)
  }

  /** Returns a byte string that differs from this one by one bit. */
  private fun ByteString.offByOneBit(): ByteString =
    Buffer()
      .write(this, 0, size - 1)
      .writeByte(this[size - 1].toInt() xor 1)
      .readByteString()

  private fun date(s: String): Date =

			t.Errorf("entry %d, want %q, got %q", i, want, gotObj.name)
		}
	}
}

func Test_newMetacacheStream(t *testing.T) {
	r := loadMetacacheSample(t)
	var buf bytes.Buffer
	w := newMetacacheWriter(&buf, 1<<20)
	defer w.Close()
	err := r.readFn(func(object metaCacheEntry) bool {
		err := w.write(object)
		if err != nil {
			t.Fatal(err)
		}
		return true
	})
	r.Close()
	if err != io.EOF {

expanded_policy_count=$(./mc admin policy list myminio/ | wc -l)

if [ $user_count -ne $expanded_user_count ]; then
	echo "BUG: original user count differs from expanded setup"
	exit 1
fi

if [ $policy_count -ne $expanded_policy_count ]; then
	echo "BUG: original policy count  differs from expanded setup"
	exit 1
fi

./mc version info myminio/versioned | grep -q "versioning is enabled"
ret=$?
if [ $ret -ne 0 ]; then

    val buffer = Buffer()
    operator.read(6, buffer, 21)
    operator.read(36, buffer, 1)
    operator.read(5, buffer, 5)
    operator.read(28, buffer, 8)
    operator.read(17, buffer, 10)
    operator.read(36, buffer, 2)
    operator.read(2, buffer, 4)
    operator.write(0, buffer, buffer.size)
    operator.read(0, buffer, 12)
    operator.read(47, buffer, 3)
    operator.read(45, buffer, 2)
    operator.read(47, buffer, 3)

        for (int i = 0; i < buffer.length; i++) {
            buffer[i] = (byte) (i % 256);
        }

        // Set structure size to 2
        SMBUtil.writeInt2(2, buffer, bufferIndex);

        // Make a copy of the buffer
        byte[] bufferCopy = buffer.clone();

        // Call readBytesWireFormat
        response.readBytesWireFormat(buffer, bufferIndex);

        // Status
        SMBUtil.writeInt4(0, buffer, headerStart + 8);
        // Command (READ = 0x0008)
        SMBUtil.writeInt2(0x0008, buffer, headerStart + 12);
        // Credit request/response
        SMBUtil.writeInt2(1, buffer, headerStart + 14);
        // Flags
        SMBUtil.writeInt4(0, buffer, headerStart + 16);
        // Next command

        @Test
        @DisplayName("Should handle malformed buffer gracefully")
        void testMalformedBuffer() {
            // Given - buffer with random data
            byte[] buffer = new byte[10];
            for (int i = 0; i < buffer.length; i++) {
                buffer[i] = (byte) (Math.random() * 256);
            }

            // When & Then
            // Should either read successfully if random data happens to be 4,

        // Arrange
        byte[] buffer = new byte[100];

        // Act & Assert
        assertEquals(0, response.readSetupWireFormat(buffer, 0, 100));
        assertEquals(0, response.readParametersWireFormat(buffer, 0, 100));
        assertEquals(0, response.readDataWireFormat(buffer, 0, 100));
    }

    @Test
    @DisplayName("Methods should handle null buffer without validation")

    void testInt2ReadWrite() {
        byte[] buffer = new byte[2];
        ServerMessageBlock.writeInt2(0x1234, buffer, 0);
        assertEquals(0x1234, ServerMessageBlock.readInt2(buffer, 0));
    }

    @Test
    void testInt4ReadWrite() {
        byte[] buffer = new byte[4];
        ServerMessageBlock.writeInt4(0x12345678, buffer, 0);
        assertEquals(0x12345678, ServerMessageBlock.readInt4(buffer, 0));
    }

    @Test

        byte[] buffer = new byte[offset + request.size()];
        int encodedLength = request.encode(buffer, offset);

        // Verify encoded length
        assertEquals(request.size(), encodedLength);

        // Verify data at correct offset
        assertEquals(DEFAULT_CAPABILITIES, SMBUtil.readInt4(buffer, offset));
        assertEquals(DEFAULT_SECURITY_MODE, SMBUtil.readInt2(buffer, offset + 20));