feat: add mptoken_issuance_history RPC

src/app/ClioApplication.cpp

@@ -124,14 +124,12 @@ ClioApplication::run(bool const useNgWebServer)
 
     auto const amendmentCenter = std::make_shared<data::AmendmentCenter const>(backend);
 
-    {
-        auto const migrationInspector = migration::makeMigrationInspector(config_, backend);
-        // Check if any migration is blocking Clio server starting.
-        if (migrationInspector->isBlockingClio() and backend->hardFetchLedgerRangeNoThrow()) {
-            LOG(util::LogService::error()) << "Existing Migration is blocking Clio, Please "
-                                              "complete the database migration first.";
-            return EXIT_FAILURE;
-        }
+    auto const migrationInspector = migration::makeMigrationInspector(config_, backend);
+    // Check if any migration is blocking Clio server starting.
+    if (migrationInspector->isBlockingClio() and backend->hardFetchLedgerRangeNoThrow()) {
+        LOG(util::LogService::error()) << "Existing Migration is blocking Clio, Please "
+                                          "complete the database migration first.";
+        return EXIT_FAILURE;
     }
 
     // Manages clients subscribed to streams
@@ -166,7 +164,14 @@ ClioApplication::run(bool const useNgWebServer)
     auto counters = rpc::Counters::makeCounters(workQueue);
 
     auto const handlerProvider = std::make_shared<rpc::impl::ProductionHandlerProvider const>(
-        config_, backend, subscriptions, balancer, etl, amendmentCenter, counters
+        config_,
+        backend,
+        subscriptions,
+        balancer,
+        etl,
+        amendmentCenter,
+        migrationInspector,
+        counters
     );
 
     using RPCEngineType = rpc::RPCEngine<rpc::Counters>;

src/rpc/CMakeLists.txt

@@ -44,6 +44,7 @@ target_sources(
         handlers/LedgerIndex.cpp
         handlers/LedgerRange.cpp
         handlers/MPTHolders.cpp
+        handlers/MPTokenIssuanceHistory.cpp
         handlers/NFTsByIssuer.cpp
         handlers/NFTBuyOffers.cpp
         handlers/NFTHistory.cpp
@@ -58,4 +59,4 @@ target_sources(
         handlers/VaultInfo.cpp
 )
 
-target_link_libraries(clio_rpc PUBLIC clio_util clio_data)
+target_link_libraries(clio_rpc PUBLIC clio_util clio_data clio_migration)

src/rpc/RPCCenter.cpp

@@ -35,6 +35,7 @@ handledRpcs()
         "ledger_index",
         "ledger_range",
         "mpt_holders",
+        "mptoken_issuance_history",
         "nfts_by_issuer",
         "nft_history",
         "nft_buy_offers",

src/rpc/common/impl/HandlerProvider.cpp

@@ -5,6 +5,7 @@
 #include "etl/ETLServiceInterface.hpp"
 #include "etl/LoadBalancerInterface.hpp"
 #include "feed/SubscriptionManagerInterface.hpp"
+#include "migration/MigrationInspectorInterface.hpp"
 #include "rpc/Counters.hpp"
 #include "rpc/common/AnyHandler.hpp"
 #include "rpc/handlers/AMMInfo.hpp"
@@ -30,6 +31,7 @@
 #include "rpc/handlers/LedgerIndex.hpp"
 #include "rpc/handlers/LedgerRange.hpp"
 #include "rpc/handlers/MPTHolders.hpp"
+#include "rpc/handlers/MPTokenIssuanceHistory.hpp"
 #include "rpc/handlers/NFTBuyOffers.hpp"
 #include "rpc/handlers/NFTHistory.hpp"
 #include "rpc/handlers/NFTInfo.hpp"
@@ -61,6 +63,7 @@ ProductionHandlerProvider::ProductionHandlerProvider(
     std::shared_ptr<etl::LoadBalancerInterface> const& balancer,
     std::shared_ptr<etl::ETLServiceInterface const> const& etl,
     std::shared_ptr<data::AmendmentCenterInterface const> const& amendmentCenter,
+    std::shared_ptr<migration::MigrationInspectorInterface const> const& migrationInspector,
     Counters const& counters
 )
     : handlerMap_{
@@ -91,6 +94,9 @@ ProductionHandlerProvider::ProductionHandlerProvider(
           {"ledger_range", {.handler = LedgerRangeHandler{backend}}},
           {"mpt_holders",
            {.handler = MPTHoldersHandler{backend}, .isClioOnly = true}},  // clio only
+          {"mptoken_issuance_history",
+           {.handler = MPTokenIssuanceHistoryHandler{backend, migrationInspector},
+            .isClioOnly = true}},  // clio only
           {"nfts_by_issuer",
            {.handler = NFTsByIssuerHandler{backend}, .isClioOnly = true}},  // clio only
           {"nft_history",

src/rpc/common/impl/HandlerProvider.hpp

@@ -5,6 +5,7 @@
 #include "etl/ETLServiceInterface.hpp"
 #include "etl/LoadBalancerInterface.hpp"
 #include "feed/SubscriptionManagerInterface.hpp"
+#include "migration/MigrationInspectorInterface.hpp"
 #include "rpc/common/AnyHandler.hpp"
 #include "rpc/common/HandlerProvider.hpp"
 #include "rpc/common/Types.hpp"
@@ -38,6 +39,7 @@ class ProductionHandlerProvider final : public HandlerProvider {
         std::shared_ptr<etl::LoadBalancerInterface> const& balancer,
         std::shared_ptr<etl::ETLServiceInterface const> const& etl,
         std::shared_ptr<data::AmendmentCenterInterface const> const& amendmentCenter,
+        std::shared_ptr<migration::MigrationInspectorInterface const> const& migrationInspector,
         Counters const& counters
     );