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.host)[:5].encode("hex")
44 if config.get('server', 'coin') == 'litecoin':
46 self.pruning = config.get('server', 'backend') == 'leveldb'
48 self.pruning_limit = config.get('leveldb', 'pruning_limit')
49 self.nick = self.prepend + self.nick
52 return self.peers.values()
55 s = 'v' + VERSION + ' '
57 s += 'p' + self.pruning_limit + ' '
59 def add_port(letter, number):
60 DEFAULT_PORTS = {'t':'50001', 's':'50002', 'h':'8081', 'g':'8082'}
61 if not number: return ''
62 if DEFAULT_PORTS[letter] == number:
65 return letter + number + ' '
67 s += add_port('t',self.stratum_tcp_port)
68 s += add_port('h',self.stratum_http_port)
69 s += add_port('s',self.stratum_tcp_ssl_port)
70 s += add_port('g',self.stratum_http_ssl_port)
74 ircname = self.getname()
75 print_log("joining IRC")
77 while not self.processor.shared.stopped():
80 s.connect(('irc.freenode.net', 6667))
84 print_log("IRC: reconnect in 10 s")
92 s.send('USER electrum 0 * :' + self.host + ' ' + ircname + '\n')
93 s.send('NICK ' + self.nick + '\n')
94 s.send('JOIN #electrum\n')
97 while not self.processor.shared.stopped():
100 except socket.timeout, e:
106 print_log( "irc: socket error" )
112 while self.message.find('\n') != -1:
113 pos = self.message.find('\n')
114 line = self.message[0:pos]
115 self.message = self.message[pos+1:]
116 line = line.strip('\r')
119 # print_log("<--", line)
121 if line[0] == 'PING':
122 out_msg.append('PONG ' + line[1] + '\n')
123 elif '353' in line[1]: # answer to /names
124 k = line.index('353')
125 for item in line[k+1:]:
126 if item.startswith(self.prepend):
127 out_msg.append('WHO %s\n' % item)
128 elif '352' in line[1]: # answer to /who
129 # warning: this is a horrible hack which apparently works
130 k = line.index('352')
132 ip = socket.gethostbyname(line[k+4])
134 print_log("gethostbyname error", line[k+4])
139 self.peers[name] = (ip, host, ports)
140 elif 'KICK' in line[1]:
142 print_log("KICK", line[3] + line[4])
144 print_log("KICK", "error")
146 if time.time() - t > 5*60:
147 #self.processor.push_response({'method': 'server.peers', 'params': [self.get_peers()]})
148 s.send('NAMES #electrum\n')
152 traceback.print_exc(file=sys.stdout)
157 print_log("quitting IRC")
160 class ServerProcessor(Processor):
162 def __init__(self, config):
163 Processor.__init__(self)
165 self.banner = config.get('server', 'banner')
167 if config.get('server', 'irc') == 'yes':
168 self.irc = IrcThread(self, config)
174 return self.irc.get_peers()
183 def process(self, session, request):
184 method = request['method']
185 params = request['params']
188 if method == 'server.banner':
189 result = self.banner.replace('\\n', '\n')
191 elif method == 'server.peers.subscribe':
192 result = self.get_peers()
194 elif method == 'server.version':
198 print_log("unknown method", method)
201 self.push_response(session, {'id': request['id'], 'result': result})