295 lines
6.8 KiB
Perl
Executable File
295 lines
6.8 KiB
Perl
Executable File
#!/usr/bin/perl
|
|
# sipgrep version 0.2. Skin for ngrep. (C) 2005-2006 Alexandr Dubovikov <shurik@start4.info>
|
|
# Modified 2007 Anthony Minessale <anthm@freeswitch.org>
|
|
|
|
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/bin/ngrep"; #path to NGREP
|
|
$ngrep_flags="-l -d eth1"; # Flag for Ngrep
|
|
|
|
$colorsmethods="INVITE|REGISTER|BYE|ACK|CANCEL|OPTIONS|REFER|NOTIFY|MESSAGE|INFO|PRACK|UPDATE";
|
|
|
|
%options=();
|
|
getopts("f:t:l:ahVp:d: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> <-d device> <-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.
|
|
-d Device for ngrep.
|
|
-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" );
|
|
|
|
#Device
|
|
$ngrep_flags .= sprintf(" -d %s", (defined $options{d}) ? $options{d} : "eth0" );
|
|
|
|
#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/
|
|
//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 if((defined $debugfilecolors));
|
|
print DBG $ltext;
|
|
close(DBG);
|
|
}
|
|
}
|