wownero-python/monero/backends/jsonrpc.py

375 lines
15 KiB
Python
Raw Normal View History

from datetime import datetime
import operator
import json
import logging
import pprint
import requests
from .. import exceptions
from ..account import Account
from ..address import address, Address, SubAddress
2018-01-06 22:12:42 +00:00
from ..numbers import from_atomic, to_atomic, PaymentID
2018-02-19 22:06:16 +00:00
from ..seed import Seed
2018-01-25 07:50:09 +00:00
from ..transaction import Transaction, IncomingPayment, OutgoingPayment
_log = logging.getLogger(__name__)
2018-01-14 22:51:18 +00:00
class JSONRPCDaemon(object):
"""
JSON RPC backend for Monero daemon
:param protocol: `http` or `https`
:param host: host name or IP
:param port: port number
:param path: path for JSON RPC requests (should not be changed)
"""
def __init__(self, protocol='http', host='127.0.0.1', port=18081, path='/json_rpc', user='', password=''):
2018-01-15 03:12:53 +00:00
self.url = '{protocol}://{host}:{port}'.format(
2018-01-14 22:51:18 +00:00
protocol=protocol,
host=host,
port=port)
_log.debug("JSONRPC daemon backend URL: {url}".format(url=self.url))
self.user = user
self.password = password
2018-01-14 22:51:18 +00:00
def info(self):
2018-01-14 22:51:18 +00:00
info = self.raw_jsonrpc_request('get_info')
return info
def send_transaction(self, blob, relay=True):
res = self.raw_request('/sendrawtransaction', {
'tx_as_hex': blob,
'do_not_relay': not relay})
2018-01-15 03:12:53 +00:00
if res['status'] == 'OK':
return res
raise exceptions.TransactionBroadcastError(
"{status}: {reason}".format(**res),
details=res)
def mempool(self):
2018-01-22 02:55:08 +00:00
res = self.raw_request('/get_transaction_pool', {})
txs = []
2018-01-22 03:03:40 +00:00
for tx in res.get('transactions', []):
2018-01-22 02:55:08 +00:00
txs.append(Transaction(
hash=tx['id_hash'],
fee=from_atomic(tx['fee']),
timestamp=datetime.fromtimestamp(tx['receive_time'])))
return txs
2018-01-15 03:12:53 +00:00
def raw_request(self, path, data):
hdr = {'Content-Type': 'application/json'}
_log.debug(u"Request: {path}\nData: {data}".format(
path=path,
data=pprint.pformat(data)))
rsp = requests.post(self.url + path, headers=hdr, data=json.dumps(data))
if rsp.status_code != 200:
raise RPCError("Invalid HTTP status {code} for path {path}.".format(
code=rsp.status_code,
path=path))
result = rsp.json()
_ppresult = pprint.pformat(result)
_log.debug(u"Result:\n{result}".format(result=_ppresult))
return result
2018-01-14 22:51:18 +00:00
def raw_jsonrpc_request(self, method, params=None):
hdr = {'Content-Type': 'application/json'}
data = {'jsonrpc': '2.0', 'id': 0, 'method': method, 'params': params or {}}
_log.debug(u"Method: {method}\nParams:\n{params}".format(
method=method,
params=pprint.pformat(params)))
auth = requests.auth.HTTPDigestAuth(self.user, self.password)
rsp = requests.post(self.url + '/json_rpc', headers=hdr, data=json.dumps(data), auth=auth)
if rsp.status_code == 401:
raise Unauthorized("401 Unauthorized. Invalid RPC user name or password.")
elif rsp.status_code != 200:
2018-01-14 22:51:18 +00:00
raise RPCError("Invalid HTTP status {code} for method {method}.".format(
code=rsp.status_code,
method=method))
result = rsp.json()
_ppresult = pprint.pformat(result)
_log.debug(u"Result:\n{result}".format(result=_ppresult))
if 'error' in result:
err = result['error']
_log.error(u"JSON RPC error:\n{result}".format(result=_ppresult))
raise RPCError(
"Method '{method}' failed with RPC Error of unknown code {code}, "
"message: {message}".format(method=method, data=data, result=result, **err))
return result['result']
2017-12-26 21:02:17 +00:00
class JSONRPCWallet(object):
"""
JSON RPC backend for Monero wallet (``monero-wallet-rpc``)
:param protocol: `http` or `https`
:param host: host name or IP
:param port: port number
:param path: path for JSON RPC requests (should not be changed)
:param user: username to authenticate with over RPC
:param password: password to authenticate with over RPC
"""
2017-12-27 00:49:59 +00:00
_master_address = None
_addresses = None
2018-01-18 01:59:54 +00:00
def __init__(self, protocol='http', host='127.0.0.1', port=18088, path='/json_rpc', user='', password=''):
self.url = '{protocol}://{host}:{port}/json_rpc'.format(
protocol=protocol,
host=host,
port=port)
2018-01-14 22:51:18 +00:00
_log.debug("JSONRPC wallet backend URL: {url}".format(url=self.url))
self.user = user
self.password = password
2018-01-14 22:51:18 +00:00
_log.debug("JSONRPC wallet backend auth: '{user}'/'{stars}'".format(
user=user, stars=('*' * len(password)) if password else ''))
def height(self):
2018-01-22 02:55:08 +00:00
return self.raw_request('getheight')['height']
def spend_key(self):
2018-01-28 12:04:47 +00:00
# NOTE: This will fail on 0.11.x, the method was missing
return self.raw_request('query_key', {'key_type': 'spend_key'})['key']
def view_key(self):
2018-01-14 05:28:28 +00:00
return self.raw_request('query_key', {'key_type': 'view_key'})['key']
def seed(self):
2018-02-19 22:06:16 +00:00
return Seed(self.raw_request('query_key', {'key_type': 'mnemonic'})['key'])
2018-01-14 05:28:28 +00:00
def accounts(self):
accounts = []
try:
2018-02-14 13:06:41 +00:00
_accounts = self.raw_request('get_accounts', squelch_error_logging=True)
except MethodNotFound:
2017-12-27 00:49:59 +00:00
# monero <= 0.11 : there's only one account and one address
2018-01-17 14:03:18 +00:00
_log.debug('Monero <= 0.11 found, no accounts')
2018-02-14 13:06:41 +00:00
self._master_address = self.addresses()[0]
return [Account(self, 0)]
idx = 0
2017-12-27 00:49:59 +00:00
self._master_address = Address(_accounts['subaddress_accounts'][0]['base_address'])
for _acc in _accounts['subaddress_accounts']:
assert idx == _acc['account_index']
accounts.append(Account(self, _acc['account_index']))
idx += 1
return accounts
def new_account(self, label=None):
_account = self.raw_request('create_account', {'label': label})
return Account(self, _account['account_index']), SubAddress(_account['address'])
def addresses(self, account=0):
_addresses = self.raw_request('getaddress', {'account_index': account})
if 'addresses' not in _addresses:
# monero <= 0.11
2018-01-17 14:03:18 +00:00
_log.debug('Monero <= 0.11 found, assuming single address')
return [Address(_addresses['address'])]
addresses = [None] * (max(map(operator.itemgetter('address_index'), _addresses['addresses'])) + 1)
for _addr in _addresses['addresses']:
addresses[_addr['address_index']] = address(
_addr['address'],
label=_addr.get('label', None))
return addresses
def new_address(self, account=0, label=None):
_address = self.raw_request(
'create_address', {'account_index': account, 'label': label})
return SubAddress(_address['address'])
def balances(self, account=0):
_balance = self.raw_request('getbalance', {'account_index': account})
return (from_atomic(_balance['balance']), from_atomic(_balance['unlocked_balance']))
2018-01-29 14:11:53 +00:00
def transfers_in(self, account, pmtfilter):
2018-01-30 18:56:36 +00:00
params = {'account_index': account, 'pending': False}
2018-01-29 14:11:53 +00:00
method = 'get_transfers'
if pmtfilter.unconfirmed:
params['in'] = pmtfilter.confirmed
params['out'] = False
params['pool'] = True
else:
if pmtfilter.payment_ids:
method = 'get_bulk_payments'
2018-01-30 18:56:36 +00:00
params['payment_ids'] = list(map(str, pmtfilter.payment_ids))
2018-01-29 14:11:53 +00:00
else:
params['in'] = pmtfilter.confirmed
params['out'] = False
params['pool'] = False
if method == 'get_transfers':
arg = 'in'
if pmtfilter.min_height:
# NOTE: the API uses (min, max] range which is confusing
params['min_height'] = pmtfilter.min_height - 1
2018-01-29 14:11:53 +00:00
params['filter_by_height'] = True
if pmtfilter.max_height:
params['max_height'] = pmtfilter.max_height
params['filter_by_height'] = True
# PR#3235 makes the following obsolete
2018-02-05 22:38:45 +00:00
# CRYPTONOTE_MAX_BLOCK_NUMBER = 500000000
params['max_height'] = params.get('max_height', 500000000)
2018-01-30 18:56:36 +00:00
else:
2018-01-29 14:11:53 +00:00
arg = 'payments'
# NOTE: the API uses (min, max] range which is confusing
params['min_block_height'] = (pmtfilter.min_height or 1) - 1
2018-01-29 14:11:53 +00:00
_pmts = self.raw_request(method, params)
pmts = _pmts.get(arg, [])
if pmtfilter.unconfirmed:
pmts.extend(_pmts.get('pool', []))
return list(pmtfilter.filter(map(self._inpayment, pmts)))
def transfers_out(self, account, pmtfilter):
_pmts = self.raw_request('get_transfers', {
2017-12-27 00:49:59 +00:00
'account_index': account,
2018-01-29 14:11:53 +00:00
'in': False,
'out': pmtfilter.confirmed,
2018-01-30 18:56:36 +00:00
'pool': False,
'pending': pmtfilter.unconfirmed})
2018-01-29 14:11:53 +00:00
pmts = _pmts.get('out', [])
if pmtfilter.unconfirmed:
2018-01-30 18:56:36 +00:00
pmts.extend(_pmts.get('pending', []))
2018-01-29 14:11:53 +00:00
return list(pmtfilter.filter(map(self._outpayment, pmts)))
2018-01-22 02:55:08 +00:00
2018-01-25 07:50:09 +00:00
def _paymentdict(self, data):
pid = data.get('payment_id', None)
2018-01-30 08:43:08 +00:00
laddr = data.get('address', None)
if laddr:
laddr = address(laddr)
result = {
'payment_id': None if pid is None else PaymentID(pid),
2018-01-25 07:50:09 +00:00
'amount': from_atomic(data['amount']),
'timestamp': datetime.fromtimestamp(data['timestamp']) if 'timestamp' in data else None,
2018-01-29 14:11:53 +00:00
'note': data.get('note', None),
'transaction': self._tx(data),
2018-01-30 08:43:08 +00:00
'local_address': laddr,
2017-11-29 03:38:29 +00:00
}
if 'destinations' in data:
result['destinations'] = [
{'address': address(x['address']), 'amount': from_atomic(data['amount'])}
for x in data.get('destinations')
]
return result
2017-11-29 03:38:29 +00:00
2018-01-25 07:50:09 +00:00
def _inpayment(self, data):
2018-01-29 14:11:53 +00:00
return IncomingPayment(**self._paymentdict(data))
2018-01-25 07:50:09 +00:00
def _outpayment(self, data):
2018-01-29 14:11:53 +00:00
return OutgoingPayment(**self._paymentdict(data))
2018-01-25 07:50:09 +00:00
def _tx(self, data):
return Transaction(**{
'hash': data.get('txid', data.get('tx_hash')),
'fee': from_atomic(data['fee']) if 'fee' in data else None,
'key': data.get('key'),
'height': data.get('height', data.get('block_height')) or None,
'timestamp': datetime.fromtimestamp(data['timestamp']) if 'timestamp' in data else None,
'blob': data.get('blob', None),
})
def export_outputs(self):
return self.raw_request('export_outputs')['outputs_data_hex']
def import_outputs(self, outputs_hex):
return self.raw_request(
'import_outputs',
{'outputs_data_hex': outputs_hex})['num_imported']
def export_key_images(self):
return self.raw_request('export_key_images')['signed_key_images']
def import_key_images(self, key_images):
_data = self.raw_request(
'import_key_images',
{'signed_key_images': key_images})
return (_data['height'], from_atomic(_data['spent']), from_atomic(_data['unspent']))
def transfer(self, destinations, priority, ringsize,
payment_id=None, unlock_time=0, account=0,
relay=True):
2017-11-29 03:38:29 +00:00
data = {
'account_index': account,
'destinations': list(map(
2017-11-30 02:43:34 +00:00
lambda dst: {'address': str(address(dst[0])), 'amount': to_atomic(dst[1])},
2017-11-29 03:38:29 +00:00
destinations)),
'mixin': ringsize - 1,
2017-11-29 03:38:29 +00:00
'priority': priority,
'unlock_time': 0,
'get_tx_keys': True,
'get_tx_hex': True,
'new_algorithm': True,
'do_not_relay': not relay,
2017-11-29 03:38:29 +00:00
}
if payment_id is not None:
data['payment_id'] = str(PaymentID(payment_id))
2017-11-29 03:38:29 +00:00
_transfers = self.raw_request('transfer_split', data)
2018-01-07 00:26:50 +00:00
_pertx = [dict(_tx) for _tx in map(
lambda vs: zip(('txid', 'amount', 'fee', 'key', 'blob', 'payment_id'), vs),
zip(*[_transfers[k] for k in (
'tx_hash_list', 'amount_list', 'fee_list', 'tx_key_list', 'tx_blob_list')]))]
for d in _pertx:
d['payment_id'] = payment_id
2018-01-25 07:50:09 +00:00
return [self._tx(data) for data in _pertx]
2018-02-14 13:06:41 +00:00
def raw_request(self, method, params=None, squelch_error_logging=False):
hdr = {'Content-Type': 'application/json'}
data = {'jsonrpc': '2.0', 'id': 0, 'method': method, 'params': params or {}}
_log.debug(u"Method: {method}\nParams:\n{params}".format(
method=method,
params=pprint.pformat(params)))
auth = requests.auth.HTTPDigestAuth(self.user, self.password)
rsp = requests.post(self.url, headers=hdr, data=json.dumps(data), auth=auth)
if rsp.status_code == 401:
raise Unauthorized("401 Unauthorized. Invalid RPC user name or password.")
elif rsp.status_code != 200:
raise RPCError("Invalid HTTP status {code} for method {method}.".format(
code=rsp.status_code,
method=method))
result = rsp.json()
_ppresult = pprint.pformat(result)
_log.debug(u"Result:\n{result}".format(result=_ppresult))
if 'error' in result:
err = result['error']
2018-02-14 13:06:41 +00:00
if not squelch_error_logging:
_log.error(u"JSON RPC error:\n{result}".format(result=_ppresult))
# XXX: workaround for 0.11 bug throwing a wrong error code
if err['code'] == -4 and 'not enough money' in err['message']:
raise exceptions.NotEnoughMoney(err['message'])
#
if err['code'] in _err2exc:
2017-11-29 03:38:29 +00:00
raise _err2exc[err['code']](err['message'])
else:
raise RPCError(
"Method '{method}' failed with RPC Error of unknown code {code}, "
"message: {message}".format(method=method, data=data, result=result, **err))
return result['result']
2017-11-29 03:38:29 +00:00
class RPCError(exceptions.BackendException):
pass
class Unauthorized(RPCError):
pass
class MethodNotFound(RPCError):
pass
_err2exc = {
2017-11-29 03:38:29 +00:00
-2: exceptions.WrongAddress,
2018-01-11 02:18:22 +00:00
-5: exceptions.WrongPaymentId,
2018-01-22 03:18:00 +00:00
-8: exceptions.TransactionNotFound,
-9: exceptions.SignatureCheckFailed,
2018-01-11 05:14:34 +00:00
-16: exceptions.TransactionNotPossible,
2018-01-22 03:51:56 +00:00
-17: exceptions.NotEnoughMoney,
2017-11-29 03:38:29 +00:00
-20: exceptions.AmountIsZero,
2018-01-28 12:04:47 +00:00
-37: exceptions.NotEnoughUnlockedMoney, # PR pending: https://github.com/monero-project/monero/pull/3197
2018-01-29 09:14:24 +00:00
-38: exceptions.NoDaemonConnection, # PR 3197
-32601: MethodNotFound,
}