use vars qw(@ISA %info);
use Tie::IxHash;
+use FS::Record qw(qsearch dbh);
use FS::part_export;
+use FS::phone_avail;
+use Data::Dumper;
@ISA = qw(FS::part_export);
tie my %options, 'Tie::IxHash',
- 'login' => { label=>'GlobalPOPs Media Services API login' },
- 'password' => { label=>'GlobalPOPs Media Services API password' },
+ 'login' => { label=>'VoIP Innovations API login' },
+ 'password' => { label=>'VoIP Innovations API password' },
+ 'endpointgroup' => { label=>'VoIP Innovations endpoint group number' },
+ 'dry_run' => { label=>"Test mode - don't actually provision" },
;
%info = (
'svc' => 'svc_phone',
- 'desc' => 'Provision phone numbers to GlobalPOPs VoIP',
+ 'desc' => 'Provision phone numbers to VoIP Innovations (formerly GlobalPOPs VoIP)',
'options' => \%options,
+ 'no_machine' => 1,
'notes' => <<'END'
Requires installation of
<a href="http://search.cpan.org/dist/Net-GlobalPOPs-MediaServicesAPI">Net::GlobalPOPs::MediaServicesAPI</a>
sub rebless { shift; }
+sub can_get_dids { 1; }
+
sub get_dids {
my $self = shift;
my %opt = ref($_[0]) ? %{$_[0]} : @_;
- my %search = ();
+ my %getdids = ();
# 'orderby' => 'npa', #but it doesn't seem to work :/
if ( $opt{'areacode'} && $opt{'exchange'} ) { #return numbers
} elsif ( $opt{'areacode'} ) { #return city (npa-nxx-XXXX)
%getdids = ( 'npa' => $opt{'areacode'} );
} elsif ( $opt{'state'} ) {
+
+ my @avail = qsearch({
+ 'table' => 'phone_avail',
+ 'hashref' => { 'exportnum' => $self->exportnum,
+ 'countrycode' => '1', #don't hardcode me when gp goes int'l
+ 'state' => $opt{'state'},
+ },
+ 'order_by' => 'ORDER BY npa',
+ });
+
+ return [ map $_->npa, @avail ] if @avail; #return cached area codes instead
+
+ #otherwise, search for em
%getdids = ( 'state' => $opt{'state'} );
+
}
my $dids = $self->gp_command('getDIDs', %getdids);
- #use Data::Dumper;
- #warn Dumper($dids);
+ if ( $dids->{'type'} eq 'Error' ) {
+ my $error = "Error running VoIP Innovations getDIDs: ".
+ $dids->{'statuscode'}. ': '. $dids->{'status'}. "\n";
+ warn $error;
+ die $error;
+ }
my $search = $dids->{'search'};
- #warn Dumper($search);
-
if ( $search->{'statuscode'} == 302200 ) {
return [];
} elsif ( $search->{'statuscode'} != 100 ) {
- die "Error running globalpop getDIDs: ".
- $search->{'statuscode'}. ': '. $search->{'status'}; #die??
+
+ my $error = "Error running VoIP Innovations getDIDs: ";
+ if ( $search->{'statuscode'} || $search->{'status'} ) {
+ $error .= $search->{'statuscode'}. ': '. $search->{'status'}. "\n";
+ } else {
+ $error .= Dumper($search);
+ }
+ warn $error;
+ die $error;
}
my @return = ();
#my $latas = $search->{state}{lata};
-
my %latas;
if ( grep $search->{state}{lata}{$_}, qw(name rate_center) ) {
%latas = map $search->{state}{lata}{$_},
my $lata_dids = $self->gp_command('getDIDs', %getdids, 'lata'=>$lata);
my $lata_search = $lata_dids->{'search'};
unless ( $lata_search->{'statuscode'} == 100 ) {
- die "Error running globalpop getDIDs: ". $lata_search->{'status'}; #die??
+ die "Error running VoIP Innovations getDIDs: ". $lata_search->{'status'}; #die??
}
my $l = $lata_search->{state}{lata}{'rate_center'};
my $tn = $npa->{nxx}{tn} || $npa->{nxx}{$opt{'exchange'}}{tn};
- my @tn = ref($tn) ? @$tn : ($tn);
+ my @tn = ref($tn) eq 'ARRAY' ? @$tn : ($tn);
#push @return, @tn;
- push @return, map {
- if ( /^\s*(\d{3})(\d{3})(\d{4})\s*$/ ) {
- "$1-$2-$3";
- } else {
- $_;
- }
- }
- @tn;
+ push @return,
+ map {
+ if ( /^\s*(\d{3})(\d{3})(\d{4})\s*$/ ) {
+ "$1-$2-$3";
+ } else {
+ $_;
+ }
+ }
+ map { ref($_) eq 'HASH' ? $_->{'content'} : $_ } #tier always 2?
+ @tn;
} elsif ( $opt{'areacode'} ) { #return city (npa-nxx-XXXX)
} elsif ( $opt{'areacode'} ) { #return city (npa-nxx-XXXX)
@return = sort { lc($a) cmp lc($b) } @return;
} elsif ( $opt{'state'} ) { #and not other things, then return areacode
+
+ #populate cache
+
+ local $SIG{HUP} = 'IGNORE';
+ local $SIG{INT} = 'IGNORE';
+ local $SIG{QUIT} = 'IGNORE';
+ local $SIG{TERM} = 'IGNORE';
+ local $SIG{TSTP} = 'IGNORE';
+ local $SIG{PIPE} = 'IGNORE';
+
+ my $oldAutoCommit = $FS::UID::AutoCommit;
+ local $FS::UID::AutoCommit = 0;
+ my $dbh = dbh;
+
+ my $errmsg = 'WARNING: error populating phone availability cache: ';
+ my $error = '';
+ foreach my $return (@return) {
+ my $phone_avail = new FS::phone_avail {
+ 'exportnum' => $self->exportnum,
+ 'countrycode' => '1', #don't hardcode me when gp goes int'l
+ 'state' => $opt{'state'},
+ 'npa' => $return,
+ };
+ $error = $phone_avail->insert();
+ if ( $error ) {
+ warn $errmsg.$error;
+ last;
+ }
+ }
+
+ if ( $error ) {
+ $dbh->rollback if $oldAutoCommit;
+ } else {
+ $dbh->commit or warn $errmsg.$dbh->errstr if $oldAutoCommit;
+ }
+
+ #end populate cache
+
#@return = sort { (split(' ', $a))[0] <=> (split(' ', $b))[0] } @return;
@return = sort { $a <=> $b } @return;
} else {
sub gp_command {
my( $self, $command, @args ) = @_;
- eval "use Net::GlobalPOPs::MediaServicesAPI;";
- die $@ if $@;
+ eval "use Net::GlobalPOPs::MediaServicesAPI 0.03;";
+ if ( $@ ) {
+ warn $@;
+ die $@;
+ }
my $gp = Net::GlobalPOPs::MediaServicesAPI->new(
'login' => $self->option('login'),
sub _export_insert {
my( $self, $svc_phone ) = (shift, shift);
+
+ return '' if $self->option('dry_run');
+
#we want to provision and catch errors now, not queue
+
+ my $r = $self->gp_command('reserveDID',
+ 'did' => $svc_phone->phonenum,
+ 'minutes' => 1,
+ 'endpointgroup' => $self->option('endpointgroup'),
+ );
+
+ my $rdid = $r->{did};
+
+ if ( $rdid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations reserveDID: ".
+ $rdid->{'statuscode'}. ': '. $rdid->{'status'};
+ }
+
+ my $a = $self->gp_command('assignDID',
+ 'did' => $svc_phone->phonenum,
+ 'endpointgroup' => $self->option('endpointgroup'),
+ #'rewrite'
+ #'cnam'
+ );
+
+ my $adid = $a->{did};
+
+ if ( $adid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations assignDID: ".
+ $adid->{'statuscode'}. ': '. $adid->{'status'};
+ }
+
+ '';
}
sub _export_replace {
my( $self, $new, $old ) = (shift, shift, shift);
+
#hmm, what's to change?
+ '';
}
sub _export_delete {
my( $self, $svc_phone ) = (shift, shift);
- #probably okay to queue the deletion...
+
+ return '' if $self->option('dry_run');
+
+ #probably okay to queue the deletion...?
+ #but hell, let's do it inline anyway, who wants phone numbers hanging around
+
+ my $r = $self->gp_command('releaseDID',
+ 'did' => $svc_phone->phonenum,
+ );
+
+ my $rdid = $r->{did};
+
+ if ( $rdid->{'statuscode'} != 100 ) {
+ return "Error running VoIP Innovations releaseDID: ".
+ $rdid->{'statuscode'}. ': '. $rdid->{'status'};
+ }
+
+ '';
}
sub _export_suspend {
my( $self, $svc_phone ) = (shift, shift);
#nop for now
+ '';
}
sub _export_unsuspend {
my( $self, $svc_phone ) = (shift, shift);
#nop for now
+ '';
}
#hmm, might forgo queueing entirely for most things, data is too much of a pita
-
-sub globalpops_voip_queue {
- my( $self, $svcnum, $method ) = (shift, shift, shift);
- my $queue = new FS::queue {
- 'svcnum' => $svcnum,
- 'job' => 'FS::part_export::globalpops_voip::globalpops_voip_command',
- };
- $queue->insert(
- $self->option('login'),
- $self->option('password'),
- $method,
- @_,
- );
-}
+#sub globalpops_voip_queue {
+# my( $self, $svcnum, $method ) = (shift, shift, shift);
+# my $queue = new FS::queue {
+# 'svcnum' => $svcnum,
+# 'job' => 'FS::part_export::globalpops_voip::globalpops_voip_command',
+# };
+# $queue->insert(
+# $self->option('login'),
+# $self->option('password'),
+# $method,
+# @_,
+# );
+#}
sub globalpops_voip_command {
my($login, $password, $method, @args) = @_;
- eval "use Net::GlobalPOPs::MediaServicesAPI;";
+ eval "use Net::GlobalPOPs::MediaServicesAPI 0.03;";
die $@ if $@;
my $gp = new Net::GlobalPOPs
projects / freeside.git / blobdiff