Add put counts and block to put translations.

Author: evoskuil

include/bitcoin/database/impl/query/extent.ipp

@@ -19,6 +19,7 @@
 #ifndef LIBBITCOIN_DATABASE_QUERY_EXTENT_IPP
 #define LIBBITCOIN_DATABASE_QUERY_EXTENT_IPP
 
+#include <numeric>
 #include <bitcoin/system.hpp>
 #include <bitcoin/database/define.hpp>
 
@@ -207,6 +208,26 @@ two_counts CLASS::put_counts(const tx_link& link) const NOEXCEPT
     return { tx.ins_count, tx.outs_count };
 }
 
+TEMPLATE
+size_t CLASS::input_count(const tx_links& txs) const NOEXCEPT
+{
+    const auto fn = [this](auto tx) NOEXCEPT { return input_count(tx); };
+    return std_reduce(bc::par_unseq, txs.begin(), txs.end(), zero, fn);
+}
+
+TEMPLATE
+size_t CLASS::output_count(const tx_links& txs) const NOEXCEPT
+{
+    const auto fn = [this](auto tx) NOEXCEPT { return output_count(tx); };
+    return std_reduce(bc::par_unseq, txs.begin(), txs.end(), zero, fn);
+}
+
+TEMPLATE
+two_counts CLASS::put_counts(const tx_links& txs) const NOEXCEPT
+{
+    return { input_count(txs), output_count(txs) };
+}
+
 TEMPLATE
 bool CLASS::address_enabled() const NOEXCEPT
 {

include/bitcoin/database/impl/query/translate.ipp

@@ -21,6 +21,7 @@
 
 #include <algorithm>
 #include <iterator>
+#include <numeric>
 #include <unordered_map>
 #include <utility>
 #include <bitcoin/system.hpp>
@@ -517,15 +518,13 @@ spend_set CLASS::to_spend_set(const tx_link& link) const NOEXCEPT
     return set;
 }
 
-// block to puts (forward navigation)
+// txs to puts (forward navigation)
 // ----------------------------------------------------------------------------
 
 TEMPLATE
-spend_links CLASS::to_block_spends(const header_link& link) const NOEXCEPT
+spend_links CLASS::to_spends(const tx_links& txs) const NOEXCEPT
 {
     spend_links spends{};
-    const auto txs = to_spending_transactions(link);
-
     for (const auto& tx: txs)
     {
         const auto tx_spends = to_spends(tx);
@@ -536,11 +535,9 @@ spend_links CLASS::to_block_spends(const header_link& link) const NOEXCEPT
 }
 
 TEMPLATE
-output_links CLASS::to_block_outputs(const header_link& link) const NOEXCEPT
+output_links CLASS::to_outputs(const tx_links& txs) const NOEXCEPT
 {
     output_links outputs{};
-    const auto txs = to_transactions(link);
-
     for (const auto& tx: txs)
     {
         const auto tx_outputs = to_outputs(tx);
@@ -551,18 +548,36 @@ output_links CLASS::to_block_outputs(const header_link& link) const NOEXCEPT
 }
 
 TEMPLATE
-output_links CLASS::to_block_prevouts(const header_link& link) const NOEXCEPT
+output_links CLASS::to_prevouts(const tx_links& txs) const NOEXCEPT
 {
-    output_links prevouts{};
-    const auto txs = to_spending_transactions(link);
+    const auto ins = to_spends(txs);
+    output_links outs(ins.size());
+    const auto fn = [this](auto spend) NOEXCEPT{ return to_prevout(spend); };
 
-    for (const auto& tx: txs)
-    {
-        const auto tx_prevouts = to_prevouts(tx);
-        prevouts.insert(prevouts.end(), tx_prevouts.begin(), tx_prevouts.end());
-    }
+    // C++17 incomplete on GCC/CLang, so presently parallel only on MSVC++.
+    std_transform(bc::par_unseq, ins.begin(), ins.end(), outs.begin(), fn);
+    return outs;
+}
 
-    return prevouts;
+// block to puts (forward navigation)
+// ----------------------------------------------------------------------------
+
+TEMPLATE
+spend_links CLASS::to_block_spends(const header_link& link) const NOEXCEPT
+{
+    return to_spends(to_spending_transactions(link));
+}
+
+TEMPLATE
+output_links CLASS::to_block_outputs(const header_link& link) const NOEXCEPT
+{
+    return to_outputs(to_transactions(link));
+}
+
+TEMPLATE
+output_links CLASS::to_block_prevouts(const header_link& link) const NOEXCEPT
+{
+    return to_prevouts(to_spending_transactions(link));
 }
 
 // block to txs (forward navigation)

include/bitcoin/database/query.hpp

@@ -217,6 +217,9 @@ class query
     size_t input_count(const tx_link& link) const NOEXCEPT;
     size_t output_count(const tx_link& link) const NOEXCEPT;
     two_counts put_counts(const tx_link& link) const NOEXCEPT;
+    size_t input_count(const tx_links& txs) const NOEXCEPT;
+    size_t output_count(const tx_links& txs) const NOEXCEPT;
+    two_counts put_counts(const tx_links& txs) const NOEXCEPT;
 
     /// Optional table state.
     bool address_enabled() const NOEXCEPT;
@@ -286,6 +289,11 @@ class query
     output_links to_outputs(const tx_link& link) const NOEXCEPT;
     output_links to_prevouts(const tx_link& link) const NOEXCEPT;
 
+    /// txs to puts (forward navigation)
+    spend_links to_spends(const tx_links& txs) const NOEXCEPT;
+    output_links to_outputs(const tx_links& txs) const NOEXCEPT;
+    output_links to_prevouts(const tx_links& txs) const NOEXCEPT;
+
     /// block to puts (forward navigation)
     spend_links to_block_spends(const header_link& link) const NOEXCEPT;
     output_links to_block_outputs(const header_link& link) const NOEXCEPT;