1 import threading, socket, traceback, time, sys
5 return ''.join(random.choice(string.ascii_uppercase + string.digits) for x in range(N))
7 from processor import Processor
10 class IrcThread(threading.Thread):
12 def __init__(self, processor, config):
13 threading.Thread.__init__(self)
14 self.processor = processor
16 self.stratum_tcp_port = config.get('server','stratum_tcp_port')
17 self.stratum_http_port = config.get('server','stratum_http_port')
19 self.host = config.get('server','host')
20 self.nick = config.get('server', 'irc_nick')
21 if not self.nick: self.nick = random_string(10)
24 return self.peers.values()
29 if self.stratum_tcp_port:
30 s += 't' + self.stratum_tcp_port + ' '
31 if self.stratum_http_port:
32 s += 'h' + self.stratum_http_port + ' '
37 ircname = self.getname()
39 while not self.processor.shared.stopped():
42 s.connect(('irc.freenode.net', 6667))
43 s.send('USER electrum 0 * :' + self.host + ' ' + ircname + '\n')
44 s.send('NICK E_' + self.nick + '\n')
45 s.send('JOIN #electrum\n')
46 sf = s.makefile('r', 0)
48 while not self.processor.shared.stopped():
50 line = line.rstrip('\r\n')
53 s.send('PONG '+line[1]+'\n')
54 elif '353' in line: # answer to /names
56 for item in line[k+1:]:
58 s.send('WHO %s\n'%item)
59 elif '352' in line: # answer to /who
60 # warning: this is a horrible hack which apparently works
63 ip = socket.gethostbyname(ip)
67 self.peers[name] = (ip, host, ports)
68 if time.time() - t > 5*60:
69 self.processor.push_response({'method':'server.peers', 'params':[self.get_peers()]})
70 s.send('NAMES #electrum\n')
74 traceback.print_exc(file=sys.stdout)
83 class ServerProcessor(Processor):
85 def __init__(self, config):
86 Processor.__init__(self)
88 self.banner = config.get('server','banner')
89 self.password = config.get('server','password')
91 if config.get('server', 'irc') == 'yes':
92 self.irc = IrcThread(self, config)
99 return self.irc.get_peers()
109 def process(self, request):
110 method = request['method']
111 params = request['params']
114 if method in ['server.stop', 'server.info']:
116 password = request['params'][0]
120 if password != self.password:
121 response = { 'id':request['id'], 'result':None, 'error':'incorrect password'}
122 self.push_response(response)
125 if method == 'server.banner':
126 result = self.banner.replace('\\n','\n')
128 elif method == 'server.peers.subscribe':
129 result = self.get_peers()
131 elif method == 'server.version':
134 elif method == 'server.stop':
138 elif method == 'server.info':
139 result = map(lambda s: { "time":s.time,
143 "subscriptions":len(s.subscriptions)},
144 self.dispatcher.request_dispatcher.get_sessions())
146 elif method == 'server.load':
147 p = self.dispatcher.request_dispatcher.processors['blockchain']
148 result = p.queue.qsize()
151 print "unknown method", request
154 response = { 'id':request['id'], 'result':result }
155 self.push_response(response)