return proxy
class Interface(threading.Thread):
- def __init__(self, host, port, debug_server, proxy):
+ def __init__(self, host, port, proxy):
threading.Thread.__init__(self)
self.daemon = True
self.host = host
self.responses = Queue.Queue()
self.unanswered_requests = {}
- self.debug_server = debug_server
-
def init_socket(self):
pass
def queue_json_response(self, c):
- if self.debug_server:
- print "<--",c
+ # uncomment to debug
+ # print "<--",c
msg_id = c.get('id')
error = c.get('error')
class PollingInterface(Interface):
""" non-persistent connection. synchronous calls"""
- def __init__(self, host, port, debug_server, proxy):
- Interface.__init__(self, host, port, debug_server, proxy)
+ def __init__(self, host, port, proxy):
+ Interface.__init__(self, host, port, proxy)
self.session_id = None
- self.debug_server = debug_server
def get_history(self, address):
self.send([('blockchain.address.get_history', [address] )])
class TcpStratumInterface(Interface):
"""json-rpc over persistent TCP connection, asynchronous"""
- def __init__(self, host, port, debug_server, proxy):
- Interface.__init__(self, host, port, debug_server, proxy)
- self.debug_server = debug_server
+ def __init__(self, host, port, proxy):
+ Interface.__init__(self, host, port, proxy)
def init_socket(self):
global proxy_modes
request = json.dumps( { 'id':self.message_id, 'method':method, 'params':params } )
self.unanswered_requests[self.message_id] = method, params
- if self.debug_server:
- print "-->",request
+ # uncomment to debug
+ # print "-->",request
self.message_id += 1
out += request + '\n'
print_error("Error: Unknown protocol")
InterfaceClass = TcpStratumInterface
- self.interface = InterfaceClass(host, port, self.wallet.debug_server, self.proxy)
+ self.interface = InterfaceClass(host, port, self.proxy)
self.wallet.interface = self.interface
def handle_response(self, r):