You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
184 lines
7.9 KiB
184 lines
7.9 KiB
# Copyright (c) 2011 Jeff Garzik |
|
# |
|
# Previous copyright, from python-jsonrpc/jsonrpc/proxy.py: |
|
# |
|
# Copyright (c) 2007 Jan-Klaas Kollhof |
|
# |
|
# This file is part of jsonrpc. |
|
# |
|
# jsonrpc is free software; you can redistribute it and/or modify |
|
# it under the terms of the GNU Lesser General Public License as published by |
|
# the Free Software Foundation; either version 2.1 of the License, or |
|
# (at your option) any later version. |
|
# |
|
# This software is distributed in the hope that it will be useful, |
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
# GNU Lesser General Public License for more details. |
|
# |
|
# You should have received a copy of the GNU Lesser General Public License |
|
# along with this software; if not, write to the Free Software |
|
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA |
|
"""HTTP proxy for opening RPC connection to bitcoind. |
|
|
|
AuthServiceProxy has the following improvements over python-jsonrpc's |
|
ServiceProxy class: |
|
|
|
- HTTP connections persist for the life of the AuthServiceProxy object |
|
(if server supports HTTP/1.1) |
|
- sends protocol 'version', per JSON-RPC 1.1 |
|
- sends proper, incrementing 'id' |
|
- sends Basic HTTP authentication headers |
|
- parses all JSON numbers that look like floats as Decimal |
|
- uses standard Python json lib |
|
""" |
|
|
|
import base64 |
|
import decimal |
|
import http.client |
|
import json |
|
import logging |
|
import socket |
|
import time |
|
import urllib.parse |
|
|
|
HTTP_TIMEOUT = 30 |
|
USER_AGENT = "AuthServiceProxy/0.1" |
|
|
|
log = logging.getLogger("BitcoinRPC") |
|
|
|
class JSONRPCException(Exception): |
|
def __init__(self, rpc_error): |
|
try: |
|
errmsg = '%(message)s (%(code)i)' % rpc_error |
|
except (KeyError, TypeError): |
|
errmsg = '' |
|
super().__init__(errmsg) |
|
self.error = rpc_error |
|
|
|
|
|
def EncodeDecimal(o): |
|
if isinstance(o, decimal.Decimal): |
|
return str(o) |
|
raise TypeError(repr(o) + " is not JSON serializable") |
|
|
|
class AuthServiceProxy(): |
|
__id_count = 0 |
|
|
|
# ensure_ascii: escape unicode as \uXXXX, passed to json.dumps |
|
def __init__(self, service_url, service_name=None, timeout=HTTP_TIMEOUT, connection=None, ensure_ascii=True): |
|
self.__service_url = service_url |
|
self._service_name = service_name |
|
self.ensure_ascii = ensure_ascii # can be toggled on the fly by tests |
|
self.__url = urllib.parse.urlparse(service_url) |
|
port = 80 if self.__url.port is None else self.__url.port |
|
user = None if self.__url.username is None else self.__url.username.encode('utf8') |
|
passwd = None if self.__url.password is None else self.__url.password.encode('utf8') |
|
authpair = user + b':' + passwd |
|
self.__auth_header = b'Basic ' + base64.b64encode(authpair) |
|
|
|
if connection: |
|
# Callables re-use the connection of the original proxy |
|
self.__conn = connection |
|
elif self.__url.scheme == 'https': |
|
self.__conn = http.client.HTTPSConnection(self.__url.hostname, port, timeout=timeout) |
|
else: |
|
self.__conn = http.client.HTTPConnection(self.__url.hostname, port, timeout=timeout) |
|
|
|
def __getattr__(self, name): |
|
if name.startswith('__') and name.endswith('__'): |
|
# Python internal stuff |
|
raise AttributeError |
|
if self._service_name is not None: |
|
name = "%s.%s" % (self._service_name, name) |
|
return AuthServiceProxy(self.__service_url, name, connection=self.__conn) |
|
|
|
def _request(self, method, path, postdata): |
|
''' |
|
Do a HTTP request, with retry if we get disconnected (e.g. due to a timeout). |
|
This is a workaround for https://bugs.python.org/issue3566 which is fixed in Python 3.5. |
|
''' |
|
headers = {'Host': self.__url.hostname, |
|
'User-Agent': USER_AGENT, |
|
'Authorization': self.__auth_header, |
|
'Content-type': 'application/json'} |
|
try: |
|
self.__conn.request(method, path, postdata, headers) |
|
return self._get_response() |
|
except http.client.BadStatusLine as e: |
|
if e.line == "''": # if connection was closed, try again |
|
self.__conn.close() |
|
self.__conn.request(method, path, postdata, headers) |
|
return self._get_response() |
|
else: |
|
raise |
|
except (BrokenPipeError, ConnectionResetError): |
|
# Python 3.5+ raises BrokenPipeError instead of BadStatusLine when the connection was reset |
|
# ConnectionResetError happens on FreeBSD with Python 3.4 |
|
self.__conn.close() |
|
self.__conn.request(method, path, postdata, headers) |
|
return self._get_response() |
|
|
|
def get_request(self, *args, **argsn): |
|
AuthServiceProxy.__id_count += 1 |
|
|
|
log.debug("-%s-> %s %s" % (AuthServiceProxy.__id_count, self._service_name, |
|
json.dumps(args, default=EncodeDecimal, ensure_ascii=self.ensure_ascii))) |
|
if args and argsn: |
|
raise ValueError('Cannot handle both named and positional arguments') |
|
return {'version': '1.1', |
|
'method': self._service_name, |
|
'params': args or argsn, |
|
'id': AuthServiceProxy.__id_count} |
|
|
|
def __call__(self, *args, **argsn): |
|
postdata = json.dumps(self.get_request(*args, **argsn), default=EncodeDecimal, ensure_ascii=self.ensure_ascii) |
|
# Kevacoin: submitblock expects a cryptonote wrapper around the block, |
|
# while submitblock_original is the original implementation. |
|
postdata = postdata.replace('submitblock', 'submitblock_original') |
|
postdata = postdata.replace('getblocktemplate', 'getblocktemplate_original') |
|
response = self._request('POST', self.__url.path, postdata.encode('utf-8')) |
|
if response['error'] is not None: |
|
raise JSONRPCException(response['error']) |
|
elif 'result' not in response: |
|
raise JSONRPCException({ |
|
'code': -343, 'message': 'missing JSON-RPC result'}) |
|
else: |
|
return response['result'] |
|
|
|
def batch(self, rpc_call_list): |
|
postdata = json.dumps(list(rpc_call_list), default=EncodeDecimal, ensure_ascii=self.ensure_ascii) |
|
log.debug("--> " + postdata) |
|
return self._request('POST', self.__url.path, postdata.encode('utf-8')) |
|
|
|
def _get_response(self): |
|
req_start_time = time.time() |
|
try: |
|
http_response = self.__conn.getresponse() |
|
except socket.timeout as e: |
|
raise JSONRPCException({ |
|
'code': -344, |
|
'message': '%r RPC took longer than %f seconds. Consider ' |
|
'using larger timeout for calls that take ' |
|
'longer to return.' % (self._service_name, |
|
self.__conn.timeout)}) |
|
if http_response is None: |
|
raise JSONRPCException({ |
|
'code': -342, 'message': 'missing HTTP response from server'}) |
|
|
|
content_type = http_response.getheader('Content-Type') |
|
if content_type != 'application/json': |
|
raise JSONRPCException({ |
|
'code': -342, 'message': 'non-JSON HTTP response with \'%i %s\' from server' % (http_response.status, http_response.reason)}) |
|
|
|
responsedata = http_response.read().decode('utf8') |
|
response = json.loads(responsedata, parse_float=decimal.Decimal) |
|
elapsed = time.time() - req_start_time |
|
if "error" in response and response["error"] is None: |
|
log.debug("<-%s- [%.6f] %s" % (response["id"], elapsed, json.dumps(response["result"], default=EncodeDecimal, ensure_ascii=self.ensure_ascii))) |
|
else: |
|
log.debug("<-- [%.6f] %s" % (elapsed, responsedata)) |
|
return response |
|
|
|
def __truediv__(self, relative_uri): |
|
return AuthServiceProxy("{}/{}".format(self.__service_url, relative_uri), self._service_name, connection=self.__conn)
|
|
|