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
9 class ServerProcessor(Processor):
11 def __init__(self, config):
12 Processor.__init__(self)
15 self.banner = config.get('server','banner')
16 self.host = config.get('server','host')
17 self.password = config.get('server','password')
19 self.native_port = config.get('server','native_port')
20 self.stratum_tcp_port = config.get('server','stratum_tcp_port')
21 self.stratum_http_port = config.get('server','stratum_http_port')
23 self.irc = config.get('server', 'irc') == 'yes'
24 self.nick = config.get('server', 'irc_nick')
25 if not self.nick: self.nick = random_string(10)
29 return self.peers.values()
35 s+= 'n' + self.native_port + ' '
36 if self.stratum_tcp_port:
37 s += 't' + self.stratum_tcp_port + ' '
38 if self.stratum_http_port:
39 s += 'h' + self.stratum_http_port + ' '
47 ircname = self.getname()
49 while not self.shared.stopped():
52 s.connect(('irc.freenode.net', 6667))
53 s.send('USER electrum 0 * :' + self.host + ' ' + ircname + '\n')
54 s.send('NICK E_' + self.nick + '\n')
55 s.send('JOIN #electrum\n')
56 sf = s.makefile('r', 0)
58 while not self.shared.stopped():
60 line = line.rstrip('\r\n')
63 s.send('PONG '+line[1]+'\n')
64 elif '353' in line: # answer to /names
66 for item in line[k+1:]:
68 s.send('WHO %s\n'%item)
69 elif '352' in line: # answer to /who
70 # warning: this is a horrible hack which apparently works
73 ip = socket.gethostbyname(ip)
77 self.peers[name] = (ip, host, ports)
78 if time.time() - t > 5*60:
79 self.push_response({'method':'server.peers', 'params':[self.get_peers()]})
80 s.send('NAMES #electrum\n')
84 traceback.print_exc(file=sys.stdout)
91 def process(self, request):
92 method = request['method']
93 params = request['params']
96 if method in ['server.stop', 'server.info']:
98 password = request['params'][0]
102 if password != self.password:
103 response = { 'id':request['id'], 'result':None, 'error':'incorrect password'}
104 self.push_response(response)
107 if method == 'server.banner':
108 result = self.banner.replace('\\n','\n')
110 elif method == 'server.peers.subscribe':
111 result = self.get_peers()
113 elif method == 'server.version':
116 elif method == 'server.stop':
120 elif method == 'server.info':
121 result = map(lambda s: { "address":s.address, "version":s.version, "subscriptions":len(s.subscriptions)}, self.dispatcher.request_dispatcher.sessions)
124 print "unknown method", request
127 response = { 'id':request['id'], 'method':method, 'params':params, 'result':result }
128 self.push_response(response)