98daf21db775afd00420624c172c5ea5c3c1f572
[p2pool.git] / p2pool / bitcoin / worker_interface.py
1 from __future__ import division
2
3 import StringIO
4 import json
5 import random
6 import sys
7
8 from twisted.internet import defer
9
10 import p2pool
11 from p2pool.bitcoin import data as bitcoin_data, getwork
12 from p2pool.util import expiring_dict, jsonrpc, pack, variable
13
14 class _Provider(object):
15     def __init__(self, parent, long_poll):
16         self.parent = parent
17         self.long_poll = long_poll
18     
19     def rpc_getwork(self, request, data=None):
20         return self.parent._getwork(request, data, long_poll=self.long_poll)
21
22 class _GETableServer(jsonrpc.HTTPServer):
23     def __init__(self, provider, render_get_func):
24         jsonrpc.HTTPServer.__init__(self, provider)
25         self.render_GET = render_get_func
26
27 class WorkerBridge(object):
28     def __init__(self):
29         self.new_work_event = variable.Event()
30     
31     def preprocess_request(self, request):
32         return request, # *args to self.compute
33     
34     def get_work(self, request):
35         raise NotImplementedError()
36
37 class WorkerInterface(object):
38     def __init__(self, worker_bridge):
39         self.worker_bridge = worker_bridge
40         
41         self.worker_views = {}
42         
43         self.merkle_root_to_handler = expiring_dict.ExpiringDict(300)
44     
45     def attach_to(self, res, get_handler=None):
46         res.putChild('', _GETableServer(_Provider(self, long_poll=False), get_handler))
47         
48         def repost(request):
49             request.content = StringIO.StringIO(json.dumps(dict(id=0, method='getwork')))
50             return s.render_POST(request)
51         s = _GETableServer(_Provider(self, long_poll=True), repost)
52         res.putChild('long-polling', s)
53     
54     @defer.inlineCallbacks
55     def _getwork(self, request, data, long_poll):
56         request.setHeader('X-Long-Polling', '/long-polling')
57         request.setHeader('X-Roll-NTime', 'expire=100')
58         request.setHeader('X-Is-P2Pool', 'true')
59         if request.getHeader('Host') is not None:
60             request.setHeader('X-Stratum', 'stratum+tcp://' + request.getHeader('Host'))
61         
62         if data is not None:
63             header = getwork.decode_data(data)
64             if header['merkle_root'] not in self.merkle_root_to_handler:
65                 print >>sys.stderr, '''Couldn't link returned work's merkle root with its handler. This should only happen if this process was recently restarted!'''
66                 defer.returnValue(False)
67             defer.returnValue(self.merkle_root_to_handler[header['merkle_root']](header, request.getUser() if request.getUser() is not None else '', '\0'*self.worker_bridge.COINBASE_NONCE_LENGTH))
68         
69         if p2pool.DEBUG:
70             id = random.randrange(1000, 10000)
71             print 'POLL %i START is_long_poll=%r user_agent=%r user=%r' % (id, long_poll, request.getHeader('User-Agent'), request.getUser())
72         
73         if long_poll:
74             request_id = request.getClientIP(), request.getHeader('Authorization')
75             if self.worker_views.get(request_id, self.worker_bridge.new_work_event.times) != self.worker_bridge.new_work_event.times:
76                 if p2pool.DEBUG:
77                     print 'POLL %i PUSH' % (id,)
78             else:
79                 if p2pool.DEBUG:
80                     print 'POLL %i WAITING' % (id,)
81                 yield self.worker_bridge.new_work_event.get_deferred()
82             self.worker_views[request_id] = self.worker_bridge.new_work_event.times
83         
84         x, handler = self.worker_bridge.get_work(*self.worker_bridge.preprocess_request(request.getUser() if request.getUser() is not None else ''))
85         res = getwork.BlockAttempt(
86             version=x['version'],
87             previous_block=x['previous_block'],
88             merkle_root=bitcoin_data.check_merkle_link(bitcoin_data.hash256(x['coinb1'] + '\0'*self.worker_bridge.COINBASE_NONCE_LENGTH + x['coinb2']), x['merkle_link']),
89             timestamp=x['timestamp'],
90             bits=x['bits'],
91             share_target=x['share_target'],
92         )
93         assert res.merkle_root not in self.merkle_root_to_handler
94         
95         self.merkle_root_to_handler[res.merkle_root] = handler
96         
97         if p2pool.DEBUG:
98             print 'POLL %i END identifier=%i' % (id, self.worker_bridge.new_work_event.times)
99         
100         defer.returnValue(res.getwork(identifier=str(self.worker_bridge.new_work_event.times), submitold=True))