Branch data Line data Source code
1 : : // Copyright (c) The Bitcoin Core developers
2 : : // Distributed under the MIT software license, see the accompanying
3 : : // file COPYING or http://www.opensource.org/licenses/mit-license.php.
4 : :
5 : : #include <common/args.h>
6 : : #include <i2p.h>
7 : : #include <netaddress.h>
8 : : #include <netbase.h>
9 : : #include <test/fuzz/FuzzedDataProvider.h>
10 : : #include <test/fuzz/fuzz.h>
11 : : #include <test/fuzz/util.h>
12 : : #include <test/fuzz/util/net.h>
13 : : #include <test/util/setup_common.h>
14 : : #include <util/fs_helpers.h>
15 : : #include <util/threadinterrupt.h>
16 : :
17 : 1 : void initialize_i2p()
18 : : {
19 [ + - + - ]: 2 : static const auto testing_setup = MakeNoLogFileContext<>();
20 [ + - ]: 2 : }
21 : :
22 [ + - ]: 836 : FUZZ_TARGET(i2p, .init = initialize_i2p)
23 : : {
24 : 424 : FuzzedDataProvider fuzzed_data_provider{buffer.data(), buffer.size()};
25 : :
26 : 424 : SetMockTime(ConsumeTime(fuzzed_data_provider));
27 : :
28 : : // Mock CreateSock() to create FuzzedSock.
29 : 424 : auto CreateSockOrig = CreateSock;
30 : 1465 : CreateSock = [&fuzzed_data_provider](int, int, int) {
31 : 1041 : return std::make_unique<FuzzedSock>(fuzzed_data_provider);
32 : 424 : };
33 : :
34 [ + - + - ]: 848 : const fs::path private_key_path = gArgs.GetDataDirNet() / "fuzzed_i2p_private_key";
35 [ + - ]: 424 : const CService addr{in6_addr(IN6ADDR_LOOPBACK_INIT), 7656};
36 : 424 : const Proxy sam_proxy{addr, false};
37 [ + - ]: 424 : CThreadInterrupt interrupt;
38 : :
39 [ + - ]: 424 : i2p::sam::Session session{private_key_path, sam_proxy, &interrupt};
40 [ + - ]: 424 : i2p::Connection conn;
41 : :
42 [ + - + + ]: 424 : if (session.Listen(conn)) {
43 [ + - + + ]: 72 : if (session.Accept(conn)) {
44 : 21 : try {
45 [ + + ]: 38 : (void)conn.sock->RecvUntilTerminator('\n', 10ms, interrupt, i2p::sam::MAX_MSG_SIZE);
46 [ - + ]: 4 : } catch (const std::runtime_error&) {
47 : 4 : }
48 : : }
49 : : }
50 : :
51 : 424 : bool proxy_error;
52 : :
53 [ + - + - : 424 : if (session.Connect(CService{}, conn, proxy_error)) {
+ + ]
54 : 10 : try {
55 [ + + ]: 10 : conn.sock->SendComplete("verack\n", 10ms, interrupt);
56 [ - + ]: 4 : } catch (const std::runtime_error&) {
57 : 4 : }
58 : : }
59 : :
60 [ + - ]: 424 : fs::remove_all(private_key_path);
61 : :
62 [ + - ]: 424 : CreateSock = CreateSockOrig;
63 : 1272 : }
|