[freeside-commits] freeside/FS/FS/part_export phone_sqlopensips.pm, NONE, 1.1.2.2

[Erik Levinson]

Update of /home/cvs/cvsroot/freeside/FS/FS/part_export
In directory wavetail.420.am:/tmp/cvs-serv13339/FS/FS/part_export

Added Files:
      Tag: FREESIDE_2_1_BRANCH
	phone_sqlopensips.pm 
Log Message:
opensips provisioning, RT10993

--- NEW FILE: phone_sqlopensips.pm ---
package FS::part_export::phone_sqlopensips;

use vars qw(@ISA @EXPORT_OK %info %options);
use Exporter;
use Tie::IxHash;
use FS::Record qw( dbh qsearch qsearchs );
use FS::part_export;
use FS::svc_phone;
use FS::export_svc;

@ISA = qw(FS::part_export);

tie %options, 'Tie::IxHash',
  'datasrc'  => { label=>'DBI data source ' },
  'username' => { label=>'Database username' },
  'password' => { label=>'Database password' },
;

%info = (
  'svc'      => 'svc_phone',
  'desc'     => 'Export DIDs to OpenSIPs dr_rules table',
  'options'  => \%options,
  'notes'    => 'Export DIDs to OpenSIPs dr_rules table',
);

sub rebless { shift; }

sub _export_insert {
  my($self, $svc_x) = (shift, shift);
  my $dbh = $self->opensips_connect;
  my $sth = $dbh->prepare("insert into dr_rules ".
	    "( groupid, prefix, timerec, routeid, gwlist, description ) ".
	    " values ( ?, ?, ?, ?, ?, ? )") or die $dbh->errstr;
  $sth->execute('0',$svc_x->phonenum,'',$svc_x->route,'',
		$svc_x->phone_name) or die $sth->errstr;
  $dbh->disconnect;
  '';
}

sub opensips_connect {
    my $self = shift;
    DBI->connect($self->option('datasrc'),$self->option('username'),
			$self->option('password')) or die $DBI::errstr;
}

sub _export_replace {
  my( $self, $new, $old ) = (shift, shift, shift);
    my @update = ();
    my @paramvalues = ();

    if($old->route ne $new->route){
	push @update, 'routeid = ?';
	push @paramvalues, $new->route;
    }

    if($old->phone_name ne $new->phone_name) {
	push @update, 'description = ?';
	push @paramvalues, $new->phone_name;
    }

    if(scalar(@update)) {
      my $update_str = join(' and ', at update);
      my $dbh = $self->opensips_connect;
      my $sth = $dbh->prepare("update dr_rules set $update_str " . 
	    " where prefix = ? ") or die $dbh->errstr;
      push @paramvalues, $old->phonenum;
      $sth->execute(@paramvalues) or die $sth->errstr;
      $dbh->disconnect;
    }
  '';
}

sub _export_suspend {
  my( $self, $svc_phone ) = (shift, shift);
  '';
}

sub _export_unsuspend {
  my( $self, $svc_phone ) = (shift, shift);
  '';
}

sub _export_delete {
  my( $self, $svc_x ) = (shift, shift);
  my $dbh = $self->opensips_connect;
  my $sth = $dbh->prepare("delete from dr_rules where prefix = ?")
    or die $dbh->errstr;
  $sth->execute($svc_x->phonenum) or die $sth->errstr;
  $dbh->disconnect;
  '';
}