ASNMTAP
view release on metacpan or search on metacpan
lib/ASNMTAP/Asnmtap/Plugins/WebTransact.pm view on Meta::CPAN
}
if ( defined $parms{timeout} ) {
$ua->timeout ( $parms{timeout} );
$ua->default_headers->push_header ( 'Keep-Alive' => $parms{timeout} ) if ( $parms{keepAlive} );
}
my $returnCode = $parms{fail_if_1} ? $ERRORS{OK} : $ERRORS{CRITICAL};
my ($response_as_content, $response, $found);
my $startTime;
if ( defined $parms{perfdataLabel} and $parms{perfdataLabel} ) {
${$self->{asnmtapInherited}}->setEndTime_and_getResponsTime ( ${$self->{asnmtapInherited}}->pluginValue ('endTime') );
$startTime = ${$self->{asnmtapInherited}}->pluginValue ('endTime');
}
my $statusTimeout;
foreach my $url_r ( @{ $self->{urls} } ) {
if ( defined $url_r->{Timeout} ) {
$statusTimeout = 1;
$ua->timeout ( $url_r->{Timeout} );
$ua->default_headers->push_header ( 'Keep-Alive' => $url_r->{Timeout} ) if ( $parms{keepAlive} );
} elsif ( defined $statusTimeout ) {
$statusTimeout = undef;
if ( defined $parms{timeout} ) {
$ua->timeout ( $parms{timeout} );
$ua->default_headers->push_header ( 'Keep-Alive' => $parms{timeout} ) if ( $parms{keepAlive} );
} else {
$ua->timeout ( ${$self->{asnmtapInherited}}->timeout () );
$ua->default_headers->push_header ( 'Keep-Alive' => ${$self->{asnmtapInherited}}->timeout () ) if ( $parms{keepAlive} );
}
}
$self->{_KnownError} = undef;
${$self->{asnmtapInherited}}->setEndTime_and_getResponsTime ( ${$self->{asnmtapInherited}}->pluginValue ('endTime') );
my $url = $url_r->{Url} ? $url_r->{Url} : &_next_url ($response, $response_as_content);
my $request = $self->_make_request ( $url_r->{Method}, $url, $url_r->{Qs_var}, $url_r->{Qs_fixed}, $cgi_parm_vals_hr );
$request->protocol ('HTTP/1.1') if ( $parms{protocol} );
$request->proxy_authorization_basic ( $proxyUsername, $proxyPassword ) if ( defined $proxyServer && defined $proxyUsername && defined $proxyPassword );
my $request_as_string = $request->as_string;
print "\n", ref ($self), '::send_request: ', $request_as_string, "\n" if ( $debug );
if ( defined $triesTiming and $triesTiming ) {
my (@timing_tries) = ( $triesTiming =~ m<(\d+(?:\.\d+)*)>g );
LWP::Debug::debug ('My retrial code policy is ['. join(' ', sort keys %triesCodesToDeterminate) .'].');
LWP::Debug::debug ('My retrial timing policy is ['. $triesTiming .'].');
my $timing_tries = 0;
foreach my $pause_if_unsuccessful ( @timing_tries, undef ) {
$response = $ua->request ($request);
my $code = $response->code;
my $message = $response->message;
$message =~ s/\s+$//s;
$timing_tries++;
unless( $triesCodesToDeterminate{$code} ) { # normal case: all is well (or 404, etc)
LWP::Debug::debug ("It returned a code ($code $message) blocking a retry");
last;
}
if ( defined $pause_if_unsuccessful ) {
LWP::Debug::debug ("It returned a code ($code $message) that'll make me retry, after $pause_if_unsuccessful seconds.");
sleep $pause_if_unsuccessful if ( $pause_if_unsuccessful );
$self->{_timing_tries}++;
} else {
LWP::Debug::debug ("I give up. I'm returning this '$code $message' response.");
}
}
print ref ($self), '::timing_tries: ', $timing_tries, " - $url\n" if ( $onDemand );
} else {
$response = $ua->request ($request);
}
if ( defined $response->content_encoding and $response->content_encoding =~ /^gzip$/i ) {
use Compress::Zlib;
$response_as_content = Compress::Zlib::memGunzip ( $response->content );
} else {
$response_as_content = $response->content;
}
if ( $debug >= 3 ) {
print "\n", ref ($self), '::request: ()', "\n", $response->as_string, "\n\n";
} elsif ( $debug >= 2 ) {
print "\n", ref ($self), '::content: ()', "\n", $response_as_content, "\n\n";
}
my $responseTime = ${$self->{asnmtapInherited}}->setEndTime_and_getResponsTime ( ${$self->{asnmtapInherited}}->pluginValue ('endTime') );
print ref ($self), '::response_time: ', $responseTime, " - $url\n" if ( $onDemand );
${$self->{asnmtapInherited}}->appendPerformanceData ( "'". $url_r->{Perfdata_Label} ."'=". $responseTime .'ms;;;;' ) if ( defined $url_r->{Perfdata_Label} );
$self->_write_debugfile ( $request_as_string, $response_as_content, $debugfile, $openAppend ) if ( defined $debugfile );
if ( $parms{fail_if_1} ) {
unless ( $response->is_success or $response->is_redirect ) {
my $response_as_request = $response->as_string;
# Deal with __Can't__ from LWP.
# Otherwise notification fails because /bin/sh is called to
# printf '$OUTPUT' and sh cannot deal with nested quotes (eg Can't echo ''')
$response_as_request =~ s#'#_#g;
$returnCode = $ERRORS{CRITICAL};
my $knownError = 0;
my $errorMessage = "other than HTTP 200";
for ( $response_as_request ) {
# ***************************************************************************
# The 500 series of Web error codes indicate an error with the Web server *
# ***************************************************************************
# The server had some sort of internal error trying to fulfil the request. The client may see a partial page or error message.
# It's a fault in the server and happens all too frequently.
/500 Can_t connect to/ && do { $knownError = 1; $errorMessage = "500 Can't connect to ..."; $returnCode = $ERRORS{UNKNOWN}; last; };
/500 Connect failed/ && do { $knownError = 1; $errorMessage = "500 Connect failed"; $returnCode = $ERRORS{UNKNOWN}; last; };
/500 proxy connect failed/ && do { $knownError = 1; $errorMessage = "500 Proxy connect failed"; $returnCode = $ERRORS{UNKNOWN}; last; };
/500 Server Error/ && do { $knownError = 1; $errorMessage = "500 Server Error"; $returnCode = $ERRORS{UNKNOWN}; last; };
/500 SSL negotiation failed/ && do { $knownError = 1; $errorMessage = "500 SSL negotiation failed"; $returnCode = $ERRORS{UNKNOWN}; last; };
/500 SSL read timeout/ && do { $knownError = 1; $errorMessage = "500 SSL read timeout"; $returnCode = $ERRORS{UNKNOWN}; last; };
/Internal Server Error/ && do { $knownError = 0; $errorMessage = "500 Internal Server Error"; $returnCode = $ERRORS{UNKNOWN}; last; };
# Function not implemented in Web server software. The request needs functionality not available on the server
/501 (?:No Server|Not Implemented)/ && do { $errorMessage = "501 Not Implemented"; last; };
# Bad Gateway: a server being used by this Web server has sent an invalid response.
# The response by an intermediary server was invalid. This may happen if there is a problem with the DNS routing tables.
/502 (?:Bad Gateway|Server Overload)/ && do { $knownError = 1; $errorMessage = "502 Bad Gateway"; last; };
# Service temporarily unavailable because of currently/temporary overload or maintenance.
/503 (?:Out of Resources|Service Unavailable)/ && do { $knownError = 1; $errorMessage = "503 Service Unavailable"; last; };
# The server did not respond back to the gateway within acceptable time period
/504 Gateway Time-?Out/ && do { $knownError = 1; $errorMessage = "504 Gateway Timeout"; last; };
# The server does not support the HTTP protocol version that was used in the request message.
/505 HTTP Version [nN]ot supported/ && do { $knownError = 1; $errorMessage = "505 HTTP Version Not Supported"; last; };
# ***************************************************************************
# The 400 series of Web error codes indicate an error with your Web browser *
# ***************************************************************************
# The request could not be understood by the server due to incorrect syntax.
/400 Bad Request/ && do { $knownError = 1; $errorMessage = "400 Bad Request"; last; };
# The client does not have access to this resource, authorization is needed
/401 (?:Unauthorized|Authorization Required)/ && do { $knownError = 1; $errorMessage = "401 Unauthorized User"; last; };
# Payment is required. Reserved for future use
/402 Payment Required/ && do { $knownError = 1; $errorMessage = "402 Payment Required"; last; };
# The server understood the request, but is refusing to fulfill it. Access to a resource is not allowed.
# The most frequent case of this occurs when directory listing access is not allowed.
/403 Forbidden/ && do { $knownError = 1; $errorMessage = "403 Forbidden Connection"; last; };
# The resource request was not found. This is the code returned for missing pages or graphics.
# Viruses will often attempt to access resources that do not exist, so the error does not necessarily represent a problem.
/404 (?:Page )?Not Found/ && do { $knownError = 1; $errorMessage = "404 Page Not Found"; last; };
# The access method (GET, POST, HEAD) is not allowed on this resource
/405 Method Not Allowed/ && do { $knownError = 1; $errorMessage = "405 Method Not Allowed"; last; };
# None of the acceptable file types (as requested by client) are available for this resource
/406 Not Acceptable/ && do { $errorMessage = "406 Not Acceptable"; last; };
# The client does not have access to this resource, proxy authorization is needed
/407 Proxy Authentication Required/ && do { $knownError = 1; $errorMessage = "407 Proxy Authentication Required"; last; };
# The client did not send a request within the required time period
/408 Request Time(?:[- ])?[oO]ut/ && do { $knownError = 1; $errorMessage = "408 Request Timeout"; last; };
# The request could not be completed due to a conflict with the current state of the resource.
/409 Conflict/ && do { $knownError = 1; $errorMessage = "409 Conflict"; last; };
# The requested resource is no longer available at the server and no forwarding address is known.
# This condition is similar to 404, except that the 410 error condition is expected to be permanent.
# Any robot seeing this response should delete the reference from its information store.
/410 Gone/ && do { $knownError = 1; $errorMessage = "410 Gone"; last; };
# The request requires the Content-Length HTTP request field to be specified
/411 (?:Content )?Length Required/ && do { $knownError = 1; $errorMessage = "411 Length Required"; last; };
# The precondition given in one or more of the request-header fields evaluated to false when it was tested on the server.
/412 Precondition Failed/ && do { $knownError = 1; $errorMessage = "412 Precondition Failed"; last; };
# The server is refusing to process a request because the request entity is larger than the server is willing or able to process.
/413 Request Entity Too Large/ && do { $knownError = 1; $errorMessage = "413 Request Entity Too Large"; last; };
# The server is refusing to service the request because the Request-URI is longer than the server is willing to interpret.
# The URL is too long (possibly too many query keyword/value pairs)
/414 Request[- ]URL Too Large/ && do { $knownError = 1; $errorMessage = "414 Request URL Too Large"; last; };
# The server is refusing to service the request because the entity of the request is in a format not supported by the requested resource for the requested method.
/415 Unsupported Media Type/ && do { $knownError = 1; $errorMessage = "415 Unsupported Media Type"; last; };
# The portion of the resource requested is not available or out of range
/416 Requested Range (?:Invalid|Not Satisfiable)/ && do { $knownError = 1; $errorMessage = "416 Requested Range Invalid"; last; };
# The Expect specifier in the HTTP request header can not be met
/417 Expectation Failed/ && do { $knownError = 1; $errorMessage = "417 Expectation Failed"; last; };
}
${$self->{asnmtapInherited}}->pluginValues ( { stateValue => $returnCode, alert => "'". $errorMessage ."' - ". $url_r->{Msg}, error => &_error_message( $request->method .' '. $request->uri ), result => $response_as_content }, $TYPE{REPLACE} )...
$self->{_KnownError} = $debugfile if ( defined $debugfile and $knownError );
$self->{_unknownErrors}++ unless ( $knownError );
return ( $returnCode );
}
} else {
$returnCode = $ERRORS{OK} if $response->is_success;
}
if ( $parms{custom} ) {
my ($returnCode, $knownError, $errorMessage) = $parms{custom}->( $response_as_content );
if ( $returnCode != $ERRORS{OK} and defined $errorMessage ) {
${$self->{asnmtapInherited}}->pluginValues ( { stateValue => $returnCode, alert => $errorMessage .' - '. $url_r->{Msg}, error => &_error_message ( $request->method .' '. $request->uri ), result => $response_as_content }, $TYPE{REPLACE} );
$self->{_KnownError} = $debugfile if ( defined $debugfile and $knownError );
$self->{_unknownErrors}++ unless ( $knownError );
return ( $returnCode );
}
}
$self->_my_return ( $url_r->{Exp_Return}, $response_as_content );
if ( $self->_my_match ( $url_r->{Exp_Fault}, $response_as_content, 0 ) ) {
my $fault_ind = $url_r->{Exp_Fault};
my ($bad_stuff) = $response_as_content =~ /($fault_ind.*\n.*\n)/;
${$self->{asnmtapInherited}}->pluginValues ( { stateValue => $ERRORS{CRITICAL}, alert => $url_r->{Msg_Fault}, error => &_error_message ( $request->method .' '. $request->uri ), result => $bad_stuff }, $TYPE{REPLACE} );
$self->{_unknownErrors}++;
return ( $ERRORS{CRITICAL} );
} elsif ( ! ($found = $self->_my_match ( $url_r->{Exp}, $response_as_content, 1 )) ) {
my $exp_type = ref $url_r->{Exp};
my $exp_str = $exp_type eq 'ARRAY' ? "@{$url_r->{Exp}}" : $url_r->{Exp};
${$self->{asnmtapInherited}}->pluginValues ( { stateValue => $ERRORS{CRITICAL}, alert => "'". $url_r->{Msg} ."' - '". $exp_str ."' not in response", error => &_error_message ( $request->method .' '. $request->uri ), result => $response_as_conte...
$self->{_unknownErrors}++;
return ( $ERRORS{CRITICAL} );
( run in 1.008 second using v1.01-cache-2.11-cpan-39bf76dae61 )