Add script for pretty print tracerouters from RIPE Atlas in console t…

…raceroute/tracepath manner

ripe_atlas_traceroute_printer.pl

@@ -0,0 +1,117 @@
+#!/usr/bin/perl
+
+use strict;
+use warnings;
+
+use Data::Dumper;
+use Net::DNS::Resolver;
+use List::Util qw(sum);
+
+use lib "/opt/local/lib/perl5/vendor_perl/5.16.3";
+use JSON;
+
+# Description: script for printing traceroute results from ATLAS in pretty form
+# Author: Pavel Odintsov
+# Email: pavel.odintsov@gmail.com
+# How to install JSON module on MAC OS X? sudo port install p5-json 
+
+sub get_reverse {
+    my $ip = shift;
+
+    unless ($ip) {
+        return '';
+    }
+
+    my $res = Net::DNS::Resolver->new;
+
+    # Prevent hungup on DNS resolve
+    $res->tcp_timeout( 1 );
+    $res->udp_timeout( 1 );
+
+    # create the reverse lookup DNS name (note that the octets in the IP address need to be reversed).
+    my $reversed_ip = join '.', reverse split(/\./, $ip);
+    my $target_IP = "$reversed_ip.in-addr.arpa";
+
+    my $query = $res->query("$target_IP", "PTR");
+
+    if ($query) {
+        foreach my $rr ($query->answer) {
+    	    unless ($rr->type eq "PTR") {
+                next;
+	    }
+    	    return $rr->rdatastr;
+  	}
+    } else {
+        return '';
+    }
+}
+
+if (scalar @ARGV == 0) {
+    print "Please provide path to file with json data from ATLAS\n";
+    exit 1;
+}
+
+open my $fl, "<", $ARGV[0] or die "Can't open file $ARGV[0]";
+my $data = join '', <$fl>;
+
+my $decoded = decode_json($data);
+
+my $measures_sorted_by_probe_id = {};
+for my $measure (@$decoded) {
+    push @{ $measures_sorted_by_probe_id->{ $measure->{prb_id} } }, $measure;  
+}
+
+for my $probe_id (keys %$measures_sorted_by_probe_id) {
+    print "Probe ID: $probe_id\n\n";
+    for my $measure (@{$measures_sorted_by_probe_id->{$probe_id}}) {
+        my @hops = @{ $measure->{result} };
+
+        my $pretty_timestamp = localtime($measure->{timestamp});
+        print "Traceroute measure executed from $measure->{src_addr} to $measure->{dst_addr} at $pretty_timestamp\n"; 
+
+        # print Dumper($measure);
+        # exit 1;
+
+        for my $hop (@hops) {
+	    #print Dumper $hop;
+            my $first_try = $hop->{result}->[0];
+            my $this_request_failed = $first_try->{x} && $first_try->{x} eq '*'; 
+
+            if ($this_request_failed) {
+                print " $hop->{hop} *\n";
+                next;
+            }
+
+            my $average_rtt = 0;
+
+            if (ref $hop->{result} eq 'ARRAY' && scalar @{ $hop->{result} } > 0 && !$this_request_failed) {
+                my @rtts = ();
+                for my $tracrouter_retry (@{ $hop->{result} }) {
+                    # Filter out only defined entries
+                    if ($tracrouter_retry->{rtt}) {
+                        push @rtts, $tracrouter_retry->{rtt};
+                    }
+                }
+
+                # print Dumper(\@rtts);
+
+                if (scalar @rtts > 0) {
+                    $average_rtt = sum(@rtts) / scalar @rtts;
+                    # Round by 3 digits after point 
+                    $average_rtt = sprintf("%.3f", $average_rtt);
+                }
+            }
+
+            #print Dumper($first_try);
+            my $reverse = get_reverse($first_try->{from});
+
+            unless ($reverse) {
+                $reverse = $first_try->{from};
+            }
+
+            print " $hop->{hop} $reverse ($first_try->{from}) $average_rtt ms\n";
+        }
+
+        print "\n\n";  
+    }
+}