-class PollingInterface(InterfaceAncestor):
+
+class HttpStratumInterface(InterfaceAncestor):
""" non-persistent connection. synchronous calls"""
def __init__(self, host, port, proxy=None):
def get_history(self, address):
self.send([('blockchain.address.get_history', [address] )])
- def poll(self):
- pass
-
def run(self):
self.is_connected = True
while self.is_connected:
self.poke()
-
-
-
-
-
-
-
-class HttpStratumInterface(PollingInterface):
-
def poll(self):
self.send([])
host, port, protocol = s.split(':')
port = int(port)
+ self.protocol = protocol
proxy = self.parse_proxy_options(config.get('proxy','none'))
self.server = host + ':%d:%s'%(port, protocol)
TcpStratumInterface.__init__(self, host, port, proxy)
+ def run(self):
+ if self.protocol == 't':
+ TcpStratumInterface.run(self)
+ else:
+ HttpStratumInterface.run(self)
+
+ def send(self, messages):
+ if self.protocol == 't':
+ TcpStratumInterface.send(self, messages)
+ else:
+ HttpStratumInterface.send(self, messages)
+
+
def parse_proxy_options(self, s):
if type(s) != type(""): return None
if s.lower() == 'none': return None