'row_callback' => sub { my $row = shift;
return ' ' if $row =~ /.*Log (begins|ends)$/;
die "invalid row format for '$row'" unless
- $row =~ /^(\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}) ([A-Za-z ]+) (\[SMSC:\w+\] \[SVC:\w*\] \[ACT:\w*\] \[BINF:\w*\] \[FID:\w*\]) \[from:(|\+)(\d+)\] \[to:(|\+)(\d+)\] (\[flags:.*?\]) \[msg:(\d+):(.*?)\] (\[udh:.*?\])$/;
- $row = "$1,$2,$3,$5,$7,$8,$9,$11";
+ $row =~ /^(\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}) ([A-Za-z ]+) (\[SMSC:\w+\] \[SVC:\w*\] \[ACT:\w*\] \[BINF:\w*\] \[FID:\w*\]) \[from:(.*?)\] \[to:(.*?)\] (\[flags:.*?\]) \[msg:(\d+):.*?\] (\[udh:.*?\])$/;
+ $row = "$1,$2,$3,$4,$5,$6,$7,$8";
$row;
},
'import_fields' => [
_cdr_date_parser_maker('startdate'),
'disposition',
'userfield', # [SMSC: ... FID...], five fields
- 'src',
- 'dst',
+
+ sub {
+ my($cdr, $src) = @_;
+ $src =~ s/[^\+\d]//g;
+ $src =~ /^(\+|)(\d+)$/
+ or die "unparsable number: $src"; #maybe we shouldn't die...
+ $cdr->src("$1$2");
+ },
+
+ sub {
+ my($cdr, $dst) = @_;
+ $dst =~ s/[^\+\d]//g;
+ $dst =~ /^(\+|)(\d+)$/
+ or die "unparsable number: $dst"; #maybe we shouldn't die...
+ $cdr->dst("$1$2");
+ },
sub { my($cdr, $flags) = @_;
$cdr->userfield($cdr->userfield." $flags");