// Copyright (c) 2020-2022 The Bitcoin Core developers

// Distributed under the MIT software license, see the accompanying

// file COPYING or http://www.opensource.org/licenses/mit-license.php.

#include <checkqueue.h>

#include <test/fuzz/FuzzedDataProvider.h>

#include <test/fuzz/fuzz.h>

#include <test/fuzz/util.h>

#include <cstdint>

#include <string>

#include <vector>

namespace {

struct DumbCheck {

    bool result = false;

    explicit DumbCheck(const bool _result) : result(_result)

    {

    }

    std::optional<int> operator()() const

    {

        if (result) return std::nullopt;

        return 1;

    }

};

} // namespace

FUZZ_TARGET(checkqueue)

{

    FuzzedDataProvider fuzzed_data_provider(buffer.data(), buffer.size());

    const unsigned int batch_size = fuzzed_data_provider.ConsumeIntegralInRange<unsigned int>(0, 1024);

    CCheckQueue<DumbCheck> check_queue_1{batch_size, /*worker_threads_num=*/0};

    CCheckQueue<DumbCheck> check_queue_2{batch_size, /*worker_threads_num=*/0};

    std::vector<DumbCheck> checks_1;

    std::vector<DumbCheck> checks_2;

    const int size = fuzzed_data_provider.ConsumeIntegralInRange<int>(0, 1024);

    for (int i = 0; i < size; ++i) {

        const bool result = fuzzed_data_provider.ConsumeBool();

        checks_1.emplace_back(result);

        checks_2.emplace_back(result);

    }

    if (fuzzed_data_provider.ConsumeBool()) {

        check_queue_1.Add(std::move(checks_1));

    }

    if (fuzzed_data_provider.ConsumeBool()) {

        (void)check_queue_1.Complete();

    }

    CCheckQueueControl<DumbCheck> check_queue_control{&check_queue_2};

    if (fuzzed_data_provider.ConsumeBool()) {

        check_queue_control.Add(std::move(checks_2));

    }

    if (fuzzed_data_provider.ConsumeBool()) {

        (void)check_queue_control.Complete();

    }

}