Implement some electrum interface methods, refactor.

Makefile.am

@@ -87,6 +87,7 @@ console_bs_SOURCES = \
     console/executor.cpp \
     console/executor.hpp \
     console/executor_commands.cpp \
+    console/executor_daemon.cpp \
     console/executor_dumps.cpp \
     console/executor_events.cpp \
     console/executor_logging.cpp \

builds/cmake/CMakeLists.txt

@@ -325,6 +325,7 @@ if (with-console)
         "../../console/executor.cpp"
         "../../console/executor.hpp"
         "../../console/executor_commands.cpp"
+        "../../console/executor_daemon.cpp"
         "../../console/executor_dumps.cpp"
         "../../console/executor_events.cpp"
         "../../console/executor_logging.cpp"

builds/msvc/vs2022/bs/bs.vcxproj

@@ -132,6 +132,7 @@
       <ObjectFileName>$(IntDir)console_executor.obj</ObjectFileName>
     </ClCompile>
     <ClCompile Include="..\..\..\..\console\executor_commands.cpp" />
+    <ClCompile Include="..\..\..\..\console\executor_daemon.cpp" />
     <ClCompile Include="..\..\..\..\console\executor_dumps.cpp" />
     <ClCompile Include="..\..\..\..\console\executor_events.cpp" />
     <ClCompile Include="..\..\..\..\console\executor_logging.cpp" />

builds/msvc/vs2022/bs/bs.vcxproj.filters

@@ -54,6 +54,9 @@
     <ClCompile Include="..\..\..\..\console\executor_commands.cpp">
       <Filter>src</Filter>
     </ClCompile>
+    <ClCompile Include="..\..\..\..\console\executor_daemon.cpp">
+      <Filter>src</Filter>
+    </ClCompile>
     <ClCompile Include="..\..\..\..\console\executor_dumps.cpp">
       <Filter>src</Filter>
     </ClCompile>

console/executor_daemon.cpp

@@ -0,0 +1,25 @@
+/**
+ * Copyright (c) 2011-2025 libbitcoin developers (see AUTHORS)
+ *
+ * This file is part of libbitcoin.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+#include "executor.hpp"
+
+namespace libbitcoin {
+namespace server {
+
+} // namespace server
+} // namespace libbitcoin

console/executor_signals.cpp

@@ -62,7 +62,7 @@ void executor::set_signal_handlers()
 #if defined(HAVE_MSC)
     ::SetConsoleCtrlHandler(&executor::control_handler, TRUE);
 #else
-    // struct keywork avoids name conflict with posix function sigaction.
+    // struct keyword avoids name conflict with posix function sigaction.
     struct sigaction action{};
 
     // Restart interrupted system calls.

console/main.cpp

@@ -78,10 +78,8 @@ BC_USE_LIBBITCOIN_MAIN
 /// All console input and output streams for the application originate here.
 int bc::system::main(int argc, char* argv[])
 {
-    using namespace bc;
     using namespace bc::system;
     using namespace bc::network;
-    using namespace bc::node;
     using namespace bc::server;
 
     // en.cppreference.com/w/cpp/io/ios_base/sync_with_stdio

include/bitcoin/server/interfaces/bitcoind_rpc.hpp

@@ -126,7 +126,7 @@ struct bitcoind_rpc_methods
         ////method<"listreceivedbyaddress", optional<1>, optional<false>, optional<false>, optional<""_t>>{ "minconf", "include_empty", "include_watchonly", "address_filter" },
         ////method<"listreceivedbylabel", optional<1>, optional<false>, optional<false>>{ "minconf", "include_empty", "include_watchonly" },
         ////method<"listtransactions", optional<""_t>, optional<10>, optional<0>, optional<false>>{ "label", "count", "skip", "include_watchonly" },
-        ////method<"listunspent", optional<1>, optional<empty::array>, optional<true>, optional<false>>{ "minconf", "addresses", "include_unsafe", "query_options" },
+        ////method<"list_unspent", optional<1>, optional<empty::array>, optional<true>, optional<false>>{ "minconf", "addresses", "include_unsafe", "query_options" },
         ////method<"loadwallet", string_t, optional<false>>{ "filename", "load_on_startup" },
         ////method<"lockunspent", boolean_t, optional<empty::array>>{ "unlock", "transactions" },
         ////method<"removeprunedfunds", string_t>{ "txid" },

include/bitcoin/server/interfaces/electrum.hpp

@@ -35,12 +35,12 @@ struct electrum_methods
         method<"blockchain.block.header", number_t, number_t>{ "height", "cp_height" },
         method<"blockchain.block.headers", number_t, number_t, number_t>{ "start_height", "count", "cp_height" },
         method<"blockchain.headers.subscribe">{},
-        method<"blockchain.estimatefee", number_t>{ "number" },
+        method<"blockchain.estimatefee", number_t, optional<""_t>>{ "number", "mode" },
         method<"blockchain.relayfee">{},
         method<"blockchain.scripthash.get_balance", string_t>{ "scripthash" },
         method<"blockchain.scripthash.get_history", string_t>{ "scripthash" },
         method<"blockchain.scripthash.get_mempool", string_t>{ "scripthash" },
-        method<"blockchain.scripthash.listunspent", string_t>{ "scripthash" },
+        method<"blockchain.scripthash.list_unspent", string_t>{ "scripthash" },
         method<"blockchain.scripthash.subscribe", string_t>{ "scripthash" },
         method<"blockchain.scripthash.unsubscribe", string_t>{ "scripthash" },
         method<"blockchain.transaction.broadcast", string_t>{ "raw_tx" },
@@ -71,12 +71,12 @@ struct electrum_methods
     using blockchain_block_header = at<0>;
     using blockchain_block_headers = at<1>;
     using blockchain_headers_subscribe = at<2>;
-    using blockchain_estimatefee = at<3>;
-    using blockchain_relayfee = at<4>;
+    using blockchain_estimate_fee = at<3>;
+    using blockchain_relay_fee = at<4>;
     using blockchain_scripthash_get_balance = at<5>;
     using blockchain_scripthash_get_history = at<6>;
     using blockchain_scripthash_get_mempool = at<7>;
-    using blockchain_scripthash_listunspent = at<8>;
+    using blockchain_scripthash_list_unspent = at<8>;
     using blockchain_scripthash_subscribe = at<9>;
     using blockchain_scripthash_unsubscribe = at<10>;
     using blockchain_transaction_broadcast = at<11>;

include/bitcoin/server/protocols/protocol_electrum.hpp

@@ -59,10 +59,11 @@ class BCS_API protocol_electrum
         double count, double cp_height) NOEXCEPT;
     void handle_blockchain_headers_subscribe(const code& ec,
         rpc_interface::blockchain_headers_subscribe) NOEXCEPT;
-    void handle_blockchain_estimatefee(const code& ec,
-        rpc_interface::blockchain_estimatefee, double) NOEXCEPT;
-    void handle_blockchain_relayfee(const code& ec,
-        rpc_interface::blockchain_relayfee) NOEXCEPT;
+    void handle_blockchain_estimate_fee(const code& ec,
+        rpc_interface::blockchain_estimate_fee, double number,
+        const std::string& mode) NOEXCEPT;
+    void handle_blockchain_relay_fee(const code& ec,
+        rpc_interface::blockchain_relay_fee) NOEXCEPT;
     void handle_blockchain_scripthash_get_balance(const code& ec,
         rpc_interface::blockchain_scripthash_get_balance,
         const std::string& scripthash) NOEXCEPT;
@@ -72,8 +73,8 @@ class BCS_API protocol_electrum
     void handle_blockchain_scripthash_get_mempool(const code& ec,
         rpc_interface::blockchain_scripthash_get_mempool,
         const std::string& scripthash) NOEXCEPT;
-    void handle_blockchain_scripthash_listunspent(const code& ec,
-        rpc_interface::blockchain_scripthash_listunspent,
+    void handle_blockchain_scripthash_list_unspent(const code& ec,
+        rpc_interface::blockchain_scripthash_list_unspent,
         const std::string& scripthash) NOEXCEPT;
     void handle_blockchain_scripthash_subscribe(const code& ec,
         rpc_interface::blockchain_scripthash_subscribe,

include/bitcoin/server/protocols/protocol_electrum_version.hpp

@@ -48,7 +48,7 @@ class BCS_API protocol_electrum_version
     }
 
     virtual void shake(network::result_handler&& handler) NOEXCEPT;
-    virtual void complete(const code& ec, const code& shake) NOEXCEPT;
+    virtual void finished(const code& ec, const code& shake) NOEXCEPT;
 
 protected:
     static constexpr electrum_version minimum = electrum_version::v1_4;

src/parsers/native_query.cpp

@@ -128,6 +128,8 @@ media_type get_media(const rpc::request_t& model) NOEXCEPT
                 case media_type::application_json:
                 case media_type::application_octet_stream:
                     return value;
+                default:
+                    return media_type::unknown;
             }
         }
     }

src/protocols/protocol_electrum.cpp

@@ -29,6 +29,7 @@ namespace server {
 
 #define CLASS protocol_electrum
 
+using namespace system;
 using namespace interface;
 using namespace std::placeholders;
 
@@ -50,12 +51,12 @@ void protocol_electrum::start() NOEXCEPT
     SUBSCRIBE_RPC(handle_blockchain_block_header, _1, _2, _3, _4);
     SUBSCRIBE_RPC(handle_blockchain_block_headers, _1, _2, _3, _4, _5);
     SUBSCRIBE_RPC(handle_blockchain_headers_subscribe, _1, _2);
-    SUBSCRIBE_RPC(handle_blockchain_estimatefee, _1, _2, _3);
-    SUBSCRIBE_RPC(handle_blockchain_relayfee, _1, _2);
+    SUBSCRIBE_RPC(handle_blockchain_estimate_fee, _1, _2, _3, _4);
+    SUBSCRIBE_RPC(handle_blockchain_relay_fee, _1, _2);
     SUBSCRIBE_RPC(handle_blockchain_scripthash_get_balance, _1, _2, _3);
     SUBSCRIBE_RPC(handle_blockchain_scripthash_get_history, _1, _2, _3);
     SUBSCRIBE_RPC(handle_blockchain_scripthash_get_mempool, _1, _2, _3);
-    SUBSCRIBE_RPC(handle_blockchain_scripthash_listunspent, _1, _2, _3);
+    SUBSCRIBE_RPC(handle_blockchain_scripthash_list_unspent, _1, _2, _3);
     SUBSCRIBE_RPC(handle_blockchain_scripthash_subscribe, _1, _2, _3);
     SUBSCRIBE_RPC(handle_blockchain_scripthash_unsubscribe, _1, _2, _3);
     SUBSCRIBE_RPC(handle_blockchain_transaction_broadcast, _1, _2, _3);
@@ -99,22 +100,60 @@ void protocol_electrum::handle_blockchain_block_headers(const code& ec,
 void protocol_electrum::handle_blockchain_headers_subscribe(const code& ec,
     rpc_interface::blockchain_headers_subscribe) NOEXCEPT
 {
-    if (stopped(ec)) return;
-    send_code(error::not_implemented);
+    if (stopped(ec))
+        return;
+
+    const auto& query = archive();
+    const auto link = query.to_header(query.get_top_confirmed_hash());
+    const auto height = query.get_height(link);
+    const auto header = query.get_header(link);
+    if (height.is_terminal() || !header)
+    {
+        send_code(error::not_found);
+        return;
+    }
+
+    // See protocol_native::to_hex().
+    std::string hex(two * chain::header::serialized_size(), '\0');
+    stream::out::fast sink{ hex };
+    write::base16::fast writer{ sink };
+    header->to_data(writer);
+    BC_ASSERT(writer);
+
+    // TODO: idempotent subscribe to chase::organized via session/chaser/node.
+    // TODO: upon notification send just the header notified by the link.
+    // TODO: it is client responsibility to deal with reorgs and race gaps.
+    send_result(value_t
+        {
+            object_t
+            {
+                { "height", height.value },
+                { "hex", hex }
+            }
+        }, 256, BIND(complete, _1));
 }
 
-void protocol_electrum::handle_blockchain_estimatefee(const code& ec,
-    rpc_interface::blockchain_estimatefee, double ) NOEXCEPT
+void protocol_electrum::handle_blockchain_estimate_fee(const code& ec,
+    rpc_interface::blockchain_estimate_fee, double number,
+    const std::string& ) NOEXCEPT
 {
-    if (stopped(ec)) return;
-    send_code(error::not_implemented);
+    if (stopped(ec))
+        return;
+
+    // TODO: estimate fees from blocks based on expected block inclusion.
+    // TODO: this can be computed from recent blocks and cached by the server.
+    // TODO: update the cache before broadcasting header notifications.
+    send_result(number, 70, BIND(complete, _1));
 }
 
-void protocol_electrum::handle_blockchain_relayfee(const code& ec,
-    rpc_interface::blockchain_relayfee) NOEXCEPT
+void protocol_electrum::handle_blockchain_relay_fee(const code& ec,
+    rpc_interface::blockchain_relay_fee) NOEXCEPT
 {
-    if (stopped(ec)) return;
-    send_code(error::not_implemented);
+    if (stopped(ec))
+        return;
+
+    // TODO: implement from [node] config, removed in protocol 1.6.
+    send_result(0.00000001, 70, BIND(complete, _1));
 }
 
 void protocol_electrum::handle_blockchain_scripthash_get_balance(const code& ec,
@@ -141,8 +180,8 @@ void protocol_electrum::handle_blockchain_scripthash_get_mempool(const code& ec,
     send_code(error::not_implemented);
 }
 
-void protocol_electrum::handle_blockchain_scripthash_listunspent(const code& ec,
-    rpc_interface::blockchain_scripthash_listunspent,
+void protocol_electrum::handle_blockchain_scripthash_list_unspent(const code& ec,
+    rpc_interface::blockchain_scripthash_list_unspent,
     const std::string& ) NOEXCEPT
 {
     if (stopped(ec)) return;
@@ -210,8 +249,10 @@ void protocol_electrum::handle_server_add_peer(const code& ec,
 void protocol_electrum::handle_server_banner(const code& ec,
     rpc_interface::server_banner) NOEXCEPT
 {
-    if (stopped(ec)) return;
-    send_code(error::not_implemented);
+    if (stopped(ec))
+        return;
+
+    send_result(network_settings().user_agent, 70, BIND(complete, _1));
 }
 
 void protocol_electrum::handle_server_donation_address(const code& ec,
@@ -248,8 +289,19 @@ void protocol_electrum::handle_server_ping(const code& ec,
 void protocol_electrum::handle_mempool_get_fee_histogram(const code& ec,
     rpc_interface::mempool_get_fee_histogram) NOEXCEPT
 {
-    if (stopped(ec)) return;
-    send_code(error::not_implemented);
+    if (stopped(ec))
+        return;
+
+    // TODO: requires tx pool metadata graph.
+    send_result(value_t
+        {
+            array_t
+            {
+                array_t{ 1, 1024 },
+                array_t{ 2, 2048 },
+                array_t{ 4, 4096 }
+            }
+        }, 256, BIND(complete, _1));
 }
 
 BC_POP_WARNING()

src/protocols/protocol_electrum_version.cpp

@@ -38,7 +38,7 @@ BC_PUSH_WARNING(NO_THROW_IN_NOEXCEPT)
 BC_PUSH_WARNING(SMART_PTR_NOT_NEEDED)
 BC_PUSH_WARNING(NO_VALUE_OR_CONST_REF_SHARED_PTR)
 
-// Start/complete (handshake).
+// Start/finished (handshake).
 // ----------------------------------------------------------------------------
 
 // Session resumes the channel following return from start().
@@ -59,7 +59,7 @@ void protocol_electrum_version::shake(result_handler&& handler) NOEXCEPT
     protocol_rpc<channel_electrum>::start();
 }
 
-void protocol_electrum_version::complete(const code& ec,
+void protocol_electrum_version::finished(const code& ec,
     const code& shake) NOEXCEPT
 {
     BC_ASSERT(stranded());
@@ -92,7 +92,7 @@ void protocol_electrum_version::handle_server_version(const code& ec,
         (!set_client(client_name) || !set_version(protocol_version)))
     {
         const auto reason = error::invalid_argument;
-        send_code(reason, BIND(complete, _1, reason));
+        send_code(reason, BIND(finished, _1, reason));
     }
     else
     {
@@ -103,7 +103,7 @@ void protocol_electrum_version::handle_server_version(const code& ec,
                     { string_t{ server_name() } },
                     { string_t{ negotiated_version() } }
                 }
-            }, 70, BIND(complete, _1, error::success));
+            }, 70, BIND(finished, _1, error::success));
     }
 
     // Handshake must leave channel paused, before leaving stranded handler.
@@ -225,6 +225,7 @@ std::string_view protocol_electrum_version::version_to_string(
 {
     static const std::unordered_map<electrum_version, std::string_view> map
     {
+        { electrum_version::v0_0,   "0.0" },
         { electrum_version::v0_6,   "0.6" },
         { electrum_version::v0_8,   "0.8" },
         { electrum_version::v0_9,   "0.9" },
@@ -236,8 +237,7 @@ std::string_view protocol_electrum_version::version_to_string(
         { electrum_version::v1_4,   "1.4" },
         { electrum_version::v1_4_1, "1.4.1" },
         { electrum_version::v1_4_2, "1.4.2" },
-        { electrum_version::v1_6,   "1.6" },
-        { electrum_version::v0_0,   "0.0" }
+        { electrum_version::v1_6,   "1.6" }
     };
 
     const auto it = map.find(version);
@@ -250,6 +250,7 @@ electrum_version protocol_electrum_version::version_from_string(
 {
     static const std::unordered_map<std::string_view, electrum_version> map
     {
+        { "0.0",   electrum_version::v0_0 },
         { "0.6",   electrum_version::v0_6 },
         { "0.8",   electrum_version::v0_8 },
         { "0.9",   electrum_version::v0_9 },
@@ -261,8 +262,7 @@ electrum_version protocol_electrum_version::version_from_string(
         { "1.4",   electrum_version::v1_4 },
         { "1.4.1", electrum_version::v1_4_1 },
         { "1.4.2", electrum_version::v1_4_2 },
-        { "1.6",   electrum_version::v1_6 },
-        { "0.0",   electrum_version::v0_0 }
+        { "1.6",   electrum_version::v1_6 }
     };
 
     const auto it = map.find(version);

src/protocols/protocol_native.cpp

@@ -139,7 +139,7 @@ bool protocol_native::try_dispatch_object(const http::request& request) NOEXCEPT
 // Serialization.
 // ----------------------------------------------------------------------------
 
-constexpr auto html = to_value(http::media_type::text_html);
+////constexpr auto html = to_value(http::media_type::text_html);
 constexpr auto text = to_value(http::media_type::text_plain);
 constexpr auto json = to_value(http::media_type::application_json);
 constexpr auto data = to_value(http::media_type::application_octet_stream);