|
@ -251,10 +251,10 @@ class bc(object): |
|
|
if self.method == '-e': |
|
|
if self.method == '-e': |
|
|
self.method = '-E' |
|
|
self.method = '-E' |
|
|
try: |
|
|
try: |
|
|
self.content = subprocess.check_output(['lft', '-S', '-n', self.method, self.destination_ip]) |
|
|
self.content = subprocess.check_output(['lft', '-S', '-n', self.destination_ip]) |
|
|
# support for older python versions (<2.7) that don't support subprocess.check_output |
|
|
# support for older python versions (<2.7) that don't support subprocess.check_output |
|
|
except: |
|
|
except: |
|
|
a = subprocess.Popen(['lft', '-S', '-n', self.method, self.destination_ip], stdout=subprocess.PIPE) |
|
|
a = subprocess.Popen(['lft', '-S', '-n', self.destination_ip], stdout=subprocess.PIPE) |
|
|
self.content = a.stdout.read() |
|
|
self.content = a.stdout.read() |
|
|
|
|
|
|
|
|
self.attempts += 1 |
|
|
self.attempts += 1 |
|
@ -331,27 +331,21 @@ class bc(object): |
|
|
self.attempts = 0 |
|
|
self.attempts = 0 |
|
|
self.result_list = [] |
|
|
self.result_list = [] |
|
|
self.lft() |
|
|
self.lft() |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if self.options.debug == True: |
|
|
if self.options.debug == True: |
|
|
logfile = open('tracelogfile', 'a') |
|
|
logfile = open('tracelogfile', 'a') |
|
|
thingstolog = ['='*45 + "\n", "Browser: ", self.browser_path.split('/')[-1], "\n", "Version: ", self.browser_version, "\n", "Path to browser: ", self.browser_path, "\n", "History db: ", self.browser_history_path, "\n","URL: ", self.url[0], "\n", "Host: ",url, "\n", "Host ip: ", url_ip, "\n", '='*45, "\n"] |
|
|
thingstolog = ['='*45 + "\n", "Browser: ", self.browser_path.split('/')[-1], "\n", "Version: ", self.browser_version, "\n", "Path to browser: ", self.browser_path, "\n", "History db: ", self.browser_history_path, "\n","URL: ", self.url[0], "\n", "Host: ",url, "\n", "Host ip: ", url_ip, "\n", '='*45, "\n"] |
|
|
for item in thingstolog: |
|
|
for item in thingstolog: |
|
|
logfile.write(item) |
|
|
logfile.write(item) |
|
|
print '='*45 + "\n" + "Packages Route:\n" + '='*45 |
|
|
print '='*45 + "\n" + "Packages Route:\n" + '='*45 |
|
|
|
|
|
|
|
|
output = self.content.splitlines() |
|
|
output = self.content.splitlines() |
|
|
|
|
|
|
|
|
for line in output: |
|
|
for line in output: |
|
|
if self.options.debug == True: |
|
|
if self.options.debug == True: |
|
|
logfile.write(line+'\n') |
|
|
logfile.write(line+'\n') |
|
|
|
|
|
|
|
|
line = line.split() |
|
|
line = line.split() |
|
|
|
|
|
|
|
|
for ip in line: |
|
|
for ip in line: |
|
|
if re.match(r"^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}$",ip): |
|
|
if re.match(r"^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}$",ip): |
|
|
self.hop_ip = ip |
|
|
self.hop_ip = ip |
|
|
|
|
|
|
|
|
record = self.geoip.record_by_addr(ip) |
|
|
record = self.geoip.record_by_addr(ip) |
|
|
try: |
|
|
try: |
|
|
self.asn = self.geoasn.org_by_addr(ip) |
|
|
self.asn = self.geoasn.org_by_addr(ip) |
|
@ -389,8 +383,9 @@ class bc(object): |
|
|
self.vardict = {'destination_ip': self.destination_ip, 'hop_count': self.hop_count,'hop_ip': self.hop_ip, 'server_name': self.server_name, 'country': self.country, 'city': self.city, 'longitude': self.longitude, 'latitude': self.latitude, 'asn' : self.asn, 'timestamp' : self.timestamp } |
|
|
self.vardict = {'destination_ip': self.destination_ip, 'hop_count': self.hop_count,'hop_ip': self.hop_ip, 'server_name': self.server_name, 'country': self.country, 'city': self.city, 'longitude': self.longitude, 'latitude': self.latitude, 'asn' : self.asn, 'timestamp' : self.timestamp } |
|
|
except: |
|
|
except: |
|
|
print "Trace:", self.hop_count, "->", "Not allowed" |
|
|
print "Trace:", self.hop_count, "->", "Not allowed" |
|
|
self.hop_count+=1 |
|
|
self.vardict = {'destination_ip': self.destination_ip, 'hop_count': self.hop_count,'hop_ip': self.hop_ip, 'server_name': self.server_name, 'country': '-', 'city': '-', 'longitude': '-', 'latitude': '-', 'asn' : self.asn, 'timestamp' : self.timestamp } |
|
|
|
|
|
|
|
|
|
|
|
self.hop_count+=1 |
|
|
# write xml data to file |
|
|
# write xml data to file |
|
|
self.result_list.append(self.vardict) |
|
|
self.result_list.append(self.vardict) |
|
|
xml_results = xml_reporting(self) |
|
|
xml_results = xml_reporting(self) |
|
@ -403,10 +398,8 @@ class bc(object): |
|
|
logfile.close() |
|
|
logfile.close() |
|
|
self.old_url = url |
|
|
self.old_url = url |
|
|
self.hop_count = 0 # to start a new map |
|
|
self.hop_count = 0 # to start a new map |
|
|
print "\n" |
|
|
|
|
|
return |
|
|
return |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def getGEO(self): |
|
|
def getGEO(self): |
|
|
""" |
|
|
""" |
|
|
Get Geolocation database (http://dev.maxmind.com/geoip/legacy/geolite/) |
|
|
Get Geolocation database (http://dev.maxmind.com/geoip/legacy/geolite/) |
|
|