diff options
Diffstat (limited to 'tor-metrics/generate.py')
| -rwxr-xr-x | tor-metrics/generate.py | 44 |
1 files changed, 34 insertions, 10 deletions
diff --git a/tor-metrics/generate.py b/tor-metrics/generate.py index 2f573a5..fdb0a25 100755 --- a/tor-metrics/generate.py +++ b/tor-metrics/generate.py @@ -15,6 +15,7 @@ def generate_html(relays): pages_by_key(relays, 'as') pages_by_key(relays, 'country') pages_by_key(relays, 'platform') + effective_family(relays) unsorted(relays, 'index.html', is_index=True) unsorted(relays.json['relays'], 'all.html', is_index=False) static_src_path = os.path.join(abs_path, 'static') @@ -23,12 +24,31 @@ def generate_html(relays): copytree(static_src_path, static_dest_path) def unsorted(relays, filename, is_index): - template_env = env.get_template(filename) - template_render = template_env.render(relays=relays, is_index=is_index) + template = env.get_template(filename) + template_render = template.render(relays=relays, is_index=is_index) output = os.path.join(config.CONFIG['output_root'], filename) with open(output, 'w', encoding='utf8') as out: out.write(template_render) +def effective_family(relays): + template = env.get_template('effective_family.html') + output_path = os.path.join(config.CONFIG['output_root'], 'family') + relay_list = relays.json['relays'] + q_relays = [] # qualified relays w/ > 1 effective family member + for relay in relay_list: + if len(relay['effective_family']) > 1: + q_relays.append(relay) + for relay in q_relays: + fingerprint = relay['fingerprint'] + members = [] # list of member relays (dict) + bandwidth = 0 # total bandwidth for family subset + for p_relay in q_relays: + if fingerprint in p_relay['effective_family']: + members.append(p_relay) + bandwidth += p_relay['observed_bandwidth'] + write(output_path, members, bandwidth, template, fingerprint, + category='family') + def pages_by_key(relays, key): template = env.get_template(key + '.html') output_path = os.path.join(config.CONFIG['output_root'], key) @@ -46,14 +66,18 @@ def pages_by_key(relays, key): if p_relay.get(key) and p_relay[key] == relay[key]: found_relays.append(p_relay) bandwidth += p_relay['observed_bandwidth'] - bandwidth = round(bandwidth / 1000000, 2) # convert to MB/s - dir_path = os.path.join(output_path, relay[key]) - os.makedirs(dir_path) - rendered = template.render(relays=found_relays, bandwidth=bandwidth, - deactivate=key, is_index=False, path_prefix='../../', - special_countries=countries.the_prefixed) - with open(os.path.join(dir_path, 'index.html'), 'w', encoding='utf8') as html: - html.write(rendered) + write(output_path, found_relays, bandwidth, template, relay[key]) + +def write(parent_dir, relays, bandwidth, template, key, category=None): + dir_path = os.path.join(parent_dir, key) + os.makedirs(dir_path) + f_bandwidth = round(bandwidth / 1000000, 2) # convert to MB/s + rendered = template.render(relays=relays, bandwidth=f_bandwidth, + focused=key, is_index=False, category=category, path_prefix='../../', + special_countries=countries.the_prefixed) + with open(os.path.join(dir_path, 'index.html'), 'w', encoding='utf8') as html: + html.write(rendered) + relays = Relays() generate_html(relays) |