2 from blockchain import Blockchain
3 import threading, time, Queue, os, sys, shutil
4 from util import user_dir, appdata_dir, print_error
8 class Network(threading.Thread):
10 def __init__(self, config):
11 threading.Thread.__init__(self)
14 self.lock = threading.Lock()
15 self.blockchain = Blockchain(config)
17 self.queue = Queue.Queue()
18 self.default_server = self.config.get('server')
19 self.servers_list = interface.filter_protocol(interface.DEFAULT_SERVERS,'s')
23 def start_interfaces(self):
25 for server in self.servers_list:
26 self.interfaces[server] = interface.Interface({'server':server})
28 for i in self.interfaces.values():
31 if self.default_server:
32 self.interface = interface.Interface({'server':self.default_server})
33 self.interface.start(self.queue)
35 self.interface = self.interfaces[0]
43 self.blockchain.start()
44 self.start_interfaces()
49 while self.is_running():
53 i.register_channel('verifier', self.blockchain.queue)
54 i.register_channel('get_header')
55 i.send([ ('blockchain.headers.subscribe',[])], 'verifier')
56 if i == self.interface:
57 i.send([('server.banner',[])])
58 i.send([('server.peers.subscribe',[])])
60 self.interfaces.pop(i.server)
61 if i == self.interface:
62 if self.default_server is None:
63 print_msg("Using random server...")
64 server = random.choice( self.servers_list )
65 self.interface = interface.Interface({'server':self.default_server})
67 #i.trigger_callback('disconnected')
70 def on_peers(self, resut):
73 def on_banner(self, result):
77 with self.lock: self.running = False
80 with self.lock: return self.running
83 def resend_subscriptions(self):
84 for channel, messages in self.subscriptions.items():
86 self.send(messages, channel)
90 if not self.is_connected and self.config.get('auto_cycle'):
91 print_msg("Using random server...")
92 servers = filter_protocol(DEFAULT_SERVERS, 's')
94 server = random.choice( servers )
95 servers.remove(server)
97 self.config.set_key('server', server, False)
98 self.init_with_server(self.config)
99 if self.is_connected: break
101 if not self.is_connected:
102 print 'no server available'
103 self.connect_event.set() # to finish start
104 self.server = 'ecdsa.org:50001:t'
111 if __name__ == "__main__":
113 config = simple_config.SimpleConfig({'verbose':True})
114 network = Network(config)