X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=FS%2FFS%2Fpart_export%2Fhttp.pm;h=43ccfc52569d4b4aa1e2a29e99d03960d7eb6c80;hp=3749224ffca5b1c8f80ae05bcd81b82ec621c0ae;hb=929783d1045757abbe5c84ff2439547b0f8eca23;hpb=1db88f014fc9206bf00ce74d04d9692bdae29abc diff --git a/FS/FS/part_export/http.pm b/FS/FS/part_export/http.pm index 3749224ff..43ccfc525 100644 --- a/FS/FS/part_export/http.pm +++ b/FS/FS/part_export/http.pm @@ -3,6 +3,9 @@ package FS::part_export::http; use base qw( FS::part_export ); use vars qw( %options %info ); use Tie::IxHash; +use LWP::UserAgent; +use HTTP::Request::Common qw( POST ); +use IO::Socket::SSL; tie %options, 'Tie::IxHash', 'method' => { label =>'Method', @@ -11,6 +14,9 @@ tie %options, 'Tie::IxHash', 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', @@ -33,6 +39,18 @@ tie %options, 'Tie::IxHash', 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 => '', @@ -41,13 +59,21 @@ tie %options, 'Tie::IxHash', %info = ( 'svc' => 'svc_domain', - 'desc' => 'Send an HTTP or HTTPS GET or POST request', + 'desc' => 'Send an HTTP or HTTPS GET or POST request, for domains1', 'options' => \%options, + 'no_machine' => 1, 'notes' => <<'END' -Send an HTTP or HTTPS GET or POST to the specified URL. For HTTPS support, -Crypt::SSLeay -or IO::Socket::SSL -is required. +Send an HTTP or HTTPS GET or POST to the specified URL on domain addition, +modification and deletion. +

Each "Data" option takes a list of name value pairs on successive +lines. +

+If "Success Regexp" is specified, the response from the server will be +tested against it to determine if the export succeeded.

END ); @@ -63,16 +89,25 @@ sub _export_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"); - my $cust_main = $svc_x->table eq 'cust_main' - ? $svc_x - : $svc_x->cust_svc->cust_pkg->cust_main; + my $cust_main = $svc_x->cust_main or return; $self->http_queue( $svc_x->svcnum, + ( $self->option('ssl_no_verify') ? 'ssl_no_verify' : '' ), $self->option('method'), $self->option('url'), $self->option('success_regexp'), @@ -92,12 +127,11 @@ sub _export_replace { return unless $self->option('replace_data'); - my $new_cust_main = $new->table eq 'cust_main' - ? $new - : $new->cust_svc->cust_pkg->cust_main; + 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('success_regexp'), @@ -120,16 +154,18 @@ sub http_queue { } sub http { + my $ssl_no_verify = ( $_[0] eq 'ssl_no_verify' || $_[0] eq '' ) ? shift : ''; my($method, $url, $success_regexp, @data) = @_; $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,