Class: Casper::CasperClient

Inherits:
Object
  • Object
show all
Defined in:
lib/casper_network.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(ip_address) ⇒ CasperClient

Constructor

Parameters:

  • ip_address (String) 


26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/casper_network.rb', line 26

def initialize(ip_address)
  @ip_address = ip_address
  @url = "http://" + @ip_address + ":7777/rpc"
  @state_root_hash = ""
  @peer_array = []
  @block_hash = ""
  @deploy = {}
  @node_status = {}
  @block_transfers = []
  @block_info = {}
  @era_summary = {}
  @balance_value = ""
  @auction_state = {}
 
  @rpc_error = Casper::RpcError::ErrorHandle.new
  @err = @rpc_error.error_handling(@url)

  @pr = []

end

Instance Attribute Details

#ip_address ⇒ Object

Returns the value of attribute ip_address.



22
23
24
 
# File 'lib/casper_network.rb', line 22

def ip_address
  @ip_address
end

#port ⇒ Object

Returns the value of attribute port.



22
23
24
 
# File 'lib/casper_network.rb', line 22

def port
  @port
end

#state_root_hash ⇒ Object

Returns the value of attribute state_root_hash.



22
23
24
 
# File 'lib/casper_network.rb', line 22

def state_root_hash
  @state_root_hash
end

#url ⇒ Object

Returns the value of attribute url.



22
23
24
 
# File 'lib/casper_network.rb', line 22

def url
  @url
end

Instance Method Details

#chain_get_block(block_hash) ⇒ Hash

Returns block_info.

Parameters:

  • block_hash (String)

Returns:

  • (Hash) —

    block_info



171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
 
# File 'lib/casper_network.rb', line 171

def chain_get_block(block_hash)
  begin 
    state = Timeout::timeout(10) {
      client = Jimson::Client.new(@url)
      result = client.chain_get_block({"block_identifier" => {"Hash" => block_hash}})
      @block_info = result["block"]
      if (!@block_info.empty?() && @block_info["hash"] != block_hash)
        raise("Returned block does not have a matching hash.")
      else
        @block_info
      end
    }
  rescue
    Casper::RpcError::InvalidParameter.error
  end
end

#chain_get_block_transfers(block_hash = "") ⇒ Array<Hash>

Returns block_transfers.

Parameters:

  • block_hash (String) (defaults to: "")

Returns:

  • (Array<Hash>) —

    block_transfers



154
155
156
157
158
159
160
161
162
163
164
165
166
167
 
# File 'lib/casper_network.rb', line 154

def chain_get_block_transfers(block_hash = "") 
  begin
    status = Timeout::timeout(5) {
      client = Jimson::Client.new(@url)
      response = client.chain_get_block_transfers({
        "block_identifier" => {"Hash" => block_hash}
      })
      @transfers = response["transfers"]
      @transfers.map { |transfer| Casper::Entity::Transfer.new(transfer.deep_symbolize_keys!)}
    }
  rescue
    Casper::RpcError::InvalidParameter.error
  end
end

#chain_get_eraInfo_by_SwitchBlock(block_hash) ⇒ Hash

Returns era_summary.

Parameters:

  • block_hash (String)

Returns:

  • (Hash) —

    era_summary



190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
 
# File 'lib/casper_network.rb', line 190

def chain_get_eraInfo_by_SwitchBlock(block_hash)
  begin
    state = Timeout::timeout(10) {
    client = Jimson::Client.new(@url)
    response = client.chain_get_era_info_by_switch_block("block_identifier" => {"Hash" => block_hash})
    @era_summary = response["era_summary"]
    
    if @era_summary == nil
      Casper::RpcError::InvalidParameter.error
    else
      @era_summary
    end
    }
  rescue
    Casper::RpcError::InvalidParameter.error
  end
end

#chain_get_StateRootHash(block_hash = "") ⇒ String

Returns state_root_hash value.

Returns:

  • (String) —

    state_root_hash value



81
82
83
84
85
86
87
88
89
90
91
92
 
# File 'lib/casper_network.rb', line 81

def chain_get_StateRootHash(block_hash = "")
  begin 
    status = Timeout::timeout(10) {
      client = Jimson::Client.new(@url)
      result = client.chain_get_state_root_hash
      @state_root_hash = result["state_root_hash"]
    }
  rescue
    @rpc_error = Casper::RpcError::ErrorHandle.new
    @error = @rpc_error.error_handling(@url)
  end
end

#get_error ⇒ Object 



47
48
49
 
# File 'lib/casper_network.rb', line 47

def get_error 
  @err
end

#info_get_deploy(deploy_hash) ⇒ Hash

Get information about a single deploy by hash. def info_get_deploy(deploy_hash)

begin
  status = Timeout::timeout(10) {
    client = Jimson::Client.new(@url)
    response = client.info_get_deploy({"deploy_hash"=> deploy_hash })
    if (deploy_hash == "" || deploy_hash == nil)
      Casper::RpcError::InvalidParameter.error
    end
    @deploy = response["deploy"]
    # @deploy.keys.each do |key|  
    #     @deploy[(key.to_sym rescue key) || key] = @deploy.delete(key)
    # end
    @deploy
  }
rescue
  Casper::RpcError::InvalidParameter.error 
end

end

Parameters:

  • deploy_hash (String)

Returns:

  • (Hash) —

    Deploy



115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
 
# File 'lib/casper_network.rb', line 115

def info_get_deploy(deploy_hash)
  @dep = nil
  begin
    status = Timeout::timeout(60) {
      client = Jimson::Client.new(@url)
      response = client.info_get_deploy({"deploy_hash"=> deploy_hash })
      if (deploy_hash == "" || deploy_hash == nil)
        Casper::RpcError::InvalidParameter.error
      end
      # @deploy.keys.each do |key|  
      #     @deploy[(key.to_sym rescue key) || key] = @deploy.delete(key)
      # end
      temp = []
      @deploy = response["deploy"]
      @deploy.deep_symbolize_keys!
      Casper::Entity::Deploy.new(@deploy[:hash], @deploy[:header], @deploy[:payment], @deploy[:session], @deploy[:approvals])
    }
  rescue
    Casper::RpcError::InvalidParameter.error 
  end
end

#info_get_peers ⇒ Array<Hash>

Returns peers array.

Returns:

  • (Array<Hash>) —

    peers array



64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/casper_network.rb', line 64

def info_get_peers
    begin
      client = Jimson::Client.new(@url)
      response = client.info_get_peers
      @peers = response["peers"]
      # @peers.map! do |peer|
      #   peer.symbolize_keys
      # end
      @peers.map { |item| @pr << Casper::Entity::Peer.new(item.symbolize_keys) }
      @pr
    rescue
      @rpc_error = Casper::RpcError::ErrorHandle.new
      @error = @rpc_error.error_handling(@url)
    end
end

#info_get_status ⇒ Object

Receive node status information

Returns:

  • node_status



140
141
142
143
144
145
146
147
148
149
150
 
# File 'lib/casper_network.rb', line 140

def info_get_status
  begin
    status = Timeout::timeout(10) {
      client = Jimson::Client.new(@url)
      @node_status = client.info_get_status
    }
  rescue
    @rpc_error = Casper::RpcError::ErrorHandle.new
    @error = @rpc_error.error_handling(@url)
  end
end

#put_deploy(deploy) ⇒ Object 



281
282
283
284
285
 
# File 'lib/casper_network.rb', line 281

def put_deploy(deploy)
  client = Jimson::Client.new(url)
  response = client.(deploy)
  response['deploy_hash']
end

#state_get_AuctionInfo ⇒ Hash

Returns current auction system contract information.

Returns:

  • (Hash) —

    auction_state



267
268
269
270
271
272
273
274
275
276
277
278
279
 
# File 'lib/casper_network.rb', line 267

def state_get_AuctionInfo
  begin 
    state = Timeout::timeout(50) {
    client = Jimson::Client.new(@url)
    response = client.state_get_auction_info
    @auction_state = response['auction_state']
    @auction_state
    }
  rescue
    @rpc_error = Casper::RpcError::ErrorHandle.new
    @error = @rpc_error.error_handling(@url)
  end
end

#state_get_balance(state_root_hash, balance_uref) ⇒ Object

Parameters:

  • state_root_hash (String)
  • balance_uref (String) 


249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
 
# File 'lib/casper_network.rb', line 249

def state_get_balance(state_root_hash, balance_uref)
  begin
    state = Timeout::timeout(5) {
      client = Jimson::Client.new(@url)
      response = client.state_get_balance({
        "state_root_hash" => state_root_hash,
        "purse_uref" => balance_uref
      })
      @balance_value = response["balance_value"]
      @balance_value
    }
  rescue
    Casper::RpcError::InvalidParameter.error
  end
end

#state_get_dictionary_item(state_root_hash, item_key, uref) ⇒ Object

Parameters:

  • state_root_hash (String)
  • item_key (String)
  • uref (String) 


231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
 
# File 'lib/casper_network.rb', line 231

def state_get_dictionary_item(state_root_hash, item_key, uref)
  begin
    state = Timeout::timeout(10) {
      client = Jimson::Client.new(@url)
      response = client.state_get_dictionary_item({
        "state_root_hash" => state_root_hash,
        "dictionary_identifier" => {'URef' => 
          {'seed_uref' => uref, 'dictionary_item_key' => item_key} }})
        @stored_value = response["stored_value"]
        @stored_value
    }
  rescue
    Casper::RpcError::InvalidParameter.error
  end
end

#state_get_item(state_root_hash, key, path) ⇒ Object

Parameters:

  • state_root_hash (String)
  • key (String)
  • path (Array) 


211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
 
# File 'lib/casper_network.rb', line 211

def state_get_item(state_root_hash, key, path)
  begin
    state = Timeout::timeout(20) {
      client = Jimson::Client.new(@url)
      response = client.state_get_item({ 
        "state_root_hash" => state_root_hash, 
        "key" => key,
        "path" => path
      })
      @stored_value = response["stored_value"]
      @stored_value
    }
  rescue
    Casper::RpcError::InvalidParameter.error
  end
end