peermanager.py

# -*- coding: utf-8 -*-

from servent import * #Servent object and lots of EVTs possibly

class PeerManager:
  def __init__(self, argv, peergov):
    self.datamanager = peergov.manager
    self.peergov = peergov
    if len(argv)==0:
      print("Note: No meta-peers found on command line. TODO: look for peers in peer history")
    defaultport = self.peergov.port or 4991
    self.servent = Servent(self, defaultport)
    for peer in argv:
      try:
        hp = peer.split(":") #host:port for ipv4 or name lookup. FIXME: needs regexp for ipv6
        port = hp[1:2] and int(hp[1]) or defaultport
        self.servent.connectTo((2,1,6,'',(hp[0], port))) 
        pass
      except Exception,e:
        print str(e)

  def handleServentEvent(self, event, peerid):
    if event == EVT_PEER_PROTOCOL_VERIFIED:
      self.servent.syncAuthorities(peerid)
    elif event == EVT_PEER_AUTHORITIES_SYNCHRONIZED:   
      with self.datamanager.authorities_lock:
        authorities = self.datamanager.authorities 
        if authorities:
          for authfpr in authorities.keys():
            authority = authorities[authfpr]
            if authority.interesting:
              self.servent.syncTopics(peerid, authority)
        else:
          print("No authorities?")
      self.peergov.resetTree()
    elif event == EVT_PEER_TOPIC_SYNCHRONIZED:
      self.peergov.resetTree()