projects
/
freeside.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
add "Ignore accounting records from this database" to broadband_sqlradius export...
[freeside.git]
/
FS
/
FS
/
part_export
/
http.pm
diff --git
a/FS/FS/part_export/http.pm
b/FS/FS/part_export/http.pm
index
0be2a0f
..
42a35cb
100644
(file)
--- a/
FS/FS/part_export/http.pm
+++ b/
FS/FS/part_export/http.pm
@@
-1,24
+1,28
@@
package FS::part_export::http;
package FS::part_export::http;
-use vars qw(@ISA %info);
+use base qw( FS::part_export );
+use vars qw( %options %info );
use Tie::IxHash;
use Tie::IxHash;
-use FS::part_export;
+use LWP::UserAgent;
+use HTTP::Request::Common qw( POST );
+use IO::Socket::SSL;
-@ISA = qw(FS::part_export);
-
-tie my %options, 'Tie::IxHash',
+tie %options, 'Tie::IxHash',
'method' => { label =>'Method',
type =>'select',
#options =>[qw(POST GET)],
options =>[qw(POST)],
default =>'POST' },
'url' => { label => 'URL', default => 'http://', },
'method' => { label =>'Method',
type =>'select',
#options =>[qw(POST GET)],
options =>[qw(POST)],
default =>'POST' },
'url' => { label => 'URL', default => 'http://', },
+ 'ssl_no_verify' => { label => 'Skip SSL certificate validation',
+ type => 'checkbox',
+ },
'insert_data' => {
label => 'Insert data',
type => 'textarea',
default => join("\n",
'DomainName $svc_x->domain',
'insert_data' => {
label => 'Insert data',
type => 'textarea',
default => join("\n",
'DomainName $svc_x->domain',
- 'Email ( grep { $_
ne "POST"
} $svc_x->cust_svc->cust_pkg->cust_main->invoicing_list)[0]',
+ 'Email ( grep { $_
!~ /^(POST|FAX)$/
} $svc_x->cust_svc->cust_pkg->cust_main->invoicing_list)[0]',
'test 1',
'reseller $svc_x->cust_svc->cust_pkg->part_pkg->pkg =~ /reseller/i',
),
'test 1',
'reseller $svc_x->cust_svc->cust_pkg->part_pkg->pkg =~ /reseller/i',
),
@@
-35,12
+39,29
@@
tie my %options, 'Tie::IxHash',
default => join("\n",
),
},
default => join("\n",
),
},
+ 'suspend_data' => {
+ label => 'Suspend data',
+ type => 'textarea',
+ default => join("\n",
+ ),
+ },
+ 'unsuspend_data' => {
+ label => 'Unsuspend data',
+ type => 'textarea',
+ default => join("\n",
+ ),
+ },
+ 'success_regexp' => {
+ label => 'Success Regexp',
+ default => '',
+ },
;
%info = (
'svc' => 'svc_domain',
'desc' => 'Send an HTTP or HTTPS GET or POST request',
'options' => \%options,
;
%info = (
'svc' => 'svc_domain',
'desc' => 'Send an HTTP or HTTPS GET or POST request',
'options' => \%options,
+ 'no_machine' => 1,
'notes' => <<'END'
Send an HTTP or HTTPS GET or POST to the specified URL. For HTTPS support,
<a href="http://search.cpan.org/dist/Crypt-SSLeay">Crypt::SSLeay</a>
'notes' => <<'END'
Send an HTTP or HTTPS GET or POST to the specified URL. For HTTPS support,
<a href="http://search.cpan.org/dist/Crypt-SSLeay">Crypt::SSLeay</a>
@@
-61,14
+82,28
@@
sub _export_delete {
$self->_export_command('delete', @_);
}
$self->_export_command('delete', @_);
}
+sub _export_suspend {
+ my $self = shift;
+ $self->_export_command('suspend', @_);
+}
+
+sub _export_unsuspend {
+ my $self = shift;
+ $self->_export_command('unsuspend', @_);
+}
+
sub _export_command {
my( $self, $action, $svc_x ) = ( shift, shift, shift );
return unless $self->option("${action}_data");
sub _export_command {
my( $self, $action, $svc_x ) = ( shift, shift, shift );
return unless $self->option("${action}_data");
+ my $cust_main = $svc_x->cust_main or return;
+
$self->http_queue( $svc_x->svcnum,
$self->http_queue( $svc_x->svcnum,
+ ( $self->option('ssl_no_verify') ? 'ssl_no_verify' : '' ),
$self->option('method'),
$self->option('url'),
$self->option('method'),
$self->option('url'),
+ $self->option('success_regexp'),
map {
/^\s*(\S+)\s+(.*)$/ or /()()/;
my( $field, $value_expression ) = ( $1, $2 );
map {
/^\s*(\S+)\s+(.*)$/ or /()()/;
my( $field, $value_expression ) = ( $1, $2 );
@@
-85,12
+120,18
@@
sub _export_replace {
return unless $self->option('replace_data');
return unless $self->option('replace_data');
- $self->http_queue( $svc_x->svcnum,
+ my $new_cust_main = $new->cust_main or return;
+ my $cust_main = $new_cust_main; #so folks can use $new_cust_main or $cust_main
+
+ $self->http_queue( $new->svcnum,
+ ( $self->option('ssl_no_verify') ? 'ssl_no_verify' : '' ),
$self->option('method'),
$self->option('url'),
$self->option('method'),
$self->option('url'),
+ $self->option('success_regexp'),
map {
/^\s*(\S+)\s+(.*)$/ or /()()/;
my( $field, $value_expression ) = ( $1, $2 );
map {
/^\s*(\S+)\s+(.*)$/ or /()()/;
my( $field, $value_expression ) = ( $1, $2 );
+ my $value = eval $value_expression;
die $@ if $@;
( $field, $value );
} split(/\n/, $self->option('replace_data') )
die $@ if $@;
( $field, $value );
} split(/\n/, $self->option('replace_data') )
@@
-100,24
+141,24
@@
sub _export_replace {
sub http_queue {
my($self, $svcnum) = (shift, shift);
sub http_queue {
my($self, $svcnum) = (shift, shift);
- my $queue = new FS::queue {
- 'svcnum' => $svcnum,
- 'job' => "FS::part_export::http::http",
- };
+ my $queue = new FS::queue { 'job' => "FS::part_export::http::http" };
+ $queue->svcnum($svcnum) if $svcnum;
$queue->insert( @_ );
}
sub http {
$queue->insert( @_ );
}
sub http {
- my($method, $url, @data) = @_;
+ my $ssl_no_verify = ( $_[0] eq 'ssl_no_verify' || $_[0] eq '' ) ? shift : '';
+ my($method, $url, $success_regexp, @data) = @_;
$method = lc($method);
$method = lc($method);
- eval "use LWP::UserAgent;";
- die "using LWP::UserAgent: $@" if $@;
- eval "use HTTP::Request::Common;";
- die "using HTTP::Request::Common: $@" if $@;
-
- my $ua = LWP::UserAgent->new;
+ my @lwp_opts = ();
+ push @lwp_opts, 'ssl_opts' => {
+ verify_hostname => 0,
+ SSL_verify_mode => IO::Socket::SSL::SSL_VERIFY_NONE,
+ }
+ if $ssl_no_verify;
+ my $ua = LWP::UserAgent->new(@lwp_opts);
#my $response = $ua->$method(
# $url, \%data,
#my $response = $ua->$method(
# $url, \%data,
@@
-128,6
+169,11
@@
sub http {
die $response->error_as_HTML if $response->is_error;
die $response->error_as_HTML if $response->is_error;
+ if(length($success_regexp) > 1) {
+ my $response_content = $response->content;
+ die $response_content unless $response_content =~ /$success_regexp/;
+ }
+
}
1;
}
1;