7 from processor import Processor
8 from utils import Hash, print_log
9 from version import VERSION
12 class IrcThread(threading.Thread):
14 def __init__(self, processor, config):
15 threading.Thread.__init__(self)
17 self.processor = processor
19 self.stratum_tcp_port = config.get('server', 'stratum_tcp_port')
20 self.stratum_http_port = config.get('server', 'stratum_http_port')
21 self.stratum_tcp_ssl_port = config.get('server', 'stratum_tcp_ssl_port')
22 self.stratum_http_ssl_port = config.get('server', 'stratum_http_ssl_port')
23 self.report_stratum_tcp_port = config.get('server', 'report_stratum_tcp_port')
24 self.report_stratum_http_port = config.get('server', 'report_stratum_http_port')
25 self.report_stratum_tcp_ssl_port = config.get('server', 'report_stratum_tcp_ssl_port')
26 self.report_stratum_http_ssl_port = config.get('server', 'report_stratum_http_ssl_port')
28 self.host = config.get('server', 'host')
29 self.report_host = config.get('server', 'report_host')
30 self.nick = config.get('server', 'irc_nick')
31 if self.report_stratum_tcp_port:
32 self.stratum_tcp_port = self.report_stratum_tcp_port
33 if self.report_stratum_http_port:
34 self.stratum_http_port = self.report_stratum_http_port
35 if self.report_stratum_tcp_ssl_port:
36 self.stratum_tcp_ssl_port = self.report_stratum_tcp_ssl_port
37 if self.report_stratum_http_ssl_port:
38 self.stratum_http_ssl_port = self.report_stratum_http_ssl_port
40 self.host = self.report_host
42 self.nick = Hash(self.report_host)[:10]
44 if config.get('server', 'coin') == 'litecoin':
46 self.pruning = config.get('server', 'backend') == 'leveldb'
47 self.nick = self.prepend + self.nick
50 return self.peers.values()
53 s = 'v' + VERSION + ' '
56 if self.stratum_tcp_port:
57 s += 't' + self.stratum_tcp_port + ' '
58 if self.stratum_http_port:
59 s += 'h' + self.stratum_http_port + ' '
60 if self.stratum_tcp_port:
61 s += 's' + self.stratum_tcp_ssl_port + ' '
62 if self.stratum_http_port:
63 s += 'g' + self.stratum_http_ssl_port + ' '
67 ircname = self.getname()
69 while not self.processor.shared.stopped():
72 s.connect(('irc.freenode.net', 6667))
80 s.send('USER electrum 0 * :' + self.host + ' ' + ircname + '\n')
81 s.send('NICK ' + self.nick + '\n')
82 s.send('JOIN #electrum\n')
83 sf = s.makefile('r', 0)
85 while not self.processor.shared.stopped():
86 line = sf.readline().rstrip('\r\n').split()
90 s.send('PONG ' + line[1] + '\n')
91 elif '353' in line: # answer to /names
93 for item in line[k+1:]:
94 if item.startswith(self.prepend):
95 s.send('WHO %s\n' % item)
96 elif '352' in line: # answer to /who
97 # warning: this is a horrible hack which apparently works
100 ip = socket.gethostbyname(line[k+4])
102 print_log("gethostbyname error", line[k+4])
107 self.peers[name] = (ip, host, ports)
108 if time.time() - t > 5*60:
109 self.processor.push_response({'method': 'server.peers', 'params': [self.get_peers()]})
110 s.send('NAMES #electrum\n')
114 traceback.print_exc(file=sys.stdout)
119 print_log("quitting IRC")
122 class ServerProcessor(Processor):
124 def __init__(self, config):
125 Processor.__init__(self)
127 self.banner = config.get('server', 'banner')
128 self.password = config.get('server', 'password')
130 if config.get('server', 'irc') == 'yes':
131 self.irc = IrcThread(self, config)
137 return self.irc.get_peers()
146 def process(self, request):
147 method = request['method']
148 params = request['params']
151 if method in ['server.stop', 'server.info']:
153 password = request['params'][0]
157 if password != self.password:
158 self.push_response({'id': request['id'],
160 'error': 'incorrect password'})
163 if method == 'server.banner':
164 result = self.banner.replace('\\n', '\n')
166 elif method == 'server.peers.subscribe':
167 result = self.get_peers()
169 elif method == 'server.version':
172 elif method == 'server.stop':
174 result = 'stopping, please wait until all threads terminate.'
176 elif method == 'server.info':
177 result = map(lambda s: {"time": s.time,
179 "address": s.address,
180 "version": s.version,
181 "subscriptions": len(s.subscriptions)},
182 self.dispatcher.request_dispatcher.get_sessions())
184 elif method == 'server.cache':
185 p = self.dispatcher.request_dispatcher.processors['blockchain']
186 result = len(repr(p.store.tx_cache))
188 elif method == 'server.load':
189 p = self.dispatcher.request_dispatcher.processors['blockchain']
190 result = p.queue.qsize()
193 print_log("unknown method", request)
196 self.push_response({'id': request['id'], 'result': result})