use Getopt::Std;
my %opt;
-getopts('H:U:P:D:T:s:e:', \%opt);
+getopts('H:U:P:D:T:s:e:c:', \%opt);
my $user = shift or die &usage;
my $dsn = 'dbi:mysql';
warn $row->{'time'} . ": no callid, skipped.\n";
next;
}
- my ($src) = $row->{'caller_id'} =~ /^sip:(\d+)@/;
- my ($dst) = $row->{'callee_id'} =~ /^sip:(\d+)@/;
+
+ #i guess now we're NANPA-centric, but at least we warn on non-numeric numbers
+ my $src = '';
+ my $src_ip = '';
+ if ( $row->{'caller_id'} =~ /^sip:(\+1?)?(\w+)@(.*)/ ) {
+ $src = $2;
+ my $rest = $3;
+ if ($rest =~ /^([\d\.]{7,15})/) {
+ # canonicalize it so that ascii sort order works
+ $src_ip = sprintf('%03d.%03d.%03d.%03d', split('\.', $1));
+ }
+ } else {
+ warn "unparseable caller_id ". $row->{'caller_id'}. "\n";
+ }
+
+ my $dst = '';
+ my $dst_ip = '';
+ if ( $row->{'callee_id'} =~ /^sip:(\+1?)?(\w+)@(.*)/ ) {
+ $dst = $2;
+ my $rest = $3;
+ if ($rest =~ /^([\d\.]{7,15})/) {
+ $dst_ip = sprintf('%03d.%03d.%03d.%03d', split('\.', $1));
+ }
+ } else {
+ warn "unparseable callee_id ". $row->{'callee_id'}. "\n";
+ }
my $cdr = $cdrs{$callid};
if ( !$cdr ) {
uniqueid => $callid,
cdrbatchnum => $cdrbatchnum,
});
+ $cdr->cdrtypenum($opt{c}) if $opt{c};
}
my $date = str2time($row->{'time'});
if ( $row->{'method'} eq 'INVITE' ) {
$cdr->startdate($date);
$cdr->src($src);
$cdr->dst($dst);
+ $cdr->src_ip_addr($src_ip);
+ $cdr->dst_ip_addr($dst_ip);
}
elsif ( $row->{'method'} eq 'ACK' ) {
$cdr->answerdate($date);
$mysql->disconnect;
sub usage {
- "Usage: \n cdr-opensips.import\n\t[ -H host ]\n\t-D database\n\t-U user\n\t-P password\n\t[ -s start ] [ -e end ]\n\tfreesideuser\n";
+ "Usage: \n cdr-opensips.import\n\t[ -H host ]\n\t-D database\n\t-U user\n\t-P password\n\t[ -s start ] [ -e end ] [ -c cdrtypenum ] \n\tfreesideuser\n";
}
sub check_cdr {