aboutsummaryrefslogtreecommitdiff
path: root/utils/python-rpc/framework
diff options
context:
space:
mode:
Diffstat (limited to 'utils/python-rpc/framework')
-rw-r--r--utils/python-rpc/framework/daemon.py120
-rw-r--r--utils/python-rpc/framework/wallet.py114
2 files changed, 223 insertions, 11 deletions
diff --git a/utils/python-rpc/framework/daemon.py b/utils/python-rpc/framework/daemon.py
index f60fe62db..f4d5e90f0 100644
--- a/utils/python-rpc/framework/daemon.py
+++ b/utils/python-rpc/framework/daemon.py
@@ -33,14 +33,17 @@ from .rpc import JSONRPC
class Daemon(object):
def __init__(self, protocol='http', host='127.0.0.1', port=0, idx=0):
+ self.host = host
+ self.port = port
self.rpc = JSONRPC('{protocol}://{host}:{port}'.format(protocol=protocol, host=host, port=port if port else 18180+idx))
- def getblocktemplate(self, address):
+ def getblocktemplate(self, address, prev_block = ""):
getblocktemplate = {
'method': 'getblocktemplate',
'params': {
'wallet_address': address,
- 'reserve_size' : 1
+ 'reserve_size' : 1,
+ 'prev_block' : prev_block,
},
'jsonrpc': '2.0',
'id': '0'
@@ -143,13 +146,15 @@ class Daemon(object):
}
return self.rpc.send_json_rpc_request(hard_fork_info)
- def generateblocks(self, address, blocks=1):
+ def generateblocks(self, address, blocks=1, prev_block = "", starting_nonce = 0):
generateblocks = {
'method': 'generateblocks',
'params': {
'amount_of_blocks' : blocks,
'reserve_size' : 20,
- 'wallet_address': address
+ 'wallet_address': address,
+ 'prev_block': prev_block,
+ 'starting_nonce': starting_nonce,
},
'jsonrpc': '2.0',
'id': '0'
@@ -217,3 +222,110 @@ class Daemon(object):
'id': '0'
}
return self.rpc.send_json_rpc_request(get_version)
+
+ def get_bans(self):
+ get_bans = {
+ 'method': 'get_bans',
+ 'params': {
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_bans)
+
+ def set_bans(self, bans = []):
+ set_bans = {
+ 'method': 'set_bans',
+ 'params': {
+ 'bans': bans
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(set_bans)
+
+ def get_transactions(self, txs_hashes = [], decode_as_json = False, prune = False, split = False):
+ get_transactions = {
+ 'txs_hashes': txs_hashes,
+ 'decode_as_json': decode_as_json,
+ 'prune': prune,
+ 'split': split,
+ }
+ return self.rpc.send_request('/get_transactions', get_transactions)
+
+ def get_outs(self, outputs = [], get_txid = False):
+ get_outs = {
+ 'outputs': outputs,
+ 'get_txid': get_txid,
+ }
+ return self.rpc.send_request('/get_outs', get_outs)
+
+ def get_coinbase_tx_sum(self, height, count):
+ get_coinbase_tx_sum = {
+ 'method': 'get_coinbase_tx_sum',
+ 'params': {
+ 'height': height,
+ 'count': count,
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_coinbase_tx_sum)
+
+ def get_output_distribution(self, amounts = [], from_height = 0, to_height = 0, cumulative = False, binary = False, compress = False):
+ get_output_distribution = {
+ 'method': 'get_output_distribution',
+ 'params': {
+ 'amounts': amounts,
+ 'from_height': from_height,
+ 'to_height': to_height,
+ 'cumulative': cumulative,
+ 'binary': binary,
+ 'compress': compress,
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_output_distribution)
+
+ def get_output_histogram(self, amounts = [], min_count = 0, max_count = 0, unlocked = False, recent_cutoff = 0):
+ get_output_histogram = {
+ 'method': 'get_output_histogram',
+ 'params': {
+ 'amounts': amounts,
+ 'min_count': min_count,
+ 'max_count': max_count,
+ 'unlocked': unlocked,
+ 'recent_cutoff': recent_cutoff,
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_output_histogram)
+
+ def set_log_level(self, level):
+ set_log_level = {
+ 'level': level,
+ }
+ return self.rpc.send_request('/set_log_level', set_log_level)
+
+ def set_log_categories(self, categories = ''):
+ set_log_categories = {
+ 'categories': categories,
+ }
+ return self.rpc.send_request('/set_log_categories', set_log_categories)
+
+ def get_alt_blocks_hashes(self):
+ get_alt_blocks_hashes = {
+ }
+ return self.rpc.send_request('/get_alt_blocks_hashes', get_alt_blocks_hashes)
+
+ def get_alternate_chains(self):
+ get_alternate_chains = {
+ 'method': 'get_alternate_chains',
+ 'params': {
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_alternate_chains)
diff --git a/utils/python-rpc/framework/wallet.py b/utils/python-rpc/framework/wallet.py
index ea683b8c5..a80aaefec 100644
--- a/utils/python-rpc/framework/wallet.py
+++ b/utils/python-rpc/framework/wallet.py
@@ -33,6 +33,8 @@ from .rpc import JSONRPC
class Wallet(object):
def __init__(self, protocol='http', host='127.0.0.1', port=0, idx=0):
+ self.host = host
+ self.port = port
self.rpc = JSONRPC('{protocol}://{host}:{port}'.format(protocol=protocol, host=host, port=port if port else 18090+idx))
def make_uniform_destinations(self, address, transfer_amount, transfer_number_of_destinations=1):
@@ -89,6 +91,18 @@ class Wallet(object):
}
return self.rpc.send_json_rpc_request(transfer)
+ def get_transfer_by_txid(self, txid, account_index = 0):
+ get_transfer_by_txid = {
+ 'method': 'get_transfer_by_txid',
+ 'params': {
+ 'txid': txid,
+ 'account_index': account_index,
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_transfer_by_txid)
+
def get_bulk_payments(self, payment_ids = [], min_block_height = 0):
get_bulk_payments = {
'method': 'get_bulk_payments',
@@ -101,24 +115,25 @@ class Wallet(object):
}
return self.rpc.send_json_rpc_request(get_bulk_payments)
- def describe_transfer(self, unsigned_txset):
+ def describe_transfer(self, unsigned_txset = '', multisig_txset = ''):
describe_transfer = {
'method': 'describe_transfer',
'params': {
'unsigned_txset': unsigned_txset,
+ 'multisig_txset': multisig_txset,
},
'jsonrpc': '2.0',
'id': '0'
}
return self.rpc.send_json_rpc_request(describe_transfer)
- def create_wallet(self, index=''):
+ def create_wallet(self, filename='', password = '', language = 'English'):
create_wallet = {
'method': 'create_wallet',
'params': {
- 'filename': 'testWallet' + index,
- 'password' : '',
- 'language' : 'English'
+ 'filename': filename,
+ 'password': password,
+ 'language': language
},
'jsonrpc': '2.0',
'id': '0'
@@ -146,11 +161,23 @@ class Wallet(object):
}
return self.rpc.send_json_rpc_request(sweep_dust)
- def sweep_all(self, address):
+ def sweep_all(self, address = '', account_index = 0, subaddr_indices = [], priority = 0, ring_size = 0, outputs = 1, unlock_time = 0, payment_id = '', get_tx_keys = False, below_amount = 0, do_not_relay = False, get_tx_hex = False, get_tx_metadata = False):
sweep_all = {
'method': 'sweep_all',
'params' : {
- 'address' : ''
+ 'address' : address,
+ 'account_index' : account_index,
+ 'subaddr_indices' : subaddr_indices,
+ 'priority' : priority,
+ 'ring_size' : ring_size,
+ 'outputs' : outputs,
+ 'unlock_time' : unlock_time,
+ 'payment_id' : payment_id,
+ 'get_tx_keys' : get_tx_keys,
+ 'below_amount' : below_amount,
+ 'do_not_relay' : do_not_relay,
+ 'get_tx_hex' : get_tx_hex,
+ 'get_tx_metadata' : get_tx_metadata,
},
'jsonrpc': '2.0',
'id': '0'
@@ -591,6 +618,79 @@ class Wallet(object):
}
return self.rpc.send_json_rpc_request(verify)
+ def get_height(self):
+ get_height = {
+ 'method': 'get_height',
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_height)
+
+ def relay_tx(self, hex_):
+ relay_tx = {
+ 'method': 'relay_tx',
+ 'params': {
+ 'hex': hex_,
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(relay_tx)
+
+ def get_languages(self):
+ get_languages = {
+ 'method': 'get_languages',
+ 'params': {
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(get_languages)
+
+ def export_outputs(self):
+ export_outputs = {
+ 'method': 'export_outputs',
+ 'params': {
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(export_outputs)
+
+ def import_outputs(self, outputs_data_hex):
+ import_outputs = {
+ 'method': 'import_outputs',
+ 'params': {
+ 'outputs_data_hex': outputs_data_hex
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(import_outputs)
+
+ def export_key_images(self, all_ = False):
+ export_key_images = {
+ 'method': 'export_key_images',
+ 'params': {
+ 'all': all_
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(export_key_images)
+
+ def import_key_images(self, signed_key_images, offset = 0):
+ import_key_images = {
+ 'method': 'import_key_images',
+ 'params': {
+ 'offset': offset,
+ 'signed_key_images': signed_key_images,
+ },
+ 'jsonrpc': '2.0',
+ 'id': '0'
+ }
+ return self.rpc.send_json_rpc_request(import_key_images)
+
def get_version(self):
get_version = {
'method': 'get_version',
generated by cgit v1.2.3 (git 2.25.1) at 2025-02-02 06:53:07 +0000