X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=blobdiff_plain;f=backends%2Firc%2F__init__.py;h=46ec92146f9bf427fae491bf320f6e02f9333270;hp=037200295044413d048a6c3a7d2c79e21c8e3e36;hb=3989b283341f5d456a5c6ffdd4e7fd00f57d0fcd;hpb=189fded888582341014f2e34ed6c173926ad5417 diff --git a/backends/irc/__init__.py b/backends/irc/__init__.py index 0372002..46ec921 100644 --- a/backends/irc/__init__.py +++ b/backends/irc/__init__.py @@ -15,13 +15,26 @@ class IrcThread(threading.Thread): self.daemon = True self.stratum_tcp_port = config.get('server','stratum_tcp_port') self.stratum_http_port = config.get('server','stratum_http_port') + self.stratum_tcp_ssl_port = config.get('server','stratum_tcp_ssl_port') + self.stratum_http_ssl_port = config.get('server','stratum_http_ssl_port') + self.report_stratum_tcp_port = config.get('server','report_stratum_tcp_port') + self.report_stratum_http_port = config.get('server','report_stratum_http_port') + self.report_stratum_tcp_ssl_port = config.get('server','report_stratum_tcp_ssl_port') + self.report_stratum_http_ssl_port = config.get('server','report_stratum_http_ssl_port') self.peers = {} self.host = config.get('server','host') + self.report_host = config.get('server','report_host') self.nick = config.get('server', 'irc_nick') + if self.report_stratum_tcp_port: self.stratum_tcp_port = self.report_stratum_tcp_port + if self.report_stratum_http_port: self.stratum_http_port = self.report_stratum_http_port + if self.report_stratum_tcp_ssl_port: self.stratum_tcp_ssl_port = self.report_stratum_tcp_ssl_port + if self.report_stratum_http_ssl_port: self.stratum_http_ssl_port = self.report_stratum_http_ssl_port + if self.report_host: self.host = self.report_host if not self.nick: self.nick = random_string(10) self.prepend = 'E_' if config.get('server', 'coin') == 'litecoin': self.prepend = 'EL_' + self.pruning = config.get('server', 'backend') == 'leveldb' self.nick = self.prepend + self.nick def get_peers(self): @@ -30,10 +43,15 @@ class IrcThread(threading.Thread): def getname(self): s = 'v' + VERSION + ' ' + if self.pruning: s += 'p ' if self.stratum_tcp_port: s += 't' + self.stratum_tcp_port + ' ' if self.stratum_http_port: s += 'h' + self.stratum_http_port + ' ' + if self.stratum_tcp_port: + s += 's' + self.stratum_tcp_ssl_port + ' ' + if self.stratum_http_port: + s += 'g' + self.stratum_http_ssl_port + ' ' return s @@ -44,6 +62,11 @@ class IrcThread(threading.Thread): try: s = socket.socket() s.connect(('irc.freenode.net', 6667)) + except: + time.sleep(10) + continue + + try: s.send('USER electrum 0 * :' + self.host + ' ' + ircname + '\n') s.send('NICK ' + self.nick + '\n') s.send('JOIN #electrum\n') @@ -138,7 +161,7 @@ class ServerProcessor(Processor): elif method == 'server.stop': self.shared.stop() - result = 'ok' + result = 'stopping, please wait until all threads terminate.' elif method == 'server.info': result = map(lambda s: { "time":s.time,