mirror of
https://github.com/sileht/bird-lg.git
synced 2024-11-05 15:44:42 +01:00
217 lines
6.7 KiB
Python
Executable file
217 lines
6.7 KiB
Python
Executable file
#!/usr/bin/python
|
|
|
|
import sys
|
|
import os
|
|
import subprocess
|
|
import re
|
|
from urllib2 import urlopen
|
|
from urllib import quote
|
|
|
|
from toolbox import mask_is_valid, ipv6_is_valid, ipv4_is_valid, resolve
|
|
|
|
from bird import BirdSocketSingleton
|
|
from flask import Flask, render_template, jsonify, redirect, session, request
|
|
|
|
app = Flask(__name__)
|
|
app.config.from_pyfile('lg.cfg')
|
|
|
|
|
|
#def same_origin_policy_hander(resp):
|
|
# resp.headers["Access-Control-Allow-Origin"] = "*"
|
|
# return resp
|
|
#
|
|
#app.after_request(same_origin_policy_hander)
|
|
#
|
|
|
|
def add_links(text):
|
|
if type(text) in [ str, unicode ]:
|
|
text = text.split("\n")
|
|
|
|
ret_text = []
|
|
for line in text:
|
|
if line.strip().startswith("BGP.as_path:") or \
|
|
line.strip().startswith("Neighbor AS:") :
|
|
ret_text.append(re.sub(r'(\d+)',r'<a href="/whois/\1" class="whois">\1</a>',line))
|
|
else:
|
|
line = re.sub(r'([a-zA-Z0-9\-]*\.([a-zA-Z]{2,3}){1,2})(\s|$)', r'<a href="/whois/\1" class="whois">\1</a>',line)
|
|
line = re.sub(r'AS(\d+)', r'<a href="/whois/\1" class="whois">AS\1</a>',line)
|
|
line = re.sub(r'(\d+\.\d+\.\d+\.\d+)', r'<a href="/whois/\1" class="whois">\1</a>',line)
|
|
ret_text.append(line)
|
|
return "\n".join(ret_text)
|
|
|
|
def set_session(req_type, hosts, proto, request_args):
|
|
session.permanent = True
|
|
session.update( {
|
|
"req_type": req_type,
|
|
"hosts": hosts,
|
|
"proto": proto,
|
|
"request_args": request_args,
|
|
})
|
|
history = session.get("history", {})
|
|
req_hist = history.get(req_type, [])
|
|
if request_args and request_args not in req_hist: req_hist.insert(0, request_args)
|
|
if not history: session["history"] = {}
|
|
session["history"][req_type] = req_hist[:10]
|
|
|
|
def bird_command(host, proto, query):
|
|
return bird_proxy(host, proto, "bird", query)
|
|
|
|
def bird_proxy(host, proto, service, query):
|
|
path = ""
|
|
if proto == "ipv6": path = service + "6"
|
|
elif proto == "ipv4": path = service
|
|
port = app.config["PROXY"].get(host,"")
|
|
if not port or not path:
|
|
return False, "Host/Proto not allowed"
|
|
else:
|
|
url = "http://%s.%s:%d/%s?q=%s" % (host, app.config["DOMAIN"], port, path, quote(query))
|
|
try:
|
|
f = urlopen(url)
|
|
resultat = f.read()
|
|
status = True # retreive remote status
|
|
except IOError:
|
|
resultat = "Failed retreive url: %s" % url
|
|
status = False
|
|
return status, resultat
|
|
|
|
@app.context_processor
|
|
def inject_all_host():
|
|
return dict(all_hosts="+".join(app.config["PROXY"].keys()))
|
|
|
|
@app.route("/")
|
|
def hello():
|
|
return redirect("/summary/%s/ipv4" % "+".join(app.config["PROXY"].keys()) )
|
|
|
|
def error_page(text):
|
|
return render_template('error.html', data = { "error": text } ), 500
|
|
|
|
|
|
@app.route("/whois/<query>")
|
|
def whois(query):
|
|
try:
|
|
asnum = int(query)
|
|
query = "as%d"%asnum
|
|
except:
|
|
m = re.match(r"[\w\d-]*\.(?P<domain>[\d\w-]+\.[\d\w-]+)$", query)
|
|
if m: query = query.groupdict()["domain"]
|
|
output = subprocess.Popen( [ 'whois', query], stdout=subprocess.PIPE).communicate()[0].decode('utf-8', 'ignore').replace("\n","<br>")
|
|
return jsonify(output=output, title=query)
|
|
|
|
SUMMARY_UNWANTED_PROTOS = ["Kernel", "Static", "Device"]
|
|
SUMMARY_RE_MATCH = r"(?P<name>[\w_]+)\s+(?P<proto>\w+)\s+(?P<table>\w+)\s+(?P<state>\w+)\s+(?P<since>((|\d\d\d\d-\d\d-\d\d\s)(|\d\d:)\d\d:\d\d|\w\w\w\d\d))($|\s+(?P<info>.*))"
|
|
|
|
@app.route("/summary/<hosts>")
|
|
@app.route("/summary/<hosts>/<proto>")
|
|
def summary(hosts, proto="ipv4"):
|
|
set_session("summary", hosts, proto, "")
|
|
command = "show protocols"
|
|
|
|
summary = {}
|
|
for host in hosts.split("+"):
|
|
ret, res = bird_command(host, proto, command)
|
|
res = res.split("\n")
|
|
if len(res) > 1: #if ret:
|
|
data = []
|
|
for line in res[1:]:
|
|
line = line.strip()
|
|
if line and ( line.split() + [""] )[1] not in SUMMARY_UNWANTED_PROTOS:
|
|
m = re.match(SUMMARY_RE_MATCH ,line)
|
|
if m:
|
|
data.append(m.groupdict())
|
|
else:
|
|
app.logger.warning("couldn't parse: %s" , line)
|
|
|
|
summary[host] = data
|
|
else:
|
|
summary[host] = { "error" : "\n".join(res) }
|
|
|
|
return render_template('summary.html', summary=summary, command=command)
|
|
|
|
@app.route("/detail/<hosts>/<proto>")
|
|
def detail(hosts, proto):
|
|
name = request.args.get('q', '')
|
|
set_session("detail", hosts, proto, name)
|
|
command = "show protocols all %s" % name
|
|
|
|
detail = {}
|
|
for host in hosts.split("+"):
|
|
ret, res = bird_command(host, proto, command)
|
|
res = res.split("\n")
|
|
if len(res) > 1 : #if ret:
|
|
detail[host] = { "status": res[1], "description": add_links(res[2:]) }
|
|
else:
|
|
detail[host] = { "status": "bird error: %s" % "\n".join(res), "description": "" }
|
|
|
|
return render_template('detail.html', detail=detail, command=command)
|
|
|
|
@app.route("/traceroute/<hosts>/<proto>")
|
|
def traceroute(hosts, proto):
|
|
q = request.args.get('q', '')
|
|
set_session("traceroute", hosts, proto, q)
|
|
|
|
infos = {}
|
|
for host in hosts.split("+"):
|
|
status, resultat = bird_proxy(host, proto, "traceroute", q)
|
|
infos[host] = add_links(resultat)
|
|
return render_template('traceroute.html', infos=infos)
|
|
|
|
@app.route("/where/<hosts>/<proto>")
|
|
def show_route_where(hosts, proto):
|
|
return show_route("where", hosts, proto)
|
|
|
|
@app.route("/where_detail/<hosts>/<proto>")
|
|
def show_route_where_detail(hosts, proto):
|
|
return show_route("where_detail", hosts, proto)
|
|
|
|
@app.route("/prefix/<hosts>/<proto>")
|
|
def show_route_for(hosts, proto):
|
|
return show_route("prefix", hosts, proto)
|
|
|
|
@app.route("/prefix_detail/<hosts>/<proto>")
|
|
def show_route_for_detail(hosts, proto):
|
|
return show_route("prefix_detail", hosts, proto)
|
|
|
|
def show_route(req_type, hosts, proto):
|
|
expression = request.args.get('q', '')
|
|
set_session(req_type, hosts, proto, expression)
|
|
|
|
all = (req_type.endswith("detail") and " all" or "" )
|
|
|
|
if req_type.startswith("where"):
|
|
command = "show route where net ~ [ " + expression + " ]" + all
|
|
else:
|
|
mask = ""
|
|
if len(expression.split("/")) > 1:
|
|
expression, mask = (expression.split("/"))
|
|
|
|
if not mask and proto == "ipv4" : mask = "32"
|
|
if not mask and proto == "ipv6" : mask = "128"
|
|
if not mask_is_valid(mask):
|
|
return error_page("mask %s invalid" % mask)
|
|
if proto == "ipv6" and not ipv6_is_valid(expression):
|
|
try: expression = resolve(expression, "AAAA")
|
|
except: return error_page("%s unresolvable/invalid" % expression)
|
|
if proto == "ipv4" and not ipv4_is_valid(expression):
|
|
try: expression = resolve(expression, "A")
|
|
except: return error_page("%s unresolvable/invalid" % expression)
|
|
|
|
if mask: expression += "/" + mask
|
|
command = "show route for " + expression + all
|
|
|
|
detail = {}
|
|
for host in hosts.split("+"):
|
|
ret, res = bird_command(host, proto, command)
|
|
|
|
res = res.split("\n")
|
|
if len(res) > 1 : #if ret:
|
|
detail[host] = add_links(res)
|
|
else:
|
|
detail[host] = "bird error: %s" % "\n".join(res)
|
|
|
|
return render_template('route.html', detail=detail, command=command, expression=expression )
|
|
|
|
app.secret_key = app.config["SESSION_KEY"]
|
|
app.debug = True
|
|
if __name__ == "__main__":
|
|
app.run("0.0.0.0")
|