self.pending_responses.append(response)
class HttpServer(threading.Thread):
- def __init__(self, shared, _processor, host, port):
- self.shared = shared
- self.processor = _processor
+ def __init__(self, dispatcher, host, port):
+ self.shared = dispatcher.shared
+ self.dispatcher = dispatcher.request_dispatcher
threading.Thread.__init__(self)
self.daemon = True
self.host = host
from SocketServer import ThreadingMixIn
class StratumThreadedJSONRPCServer(ThreadingMixIn, StratumJSONRPCServer): pass
self.server = StratumThreadedJSONRPCServer(( self.host, self.port))
- for s in ['server.peers', 'server.banner', 'transaction.broadcast', \
- 'address.get_history','address.subscribe', 'numblocks.subscribe', 'client.version']:
+ for s in ['server.peers.subscribe', 'server.banner', 'blockchain.transaction.broadcast', \
+ 'blockchain.address.get_history','blockchain.address.subscribe', \
+ 'blockchain.numblocks.subscribe', 'client.version' ]:
self.server.register_function(self.process, s)
self.server.register_function(self.do_stop, 'stop')
#print session, request
session = self.server.sessions.get(session_id)
if session:
- #print "zz",session_id,session
- request['id'] = self.processor.store_session_id(session, request['id'])
- self.processor.process(request)
+ self.dispatcher.process(session, request)
def do_stop(self, session, request):
self.shared.stop()