mirror of
https://github.com/bitcoin/bitcoin.git
synced 2026-04-06 13:47:56 +02:00
a7e4a59d6d
Adds a lint check for `remove_all()` `fs::remove_all()`/`std::filesystem::remove_all()` is extremely dangerous, all user-facing instances of it have been removed, and it also deserves to be removed from the places in our test code where it is being used unnecessarily.
68 lines
2.0 KiB
C++
68 lines
2.0 KiB
C++
// 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()};
|
|
|
|
NodeClockContext clock_ctx{ConsumeTime(fuzzed_data_provider)};
|
|
|
|
// Mock CreateSock() to create FuzzedSock.
|
|
auto CreateSockOrig = CreateSock;
|
|
CreateSock = [&fuzzed_data_provider](int, int, int) {
|
|
return std::make_unique<FuzzedSock>(fuzzed_data_provider);
|
|
};
|
|
|
|
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)) {
|
|
if (session.Accept(conn)) {
|
|
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)) {
|
|
try {
|
|
conn.sock->SendComplete("verack\n", 10ms, *interrupt);
|
|
} catch (const std::runtime_error&) {
|
|
}
|
|
}
|
|
|
|
fs::remove(private_key_path);
|
|
|
|
CreateSock = CreateSockOrig;
|
|
}
|