Skip to content

Commit 27f7df1

Browse files
evoskuilevoskuil
committed
Add initial service endpoint functional test.
1 parent 4a830bb commit 27f7df1

5 files changed

Lines changed: 167 additions & 0 deletions

File tree

‎Makefile.am‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,7 @@ test_libbitcoin_server_test_SOURCES = \
7171
test/settings.cpp \
7272
test/test.cpp \
7373
test/test.hpp \
74+
test/endpoints/electrum.cpp \
7475
test/parsers/bitcoind_query.cpp \
7576
test/parsers/bitcoind_target.cpp \
7677
test/parsers/native_query.cpp \

‎builds/cmake/CMakeLists.txt‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -296,6 +296,7 @@ if (with-tests)
296296
"../../test/test.hpp"
297297
"../../test/endpoints/README.md"
298298
"../../test/endpoints/conftest.py"
299+
"../../test/endpoints/electrum.cpp"
299300
"../../test/endpoints/test_bitcoind_rpc.py"
300301
"../../test/endpoints/test_electrum.py"
301302
"../../test/endpoints/test_native.py"

‎builds/msvc/vs2022/libbitcoin-server-test/libbitcoin-server-test.vcxproj‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@
119119
</ImportGroup>
120120
<ItemGroup>
121121
<ClCompile Include="..\..\..\..\test\configuration.cpp" />
122+
<ClCompile Include="..\..\..\..\test\endpoints\electrum.cpp" />
122123
<ClCompile Include="..\..\..\..\test\error.cpp" />
123124
<ClCompile Include="..\..\..\..\test\estimator.cpp" />
124125
<ClCompile Include="..\..\..\..\test\main.cpp" />

‎builds/msvc/vs2022/libbitcoin-server-test/libbitcoin-server-test.vcxproj.filters‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,9 @@
2121
<ClCompile Include="..\..\..\..\test\configuration.cpp">
2222
<Filter>src</Filter>
2323
</ClCompile>
24+
<ClCompile Include="..\..\..\..\test\endpoints\electrum.cpp">
25+
<Filter>src\endpoints</Filter>
26+
</ClCompile>
2427
<ClCompile Include="..\..\..\..\test\error.cpp">
2528
<Filter>src</Filter>
2629
</ClCompile>

‎test/endpoints/electrum.cpp‎

Lines changed: 161 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,161 @@
1+
/**
2+
* Copyright (c) 2011-2026 libbitcoin developers (see AUTHORS)
3+
*
4+
* This file is part of libbitcoin.
5+
*
6+
* This program is free software: you can redistribute it and/or modify
7+
* it under the terms of the GNU Affero General Public License as published by
8+
* the Free Software Foundation, either version 3 of the License, or
9+
* (at your option) any later version.
10+
*
11+
* This program is distributed in the hope that it will be useful,
12+
* but WITHOUT ANY WARRANTY; without even the implied warranty of
13+
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14+
* GNU Affero General Public License for more details.
15+
*
16+
* You should have received a copy of the GNU Affero General Public License
17+
* along with this program. If not, see <http://www.gnu.org/licenses/>.
18+
*/
19+
#include "../test.hpp"
20+
21+
#include <future>
22+
23+
BOOST_FIXTURE_TEST_SUITE(electrum_tests, test::directory_setup_fixture)
24+
25+
// nop event handler.
26+
const auto events = [](auto, auto) {};
27+
28+
using namespace system;
29+
30+
constexpr auto block0_hash = base16_hash("000000000019d6689c085ae165831e934ff763ae46a2a6c172b3f1b60a8ce26f");
31+
constexpr auto block1_hash = base16_hash("00000000839a8e6886ab5951d76f411475428afc90947ee320161bbf18eb6048");
32+
constexpr auto block2_hash = base16_hash("000000006a625f06636b8bb6ac7b960a8d03705d1ace08b1a19da3fdcc99ddbd");
33+
constexpr auto block3_hash = base16_hash("0000000082b5015589a3fdf2d4baff403e6f0be035a5d9742c1cae6295464449");
34+
constexpr auto block4_hash = base16_hash("000000004ebadb55ee9096c9a2f8880e09da59c0d68b1c228da88e48844a1485");
35+
constexpr auto block5_hash = base16_hash("000000009b7262315dbf071787ad3656097b892abffd1f95a1a022f896f533fc");
36+
constexpr auto block6_hash = base16_hash("000000003031a0e73735690c5a1ff2a4be82553b2a12b776fbd3a215dc8f778d");
37+
constexpr auto block7_hash = base16_hash("0000000071966c2b1d065fd446b1e485b2c9d9594acd2007ccbd5441cfc89444");
38+
constexpr auto block8_hash = base16_hash("00000000408c48f847aa786c2268fc3e6ec2af68e8468a34a28c61b7f1de0dc6");
39+
40+
// blockchain.info/rawblock/[block-hash]?format=hex
41+
constexpr auto block1_data = base16_array("010000006fe28c0ab6f1b372c1a6a246ae63f74f931e8365e15a089c68d6190000000000982051fd1e4ba744bbbe680e1fee14677ba1a3c3540bf7b1cdb606e857233e0e61bc6649ffff001d01e362990101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d0104ffffffff0100f2052a0100000043410496b538e853519c726a2c91e61ec11600ae1390813a627c66fb8be7947be63c52da7589379515d4e0a604f8141781e62294721166bf621e73a82cbf2342c858eeac00000000");
42+
constexpr auto block2_data = base16_array("010000004860eb18bf1b1620e37e9490fc8a427514416fd75159ab86688e9a8300000000d5fdcc541e25de1c7a5addedf24858b8bb665c9f36ef744ee42c316022c90f9bb0bc6649ffff001d08d2bd610101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d010bffffffff0100f2052a010000004341047211a824f55b505228e4c3d5194c1fcfaa15a456abdf37f9b9d97a4040afc073dee6c89064984f03385237d92167c13e236446b417ab79a0fcae412ae3316b77ac00000000");
43+
constexpr auto block3_data = base16_array("01000000bddd99ccfda39da1b108ce1a5d70038d0a967bacb68b6b63065f626a0000000044f672226090d85db9a9f2fbfe5f0f9609b387af7be5b7fbb7a1767c831c9e995dbe6649ffff001d05e0ed6d0101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d010effffffff0100f2052a0100000043410494b9d3e76c5b1629ecf97fff95d7a4bbdac87cc26099ada28066c6ff1eb9191223cd897194a08d0c2726c5747f1db49e8cf90e75dc3e3550ae9b30086f3cd5aaac00000000");
44+
constexpr auto block4_data = base16_array("010000004944469562ae1c2c74d9a535e00b6f3e40ffbad4f2fda3895501b582000000007a06ea98cd40ba2e3288262b28638cec5337c1456aaf5eedc8e9e5a20f062bdf8cc16649ffff001d2bfee0a90101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d011affffffff0100f2052a01000000434104184f32b212815c6e522e66686324030ff7e5bf08efb21f8b00614fb7690e19131dd31304c54f37baa40db231c918106bb9fd43373e37ae31a0befc6ecaefb867ac00000000");
45+
constexpr auto block5_data = base16_array("0100000085144a84488ea88d221c8bd6c059da090e88f8a2c99690ee55dbba4e00000000e11c48fecdd9e72510ca84f023370c9a38bf91ac5cae88019bee94d24528526344c36649ffff001d1d03e4770101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d0120ffffffff0100f2052a0100000043410456579536d150fbce94ee62b47db2ca43af0a730a0467ba55c79e2a7ec9ce4ad297e35cdbb8e42a4643a60eef7c9abee2f5822f86b1da242d9c2301c431facfd8ac00000000");
46+
constexpr auto block6_data = base16_array("01000000fc33f596f822a0a1951ffdbf2a897b095636ad871707bf5d3162729b00000000379dfb96a5ea8c81700ea4ac6b97ae9a9312b2d4301a29580e924ee6761a2520adc46649ffff001d189c4c970101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d0123ffffffff0100f2052a0100000043410408ce279174b34c077c7b2043e3f3d45a588b85ef4ca466740f848ead7fb498f0a795c982552fdfa41616a7c0333a269d62108588e260fd5a48ac8e4dbf49e2bcac00000000");
47+
constexpr auto block7_data = base16_array("010000008d778fdc15a2d3fb76b7122a3b5582bea4f21f5a0c693537e7a03130000000003f674005103b42f984169c7d008370967e91920a6a5d64fd51282f75bc73a68af1c66649ffff001d39a59c860101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d012bffffffff0100f2052a01000000434104a59e64c774923d003fae7491b2a7f75d6b7aa3f35606a8ff1cf06cd3317d16a41aa16928b1df1f631f31f28c7da35d4edad3603adb2338c4d4dd268f31530555ac00000000");
48+
constexpr auto block8_data = base16_array("010000004494c8cf4154bdcc0720cd4a59d9c9b285e4b146d45f061d2b6c967100000000e3855ed886605b6d4a99d5fa2ef2e9b0b164e63df3c4136bebf2d0dac0f1f7a667c86649ffff001d1c4b56660101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0704ffff001d012cffffffff0100f2052a01000000434104cc8d85f5e7933cb18f13b97d165e1189c1fb3e9c98b0dd5446b2a1989883ff9e740a8a75da99cc59a21016caf7a7afd3e4e9e7952983e18d1ff70529d62e0ba1ac00000000");
49+
50+
const auto genesis = system::settings{ chain::selection::mainnet }.genesis_block;
51+
const chain::block block1{ block1_data, true };
52+
const chain::block block2{ block2_data, true };
53+
const chain::block block3{ block3_data, true };
54+
const chain::block block4{ block4_data, true };
55+
const chain::block block5{ block5_data, true };
56+
const chain::block block6{ block6_data, true };
57+
const chain::block block7{ block7_data, true };
58+
const chain::block block8{ block8_data, true };
59+
60+
using context_t = database::context;
61+
using store_t = database::store<database::map>;
62+
using query_t = database::query<database::store<database::map>>;
63+
static const server::settings::embedded_pages admin{};
64+
static const server::settings::embedded_pages native{};
65+
66+
bool setup_eight_block_store(query_t& query) NOEXCEPT
67+
{
68+
return query.initialize(genesis) &&
69+
query.set(block1, context_t{ 0, 1, 0 }, false, false) &&
70+
query.set(block2, context_t{ 0, 2, 0 }, false, false) &&
71+
query.set(block3, context_t{ 0, 3, 0 }, false, false) &&
72+
query.set(block4, context_t{ 0, 4, 0 }, false, false) &&
73+
query.set(block5, context_t{ 0, 5, 0 }, false, false) &&
74+
query.set(block6, context_t{ 0, 6, 0 }, false, false) &&
75+
query.set(block7, context_t{ 0, 7, 0 }, false, false) &&
76+
query.set(block8, context_t{ 0, 8, 0 }, false, false) &&
77+
query.push_confirmed(query.to_header(block1_hash), false) &&
78+
query.push_confirmed(query.to_header(block2_hash), false) &&
79+
query.push_confirmed(query.to_header(block3_hash), false) &&
80+
query.push_confirmed(query.to_header(block4_hash), false) &&
81+
query.push_confirmed(query.to_header(block5_hash), false) &&
82+
query.push_confirmed(query.to_header(block6_hash), false) &&
83+
query.push_confirmed(query.to_header(block7_hash), false) &&
84+
query.push_confirmed(query.to_header(block8_hash), false);
85+
}
86+
87+
// TODO: move server setup to fixiture for all electrum tests.
88+
// TODO: make test utilities for server setup, start, request, response, close.
89+
BOOST_AUTO_TEST_CASE(endpoint_electrum_test)
90+
{
91+
const network::config::authority authority{ "127.0.0.1:65000" };
92+
const std::string request{ R"({"id":1,"method":"server.version","params":["test_client","1.4"]})" "\n" };
93+
94+
// Create base configuration.
95+
configuration configure(chain::selection::mainnet, native, admin);
96+
auto& database_settings = configure.database;
97+
auto& network_settings = configure.network;
98+
auto& server_settings = configure.server;
99+
auto& node_settings = configure.node;
100+
auto& electrum = server_settings.electrum;
101+
102+
// Create and populate the store.
103+
database_settings.path = TEST_DIRECTORY;
104+
database_settings.interval_depth = 2;
105+
store_t store{ database_settings };
106+
query_t query{ store };
107+
BOOST_REQUIRE(!store.create(events));
108+
BOOST_REQUIRE(setup_eight_block_store(query));
109+
110+
// Create the server with a reference to the store, config and log.
111+
network::logger log{};
112+
node_settings.delay_inbound = false;
113+
network_settings.inbound.connections = 0;
114+
network_settings.outbound.connections = 0;
115+
electrum.connections = 1;
116+
electrum.maximum_headers = 100;
117+
electrum.binds.push_back(authority);
118+
server::server_node server{ query, configure, log };
119+
120+
// Run the server, start is not required here (seeding, manual, and chasers).
121+
std::promise<code> running{};
122+
server.run([&](const code& ec) NOEXCEPT
123+
{
124+
running.set_value(ec);
125+
});
126+
127+
// Blocks until server is running.
128+
BOOST_REQUIRE(!running.get_future().get());
129+
130+
// Connect, send request, and capture response.
131+
boost::asio::io_context io{};
132+
boost::asio::ip::tcp::socket sock{ io };
133+
sock.connect(electrum.binds.back().to_endpoint());
134+
sock.send(boost::asio::buffer(request));
135+
boost::asio::streambuf stream{};
136+
read_until(sock, stream, '\n');
137+
sock.close();
138+
139+
// Parser and verify server response.
140+
std::string response{};
141+
std::istream response_stream{ &stream };
142+
std::getline(response_stream, response);
143+
144+
const auto parsed = boost::json::parse(response);
145+
BOOST_REQUIRE_EQUAL(parsed.at("id").as_int64(), 1);
146+
BOOST_REQUIRE(parsed.at("result").is_array());
147+
148+
const auto& result = parsed.at("result").as_array();
149+
BOOST_REQUIRE_EQUAL(result.size(), 2u);
150+
BOOST_REQUIRE(result.at(0).is_string());
151+
BOOST_REQUIRE(result.at(1).is_string());
152+
BOOST_TEST_MESSAGE("Version response: " + response);
153+
154+
// Server close blocks until all threads joined.
155+
server.close();
156+
157+
// Store close is required as well.
158+
BOOST_REQUIRE(!store.close(events));
159+
}
160+
161+
BOOST_AUTO_TEST_SUITE_END()

0 commit comments

Comments
 (0)