/ src / kernel / bitcoinkernel.cpp
bitcoinkernel.cpp
   1  // Copyright (c) 2022-present 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  #define BITCOINKERNEL_BUILD
   6  
   7  #include <kernel/bitcoinkernel.h>
   8  
   9  #include <chain.h>
  10  #include <coins.h>
  11  #include <consensus/amount.h>
  12  #include <consensus/validation.h>
  13  #include <kernel/caches.h>
  14  #include <kernel/chainparams.h>
  15  #include <kernel/checks.h>
  16  #include <kernel/context.h>
  17  #include <kernel/cs_main.h>
  18  #include <kernel/notifications_interface.h>
  19  #include <kernel/warning.h>
  20  #include <logging.h>
  21  #include <node/blockstorage.h>
  22  #include <node/chainstate.h>
  23  #include <primitives/block.h>
  24  #include <primitives/transaction.h>
  25  #include <script/interpreter.h>
  26  #include <script/script.h>
  27  #include <serialize.h>
  28  #include <streams.h>
  29  #include <sync.h>
  30  #include <tinyformat.h>
  31  #include <uint256.h>
  32  #include <undo.h>
  33  #include <util/fs.h>
  34  #include <util/result.h>
  35  #include <util/signalinterrupt.h>
  36  #include <util/task_runner.h>
  37  #include <util/translation.h>
  38  #include <validation.h>
  39  #include <validationinterface.h>
  40  
  41  #include <cassert>
  42  #include <cstddef>
  43  #include <cstring>
  44  #include <exception>
  45  #include <functional>
  46  #include <list>
  47  #include <memory>
  48  #include <span>
  49  #include <string>
  50  #include <tuple>
  51  #include <utility>
  52  #include <vector>
  53  
  54  using util::ImmediateTaskRunner;
  55  
  56  // Define G_TRANSLATION_FUN symbol in libbitcoinkernel library so users of the
  57  // library aren't required to export this symbol
  58  extern const std::function<std::string(const char*)> G_TRANSLATION_FUN{nullptr};
  59  
  60  static const kernel::Context btck_context_static{};
  61  
  62  namespace {
  63  
  64  bool is_valid_flag_combination(script_verify_flags flags)
  65  {
  66      if (flags & SCRIPT_VERIFY_CLEANSTACK && ~flags & (SCRIPT_VERIFY_P2SH | SCRIPT_VERIFY_WITNESS)) return false;
  67      if (flags & SCRIPT_VERIFY_WITNESS && ~flags & SCRIPT_VERIFY_P2SH) return false;
  68      return true;
  69  }
  70  
  71  class WriterStream
  72  {
  73  private:
  74      btck_WriteBytes m_writer;
  75      void* m_user_data;
  76  
  77  public:
  78      WriterStream(btck_WriteBytes writer, void* user_data)
  79          : m_writer{writer}, m_user_data{user_data} {}
  80  
  81      //
  82      // Stream subset
  83      //
  84      void write(std::span<const std::byte> src)
  85      {
  86          if (m_writer(std::data(src), src.size(), m_user_data) != 0) {
  87              throw std::runtime_error("Failed to write serialization data");
  88          }
  89      }
  90  
  91      template <typename T>
  92      WriterStream& operator<<(const T& obj)
  93      {
  94          ::Serialize(*this, obj);
  95          return *this;
  96      }
  97  };
  98  
  99  template <typename C, typename CPP>
 100  struct Handle {
 101      static C* ref(CPP* cpp_type)
 102      {
 103          return reinterpret_cast<C*>(cpp_type);
 104      }
 105  
 106      static const C* ref(const CPP* cpp_type)
 107      {
 108          return reinterpret_cast<const C*>(cpp_type);
 109      }
 110  
 111      template <typename... Args>
 112      static C* create(Args&&... args)
 113      {
 114          auto cpp_obj{std::make_unique<CPP>(std::forward<Args>(args)...)};
 115          return reinterpret_cast<C*>(cpp_obj.release());
 116      }
 117  
 118      static C* copy(const C* ptr)
 119      {
 120          auto cpp_obj{std::make_unique<CPP>(get(ptr))};
 121          return reinterpret_cast<C*>(cpp_obj.release());
 122      }
 123  
 124      static const CPP& get(const C* ptr)
 125      {
 126          return *reinterpret_cast<const CPP*>(ptr);
 127      }
 128  
 129      static CPP& get(C* ptr)
 130      {
 131          return *reinterpret_cast<CPP*>(ptr);
 132      }
 133  
 134      static void operator delete(void* ptr)
 135      {
 136          delete reinterpret_cast<CPP*>(ptr);
 137      }
 138  };
 139  
 140  } // namespace
 141  
 142  struct btck_BlockTreeEntry: Handle<btck_BlockTreeEntry, CBlockIndex> {};
 143  struct btck_Block : Handle<btck_Block, std::shared_ptr<const CBlock>> {};
 144  struct btck_BlockValidationState : Handle<btck_BlockValidationState, BlockValidationState> {};
 145  
 146  namespace {
 147  
 148  BCLog::Level get_bclog_level(btck_LogLevel level)
 149  {
 150      switch (level) {
 151      case btck_LogLevel_INFO: {
 152          return BCLog::Level::Info;
 153      }
 154      case btck_LogLevel_DEBUG: {
 155          return BCLog::Level::Debug;
 156      }
 157      case btck_LogLevel_TRACE: {
 158          return BCLog::Level::Trace;
 159      }
 160      }
 161      assert(false);
 162  }
 163  
 164  BCLog::LogFlags get_bclog_flag(btck_LogCategory category)
 165  {
 166      switch (category) {
 167      case btck_LogCategory_BENCH: {
 168          return BCLog::LogFlags::BENCH;
 169      }
 170      case btck_LogCategory_BLOCKSTORAGE: {
 171          return BCLog::LogFlags::BLOCKSTORAGE;
 172      }
 173      case btck_LogCategory_COINDB: {
 174          return BCLog::LogFlags::COINDB;
 175      }
 176      case btck_LogCategory_LEVELDB: {
 177          return BCLog::LogFlags::LEVELDB;
 178      }
 179      case btck_LogCategory_MEMPOOL: {
 180          return BCLog::LogFlags::MEMPOOL;
 181      }
 182      case btck_LogCategory_PRUNE: {
 183          return BCLog::LogFlags::PRUNE;
 184      }
 185      case btck_LogCategory_RAND: {
 186          return BCLog::LogFlags::RAND;
 187      }
 188      case btck_LogCategory_REINDEX: {
 189          return BCLog::LogFlags::REINDEX;
 190      }
 191      case btck_LogCategory_VALIDATION: {
 192          return BCLog::LogFlags::VALIDATION;
 193      }
 194      case btck_LogCategory_KERNEL: {
 195          return BCLog::LogFlags::KERNEL;
 196      }
 197      case btck_LogCategory_ALL: {
 198          return BCLog::LogFlags::ALL;
 199      }
 200      }
 201      assert(false);
 202  }
 203  
 204  btck_SynchronizationState cast_state(SynchronizationState state)
 205  {
 206      switch (state) {
 207      case SynchronizationState::INIT_REINDEX:
 208          return btck_SynchronizationState_INIT_REINDEX;
 209      case SynchronizationState::INIT_DOWNLOAD:
 210          return btck_SynchronizationState_INIT_DOWNLOAD;
 211      case SynchronizationState::POST_INIT:
 212          return btck_SynchronizationState_POST_INIT;
 213      } // no default case, so the compiler can warn about missing cases
 214      assert(false);
 215  }
 216  
 217  btck_Warning cast_btck_warning(kernel::Warning warning)
 218  {
 219      switch (warning) {
 220      case kernel::Warning::UNKNOWN_NEW_RULES_ACTIVATED:
 221          return btck_Warning_UNKNOWN_NEW_RULES_ACTIVATED;
 222      case kernel::Warning::LARGE_WORK_INVALID_CHAIN:
 223          return btck_Warning_LARGE_WORK_INVALID_CHAIN;
 224      } // no default case, so the compiler can warn about missing cases
 225      assert(false);
 226  }
 227  
 228  struct LoggingConnection {
 229      std::unique_ptr<std::list<std::function<void(const std::string&)>>::iterator> m_connection;
 230      void* m_user_data;
 231      std::function<void(void* user_data)> m_deleter;
 232  
 233      LoggingConnection(btck_LogCallback callback, void* user_data, btck_DestroyCallback user_data_destroy_callback)
 234      {
 235          LOCK(cs_main);
 236  
 237          auto connection{LogInstance().PushBackCallback([callback, user_data](const std::string& str) { callback(user_data, str.c_str(), str.length()); })};
 238  
 239          // Only start logging if we just added the connection.
 240          if (LogInstance().NumConnections() == 1 && !LogInstance().StartLogging()) {
 241              LogError("Logger start failed.");
 242              LogInstance().DeleteCallback(connection);
 243              if (user_data && user_data_destroy_callback) {
 244                  user_data_destroy_callback(user_data);
 245              }
 246              throw std::runtime_error("Failed to start logging");
 247          }
 248  
 249          m_connection = std::make_unique<std::list<std::function<void(const std::string&)>>::iterator>(connection);
 250          m_user_data = user_data;
 251          m_deleter = user_data_destroy_callback;
 252  
 253          LogDebug(BCLog::KERNEL, "Logger connected.");
 254      }
 255  
 256      ~LoggingConnection()
 257      {
 258          LOCK(cs_main);
 259          LogDebug(BCLog::KERNEL, "Logger disconnecting.");
 260  
 261          // Switch back to buffering by calling DisconnectTestLogger if the
 262          // connection that we are about to remove is the last one.
 263          if (LogInstance().NumConnections() == 1) {
 264              LogInstance().DisconnectTestLogger();
 265          } else {
 266              LogInstance().DeleteCallback(*m_connection);
 267          }
 268  
 269          m_connection.reset();
 270          if (m_user_data && m_deleter) {
 271              m_deleter(m_user_data);
 272          }
 273      }
 274  };
 275  
 276  class KernelNotifications final : public kernel::Notifications
 277  {
 278  private:
 279      btck_NotificationInterfaceCallbacks m_cbs;
 280  
 281  public:
 282      KernelNotifications(btck_NotificationInterfaceCallbacks cbs)
 283          : m_cbs{cbs}
 284      {
 285      }
 286  
 287      ~KernelNotifications()
 288      {
 289          if (m_cbs.user_data && m_cbs.user_data_destroy) {
 290              m_cbs.user_data_destroy(m_cbs.user_data);
 291          }
 292          m_cbs.user_data_destroy = nullptr;
 293          m_cbs.user_data = nullptr;
 294      }
 295  
 296      kernel::InterruptResult blockTip(SynchronizationState state, const CBlockIndex& index, double verification_progress) override
 297      {
 298          if (m_cbs.block_tip) m_cbs.block_tip(m_cbs.user_data, cast_state(state), btck_BlockTreeEntry::ref(&index), verification_progress);
 299          return {};
 300      }
 301      void headerTip(SynchronizationState state, int64_t height, int64_t timestamp, bool presync) override
 302      {
 303          if (m_cbs.header_tip) m_cbs.header_tip(m_cbs.user_data, cast_state(state), height, timestamp, presync ? 1 : 0);
 304      }
 305      void progress(const bilingual_str& title, int progress_percent, bool resume_possible) override
 306      {
 307          if (m_cbs.progress) m_cbs.progress(m_cbs.user_data, title.original.c_str(), title.original.length(), progress_percent, resume_possible ? 1 : 0);
 308      }
 309      void warningSet(kernel::Warning id, const bilingual_str& message) override
 310      {
 311          if (m_cbs.warning_set) m_cbs.warning_set(m_cbs.user_data, cast_btck_warning(id), message.original.c_str(), message.original.length());
 312      }
 313      void warningUnset(kernel::Warning id) override
 314      {
 315          if (m_cbs.warning_unset) m_cbs.warning_unset(m_cbs.user_data, cast_btck_warning(id));
 316      }
 317      void flushError(const bilingual_str& message) override
 318      {
 319          if (m_cbs.flush_error) m_cbs.flush_error(m_cbs.user_data, message.original.c_str(), message.original.length());
 320      }
 321      void fatalError(const bilingual_str& message) override
 322      {
 323          if (m_cbs.fatal_error) m_cbs.fatal_error(m_cbs.user_data, message.original.c_str(), message.original.length());
 324      }
 325  };
 326  
 327  class KernelValidationInterface final : public CValidationInterface
 328  {
 329  public:
 330      btck_ValidationInterfaceCallbacks m_cbs;
 331  
 332      explicit KernelValidationInterface(const btck_ValidationInterfaceCallbacks vi_cbs) : m_cbs{vi_cbs} {}
 333  
 334      ~KernelValidationInterface()
 335      {
 336          if (m_cbs.user_data && m_cbs.user_data_destroy) {
 337              m_cbs.user_data_destroy(m_cbs.user_data);
 338          }
 339          m_cbs.user_data = nullptr;
 340          m_cbs.user_data_destroy = nullptr;
 341      }
 342  
 343  protected:
 344      void BlockChecked(const std::shared_ptr<const CBlock>& block, const BlockValidationState& stateIn) override
 345      {
 346          if (m_cbs.block_checked) {
 347              m_cbs.block_checked(m_cbs.user_data,
 348                                  btck_Block::copy(btck_Block::ref(&block)),
 349                                  btck_BlockValidationState::ref(&stateIn));
 350          }
 351      }
 352  
 353      void NewPoWValidBlock(const CBlockIndex* pindex, const std::shared_ptr<const CBlock>& block) override
 354      {
 355          if (m_cbs.pow_valid_block) {
 356              m_cbs.pow_valid_block(m_cbs.user_data,
 357                                    btck_Block::copy(btck_Block::ref(&block)),
 358                                    btck_BlockTreeEntry::ref(pindex));
 359          }
 360      }
 361  
 362      void BlockConnected(ChainstateRole role, const std::shared_ptr<const CBlock>& block, const CBlockIndex* pindex) override
 363      {
 364          if (m_cbs.block_connected) {
 365              m_cbs.block_connected(m_cbs.user_data,
 366                                    btck_Block::copy(btck_Block::ref(&block)),
 367                                    btck_BlockTreeEntry::ref(pindex));
 368          }
 369      }
 370  
 371      void BlockDisconnected(const std::shared_ptr<const CBlock>& block, const CBlockIndex* pindex) override
 372      {
 373          if (m_cbs.block_disconnected) {
 374              m_cbs.block_disconnected(m_cbs.user_data,
 375                                       btck_Block::copy(btck_Block::ref(&block)),
 376                                       btck_BlockTreeEntry::ref(pindex));
 377          }
 378      }
 379  };
 380  
 381  struct ContextOptions {
 382      mutable Mutex m_mutex;
 383      std::unique_ptr<const CChainParams> m_chainparams GUARDED_BY(m_mutex);
 384      std::shared_ptr<KernelNotifications> m_notifications GUARDED_BY(m_mutex);
 385      std::shared_ptr<KernelValidationInterface> m_validation_interface GUARDED_BY(m_mutex);
 386  };
 387  
 388  class Context
 389  {
 390  public:
 391      std::unique_ptr<kernel::Context> m_context;
 392  
 393      std::shared_ptr<KernelNotifications> m_notifications;
 394  
 395      std::unique_ptr<util::SignalInterrupt> m_interrupt;
 396  
 397      std::unique_ptr<ValidationSignals> m_signals;
 398  
 399      std::unique_ptr<const CChainParams> m_chainparams;
 400  
 401      std::shared_ptr<KernelValidationInterface> m_validation_interface;
 402  
 403      Context(const ContextOptions* options, bool& sane)
 404          : m_context{std::make_unique<kernel::Context>()},
 405            m_interrupt{std::make_unique<util::SignalInterrupt>()}
 406      {
 407          if (options) {
 408              LOCK(options->m_mutex);
 409              if (options->m_chainparams) {
 410                  m_chainparams = std::make_unique<const CChainParams>(*options->m_chainparams);
 411              }
 412              if (options->m_notifications) {
 413                  m_notifications = options->m_notifications;
 414              }
 415              if (options->m_validation_interface) {
 416                  m_signals = std::make_unique<ValidationSignals>(std::make_unique<ImmediateTaskRunner>());
 417                  m_validation_interface = options->m_validation_interface;
 418                  m_signals->RegisterSharedValidationInterface(m_validation_interface);
 419              }
 420          }
 421  
 422          if (!m_chainparams) {
 423              m_chainparams = CChainParams::Main();
 424          }
 425          if (!m_notifications) {
 426              m_notifications = std::make_shared<KernelNotifications>(btck_NotificationInterfaceCallbacks{
 427                  nullptr, nullptr, nullptr, nullptr, nullptr, nullptr, nullptr, nullptr, nullptr});
 428          }
 429  
 430          if (!kernel::SanityChecks(*m_context)) {
 431              sane = false;
 432          }
 433      }
 434  
 435      ~Context()
 436      {
 437          if (m_signals) {
 438              m_signals->UnregisterSharedValidationInterface(m_validation_interface);
 439          }
 440      }
 441  };
 442  
 443  //! Helper struct to wrap the ChainstateManager-related Options
 444  struct ChainstateManagerOptions {
 445      mutable Mutex m_mutex;
 446      ChainstateManager::Options m_chainman_options GUARDED_BY(m_mutex);
 447      node::BlockManager::Options m_blockman_options GUARDED_BY(m_mutex);
 448      std::shared_ptr<const Context> m_context;
 449      node::ChainstateLoadOptions m_chainstate_load_options GUARDED_BY(m_mutex);
 450  
 451      ChainstateManagerOptions(const std::shared_ptr<const Context>& context, const fs::path& data_dir, const fs::path& blocks_dir)
 452          : m_chainman_options{ChainstateManager::Options{
 453                .chainparams = *context->m_chainparams,
 454                .datadir = data_dir,
 455                .notifications = *context->m_notifications,
 456                .signals = context->m_signals.get()}},
 457            m_blockman_options{node::BlockManager::Options{
 458                .chainparams = *context->m_chainparams,
 459                .blocks_dir = blocks_dir,
 460                .notifications = *context->m_notifications,
 461                .block_tree_db_params = DBParams{
 462                    .path = data_dir / "blocks" / "index",
 463                    .cache_bytes = kernel::CacheSizes{DEFAULT_KERNEL_CACHE}.block_tree_db,
 464                }}},
 465            m_context{context}, m_chainstate_load_options{node::ChainstateLoadOptions{}}
 466      {
 467      }
 468  };
 469  
 470  struct ChainMan {
 471      std::unique_ptr<ChainstateManager> m_chainman;
 472      std::shared_ptr<const Context> m_context;
 473  
 474      ChainMan(std::unique_ptr<ChainstateManager> chainman, std::shared_ptr<const Context> context)
 475          : m_chainman(std::move(chainman)), m_context(std::move(context)) {}
 476  };
 477  
 478  } // namespace
 479  
 480  struct btck_Transaction : Handle<btck_Transaction, std::shared_ptr<const CTransaction>> {};
 481  struct btck_TransactionOutput : Handle<btck_TransactionOutput, CTxOut> {};
 482  struct btck_ScriptPubkey : Handle<btck_ScriptPubkey, CScript> {};
 483  struct btck_LoggingConnection : Handle<btck_LoggingConnection, LoggingConnection> {};
 484  struct btck_ContextOptions : Handle<btck_ContextOptions, ContextOptions> {};
 485  struct btck_Context : Handle<btck_Context, std::shared_ptr<const Context>> {};
 486  struct btck_ChainParameters : Handle<btck_ChainParameters, CChainParams> {};
 487  struct btck_ChainstateManagerOptions : Handle<btck_ChainstateManagerOptions, ChainstateManagerOptions> {};
 488  struct btck_ChainstateManager : Handle<btck_ChainstateManager, ChainMan> {};
 489  struct btck_Chain : Handle<btck_Chain, CChain> {};
 490  struct btck_BlockSpentOutputs : Handle<btck_BlockSpentOutputs, std::shared_ptr<CBlockUndo>> {};
 491  struct btck_TransactionSpentOutputs : Handle<btck_TransactionSpentOutputs, CTxUndo> {};
 492  struct btck_Coin : Handle<btck_Coin, Coin> {};
 493  struct btck_BlockHash : Handle<btck_BlockHash, uint256> {};
 494  struct btck_TransactionInput : Handle<btck_TransactionInput, CTxIn> {};
 495  struct btck_TransactionOutPoint: Handle<btck_TransactionOutPoint, COutPoint> {};
 496  struct btck_Txid: Handle<btck_Txid, Txid> {};
 497  
 498  btck_Transaction* btck_transaction_create(const void* raw_transaction, size_t raw_transaction_len)
 499  {
 500      if (raw_transaction == nullptr && raw_transaction_len != 0) {
 501          return nullptr;
 502      }
 503      try {
 504          DataStream stream{std::span{reinterpret_cast<const std::byte*>(raw_transaction), raw_transaction_len}};
 505          return btck_Transaction::create(std::make_shared<const CTransaction>(deserialize, TX_WITH_WITNESS, stream));
 506      } catch (...) {
 507          return nullptr;
 508      }
 509  }
 510  
 511  size_t btck_transaction_count_outputs(const btck_Transaction* transaction)
 512  {
 513      return btck_Transaction::get(transaction)->vout.size();
 514  }
 515  
 516  const btck_TransactionOutput* btck_transaction_get_output_at(const btck_Transaction* transaction, size_t output_index)
 517  {
 518      const CTransaction& tx = *btck_Transaction::get(transaction);
 519      assert(output_index < tx.vout.size());
 520      return btck_TransactionOutput::ref(&tx.vout[output_index]);
 521  }
 522  
 523  size_t btck_transaction_count_inputs(const btck_Transaction* transaction)
 524  {
 525      return btck_Transaction::get(transaction)->vin.size();
 526  }
 527  
 528  const btck_TransactionInput* btck_transaction_get_input_at(const btck_Transaction* transaction, size_t input_index)
 529  {
 530      assert(input_index < btck_Transaction::get(transaction)->vin.size());
 531      return btck_TransactionInput::ref(&btck_Transaction::get(transaction)->vin[input_index]);
 532  }
 533  
 534  const btck_Txid* btck_transaction_get_txid(const btck_Transaction* transaction)
 535  {
 536      return btck_Txid::ref(&btck_Transaction::get(transaction)->GetHash());
 537  }
 538  
 539  btck_Transaction* btck_transaction_copy(const btck_Transaction* transaction)
 540  {
 541      return btck_Transaction::copy(transaction);
 542  }
 543  
 544  int btck_transaction_to_bytes(const btck_Transaction* transaction, btck_WriteBytes writer, void* user_data)
 545  {
 546      try {
 547          WriterStream ws{writer, user_data};
 548          ws << TX_WITH_WITNESS(btck_Transaction::get(transaction));
 549          return 0;
 550      } catch (...) {
 551          return -1;
 552      }
 553  }
 554  
 555  void btck_transaction_destroy(btck_Transaction* transaction)
 556  {
 557      delete transaction;
 558  }
 559  
 560  btck_ScriptPubkey* btck_script_pubkey_create(const void* script_pubkey, size_t script_pubkey_len)
 561  {
 562      if (script_pubkey == nullptr && script_pubkey_len != 0) {
 563          return nullptr;
 564      }
 565      auto data = std::span{reinterpret_cast<const uint8_t*>(script_pubkey), script_pubkey_len};
 566      return btck_ScriptPubkey::create(data.begin(), data.end());
 567  }
 568  
 569  int btck_script_pubkey_to_bytes(const btck_ScriptPubkey* script_pubkey_, btck_WriteBytes writer, void* user_data)
 570  {
 571      const auto& script_pubkey{btck_ScriptPubkey::get(script_pubkey_)};
 572      return writer(script_pubkey.data(), script_pubkey.size(), user_data);
 573  }
 574  
 575  btck_ScriptPubkey* btck_script_pubkey_copy(const btck_ScriptPubkey* script_pubkey)
 576  {
 577      return btck_ScriptPubkey::copy(script_pubkey);
 578  }
 579  
 580  void btck_script_pubkey_destroy(btck_ScriptPubkey* script_pubkey)
 581  {
 582      delete script_pubkey;
 583  }
 584  
 585  btck_TransactionOutput* btck_transaction_output_create(const btck_ScriptPubkey* script_pubkey, int64_t amount)
 586  {
 587      return btck_TransactionOutput::create(amount, btck_ScriptPubkey::get(script_pubkey));
 588  }
 589  
 590  btck_TransactionOutput* btck_transaction_output_copy(const btck_TransactionOutput* output)
 591  {
 592      return btck_TransactionOutput::copy(output);
 593  }
 594  
 595  const btck_ScriptPubkey* btck_transaction_output_get_script_pubkey(const btck_TransactionOutput* output)
 596  {
 597      return btck_ScriptPubkey::ref(&btck_TransactionOutput::get(output).scriptPubKey);
 598  }
 599  
 600  int64_t btck_transaction_output_get_amount(const btck_TransactionOutput* output)
 601  {
 602      return btck_TransactionOutput::get(output).nValue;
 603  }
 604  
 605  void btck_transaction_output_destroy(btck_TransactionOutput* output)
 606  {
 607      delete output;
 608  }
 609  
 610  int btck_script_pubkey_verify(const btck_ScriptPubkey* script_pubkey,
 611                                const int64_t amount,
 612                                const btck_Transaction* tx_to,
 613                                const btck_TransactionOutput** spent_outputs_, size_t spent_outputs_len,
 614                                const unsigned int input_index,
 615                                const btck_ScriptVerificationFlags flags,
 616                                btck_ScriptVerifyStatus* status)
 617  {
 618      // Assert that all specified flags are part of the interface before continuing
 619      assert((flags & ~btck_ScriptVerificationFlags_ALL) == 0);
 620  
 621      if (!is_valid_flag_combination(script_verify_flags::from_int(flags))) {
 622          if (status) *status = btck_ScriptVerifyStatus_ERROR_INVALID_FLAGS_COMBINATION;
 623          return 0;
 624      }
 625  
 626      if (flags & btck_ScriptVerificationFlags_TAPROOT && spent_outputs_ == nullptr) {
 627          if (status) *status = btck_ScriptVerifyStatus_ERROR_SPENT_OUTPUTS_REQUIRED;
 628          return 0;
 629      }
 630  
 631      if (status) *status = btck_ScriptVerifyStatus_OK;
 632  
 633      const CTransaction& tx{*btck_Transaction::get(tx_to)};
 634      std::vector<CTxOut> spent_outputs;
 635      if (spent_outputs_ != nullptr) {
 636          assert(spent_outputs_len == tx.vin.size());
 637          spent_outputs.reserve(spent_outputs_len);
 638          for (size_t i = 0; i < spent_outputs_len; i++) {
 639              const CTxOut& tx_out{btck_TransactionOutput::get(spent_outputs_[i])};
 640              spent_outputs.push_back(tx_out);
 641          }
 642      }
 643  
 644      assert(input_index < tx.vin.size());
 645      PrecomputedTransactionData txdata{tx};
 646  
 647      if (spent_outputs_ != nullptr && flags & btck_ScriptVerificationFlags_TAPROOT) {
 648          txdata.Init(tx, std::move(spent_outputs));
 649      }
 650  
 651      bool result = VerifyScript(tx.vin[input_index].scriptSig,
 652                                 btck_ScriptPubkey::get(script_pubkey),
 653                                 &tx.vin[input_index].scriptWitness,
 654                                 script_verify_flags::from_int(flags),
 655                                 TransactionSignatureChecker(&tx, input_index, amount, txdata, MissingDataBehavior::FAIL),
 656                                 nullptr);
 657      return result ? 1 : 0;
 658  }
 659  
 660  btck_TransactionInput* btck_transaction_input_copy(const btck_TransactionInput* input)
 661  {
 662      return btck_TransactionInput::copy(input);
 663  }
 664  
 665  const btck_TransactionOutPoint* btck_transaction_input_get_out_point(const btck_TransactionInput* input)
 666  {
 667      return btck_TransactionOutPoint::ref(&btck_TransactionInput::get(input).prevout);
 668  }
 669  
 670  void btck_transaction_input_destroy(btck_TransactionInput* input)
 671  {
 672      delete input;
 673  }
 674  
 675  btck_TransactionOutPoint* btck_transaction_out_point_copy(const btck_TransactionOutPoint* out_point)
 676  {
 677      return btck_TransactionOutPoint::copy(out_point);
 678  }
 679  
 680  uint32_t btck_transaction_out_point_get_index(const btck_TransactionOutPoint* out_point)
 681  {
 682      return btck_TransactionOutPoint::get(out_point).n;
 683  }
 684  
 685  const btck_Txid* btck_transaction_out_point_get_txid(const btck_TransactionOutPoint* out_point)
 686  {
 687      return btck_Txid::ref(&btck_TransactionOutPoint::get(out_point).hash);
 688  }
 689  
 690  void btck_transaction_out_point_destroy(btck_TransactionOutPoint* out_point)
 691  {
 692      delete out_point;
 693  }
 694  
 695  btck_Txid* btck_txid_copy(const btck_Txid* txid)
 696  {
 697      return btck_Txid::copy(txid);
 698  }
 699  
 700  void btck_txid_to_bytes(const btck_Txid* txid, unsigned char output[32])
 701  {
 702      std::memcpy(output, btck_Txid::get(txid).begin(), 32);
 703  }
 704  
 705  int btck_txid_equals(const btck_Txid* txid1, const btck_Txid* txid2)
 706  {
 707      return btck_Txid::get(txid1) == btck_Txid::get(txid2);
 708  }
 709  
 710  void btck_txid_destroy(btck_Txid* txid)
 711  {
 712      delete txid;
 713  }
 714  
 715  void btck_logging_set_options(const btck_LoggingOptions options)
 716  {
 717      LOCK(cs_main);
 718      LogInstance().m_log_timestamps = options.log_timestamps;
 719      LogInstance().m_log_time_micros = options.log_time_micros;
 720      LogInstance().m_log_threadnames = options.log_threadnames;
 721      LogInstance().m_log_sourcelocations = options.log_sourcelocations;
 722      LogInstance().m_always_print_category_level = options.always_print_category_levels;
 723  }
 724  
 725  void btck_logging_set_level_category(btck_LogCategory category, btck_LogLevel level)
 726  {
 727      LOCK(cs_main);
 728      if (category == btck_LogCategory_ALL) {
 729          LogInstance().SetLogLevel(get_bclog_level(level));
 730      }
 731  
 732      LogInstance().AddCategoryLogLevel(get_bclog_flag(category), get_bclog_level(level));
 733  }
 734  
 735  void btck_logging_enable_category(btck_LogCategory category)
 736  {
 737      LogInstance().EnableCategory(get_bclog_flag(category));
 738  }
 739  
 740  void btck_logging_disable_category(btck_LogCategory category)
 741  {
 742      LogInstance().DisableCategory(get_bclog_flag(category));
 743  }
 744  
 745  void btck_logging_disable()
 746  {
 747      LogInstance().DisableLogging();
 748  }
 749  
 750  btck_LoggingConnection* btck_logging_connection_create(btck_LogCallback callback, void* user_data, btck_DestroyCallback user_data_destroy_callback)
 751  {
 752      try {
 753          return btck_LoggingConnection::create(callback, user_data, user_data_destroy_callback);
 754      } catch (const std::exception&) {
 755          return nullptr;
 756      }
 757  }
 758  
 759  void btck_logging_connection_destroy(btck_LoggingConnection* connection)
 760  {
 761      delete connection;
 762  }
 763  
 764  btck_ChainParameters* btck_chain_parameters_create(const btck_ChainType chain_type)
 765  {
 766      switch (chain_type) {
 767      case btck_ChainType_MAINNET: {
 768          return btck_ChainParameters::ref(const_cast<CChainParams*>(CChainParams::Main().release()));
 769      }
 770      case btck_ChainType_TESTNET: {
 771          return btck_ChainParameters::ref(const_cast<CChainParams*>(CChainParams::TestNet().release()));
 772      }
 773      case btck_ChainType_TESTNET_4: {
 774          return btck_ChainParameters::ref(const_cast<CChainParams*>(CChainParams::TestNet4().release()));
 775      }
 776      case btck_ChainType_SIGNET: {
 777          return btck_ChainParameters::ref(const_cast<CChainParams*>(CChainParams::SigNet({}).release()));
 778      }
 779      case btck_ChainType_REGTEST: {
 780          return btck_ChainParameters::ref(const_cast<CChainParams*>(CChainParams::RegTest({}).release()));
 781      }
 782      }
 783      assert(false);
 784  }
 785  
 786  btck_ChainParameters* btck_chain_parameters_copy(const btck_ChainParameters* chain_parameters)
 787  {
 788      return btck_ChainParameters::copy(chain_parameters);
 789  }
 790  
 791  void btck_chain_parameters_destroy(btck_ChainParameters* chain_parameters)
 792  {
 793      delete chain_parameters;
 794  }
 795  
 796  btck_ContextOptions* btck_context_options_create()
 797  {
 798      return btck_ContextOptions::create();
 799  }
 800  
 801  void btck_context_options_set_chainparams(btck_ContextOptions* options, const btck_ChainParameters* chain_parameters)
 802  {
 803      // Copy the chainparams, so the caller can free it again
 804      LOCK(btck_ContextOptions::get(options).m_mutex);
 805      btck_ContextOptions::get(options).m_chainparams = std::make_unique<const CChainParams>(btck_ChainParameters::get(chain_parameters));
 806  }
 807  
 808  void btck_context_options_set_notifications(btck_ContextOptions* options, btck_NotificationInterfaceCallbacks notifications)
 809  {
 810      // The KernelNotifications are copy-initialized, so the caller can free them again.
 811      LOCK(btck_ContextOptions::get(options).m_mutex);
 812      btck_ContextOptions::get(options).m_notifications = std::make_shared<KernelNotifications>(notifications);
 813  }
 814  
 815  void btck_context_options_set_validation_interface(btck_ContextOptions* options, btck_ValidationInterfaceCallbacks vi_cbs)
 816  {
 817      LOCK(btck_ContextOptions::get(options).m_mutex);
 818      btck_ContextOptions::get(options).m_validation_interface = std::make_shared<KernelValidationInterface>(vi_cbs);
 819  }
 820  
 821  void btck_context_options_destroy(btck_ContextOptions* options)
 822  {
 823      delete options;
 824  }
 825  
 826  btck_Context* btck_context_create(const btck_ContextOptions* options)
 827  {
 828      bool sane{true};
 829      const ContextOptions* opts = options ? &btck_ContextOptions::get(options) : nullptr;
 830      auto context{std::make_shared<const Context>(opts, sane)};
 831      if (!sane) {
 832          LogError("Kernel context sanity check failed.");
 833          return nullptr;
 834      }
 835      return btck_Context::create(context);
 836  }
 837  
 838  btck_Context* btck_context_copy(const btck_Context* context)
 839  {
 840      return btck_Context::copy(context);
 841  }
 842  
 843  int btck_context_interrupt(btck_Context* context)
 844  {
 845      return (*btck_Context::get(context)->m_interrupt)() ? 0 : -1;
 846  }
 847  
 848  void btck_context_destroy(btck_Context* context)
 849  {
 850      delete context;
 851  }
 852  
 853  const btck_BlockTreeEntry* btck_block_tree_entry_get_previous(const btck_BlockTreeEntry* entry)
 854  {
 855      if (!btck_BlockTreeEntry::get(entry).pprev) {
 856          LogInfo("Genesis block has no previous.");
 857          return nullptr;
 858      }
 859  
 860      return btck_BlockTreeEntry::ref(btck_BlockTreeEntry::get(entry).pprev);
 861  }
 862  
 863  btck_ValidationMode btck_block_validation_state_get_validation_mode(const btck_BlockValidationState* block_validation_state_)
 864  {
 865      auto& block_validation_state = btck_BlockValidationState::get(block_validation_state_);
 866      if (block_validation_state.IsValid()) return btck_ValidationMode_VALID;
 867      if (block_validation_state.IsInvalid()) return btck_ValidationMode_INVALID;
 868      return btck_ValidationMode_INTERNAL_ERROR;
 869  }
 870  
 871  btck_BlockValidationResult btck_block_validation_state_get_block_validation_result(const btck_BlockValidationState* block_validation_state_)
 872  {
 873      auto& block_validation_state = btck_BlockValidationState::get(block_validation_state_);
 874      switch (block_validation_state.GetResult()) {
 875      case BlockValidationResult::BLOCK_RESULT_UNSET:
 876          return btck_BlockValidationResult_UNSET;
 877      case BlockValidationResult::BLOCK_CONSENSUS:
 878          return btck_BlockValidationResult_CONSENSUS;
 879      case BlockValidationResult::BLOCK_CACHED_INVALID:
 880          return btck_BlockValidationResult_CACHED_INVALID;
 881      case BlockValidationResult::BLOCK_INVALID_HEADER:
 882          return btck_BlockValidationResult_INVALID_HEADER;
 883      case BlockValidationResult::BLOCK_MUTATED:
 884          return btck_BlockValidationResult_MUTATED;
 885      case BlockValidationResult::BLOCK_MISSING_PREV:
 886          return btck_BlockValidationResult_MISSING_PREV;
 887      case BlockValidationResult::BLOCK_INVALID_PREV:
 888          return btck_BlockValidationResult_INVALID_PREV;
 889      case BlockValidationResult::BLOCK_TIME_FUTURE:
 890          return btck_BlockValidationResult_TIME_FUTURE;
 891      case BlockValidationResult::BLOCK_HEADER_LOW_WORK:
 892          return btck_BlockValidationResult_HEADER_LOW_WORK;
 893      } // no default case, so the compiler can warn about missing cases
 894      assert(false);
 895  }
 896  
 897  btck_ChainstateManagerOptions* btck_chainstate_manager_options_create(const btck_Context* context, const char* data_dir, size_t data_dir_len, const char* blocks_dir, size_t blocks_dir_len)
 898  {
 899      if (data_dir == nullptr || data_dir_len == 0 || blocks_dir == nullptr || blocks_dir_len == 0) {
 900          LogError("Failed to create chainstate manager options: dir must be non-null and non-empty");
 901          return nullptr;
 902      }
 903      try {
 904          fs::path abs_data_dir{fs::absolute(fs::PathFromString({data_dir, data_dir_len}))};
 905          fs::create_directories(abs_data_dir);
 906          fs::path abs_blocks_dir{fs::absolute(fs::PathFromString({blocks_dir, blocks_dir_len}))};
 907          fs::create_directories(abs_blocks_dir);
 908          return btck_ChainstateManagerOptions::create(btck_Context::get(context), abs_data_dir, abs_blocks_dir);
 909      } catch (const std::exception& e) {
 910          LogError("Failed to create chainstate manager options: %s", e.what());
 911          return nullptr;
 912      }
 913  }
 914  
 915  void btck_chainstate_manager_options_set_worker_threads_num(btck_ChainstateManagerOptions* opts, int worker_threads)
 916  {
 917      LOCK(btck_ChainstateManagerOptions::get(opts).m_mutex);
 918      btck_ChainstateManagerOptions::get(opts).m_chainman_options.worker_threads_num = worker_threads;
 919  }
 920  
 921  void btck_chainstate_manager_options_destroy(btck_ChainstateManagerOptions* options)
 922  {
 923      delete options;
 924  }
 925  
 926  int btck_chainstate_manager_options_set_wipe_dbs(btck_ChainstateManagerOptions* chainman_opts, int wipe_block_tree_db, int wipe_chainstate_db)
 927  {
 928      if (wipe_block_tree_db == 1 && wipe_chainstate_db != 1) {
 929          LogError("Wiping the block tree db without also wiping the chainstate db is currently unsupported.");
 930          return -1;
 931      }
 932      auto& opts{btck_ChainstateManagerOptions::get(chainman_opts)};
 933      LOCK(opts.m_mutex);
 934      opts.m_blockman_options.block_tree_db_params.wipe_data = wipe_block_tree_db == 1;
 935      opts.m_chainstate_load_options.wipe_chainstate_db = wipe_chainstate_db == 1;
 936      return 0;
 937  }
 938  
 939  void btck_chainstate_manager_options_update_block_tree_db_in_memory(
 940      btck_ChainstateManagerOptions* chainman_opts,
 941      int block_tree_db_in_memory)
 942  {
 943      auto& opts{btck_ChainstateManagerOptions::get(chainman_opts)};
 944      LOCK(opts.m_mutex);
 945      opts.m_blockman_options.block_tree_db_params.memory_only = block_tree_db_in_memory == 1;
 946  }
 947  
 948  void btck_chainstate_manager_options_update_chainstate_db_in_memory(
 949      btck_ChainstateManagerOptions* chainman_opts,
 950      int chainstate_db_in_memory)
 951  {
 952      auto& opts{btck_ChainstateManagerOptions::get(chainman_opts)};
 953      LOCK(opts.m_mutex);
 954      opts.m_chainstate_load_options.coins_db_in_memory = chainstate_db_in_memory == 1;
 955  }
 956  
 957  btck_ChainstateManager* btck_chainstate_manager_create(
 958      const btck_ChainstateManagerOptions* chainman_opts)
 959  {
 960      auto& opts{btck_ChainstateManagerOptions::get(chainman_opts)};
 961      std::unique_ptr<ChainstateManager> chainman;
 962      try {
 963          LOCK(opts.m_mutex);
 964          chainman = std::make_unique<ChainstateManager>(*opts.m_context->m_interrupt, opts.m_chainman_options, opts.m_blockman_options);
 965      } catch (const std::exception& e) {
 966          LogError("Failed to create chainstate manager: %s", e.what());
 967          return nullptr;
 968      }
 969  
 970      try {
 971          const auto chainstate_load_opts{WITH_LOCK(opts.m_mutex, return opts.m_chainstate_load_options)};
 972  
 973          kernel::CacheSizes cache_sizes{DEFAULT_KERNEL_CACHE};
 974          auto [status, chainstate_err]{node::LoadChainstate(*chainman, cache_sizes, chainstate_load_opts)};
 975          if (status != node::ChainstateLoadStatus::SUCCESS) {
 976              LogError("Failed to load chain state from your data directory: %s", chainstate_err.original);
 977              return nullptr;
 978          }
 979          std::tie(status, chainstate_err) = node::VerifyLoadedChainstate(*chainman, chainstate_load_opts);
 980          if (status != node::ChainstateLoadStatus::SUCCESS) {
 981              LogError("Failed to verify loaded chain state from your datadir: %s", chainstate_err.original);
 982              return nullptr;
 983          }
 984  
 985          for (Chainstate* chainstate : WITH_LOCK(chainman->GetMutex(), return chainman->GetAll())) {
 986              BlockValidationState state;
 987              if (!chainstate->ActivateBestChain(state, nullptr)) {
 988                  LogError("Failed to connect best block: %s", state.ToString());
 989                  return nullptr;
 990              }
 991          }
 992      } catch (const std::exception& e) {
 993          LogError("Failed to load chainstate: %s", e.what());
 994          return nullptr;
 995      }
 996  
 997      return btck_ChainstateManager::create(std::move(chainman), opts.m_context);
 998  }
 999  
1000  const btck_BlockTreeEntry* btck_chainstate_manager_get_block_tree_entry_by_hash(const btck_ChainstateManager* chainman, const btck_BlockHash* block_hash)
1001  {
1002      auto block_index = WITH_LOCK(btck_ChainstateManager::get(chainman).m_chainman->GetMutex(),
1003                                   return btck_ChainstateManager::get(chainman).m_chainman->m_blockman.LookupBlockIndex(btck_BlockHash::get(block_hash)));
1004      if (!block_index) {
1005          LogDebug(BCLog::KERNEL, "A block with the given hash is not indexed.");
1006          return nullptr;
1007      }
1008      return btck_BlockTreeEntry::ref(block_index);
1009  }
1010  
1011  void btck_chainstate_manager_destroy(btck_ChainstateManager* chainman)
1012  {
1013      {
1014          LOCK(btck_ChainstateManager::get(chainman).m_chainman->GetMutex());
1015          for (Chainstate* chainstate : btck_ChainstateManager::get(chainman).m_chainman->GetAll()) {
1016              if (chainstate->CanFlushToDisk()) {
1017                  chainstate->ForceFlushStateToDisk();
1018                  chainstate->ResetCoinsViews();
1019              }
1020          }
1021      }
1022  
1023      delete chainman;
1024  }
1025  
1026  int btck_chainstate_manager_import_blocks(btck_ChainstateManager* chainman, const char** block_file_paths_data, size_t* block_file_paths_lens, size_t block_file_paths_data_len)
1027  {
1028      try {
1029          std::vector<fs::path> import_files;
1030          import_files.reserve(block_file_paths_data_len);
1031          for (uint32_t i = 0; i < block_file_paths_data_len; i++) {
1032              if (block_file_paths_data[i] != nullptr) {
1033                  import_files.emplace_back(std::string{block_file_paths_data[i], block_file_paths_lens[i]}.c_str());
1034              }
1035          }
1036          node::ImportBlocks(*btck_ChainstateManager::get(chainman).m_chainman, import_files);
1037      } catch (const std::exception& e) {
1038          LogError("Failed to import blocks: %s", e.what());
1039          return -1;
1040      }
1041      return 0;
1042  }
1043  
1044  btck_Block* btck_block_create(const void* raw_block, size_t raw_block_length)
1045  {
1046      if (raw_block == nullptr && raw_block_length != 0) {
1047          return nullptr;
1048      }
1049      auto block{std::make_shared<CBlock>()};
1050  
1051      DataStream stream{std::span{reinterpret_cast<const std::byte*>(raw_block), raw_block_length}};
1052  
1053      try {
1054          stream >> TX_WITH_WITNESS(*block);
1055      } catch (...) {
1056          LogDebug(BCLog::KERNEL, "Block decode failed.");
1057          return nullptr;
1058      }
1059  
1060      return btck_Block::create(block);
1061  }
1062  
1063  btck_Block* btck_block_copy(const btck_Block* block)
1064  {
1065      return btck_Block::copy(block);
1066  }
1067  
1068  size_t btck_block_count_transactions(const btck_Block* block)
1069  {
1070      return btck_Block::get(block)->vtx.size();
1071  }
1072  
1073  const btck_Transaction* btck_block_get_transaction_at(const btck_Block* block, size_t index)
1074  {
1075      assert(index < btck_Block::get(block)->vtx.size());
1076      return btck_Transaction::ref(&btck_Block::get(block)->vtx[index]);
1077  }
1078  
1079  int btck_block_to_bytes(const btck_Block* block, btck_WriteBytes writer, void* user_data)
1080  {
1081      try {
1082          WriterStream ws{writer, user_data};
1083          ws << TX_WITH_WITNESS(*btck_Block::get(block));
1084          return 0;
1085      } catch (...) {
1086          return -1;
1087      }
1088  }
1089  
1090  btck_BlockHash* btck_block_get_hash(const btck_Block* block)
1091  {
1092      return btck_BlockHash::create(btck_Block::get(block)->GetHash());
1093  }
1094  
1095  void btck_block_destroy(btck_Block* block)
1096  {
1097      delete block;
1098  }
1099  
1100  btck_Block* btck_block_read(const btck_ChainstateManager* chainman, const btck_BlockTreeEntry* entry)
1101  {
1102      auto block{std::make_shared<CBlock>()};
1103      if (!btck_ChainstateManager::get(chainman).m_chainman->m_blockman.ReadBlock(*block, btck_BlockTreeEntry::get(entry))) {
1104          LogError("Failed to read block.");
1105          return nullptr;
1106      }
1107      return btck_Block::create(block);
1108  }
1109  
1110  int32_t btck_block_tree_entry_get_height(const btck_BlockTreeEntry* entry)
1111  {
1112      return btck_BlockTreeEntry::get(entry).nHeight;
1113  }
1114  
1115  const btck_BlockHash* btck_block_tree_entry_get_block_hash(const btck_BlockTreeEntry* entry)
1116  {
1117      return btck_BlockHash::ref(btck_BlockTreeEntry::get(entry).phashBlock);
1118  }
1119  
1120  int btck_block_tree_entry_equals(const btck_BlockTreeEntry* entry1, const btck_BlockTreeEntry* entry2)
1121  {
1122      return &btck_BlockTreeEntry::get(entry1) == &btck_BlockTreeEntry::get(entry2);
1123  }
1124  
1125  btck_BlockHash* btck_block_hash_create(const unsigned char block_hash[32])
1126  {
1127      return btck_BlockHash::create(std::span<const unsigned char>{block_hash, 32});
1128  }
1129  
1130  btck_BlockHash* btck_block_hash_copy(const btck_BlockHash* block_hash)
1131  {
1132      return btck_BlockHash::copy(block_hash);
1133  }
1134  
1135  void btck_block_hash_to_bytes(const btck_BlockHash* block_hash, unsigned char output[32])
1136  {
1137      std::memcpy(output, btck_BlockHash::get(block_hash).begin(), 32);
1138  }
1139  
1140  int btck_block_hash_equals(const btck_BlockHash* hash1, const btck_BlockHash* hash2)
1141  {
1142      return btck_BlockHash::get(hash1) == btck_BlockHash::get(hash2);
1143  }
1144  
1145  void btck_block_hash_destroy(btck_BlockHash* hash)
1146  {
1147      delete hash;
1148  }
1149  
1150  btck_BlockSpentOutputs* btck_block_spent_outputs_read(const btck_ChainstateManager* chainman, const btck_BlockTreeEntry* entry)
1151  {
1152      auto block_undo{std::make_shared<CBlockUndo>()};
1153      if (btck_BlockTreeEntry::get(entry).nHeight < 1) {
1154          LogDebug(BCLog::KERNEL, "The genesis block does not have any spent outputs.");
1155          return btck_BlockSpentOutputs::create(block_undo);
1156      }
1157      if (!btck_ChainstateManager::get(chainman).m_chainman->m_blockman.ReadBlockUndo(*block_undo, btck_BlockTreeEntry::get(entry))) {
1158          LogError("Failed to read block spent outputs data.");
1159          return nullptr;
1160      }
1161      return btck_BlockSpentOutputs::create(block_undo);
1162  }
1163  
1164  btck_BlockSpentOutputs* btck_block_spent_outputs_copy(const btck_BlockSpentOutputs* block_spent_outputs)
1165  {
1166      return btck_BlockSpentOutputs::copy(block_spent_outputs);
1167  }
1168  
1169  size_t btck_block_spent_outputs_count(const btck_BlockSpentOutputs* block_spent_outputs)
1170  {
1171      return btck_BlockSpentOutputs::get(block_spent_outputs)->vtxundo.size();
1172  }
1173  
1174  const btck_TransactionSpentOutputs* btck_block_spent_outputs_get_transaction_spent_outputs_at(const btck_BlockSpentOutputs* block_spent_outputs, size_t transaction_index)
1175  {
1176      assert(transaction_index < btck_BlockSpentOutputs::get(block_spent_outputs)->vtxundo.size());
1177      const auto* tx_undo{&btck_BlockSpentOutputs::get(block_spent_outputs)->vtxundo.at(transaction_index)};
1178      return btck_TransactionSpentOutputs::ref(tx_undo);
1179  }
1180  
1181  void btck_block_spent_outputs_destroy(btck_BlockSpentOutputs* block_spent_outputs)
1182  {
1183      delete block_spent_outputs;
1184  }
1185  
1186  btck_TransactionSpentOutputs* btck_transaction_spent_outputs_copy(const btck_TransactionSpentOutputs* transaction_spent_outputs)
1187  {
1188      return btck_TransactionSpentOutputs::copy(transaction_spent_outputs);
1189  }
1190  
1191  size_t btck_transaction_spent_outputs_count(const btck_TransactionSpentOutputs* transaction_spent_outputs)
1192  {
1193      return btck_TransactionSpentOutputs::get(transaction_spent_outputs).vprevout.size();
1194  }
1195  
1196  void btck_transaction_spent_outputs_destroy(btck_TransactionSpentOutputs* transaction_spent_outputs)
1197  {
1198      delete transaction_spent_outputs;
1199  }
1200  
1201  const btck_Coin* btck_transaction_spent_outputs_get_coin_at(const btck_TransactionSpentOutputs* transaction_spent_outputs, size_t coin_index)
1202  {
1203      assert(coin_index < btck_TransactionSpentOutputs::get(transaction_spent_outputs).vprevout.size());
1204      const Coin* coin{&btck_TransactionSpentOutputs::get(transaction_spent_outputs).vprevout.at(coin_index)};
1205      return btck_Coin::ref(coin);
1206  }
1207  
1208  btck_Coin* btck_coin_copy(const btck_Coin* coin)
1209  {
1210      return btck_Coin::copy(coin);
1211  }
1212  
1213  uint32_t btck_coin_confirmation_height(const btck_Coin* coin)
1214  {
1215      return btck_Coin::get(coin).nHeight;
1216  }
1217  
1218  int btck_coin_is_coinbase(const btck_Coin* coin)
1219  {
1220      return btck_Coin::get(coin).IsCoinBase() ? 1 : 0;
1221  }
1222  
1223  const btck_TransactionOutput* btck_coin_get_output(const btck_Coin* coin)
1224  {
1225      return btck_TransactionOutput::ref(&btck_Coin::get(coin).out);
1226  }
1227  
1228  void btck_coin_destroy(btck_Coin* coin)
1229  {
1230      delete coin;
1231  }
1232  
1233  int btck_chainstate_manager_process_block(
1234      btck_ChainstateManager* chainman,
1235      const btck_Block* block,
1236      int* _new_block)
1237  {
1238      bool new_block;
1239      auto result = btck_ChainstateManager::get(chainman).m_chainman->ProcessNewBlock(btck_Block::get(block), /*force_processing=*/true, /*min_pow_checked=*/true, /*new_block=*/&new_block);
1240      if (_new_block) {
1241          *_new_block = new_block ? 1 : 0;
1242      }
1243      return result ? 0 : -1;
1244  }
1245  
1246  const btck_Chain* btck_chainstate_manager_get_active_chain(const btck_ChainstateManager* chainman)
1247  {
1248      return btck_Chain::ref(&WITH_LOCK(btck_ChainstateManager::get(chainman).m_chainman->GetMutex(), return btck_ChainstateManager::get(chainman).m_chainman->ActiveChain()));
1249  }
1250  
1251  int btck_chain_get_height(const btck_Chain* chain)
1252  {
1253      LOCK(::cs_main);
1254      return btck_Chain::get(chain).Height();
1255  }
1256  
1257  const btck_BlockTreeEntry* btck_chain_get_by_height(const btck_Chain* chain, int height)
1258  {
1259      LOCK(::cs_main);
1260      return btck_BlockTreeEntry::ref(btck_Chain::get(chain)[height]);
1261  }
1262  
1263  int btck_chain_contains(const btck_Chain* chain, const btck_BlockTreeEntry* entry)
1264  {
1265      LOCK(::cs_main);
1266      return btck_Chain::get(chain).Contains(&btck_BlockTreeEntry::get(entry)) ? 1 : 0;
1267  }