src/allmydata/web/introweb.py

   1
   2 from nevow import rend
   3 from foolscap.referenceable import SturdyRef
   4 from twisted.internet import address
   5 import allmydata
   6 from allmydata import get_package_versions_string
   7 from allmydata.util import idlib
   8 from common import getxmlfile, IClient
   9
  10 class IntroducerRoot(rend.Page):
  11
  12     addSlash = True
  13     docFactory = getxmlfile("introducer.xhtml")
  14
  15     def data_version(self, ctx, data):
  16         return get_package_versions_string()
  17     def data_import_path(self, ctx, data):
  18         return str(allmydata)
  19     def data_my_nodeid(self, ctx, data):
  20         return idlib.nodeid_b2a(IClient(ctx).nodeid)
  21
  22     def data_known_storage_servers(self, ctx, data):
  23         i = IClient(ctx).getServiceNamed("introducer")
  24         storage = [1
  25                    for (furl, service_name, ri_name, nickname, ver, oldest)
  26                    in i.get_announcements()
  27                    if service_name == "storage"]
  28         return len(storage)
  29
  30     def data_num_clients(self, ctx, data):
  31         i = IClient(ctx).getServiceNamed("introducer")
  32         num_clients = 0
  33         subscribers = i.get_subscribers()
  34         for service_name,who in subscribers.items():
  35             num_clients += len(who)
  36         return num_clients
  37
  38     def data_services(self, ctx, data):
  39         i = IClient(ctx).getServiceNamed("introducer")
  40         ann = list(i.get_announcements())
  41         ann.sort(lambda a,b: cmp( (a[1], a), (b[1], b) ) )
  42         return ann
  43
  44     def render_service_row(self, ctx, announcement):
  45         (furl, service_name, ri_name, nickname, ver, oldest) = announcement
  46         sr = SturdyRef(furl)
  47         nodeid = sr.tubID
  48         advertised = [loc.split(":")[0] for loc in sr.locationHints]
  49         ctx.fillSlots("peerid", "%s %s" % (idlib.nodeid_b2a(nodeid), nickname))
  50         ctx.fillSlots("advertised", " ".join(advertised))
  51         ctx.fillSlots("connected", "?")
  52         ctx.fillSlots("since", "?")
  53         ctx.fillSlots("announced", "?")
  54         ctx.fillSlots("version", ver)
  55         ctx.fillSlots("service_name", service_name)
  56         return ctx.tag
  57
  58     def data_subscribers(self, ctx, data):
  59         i = IClient(ctx).getServiceNamed("introducer")
  60         s = []
  61         for service_name, subscribers in i.get_subscribers().items():
  62             for rref in subscribers:
  63                 s.append( (service_name, rref) )
  64         s.sort()
  65         return s
  66
  67     def render_subscriber_row(self, ctx, s):
  68         (service_name, rref) = s
  69         sr = rref.getSturdyRef()
  70         nodeid = sr.tubID
  71         ctx.fillSlots("peerid", "%s" % idlib.nodeid_b2a(nodeid))
  72         advertised = [loc.split(":")[0] for loc in sr.locationHints]
  73         ctx.fillSlots("advertised", " ".join(advertised))
  74         remote_host = rref.tracker.broker.transport.getPeer()
  75         if isinstance(remote_host, address.IPv4Address):
  76             remote_host_s = "%s:%d" % (remote_host.host, remote_host.port)
  77         else:
  78             # loopback is a non-IPv4Address
  79             remote_host_s = str(remote_host)
  80         ctx.fillSlots("connected", remote_host_s)
  81         ctx.fillSlots("since", "?")
  82         ctx.fillSlots("service_name", service_name)
  83         return ctx.tag
  84
  85