get_all_accounts and blockchain_audit_tool

plugins/chain_api_plugin/chain_api_plugin.cpp

@@ -140,7 +140,8 @@ void chain_api_plugin::plugin_startup() {
       CHAIN_RW_CALL_ASYNC(push_transaction, chain_apis::read_write::push_transaction_results, 202, http_params_types::params_required),
       CHAIN_RW_CALL_ASYNC(push_transactions, chain_apis::read_write::push_transactions_results, 202, http_params_types::params_required),
       CHAIN_RW_CALL_ASYNC_V2(send_transaction, chain_apis::read_write::push_transaction_results, 202, http_params_types::params_required),
-      CHAIN_RW_CALL_ASYNC(send_transaction, chain_apis::read_write::send_transaction_results, 202, http_params_types::params_required)
+      CHAIN_RW_CALL_ASYNC(send_transaction, chain_apis::read_write::send_transaction_results, 202, http_params_types::params_required),
+      CHAIN_RO_CALL(get_all_accounts, 200, http_params_types::params_required)
    });
 
    if (chain.account_queries_enabled()) {

plugins/chain_plugin/chain_plugin.cpp

@@ -3356,6 +3356,57 @@ eosio::chain::backing_store_type read_only::get_backing_store() const {
    return kv_database.get_backing_store();
 }
 
+read_only::get_all_accounts_result
+read_only::get_all_accounts( const get_all_accounts_params& params ) const
+{
+   get_all_accounts_result result;
+
+   using acct_obj_idx_type = chainbase::get_index_type<chain::account_object>::type;
+   const auto& accts = db.db().get_index<acct_obj_idx_type >().indices().get<chain::by_name>();
+
+   auto cur_time = fc::time_point::now();
+   auto end_time = cur_time + fc::microseconds(1000 * 10); /// 10ms max time
+
+   auto begin_itr = params.lower_bound? accts.lower_bound(*params.lower_bound) : accts.begin();
+   auto end_itr = params.upper_bound? accts.upper_bound(*params.upper_bound) : accts.end();
+
+   if( std::distance(begin_itr, end_itr) < 0 )
+      return result;
+
+   auto itr = params.reverse? end_itr : begin_itr;
+   // since end_itr could potentially be past end of array, subtract one position
+   if (params.reverse)
+      --itr;
+
+   // this flag will be set to true when we are reversing and we end on the begin iterator
+   // if this is the case, 'more' field will remain null, and will nto be in JSON response
+   bool reverse_end_begin = false;
+
+   while(cur_time <= end_time
+         && result.accounts.size() < params.limit
+         && itr != end_itr)
+   {
+      const auto &a = *itr;
+      result.accounts.push_back({a.name, a.creation_date});
+
+      cur_time = fc::time_point::now();
+      if (params.reverse && itr == begin_itr) {
+         reverse_end_begin = true;
+         break;
+      }
+      params.reverse? --itr : ++itr;
+   }
+
+   if (params.reverse && !reverse_end_begin) {
+      result.more = itr->name;
+   }
+   else if (!params.reverse && itr != end_itr) {
+      result.more = itr->name;
+   }
+
+   return result;
+}
+
 } // namespace chain_apis
 
 fc::variant chain_plugin::get_entire_trx_trace(const transaction_trace_ptr& trx_trace )const {

plugins/chain_plugin/include/eosio/chain_plugin/chain_plugin.hpp

@@ -925,6 +925,25 @@ class read_only {
 
    chain::symbol extract_core_symbol()const;
 
+   struct get_all_accounts_result {
+      struct account_result {
+         chain::name                          name;
+         chain::block_timestamp_type          creation_date;
+      };
+
+      std::vector<account_result> accounts;
+
+      std::optional<chain::name> more;
+   };
+
+   struct get_all_accounts_params {
+      uint32_t                    limit = 10;
+      std::optional<chain::name>  lower_bound;
+      std::optional<chain::name>  upper_bound;
+      bool                        reverse = false;
+   };
+
+   get_all_accounts_result get_all_accounts( const get_all_accounts_params& params)  const;
 };
 
 class read_write {
@@ -1150,4 +1169,6 @@ FC_REFLECT( eosio::chain_apis::read_only::get_required_keys_params, (transaction
 FC_REFLECT( eosio::chain_apis::read_only::get_required_keys_result, (required_keys) )
 FC_REFLECT( eosio::chain_apis::read_only::send_ro_transaction_params_v1, (return_failure_traces)(transaction) )
 FC_REFLECT( eosio::chain_apis::read_only::send_ro_transaction_results, (head_block_num)(head_block_id)(last_irreversible_block_num)(last_irreversible_block_id)(code_hash)(pending_transactions)(result) )
-
+FC_REFLECT( eosio::chain_apis::read_only::get_all_accounts_params, (limit)(lower_bound)(upper_bound)(reverse) )
+FC_REFLECT( eosio::chain_apis::read_only::get_all_accounts_result::account_result, (name)(creation_date))
+FC_REFLECT( eosio::chain_apis::read_only::get_all_accounts_result, (accounts)(more))

scripts/CMakeLists.txt

@@ -4,4 +4,5 @@ configure_file(eosio-tn_down.sh eosio-tn_down.sh COPYONLY)
 configure_file(eosio-tn_roll.sh eosio-tn_roll.sh COPYONLY)
 configure_file(eosio-tn_up.sh eosio-tn_up.sh COPYONLY)
 configure_file(abi_is_json.py abi_is_json.py COPYONLY)
-configure_file(postgres_control.sh postgres_control.sh COPYONLY)
+configure_file(postgres_control.sh postgres_control.sh COPYONLY)
+configure_file(blockchain_audit_tool.py blockchain_audit_tool.py COPYONLY)