remove get_block utility command

Author: jhunsaker

pc/request.cpp

@@ -258,47 +258,6 @@ void get_mapping::update( T *res )
   cptr->write( (pc_pub_key_t*)mkey_.data(), (pc_acc_t*)tab );
 }
 
-///////////////////////////////////////////////////////////////////////////
-// get_block
-
-get_block::get_block()
-: st_( e_sent )
-{
-}
-
-void get_block::set_slot( uint64_t slot )
-{
-  req_->set_slot( slot );
-}
-
-void get_block::set_commitment( commitment cmt )
-{
-  req_->set_commitment( cmt );
-}
-
-void get_block::on_response( rpc::get_block *res )
-{
-  if ( res->get_is_err() ) {
-    on_error_sub( res->get_err_msg(), this );
-    st_ = e_error;
-  } else if ( st_ == e_sent && res->get_is_end() ) {
-    st_ = e_done;
-  }
-}
-
-bool get_block::get_is_done() const
-{
-  return st_ == e_done;
-}
-
-void get_block::submit()
-{
-  st_ = e_sent;
-  req_->set_sub( this );
-  req_->set_program( get_manager()->get_program_pub_key() );
-  get_rpc_client()->send( req_ );
-}
-
 ///////////////////////////////////////////////////////////////////////////
 // product
 

pc/request.hpp

@@ -146,24 +146,6 @@ namespace pc
     rpc::get_account_info areq_[1];
   };
 
-  // get transactions in single block
-  class get_block : public request,
-                    public rpc_sub_i<rpc::get_block>
-  {
-  public:
-    get_block();
-    void set_slot( uint64_t slot );
-    void set_commitment( commitment cmt );
-  public:
-    void submit() override;
-    void on_response( rpc::get_block * ) override;
-    bool get_is_done() const override;
-  protected:
-    typedef enum { e_sent, e_done, e_error } state_t;
-    state_t st_;
-    rpc::get_block req_[1];
-  };
-
   // product symbol and other reference-data attributes
   class product : public request,
                   public attr_dict,

pc/rpc_client.cpp

@@ -753,118 +753,6 @@ bool rpc::get_program_accounts::get_is_http() const
   return true;
 }
 
-///////////////////////////////////////////////////////////////////////////
-// get_block
-
-void rpc::get_block::set_slot( uint64_t slot )
-{
-  bslot_ = slot;
-}
-
-void rpc::get_block::set_commitment( commitment cmt )
-{
-  cmt_ = cmt;
-}
-
-void rpc::get_block::set_program( pub_key *gkey )
-{
-  gkey_ = gkey;
-}
-
-void rpc::get_block::request( json_wtr& msg )
-{
-  msg.add_key( "method", "getConfirmedBlock" );
-  msg.add_key( "params", json_wtr::e_arr );
-  msg.add_val( bslot_ );
-  msg.add_val( json_wtr::e_obj );
-  msg.add_key( "encoding", "json" );
-  msg.add_key( "rewards", json_wtr::jfalse() );
-  msg.add_key( "commitment", commitment_to_str( cmt_ ) );
-  msg.pop();
-  msg.pop();
-}
-
-unsigned rpc::get_block::get_num_key() const
-{
-  return kvec_.size();
-}
-
-pub_key *rpc::get_block::get_key( unsigned i )
-{
-  return &kvec_[i];
-}
-
-char *rpc::get_block::get_cmd()
-{
-  return &ibuf_[0];
-}
-
-bool rpc::get_block::get_is_tx_err() const
-{
-  return is_tx_err_;
-}
-
-uint64_t rpc::get_block::get_tx_fee() const
-{
-  return fee_;
-}
-
-str rpc::get_block::get_tx_err() const
-{
-  return tx_err_;
-}
-
-bool rpc::get_block::get_is_end() const
-{
-  return is_end_;
-}
-
-void rpc::get_block::response( const jtree& jt )
-{
-  if ( on_error( jt, this ) ) return;
-  is_end_ = false;
-  uint32_t rtok = jt.find_val( 1, "result" );
-  uint32_t ttok = jt.find_val( rtok, "transactions" );
-  for( uint32_t it = jt.get_first( ttok ); it; it = jt.get_next( it ) ) {
-    uint32_t tx = jt.find_val( it, "transaction" );
-    uint32_t ms = jt.find_val( tx, "message" );
-    // determine if this is a pyth transaction
-    uint32_t ak = jt.find_val( ms, "accountKeys" );
-    bool found = false;
-    pub_key ikey;
-    kvec_.clear();
-    for( uint32_t at = jt.get_first( ak ); at; at = jt.get_next( at ) ) {
-      ikey.init_from_text( jt.get_str( at ) );
-      kvec_.push_back( ikey );
-      if ( ikey == *gkey_ ) {
-        found = true;
-      }
-    }
-    if ( !found ) continue;
-    // get meta-data
-    is_tx_err_ = false;
-    fee_ = 0UL;
-    uint32_t mx = jt.find_val( it, "meta" );
-    if ( mx && jt.get_type( mx ) == jtree::e_obj ) {
-      fee_ = jt.get_uint( jt.find_val( mx, "fee" ) );
-      uint32_t ex = jt.find_val( mx, "err" );
-      if ( ex && jt.get_type( ex ) == jtree::e_obj ) {
-        is_tx_err_ = true;
-        tx_err_ = jt.get_str( jt.get_key( jt.get_first( ex ) ) );
-      }
-    }
-    // get transaction details
-    uint32_t ix = jt.find_val( ms, "instructions" );
-    str idata = jt.get_str( jt.find_val( jt.get_first( ix ), "data" ) );
-    ibuf_.resize( idata.len_ );
-    dec_base58( (const uint8_t*)idata.str_, idata.len_,
-                (uint8_t*)&ibuf_[0] );
-    on_response( this );
-  }
-  is_end_ = true;
-  on_response( this );
-}
-
 ///////////////////////////////////////////////////////////////////////////
 // upd_price
 

pc/rpc_client.hpp

@@ -391,38 +391,6 @@ namespace pc
       uint32_t    acct_type_;
     };
 
-    // get all (pyth) transactions in a slot
-    class get_block : public rpc_request
-    {
-    public:
-      void set_slot( uint64_t slot );
-      void set_commitment( commitment );
-      void set_program( pub_key * );
-      void request( json_wtr& ) override;
-      void response( const jtree& ) override;
-      uint64_t get_fee() const;
-      bool     get_is_tx_err() const;
-      str      get_tx_err() const;
-      uint64_t get_tx_fee() const;
-      unsigned get_num_key() const;
-      pub_key *get_key( unsigned i );
-      char    *get_cmd();
-      bool     get_is_end() const;
-
-    private:
-      typedef std::vector<pub_key> key_vec_t;
-      typedef std::vector<char>    ins_vec_t;
-      uint64_t bslot_;
-      commitment cmt_;
-      pub_key   *gkey_;
-      key_vec_t  kvec_;
-      ins_vec_t  ibuf_;
-      uint64_t   fee_;
-      str        tx_err_;
-      bool       is_end_;
-      bool       is_tx_err_;
-    };
-
     // set new component price
     class upd_price : public tx_request, public rpc_request
     {