// Copyright (c) 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 <common/args.h>

#include <compat/compat.h>

#include <i2p.h>

#include <netaddress.h>

#include <netbase.h>

#include <test/fuzz/FuzzedDataProvider.h>

#include <test/fuzz/fuzz.h>

#include <test/fuzz/util.h>

#include <test/fuzz/util/net.h>

#include <test/fuzz/util/threadinterrupt.h>

#include <test/util/setup_common.h>

#include <test/util/time.h>

#include <util/fs_helpers.h>

#include <util/threadinterrupt.h>

void initialize_i2p()

{

    static const auto testing_setup = MakeNoLogFileContext<>();

}

FUZZ_TARGET(i2p, .init = initialize_i2p)

{

    SeedRandomStateForTest(SeedRand::ZEROS);

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

    FakeNodeClock clock{ConsumeTime(fuzzed_data_provider)};

    FakeSteadyClock steady_clock;

    // Mock CreateSock() to create FuzzedSock.

    auto CreateSockOrig = CreateSock;

    CreateSock = [&fuzzed_data_provider, &steady_clock](int, int, int) {

        return std::make_unique<FuzzedSock>(fuzzed_data_provider, steady_clock);

    };

    const fs::path private_key_path = gArgs.GetDataDirNet() / "fuzzed_i2p_private_key";

    const CService addr{in6_addr(COMPAT_IN6ADDR_LOOPBACK_INIT), 7656};

    const Proxy sam_proxy{addr, /*tor_stream_isolation=*/false};

    auto interrupt{ConsumeThreadInterrupt(fuzzed_data_provider)};

    i2p::sam::Session session{private_key_path, sam_proxy, interrupt};

    i2p::Connection conn;

    if (session.Listen(conn)) {

  Branch (47:9): [True: 152, False: 515]

        if (session.Accept(conn)) {

  Branch (48:13): [True: 40, False: 112]

            try {

                (void)conn.sock->RecvUntilTerminator('\n', 10ms, *interrupt, i2p::sam::MAX_MSG_SIZE);

            } catch (const std::runtime_error&) {

            }

        }

    }

    bool proxy_error;

    if (session.Connect(CService{}, conn, proxy_error)) {

  Branch (58:9): [True: 33, False: 634]

        try {

            conn.sock->SendComplete("verack\n", 10ms, *interrupt);

        } catch (const std::runtime_error&) {

        }

    }

    fs::remove(private_key_path);

    CreateSock = CreateSockOrig;

}