Johnathan Corgan
11 years ago
9 changed files with 0 additions and 193 deletions
@ -1,21 +0,0 @@ |
|||||||
AuthServiceProxy is an improved version of python-jsonrpc. |
|
||||||
|
|
||||||
It includes the following generic improvements: |
|
||||||
|
|
||||||
- HTTP connections persist for the life of the AuthServiceProxy object |
|
||||||
- sends protocol 'version', per JSON-RPC 1.1 |
|
||||||
- sends proper, incrementing 'id' |
|
||||||
- uses standard Python json lib |
|
||||||
|
|
||||||
It also includes the following bitcoin-specific details: |
|
||||||
|
|
||||||
- sends Basic HTTP authentication headers |
|
||||||
- parses all JSON numbers that look like floats as Decimal |
|
||||||
|
|
||||||
Installation: |
|
||||||
|
|
||||||
- change the first line of setup.py to point to the directory of your installation of python 2.* |
|
||||||
- run setup.py |
|
||||||
|
|
||||||
Note: This will only install bitcoinrpc. If you also want to install jsonrpc to preserve |
|
||||||
backwards compatibility, you have to replace 'bitcoinrpc' with 'jsonrpc' in setup.py and run it again. |
|
@ -1,140 +0,0 @@ |
|||||||
|
|
||||||
""" |
|
||||||
Copyright 2011 Jeff Garzik |
|
||||||
|
|
||||||
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 |
|
||||||
|
|
||||||
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 |
|
||||||
""" |
|
||||||
|
|
||||||
try: |
|
||||||
import http.client as httplib |
|
||||||
except ImportError: |
|
||||||
import httplib |
|
||||||
import base64 |
|
||||||
import json |
|
||||||
import decimal |
|
||||||
try: |
|
||||||
import urllib.parse as urlparse |
|
||||||
except ImportError: |
|
||||||
import urlparse |
|
||||||
|
|
||||||
USER_AGENT = "AuthServiceProxy/0.1" |
|
||||||
|
|
||||||
HTTP_TIMEOUT = 30 |
|
||||||
|
|
||||||
|
|
||||||
class JSONRPCException(Exception): |
|
||||||
def __init__(self, rpc_error): |
|
||||||
Exception.__init__(self) |
|
||||||
self.error = rpc_error |
|
||||||
|
|
||||||
|
|
||||||
class AuthServiceProxy(object): |
|
||||||
def __init__(self, service_url, service_name=None, timeout=HTTP_TIMEOUT, connection=None): |
|
||||||
self.__service_url = service_url |
|
||||||
self.__service_name = service_name |
|
||||||
self.__url = urlparse.urlparse(service_url) |
|
||||||
if self.__url.port is None: |
|
||||||
port = 80 |
|
||||||
else: |
|
||||||
port = self.__url.port |
|
||||||
self.__id_count = 0 |
|
||||||
(user, passwd) = (self.__url.username, self.__url.password) |
|
||||||
try: |
|
||||||
user = user.encode('utf8') |
|
||||||
except AttributeError: |
|
||||||
pass |
|
||||||
try: |
|
||||||
passwd = passwd.encode('utf8') |
|
||||||
except AttributeError: |
|
||||||
pass |
|
||||||
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 = httplib.HTTPSConnection(self.__url.hostname, port, |
|
||||||
None, None, False, |
|
||||||
timeout) |
|
||||||
else: |
|
||||||
self.__conn = httplib.HTTPConnection(self.__url.hostname, port, |
|
||||||
False, 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 __call__(self, *args): |
|
||||||
self.__id_count += 1 |
|
||||||
|
|
||||||
postdata = json.dumps({'version': '1.1', |
|
||||||
'method': self.__service_name, |
|
||||||
'params': args, |
|
||||||
'id': self.__id_count}) |
|
||||||
self.__conn.request('POST', self.__url.path, postdata, |
|
||||||
{'Host': self.__url.hostname, |
|
||||||
'User-Agent': USER_AGENT, |
|
||||||
'Authorization': self.__auth_header, |
|
||||||
'Content-type': 'application/json'}) |
|
||||||
|
|
||||||
response = self._get_response() |
|
||||||
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)) |
|
||||||
self.__conn.request('POST', self.__url.path, postdata, |
|
||||||
{'Host': self.__url.hostname, |
|
||||||
'User-Agent': USER_AGENT, |
|
||||||
'Authorization': self.__auth_header, |
|
||||||
'Content-type': 'application/json'}) |
|
||||||
|
|
||||||
return self._get_response() |
|
||||||
|
|
||||||
def _get_response(self): |
|
||||||
http_response = self.__conn.getresponse() |
|
||||||
if http_response is None: |
|
||||||
raise JSONRPCException({ |
|
||||||
'code': -342, 'message': 'missing HTTP response from server'}) |
|
||||||
|
|
||||||
return json.loads(http_response.read().decode('utf8'), |
|
||||||
parse_float=decimal.Decimal) |
|
@ -1,2 +0,0 @@ |
|||||||
from .json import loads, dumps, JSONEncodeException, JSONDecodeException |
|
||||||
from jsonrpc.proxy import ServiceProxy, JSONRPCException |
|
@ -1,3 +0,0 @@ |
|||||||
from bitcoinrpc.authproxy import AuthServiceProxy, JSONRPCException |
|
||||||
|
|
||||||
__all__ = ['AuthServiceProxy', 'JSONRPCException'] |
|
@ -1,9 +0,0 @@ |
|||||||
_json = __import__('json') |
|
||||||
loads = _json.loads |
|
||||||
dumps = _json.dumps |
|
||||||
if hasattr(_json, 'JSONEncodeException'): |
|
||||||
JSONEncodeException = _json.JSONEncodeException |
|
||||||
JSONDecodeException = _json.JSONDecodeException |
|
||||||
else: |
|
||||||
JSONEncodeException = TypeError |
|
||||||
JSONDecodeException = ValueError |
|
@ -1 +0,0 @@ |
|||||||
from bitcoinrpc.authproxy import AuthServiceProxy as ServiceProxy, JSONRPCException |
|
@ -1,15 +0,0 @@ |
|||||||
#!/usr/bin/env python |
|
||||||
|
|
||||||
from distutils.core import setup |
|
||||||
|
|
||||||
setup(name='python-bitcoinrpc', |
|
||||||
version='0.1', |
|
||||||
description='Enhanced version of python-jsonrpc for use with Bitcoin', |
|
||||||
long_description=open('README').read(), |
|
||||||
author='Jeff Garzik', |
|
||||||
author_email='<jgarzik@exmulti.com>', |
|
||||||
maintainer='Jeff Garzik', |
|
||||||
maintainer_email='<jgarzik@exmulti.com>', |
|
||||||
url='http://www.github.com/jgarzik/python-bitcoinrpc', |
|
||||||
packages=['bitcoinrpc'], |
|
||||||
classifiers=['License :: OSI Approved :: GNU Library or Lesser General Public License (LGPL)', 'Operating System :: OS Independent']) |
|
Loading…
Reference in new issue