add modified sipgrep

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@6878 d0543943-73ff-0310-b7d9-9358b9ac24b2

diff --git a/scripts/trace/sipgrep b/scripts/trace/sipgrep
new file mode 100755 (executable)
index 0000000..b1c54da
--- /dev/null
+++ b/scripts/trace/sipgrep
@@ -0,0 +1,290 @@
+#!/usr/bin/perl
+# sipgrep version 0.2. Skin for ngrep. (C) 2005-2006 Alexandr Dubovikov <shurik@start4.info>
+# Modified 2007 Anthony Minessale <anthmct@yahoo.com>
+
+use Term::ANSIColor;
+use Getopt::Std;
+
+#colors: BLACK, RED, GREEN, YELLOW, BLUE, MAGENTA, ON_BLACK, ON_RED, ON_GREEN, ON_YELLOW, ON_BLUE, ON_MAGENTA, ON_CYAN, ON_WHITE
+#
+#type: BOLD, DARK, UNDERLINE, UNDERSCORE, BLINK, REVERSE, CONCEALED, 
+
+$COLORS{'method'}='bold red';
+$COLORS{'response'} ='bold yellow';
+$COLORS{'callid'} = 'bold magenta';
+$COLORS{'fromtag'} = 'bold blue';
+$COLORS{'totag'} = 'bold green';
+$COLORS{'viabranch'} = 'bold cyan';
+
+$limit=2000;
+$ngrep="/usr/local/bin/ngrep"; #path to NGREP
+$ngrep_flags="-l"; # Flag for Ngrep
+
+$colorsmethods="INVITE|REGISTER|BYE|ACK|CANCEL|OPTIONS|REFER|NOTIFY|MESSAGE|INFO|PRACK|UPDATE";
+
+%options=();
+getopts("f:t:l:ahVp:TcCnArm:",\%options);
+
+$version=<<END;
+Sipgrep version 0.2
+    Created by Alexandr Dubovikov <shurik\@start4.info>
+
+END
+
+    $usage=<<END;
+Usage: sipgrep <-h> <-f number> <-t number> <-a> <-l file> <-V> <-p> <-T> <-n|-c>
+
+    -h   Displays this help message.
+    -A    Match anything.
+    -f    ARG Search ARG in From field.
+    -c    ARG Search ARG in Contact field.
+    -t    ARG Search ARG in To field.
+    -a   Search the ARG from '-f' and '-t' parameters in To and From fields.
+    -l    ARG Debug file name.
+    -V   Displays the current version.
+    -p   Port for ngrep.
+    -T   Parameter for ngrep. Indicating the delta between packet matches.
+    -C    Allow colors in debug file.
+    -n    Not allow colors in STDOUT.
+    -m    Allowed METHODS to filter e.g. -m "INVITE,REGISTER"
+    -r    match replies as well when matching with -m
+Example: sipgrep -f 0123456 -t 0654321 -l debug.sip
+    or
+    sipgrep -f 0123456 -a -l debug.sip
+END
+
+#version
+    if(defined $options{V})
+{
+    print $version; exit;
+}
+
+#usage
+if((!defined $options{f} && !defined $options{t} && !defined $options{c} && !defined $options{A}) || defined $options{h}) 
+{
+    print $usage; exit;
+}
+
+#TimeStamp
+$ngrep_flags .= sprintf(" %s", (defined $options{T}) ? "-T" : "-t" );
+
+#Port
+$ngrep_flags .= sprintf(" port %d", (defined $options{p}) ? $options{p} : "5060" );
+
+#our system variables
+$any=$options{A};
+$mstr=$options{m};
+$anumber=$options{f};
+$bnumber=$options{t};
+$cnumber=$options{c};
+$replies=$options{r};
+$all=$options{a};
+$filedebug=$options{l};
+$nocolors=$options{n};
+$debugfilecolors=$options{C};
+
+@METHODS = split(",", $mstr);
+
+#remove old debug file. 
+unlink $filedebug if(defined $filedebug);
+
+#open PIPE
+open(PIPE,"$ngrep $ngrep_flags |") or die "Can't run '$ngrep' programm: $!\n";
+
+select(PIPE); $| = 1;  # make unbuffered
+select(STDOUT); $| = 1;        # make unbuffered
+
+while(<PIPE>)
+{      
+    chomp($_);
+    s/\r//ig;
+    s/  // if(/^ /);
+    
+    if(/\.\. (.*)$/)
+    {
+       $tmp.=$_;               
+
+       if(create_newline($tmp)==1)
+       {
+           undef $firstvia;
+           #system_out("----------------begin of packet -----------------------------\n");     
+           foreach $key (@tmparray)
+           {   
+               system_out($key."\n");
+           }
+           #system_out("------------------end of packet -----------------------------\n");                     
+       }
+    }
+    elsif(/^#/) { undef $tmp;}
+         elsif(/^U /) { $tmp=$_."....";}
+         else { $tmp.=$_;}                 
+      }
+    close(PIPE);
+
+    sub create_newline
+{
+    my $tmpstring = shift;     
+    exit if($index > $limit);
+    undef @tmparray;
+    @tmparray=split(/\.\./,$tmpstring);                
+    $print_out=1;
+    undef $searchcallid;
+
+    if (@METHODS) {
+       $print_out=0;
+       foreach $key (@tmparray) {
+           my $test = 0;
+           $test = ($key =~ /^\S+\s+\S+\s+SIP\/2.0/) ? 1 : 0;
+
+           if ($replies && !$test) {
+               $test = $key =~ /CSeq\:/i;
+           }
+
+           if ($test) {
+               foreach $m (@METHODS) {
+                   if ($key =~ $m) {
+                       $print_out=1;
+                       last;
+                   }
+               }
+           }
+       }
+    }
+
+    if (!$print_out) {
+       return $print_out;
+    }
+
+    if ($any) {
+       $print_out=1; 
+       return $print_out;
+    }
+
+    foreach $key(@tmparray)
+    {
+       if(defined $anumber || defined $bnumber || defined $cnumber)
+       {
+           $print_out=0;
+           getmatch($key); #if(!$callid)
+           $tmpcallid=getcallid($key);                 
+           if($searchcallid==1)
+           {   
+               $GCALLID{$tmpcallid}=1;
+               $print_out=1;
+               last;
+           }
+       }                                       
+    }
+    return $print_out;
+}
+
+sub getmatch
+{
+    my $tmps = shift;
+
+    #From: "Martin Mustermann" <sip:021173067200@qsc.de>;tag=2bdf62455c76484b9e1163154d2758cd;epid=46aa53832b  
+    if($tmps=~/^From:/i && ((defined $anumber && $tmps=~/$anumber/ig) || (defined $all && defined $bnumber && $tmps=~/$bnumber/ig)))
+    {
+       $searchcallid=1;
+    }
+    elsif($tmps=~/^To:/i && ((defined $bnumber && $tmps=~/$bnumber/ig) || (defined $all && defined $anumber && $tmps=~/$anumber/ig)))
+    {
+       $searchcallid=1;
+    }
+    elsif($tmps=~/^Contact:/i && ((defined $cnumber && $tmps=~/$cnumber/ig)))
+    {
+       $searchcallid=1;
+    }
+    if($tmps=~/^Call-ID:/ig)
+    {
+       (undef,$tmpcallid)=split(/: /,$tmps,2);
+       $print_out=1 if($GCALLID{$tmpcallid}==1);
+    }
+}
+
+sub getcallid
+{
+    my $tmps = shift;
+    (undef,$tmpcallid)=split(/: /,$tmps,2) if($tmps=~/^Call-ID:/ig);
+    return $tmpcallid;
+}
+
+
+sub system_out
+{
+    my $out = shift;
+    my $tmpmain, $tmpstr;
+    
+    #Method:   
+    if($out =~/^($colorsmethods) /ig)
+    {
+       ($tmpmain,$tmpstr)=split(/ /,$out,2);
+
+       print_out($tmpmain, $COLORS{'method'});                                 
+
+       print_out(" ".$tmpstr);
+    }
+    #Response:
+    elsif($out =~/^SIP\/2\.0 [1-6][0-9][0-9] /ig)
+    {
+       ($tmpstr, $tmpmain)=split(/ /,$out,2);
+       print_out($tmpstr." ");
+       print_out($tmpmain, $COLORS{'response'});                                       
+    }
+    #Callid
+    elsif($out =~/^(Call-ID):/ig)
+    {
+       ($tmpstr, $tmpmain)=split(/: /,$out,2);
+       print_out($tmpstr.": ");
+       print_out($tmpmain, $COLORS{'callid'});                                 
+    }
+    #From/To: tag
+    elsif($out =~/^(From|f|To|t): /ig && $out=~/;tag=/ig)
+    {
+
+       ($tmpstr, $tmpmain)=split(/;tag=/,$out,2);
+       print_out($tmpstr.";tag=");
+
+       ($tmpmain, $tmpstr)=split(/;/,$tmpmain,2);
+       print_out($tmpmain, $out =~/^(From|f): / ? $COLORS{'fromtag'} : $COLORS{'totag'});                                      
+
+       print_out(";".$tmpstr) if(defined $tmpstr);
+    }  
+    #Via: branch
+    elsif($out =~/^(Via|v): /ig && $out=~/;branch=/ig && !defined $firstvia)
+    {
+
+       ($tmpstr, $tmpmain)=split(/;branch=/,$out,2);
+       print_out($tmpstr.";branch=");
+
+       ($tmpmain, $tmpstr)=split(/;/,$tmpmain,2);
+       print_out($tmpmain, $COLORS{'viabranch'});                                      
+       
+       print_out(";".$tmpstr) if(defined $tmpstr);
+       
+       $firstvia = 1;
+    }
+    else { print_out($out); }  
+}
+
+
+sub print_out
+{
+    my $ltext = shift;
+    my $lcolor = shift;
+    
+    $lcolor='reset' if(!defined $lcolor || defined $nocolors);
+    
+    print color $lcolor;
+
+    print $ltext;
+    
+    if(defined $filedebug)
+    {
+       open(DBG, ">>$filedebug");
+       $lcolor = 'reset' if(!(defined $debugfilecolors));              
+       print DBG color $lcolor;
+       print DBG $ltext;
+       close(DBG);     
+    }
+}