@Setup
    public void initResults() throws IOException {
        final BytesStreamOutput tmp = new BytesStreamOutput();
        final long bytes = new ByteSizeValue(dataMb, ByteSizeUnit.MB).getBytes();
        for (int i = 0; i < bytes / 8; i++) {
            tmp.writeLong(i);
        }
        bytesArray = tmp.copyBytes();
        if (bytesArray instanceof BytesArray == false) {

    @Setup
    public void initResults() throws IOException {
        final BytesStreamOutput tmp = new BytesStreamOutput();
        final long bytes = new ByteSizeValue(dataMb, ByteSizeUnit.MB).getBytes();
        for (int i = 0; i < bytes / 8; i++) {
            tmp.writeLong(i);
        }
        pagedBytes = tmp.bytes();
        if (pagedBytes instanceof PagedBytesReference == false) {

    /**
     * Context name for durable handle request
     */
    public static final String CONTEXT_NAME = "DHnQ";

    private static final byte[] CONTEXT_NAME_BYTES = CONTEXT_NAME.getBytes();
    private static final int STRUCTURE_SIZE = 16;

    private long reserved; // Must be zero

    /**
     * Create a new durable handle request
     */
    public DurableHandleRequest() {

        file1 = File.createTempFile("synonym", ".txt");
        FileUtil.writeBytes(file1.getAbsolutePath(),
                "a1=>A1\nb1,b2 => B1\nc1 => C1, C2\nx1,X1\ny1, Y1, y2"
                        .getBytes(Constants.UTF_8));
        // TODO set up opensearch and dictionaryManager
        synonymFile = new SynonymFile("1", file1.getAbsolutePath(), new Date());
    }

    @Override

     * @param text
     *            the text to encrypt
     * @return the encrypted text
     */
    public String encryptText(final String text) {
        try {
            return Base64Util.encode(encrypt(text.getBytes(charsetName)));
        } catch (final UnsupportedEncodingException e) {
            throw new UnsupportedEncodingRuntimeException(e);
        }
    }

    /**
     * Encrypts the given text.
     *

    }

    @Test
    public void testBodyInputStreamMethod() {
        CurlRequest request = new CurlRequest(Method.POST, "https://example.com");
        InputStream stream = new ByteArrayInputStream("test data".getBytes());

        CurlRequest result = request.body(stream);

        assertSame(request, result); // Fluent API
        assertNull(request.body()); // body() returns String body, not stream
    }

    @Test

        assertNotNull(id);
        assertEquals(Base64.getEncoder().encodeToString(text.getBytes(CoreLibConstants.CHARSET_UTF_8)), id);

        // Test empty text
        String emptyText = "";
        String emptyId = SuggestUtil.createSuggestTextId(emptyText);
        assertNotNull(emptyId);
        assertEquals(Base64.getEncoder().encodeToString(emptyText.getBytes(CoreLibConstants.CHARSET_UTF_8)), emptyId);

        // Test special characters

        response.getServerData().scapabilities = 0;
        response.getServerData().encryptionKeyLength = 8;
        // Domain name in OEM encoding (ASCII) with null terminator
        byte[] domainBytes = "DOMAIN\0".getBytes("US-ASCII");
        // Use reflection to set protected byteCount field
        int byteCountValue = 8 + domainBytes.length;
        setByteCount(response, byteCountValue);
        byte[] buffer = new byte[byteCountValue];

     * <p>
     * The input stream is not closed.
     * </p>
     *
     * @param is the input stream (must not be {@literal null})
     * @return the byte array
     */
    public static final byte[] getBytes(final InputStream is) {
        assertArgumentNotNull("is", is);

        final ByteArrayOutputStream os = new ByteArrayOutputStream(BUF_SIZE);
        CopyUtil.copy(is, os);
        return os.toByteArray();
    }

    /**
     * Context name for durable handle V2 response
     */
    public static final String CONTEXT_NAME = "DH2Q";

    private static final byte[] CONTEXT_NAME_BYTES = CONTEXT_NAME.getBytes();

    private long timeout100Ns; // timeout in 100-nanosecond intervals (wire format, unsigned 32-bit)
    private int flags;

    /**
     * Create a new durable handle V2 response
     */