Implement devel, engine, mempool, net rpc functions

Author: Seongjae Choi

devel.go

@@ -0,0 +1,44 @@
+package rpc
+
+type Devel struct {
+rpcClient rpcClient
+}
+
+func (d *Devel) GetStateTrieKeys(offset int, limit int) ([]string, error) {
+const method = "devel_getStateTrieKeys"
+var keys []string
+err := d.rpcClient.call(callInterface{method: method, id: ""}, &keys, offset, limit)
+return keys, err
+}
+
+func (d *Devel) GetStateTrieValue(key string) ([]string, error) {
+const method = "devel_getStateTrieValue"
+var keys []string
+err := d.rpcClient.call(callInterface{method: method, id: ""}, &keys, key)
+return keys, err
+}
+
+func (d *Devel) StartSealing() error {
+const method = "devel_startSealing"
+return d.rpcClient.call(callInterface{method: method, id: ""}, nil)
+}
+
+func (d *Devel) stopSealing() error {
+const method = "devel_stopSealing"
+err := d.rpcClient.call(callInterface{method: method, id: ""}, nil)
+return err
+}
+
+func (d *Devel) getBlockSyncPeers() ([]string, error) {
+const method = "devel_getBlockSyncPeers"
+var result []string
+err := d.rpcClient.call(callInterface{method: method, id: ""}, &result)
+return result, err
+}
+
+func (d *Devel) testTPS(count int, seed int, option string) (int, error) {
+const method = "devel_testTPS"
+var result int
+err := d.rpcClient.call(callInterface{method: method, id: ""}, &result, count, seed, option)
+return result, err
+}

engine.go

@@ -0,0 +1,33 @@
+package rpc
+
+type Engine struct {
+rpcClient rpcClient
+}
+
+func (e *Engine) GetCoinbase() (string, error) {
+const method = "engine_getCoinbase"
+var result string
+err := e.rpcClient.call(callInterface{method: method, id: ""}, &result)
+return result, err
+}
+
+func (e *Engine) GetBlockReward(blockNumber int) (interface{}, error) {
+const method = "engine_getBlockReward"
+var result interface{}
+err := e.rpcClient.call(callInterface{method: method, id: ""}, &result, blockNumber)
+return result, err
+}
+
+func (e *Engine) GetRecommendedConfirmation() (int, error) {
+const method = "engine_getRecommendedConfirmation"
+var result int
+err := e.rpcClient.call(callInterface{method: method, id: ""}, &result)
+return result, err
+}
+
+func (e *Engine) GetCustomActionData(handerID int, bytes string, blockNumber int) (string, error) {
+const method = "engine_getCustomActionData"
+var result string
+err := e.rpcClient.call(callInterface{method: method, id: ""}, &result, handerID, bytes, blockNumber)
+return result, err
+}

mempool.go

@@ -0,0 +1,34 @@
+package rpc
+
+type Mempool struct {
+rpcClient rpcClient
+}
+
+func (m *Mempool) SendSignedTransaction(tx string) (string, error) {
+const method = "mempool_sendSignedTransaction"
+var result string
+err := m.rpcClient.call(callInterface{method: method, id: ""}, &result, tx)
+return result, err
+}
+
+func (m *Mempool) GetErrorHint(transactionHash string) (string, error) {
+const method = "mempool_getErrorHint"
+var result string
+err := m.rpcClient.call(callInterface{method: method, id: ""}, &result, transactionHash)
+return result, err
+
+}
+
+func (m *Mempool) GetTransactionResultsByTracker(tracker string) ([]bool, error) {
+const method = "mempool_getTransactionResultsByTracker"
+var result []bool
+err := m.rpcClient.call(callInterface{method: method, id: ""}, &result, tracker)
+return result, err
+}
+
+func (m *Mempool) GetPendingTransactions(from int, to int) (interface{}, error) {
+const method = "mempool_getPendingTransactions"
+var result interface{}
+err := m.rpcClient.call(callInterface{method: method, id: ""}, from, to)
+return result, err
+}

net.go

@@ -0,0 +1,118 @@
+package rpc
+
+type Net struct {
+rpcClient rpcClient
+}
+
+func (n *Net) LocalKeyFor(address string, port int) (string, error) {
+const method = "net_localKeyFor"
+var result string
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &result, address, port)
+return result, err
+}
+
+func (n *Net) RegisterRemoteKeyFor(address string, port int, remotePublicKey string) (string, error) {
+const method = "net_registerRemoteKeyFor"
+var result string
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &result, address, port, remotePublicKey)
+return result, err
+}
+
+func (n *Net) Connect(address string, port int) error {
+const method = "net_connect"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil, address, port)
+}
+
+func (n *Net) IsConnected(address string, port int) (bool, error) {
+const method = "net_isConnected"
+var result bool
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &result, address, port)
+return result, err
+}
+
+func (n *Net) Disconnect(address string, port int) error {
+const method = "net_disconnect"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil, address, port)
+}
+
+func (n *Net) GetPeerCount() (int, error) {
+const method = "net_getPeerCount"
+var result int
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &result)
+return result, err
+}
+
+func (n *Net) GetEstablishedPeers() ([]string, error) {
+const method = "net_getEstablishedPeers"
+var result []string
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &result)
+return result, err
+}
+
+func (n *Net) GetPort() (int, error) {
+const method = "net_getPort"
+var port int
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &port)
+return port, err
+}
+
+func (n *Net) AddToWhitelist(address string, tag string) error {
+const method = "net_addToWhitelist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil, address, tag)
+}
+
+func (n *Net) RemoveFromWhitelist(address string) error {
+const method = "net_removeFromWhitelist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil, address)
+}
+
+func (n *Net) AddToBlacklist(address string, tag string) error {
+const method = "net_addToBlacklist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil, address, tag)
+}
+
+func (n *Net) RemoveFromBlacklist(address string) error {
+const method = "net_removeFromBlacklist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil, address)
+}
+
+func (n *Net) EnableWhitelist() error {
+const method = "net_enableWhitelist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil)
+}
+
+func (n *Net) DisableWhitelist() error {
+const method = "net_disableWhitelist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil)
+}
+
+func (n *Net) EnableBlacklist() error {
+const method = "net_enableBlacklist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil)
+}
+
+func (n *Net) DisableBlacklist() error {
+const method = "net_disableBlacklist"
+return n.rpcClient.call(callInterface{method: method, id: ""}, nil)
+}
+
+func (n *Net) GetWhitelist() (interface{}, error) {
+const method = "net_getWhitelist"
+var reusult interface{}
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &reusult)
+return reusult, err
+}
+
+func (n *Net) GetBlacklist() (interface{}, error) {
+const method = "net_getBlacklist"
+var reusult interface{}
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &reusult)
+return reusult, err
+}
+
+func (n *Net) RecentNetworkUsage() (interface{}, error) {
+const method = "net_recentNetworkUsage"
+var reusult interface{}
+err := n.rpcClient.call(callInterface{method: method, id: ""}, &reusult)
+return reusult, err
+}

rpc.go

@@ -5,6 +5,10 @@ type RPC struct {
 rpcClient rpcClient
 account Account
 chain Chain
+devel Devel
+engine Engine
+mempool Mempool
+net Net
 }
 
 // NewRPC is a constructor of RPC
@@ -14,7 +18,9 @@ func NewRPC(nodeURL string) RPC {
 rpcClient: rpcClient,
 account: Account{rpcClient},
 chain: Chain{rpcClient},
-}
+devel: Devel{rpcClient},
+engine: Engine{rpcClient},
+mempool: Mempool{rpcClient}}
 }
 
 // Ping sends request to node