//

// Copyright (c) 2024 Mikhail Khachayants

//

// Distributed under the Boost Software License, Version 1.0. (See accompanying

// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

//

#include <boost/beast/websocket.hpp>

#include <boost/beast/_experimental/test/stream.hpp>

extern "C" int LLVMFuzzerTestOneInput(const uint8_t* data, size_t size)

{

    using namespace boost::beast;

    error_code ec;

    flat_buffer buffer;

    net::io_context ioc;

    test::stream remote{ioc};

    websocket::stream<test::stream> ws{

        ioc, string_view{reinterpret_cast<const char*>(data), size}};

    ws.set_option(websocket::stream_base::decorator(

        [](websocket::response_type& res)

        {

            res.set(http::field::server, "websocket-server-sync");

        }));

    websocket::permessage_deflate pd;

    pd.server_enable = (size % 2) != 0;

    pd.compLevel = static_cast<int>(size % 9);

    ws.set_option(pd);

    ws.next_layer().connect(remote);

    ws.next_layer().close_remote();

    ws.accept(ec);

    if(!ec)

    {

        ws.read(buffer, ec);

        ws.text(ws.got_text());

        ws.write(buffer.data(), ec);

    }

    return 0;

}