diff --git a/lg.py b/lg.py
index e528c32..d5a1239 100644
--- a/lg.py
+++ b/lg.py
@@ -52,6 +52,13 @@ file_handler.setLevel(getattr(logging, app.config["LOG_LEVEL"].upper()))
app.logger.addHandler(file_handler)
+def reverse(ip):
+ try:
+ name, alias, addresslist = socket.gethostbyaddr(ip)
+ return name
+ except socket.herror:
+ return ""
+
def get_asn_from_as(n):
asn_zone = app.config.get("ASN_ZONE", "asn.cymru.com")
try:
@@ -64,16 +71,31 @@ def get_asn_from_as(n):
def add_links(text):
"""Browser a string and replace ipv4, ipv6, as number, with a
whois link """
+ ipv4_re = re.compile('(BGP.next_hop|BGP.originator_id):\s+(\d+\.\d+\.\d+\.\d+).*')
+ ipv6_re = re.compile('(BGP.next_hop|BGP.originator_id):\s+(([0-9a-fA-F]{1,4}:)*:?(?:([0-9a-fA-F]{1,4}))).*')
if type(text) in [str, unicode]:
text = text.split("\n")
ret_text = []
for line in text:
+ reverse = None
+ mipv4 = ipv4_re.match(line.strip())
+ mipv6 = ipv6_re.match(line.strip())
# Some heuristic to create link
if line.strip().startswith("BGP.as_path:") or \
line.strip().startswith("Neighbor AS:"):
ret_text.append(re.sub(r'(\d+)', r'\1', line))
+ elif mipv4:
+ ipv4 = mipv4.group(2)
+ reverse = dns(ipv4)
+ line = re.sub(ipv4,r''+ipv4+' '+reverse+'', line)
+ ret_text.append(line)
+ elif mipv6:
+ ipv6 = mipv6.group(2)
+ reverse = dns(ipv6)
+ line = re.sub(ipv6,r''+ipv6+' '+reverse+'', line)
+ ret_text.append(line)
else:
line = re.sub(r'([a-zA-Z0-9\-]*\.([a-zA-Z]{2,3}){1,2})(\s|$)', r'\1\3', line)
line = re.sub(r'(?<=\[)AS(\d+)', r'AS\1', line)
@@ -87,6 +109,94 @@ def add_links(text):
ret_text.append(line)
return "\n".join(ret_text)
+def add_json(text):
+ """Browser a string and replace ipv4, ipv6, as number, with a
+ whois link """
+ ipv4_re = re.compile('^(\d+\.\d+\.\d+\.\d+).*')
+ ipv6_re = re.compile('^(([0-9a-fA-F]{1,4}:)*:?(?:([0-9a-fA-F]{1,4}))).*')
+
+ if type(text) in [str, unicode]:
+ text = text.split("\n")
+
+ q = {}
+ data = []
+ current = {}
+ current['asPath'] = ""
+ current['med'] = 0
+ peer = ""
+ for line in text:
+ reverse = None
+ mipv4 = ipv4_re.match(line.strip())
+ mipv6 = ipv6_re.match(line.strip())
+ # Some heuristic to create link
+ m = re.search(r'^((?:\d+\.\d+\.\d+\.\d+)|(?:[0-9a-fA-F]{1,4}:)*:?(?:(?:[0-9a-fA-F]{1,4})?))?\/?(\d+)?\s+via\s+((?:\d+\.\d+\.\d+\.\d+)|(?:[0-9a-fA-F]{1
+,4}:)*:?(?:(?:[0-9a-fA-F]{1,4})?))\son\seth\d+\s\[([a-z0-9_]+)\s(\d+-\d+-\d+)\sfrom\s((?:\d+\.\d+\.\d+\.\d+)|(?:[0-9a-fA-F]{1,4}:)*:?(?:(?:[0-9a-fA-F]{1,4})?)
+)\].*$', line.strip())
+ if m is not None:
+ if peer != m.group(4):
+ data.append(current)
+ if m.group(1):
+ current['network'] = m.group(1)
+ current['netmask'] = m.group(2)
+ peer = m.group(4)
+ current['fromPeer'] = m.group(4)
+ current['last'] = m.group(5)
+ current['via'] = m.group(3)
+ current['from'] = m.group(6)
+ if re.match(r"\d+\.\d+\.\d+\.\d+", current['network']):
+ current["ipType"] = "IPv4"
+ elif re.match(r"(?:[0-9a-fA-F]{1,4}:)*:?(?:(?:[0-9a-fA-F]{1,4})?)", current['network']):
+ current["ipType"] = "IPv6"
+ if line.strip().startswith("BGP.as_path:"):
+ m = re.search(r"BGP.as_path: (?P\d+\s*)*", line.strip())
+ if m is not None:
+ current['asPath'] = m.group('asPath')
+ elif line.strip().startswith("BGP.origin:"):
+ m = re.search(r"BGP.origin: (?P\w+\s*)*", line.strip())
+ if m is not None:
+ current['origin'] = m.group('origin')
+ else:
+ current['origin'] = ""
+ elif line.strip().startswith("BGP.next_hop:"):
+ m = re.search(r"BGP.next_hop: (?P((([a-f\d]{0,4}:){3,10}[a-f\d]{0,4})|(\d+\.\d+\.\d+\.\d+))\s*)*", line.strip())
+ if m is not None:
+ current['nextHop'] = {'addr': m.group('nextHop'), "reverse": reverse(m.group('nextHop'))}
+ else:
+ current['nextHop'] = {'addr': "", "reverse": ""}
+ elif line.strip().startswith("BGP.med:"):
+ m = re.search(r"BGP.med: (?P\d+\s*)*", line.strip())
+ if m is not None:
+ current['med'] = int(m.group('med'))
+ else:
+ current['med'] = 0
+ elif line.strip().startswith("BGP.local_pref:"):
+ m = re.search(r"BGP.local_pref: (?P\d+\s*)*", line.strip())
+ if m is not None:
+ current['localPref'] = int(m.group('localPref'))
+ else:
+ current['localPref'] = 0
+ elif line.strip().startswith("BGP.originator_id:"):
+ m = re.search(r"BGP.originator_id: (?P((([a-f\d]{0,4}:){3,10}[a-f\d]{0,4})|(\d+\.\d+\.\d+\.\d+))\s*)*", line.strip())
+ if m is not None:
+ current['originatorId'] = {'addr': m.group('origin'), "reverse": reverse(m.group('origin'))}
+ else:
+ current['originator'] = {'addr': "", "reverse": ""}
+ elif line.strip().startswith("BGP.community:"):
+ current['community'] = []
+ for m in re.findall(r"(\d+,\d+)", line.strip()):
+ if m is not None:
+ community = m
+ current['community'].append(community.replace(',',':'))
+ else:
+ current['community'] = ""
+ elif line.strip().startswith("BGP.cluster_list:"):
+ current['clusterList'] = []
+ for m in re.findall(r"(\d+\.\d+\.\d+\.\d+)", line.strip()):
+ if m is not None:
+ current['clusterList'].append(m)
+ data.append(current)
+ return {'result':data}
+
def set_session(request_type, hosts, proto, request_args):
""" Store all data from user in the user session """
@@ -377,6 +487,12 @@ def show_route_for_detail(hosts, proto):
def show_route_for_bgpmap(hosts, proto):
return show_route("prefix_bgpmap", hosts, proto)
+@app.route("/api//")
+def show_route_for_api(hosts, proto):
+ resp = Response(response=show_route_api("prefix_detail", hosts, proto),
+ status=200,
+ mimetype="application/json")
+ return resp
def get_as_name(_as):
"""Returns a string that contain the as number following by the as name
@@ -679,5 +795,56 @@ def show_route(request_type, hosts, proto):
return render_template((bgpmap and 'bgpmap.html' or 'route.html'), detail=detail, command=command, expression=expression, errors=errors)
+def show_route_api(request_type, hosts, proto):
+ expression = get_query()
+ if not expression:
+ abort(400)
+
+ set_session(request_type, hosts, proto, expression)
+
+ mask = ""
+ if len(expression.split("/")) == 2:
+ 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 is invalid" % mask)
+ if proto == "ipv6" and not ipv6_is_valid(expression):
+ try:
+ expression = resolve(expression, "AAAA")
+ except:
+ return error_page("%s is unresolvable or invalid for %s" % (expression, proto))
+ if proto == "ipv4" and not ipv4_is_valid(expression):
+ try:
+ expression = resolve(expression, "A")
+ except:
+ return error_page("%s is unresolvable or invalid for %s" % (expression, proto))
+ if mask:
+ expression += "/" + mask
+
+ command = "show route for " + expression + "all"
+
+ detail = {}
+ errors = []
+ for host in hosts.split("+"):
+ ret, res = bird_command(host, proto, command)
+ res = res.split("\n")
+
+ if ret is False:
+ errors.append("%s" % res)
+ continue
+
+ if len(res) <= 1:
+ errors.append("%s: bird command failed with error, %s" % (host, "\n".join(res)))
+ continue
+
+ detail[host] = add_json(res)
+
+ return json.dumps(detail)
+
+
if __name__ == "__main__":
app.run(app.config.get("BIND_IP", "0.0.0.0"), app.config.get("BIND_PORT", 5000))