Merge branch 'refactor_jsonrpcserver'
[bitcoin:eloipool.git] / jsonrpc_getwork.py
1 # Eloipool - Python Bitcoin pool server
2 # Copyright (C) 2011-2012  Luke Dashjr <luke-jr+eloipool@utopios.org>
3 #
4 # This program is free software: you can redistribute it and/or modify
5 # it under the terms of the GNU Affero General Public License as
6 # published by the Free Software Foundation, either version 3 of the
7 # License, or (at your option) any later version.
8 #
9 # This program is distributed in the hope that it will be useful,
10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12 # GNU Affero General Public License for more details.
13 #
14 # You should have received a copy of the GNU Affero General Public License
15 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
16
17 from binascii import a2b_hex, b2a_hex
18 from jsonrpcserver import JSONRPCHandler
19 import logging
20 try:
21         import midstate
22         assert midstate.SHA256(b'This is just a test, ignore it. I am making it over 64-bytes long.')[:8] == (0x755f1a94, 0x999b270c, 0xf358c014, 0xfd39caeb, 0x0dcc9ebc, 0x4694cd1a, 0x8e95678e, 0x75fac450)
23 except:
24         logging.getLogger('jsonrpc_getwork').warning('Error importing \'midstate\' module; work will not provide midstates')
25         midstate = None
26 from struct import pack
27 from util import RejectedShare, swap32
28
29 _CheckForDupesHACK = {}
30 class _getwork:
31         getwork_rv_template = {
32                 'data': '000000800000000000000000000000000000000000000000000000000000000000000000000000000000000080020000',
33                 'target': 'ffffffffffffffffffffffffffffffffffffffffffffffffffffffff00000000',
34                 'hash1': '00000000000000000000000000000000000000000000000000000000000000000000008000000000000000000000000000000000000000000000000000010000',
35         }
36         def doJSON_getwork(self, data=None):
37                 if not data is None:
38                         return self.doJSON_submitwork(data)
39                 rv = dict(self.getwork_rv_template)
40                 hdr = self.server.getBlockHeader(self.Username)
41                 
42                 # FIXME: this assumption breaks with internal rollntime
43                 # NOTE: noncerange needs to set nonce to start value at least
44                 global _CheckForDupesHACK
45                 uhdr = hdr[:68] + hdr[72:]
46                 if uhdr in _CheckForDupesHACK:
47                         raise self.server.RaiseRedFlags(RuntimeError('issuing duplicate work'))
48                 _CheckForDupesHACK[uhdr] = None
49                 
50                 data = b2a_hex(swap32(hdr)).decode('utf8') + rv['data']
51                 # TODO: endian shuffle etc
52                 rv['data'] = data
53                 if midstate and 'midstate' not in self.extensions:
54                         h = midstate.SHA256(hdr)[:8]
55                         rv['midstate'] = b2a_hex(pack('<LLLLLLLL', *h)).decode('ascii')
56                 return rv
57         
58         def doJSON_submitwork(self, datax):
59                 data = swap32(a2b_hex(datax))[:80]
60                 share = {
61                         'data': data,
62                         '_origdata' : datax,
63                         'username': self.Username,
64                         'remoteHost': self.addr[0],
65                 }
66                 try:
67                         self.server.receiveShare(share)
68                 except RejectedShare as rej:
69                         self._JSONHeaders['X-Reject-Reason'] = str(rej)
70                         return False
71                 return True
72
73 JSONRPCHandler._register(_getwork)