3 from nevow import rend, inevow
4 from nevow.static import File as nevow_File
5 from nevow.util import resource_filename
8 from allmydata import get_package_versions_string
9 from allmydata.util import idlib
10 from allmydata.web.common import getxmlfile, get_arg
12 class IntroducerRoot(rend.Page):
15 docFactory = getxmlfile("introducer.xhtml")
17 child_operations = None
19 def __init__(self, introducer_node):
20 self.introducer_node = introducer_node
21 self.introducer_service = introducer_node.getServiceNamed("introducer")
22 rend.Page.__init__(self, introducer_node)
23 static_dir = resource_filename("allmydata.web", "static")
24 for filen in os.listdir(static_dir):
25 self.putChild(filen, nevow_File(os.path.join(static_dir, filen)))
27 def renderHTTP(self, ctx):
28 t = get_arg(inevow.IRequest(ctx), "t")
30 return self.render_JSON(ctx)
31 return rend.Page.renderHTTP(self, ctx)
33 def render_JSON(self, ctx):
37 for s in self.introducer_service.get_subscribers():
38 if s.service_name not in counts:
39 counts[s.service_name] = 0
40 counts[s.service_name] += 1
41 res["subscription_summary"] = counts
43 announcement_summary = {}
45 for ad in self.introducer_service.get_announcements():
46 service_name = ad.service_name
47 if service_name not in announcement_summary:
48 announcement_summary[service_name] = 0
49 announcement_summary[service_name] += 1
50 if service_name not in service_hosts:
51 service_hosts[service_name] = set()
52 # it's nice to know how many distinct hosts are available for
53 # each service. We define a "host" by a set of addresses
54 # (hostnames or ipv4 addresses), which we extract from the
55 # connection hints. In practice, this is usually close
56 # enough: when multiple services are run on a single host,
57 # they're usually either configured with the same addresses,
58 # or setLocationAutomatically picks up the same interfaces.
59 host = frozenset(ad.advertised_addresses)
60 service_hosts[service_name].add(host)
61 res["announcement_summary"] = announcement_summary
62 distinct_hosts = dict([(name, len(hosts))
64 in service_hosts.iteritems()])
65 res["announcement_distinct_hosts"] = distinct_hosts
67 return simplejson.dumps(res, indent=1) + "\n"
69 # FIXME: This code is duplicated in root.py and introweb.py.
70 def data_version(self, ctx, data):
71 return get_package_versions_string()
72 def data_import_path(self, ctx, data):
73 return str(allmydata).replace("/", "/ ") # XXX kludge for wrapping
74 def data_my_nodeid(self, ctx, data):
75 return idlib.nodeid_b2a(self.introducer_node.nodeid)
77 def render_announcement_summary(self, ctx, data):
79 for ad in self.introducer_service.get_announcements():
80 if ad.service_name not in services:
81 services[ad.service_name] = 0
82 services[ad.service_name] += 1
83 service_names = services.keys()
85 return ", ".join(["%s: %d" % (service_name, services[service_name])
86 for service_name in service_names])
88 def render_client_summary(self, ctx, data):
90 for s in self.introducer_service.get_subscribers():
91 if s.service_name not in counts:
92 counts[s.service_name] = 0
93 counts[s.service_name] += 1
94 return ", ".join([ "%s: %d" % (name, counts[name])
95 for name in sorted(counts.keys()) ] )
97 def data_services(self, ctx, data):
98 services = self.introducer_service.get_announcements(False)
99 services.sort(key=lambda ad: (ad.service_name, ad.nickname))
102 def render_service_row(self, ctx, ad):
103 ctx.fillSlots("serverid", ad.serverid)
104 ctx.fillSlots("nickname", ad.nickname)
105 ctx.fillSlots("advertised", " ".join(ad.advertised_addresses))
106 ctx.fillSlots("connected", "?")
107 when_s = time.strftime("%H:%M:%S %d-%b-%Y", time.localtime(ad.when))
108 ctx.fillSlots("announced", when_s)
109 ctx.fillSlots("version", ad.version)
110 ctx.fillSlots("service_name", ad.service_name)
113 def data_subscribers(self, ctx, data):
114 return self.introducer_service.get_subscribers()
116 def render_subscriber_row(self, ctx, s):
117 ctx.fillSlots("nickname", s.nickname)
118 ctx.fillSlots("tubid", s.tubid)
119 ctx.fillSlots("advertised", " ".join(s.advertised_addresses))
120 ctx.fillSlots("connected", s.remote_address)
121 since_s = time.strftime("%H:%M:%S %d-%b-%Y", time.localtime(s.when))
122 ctx.fillSlots("since", since_s)
123 ctx.fillSlots("version", s.version)
124 ctx.fillSlots("service_name", s.service_name)