File Coverage

blib/lib/WebService/Antispam.pm

Criterion	Covered	Total	%
statement	15	43	34.8
branch	0	10	0.0
condition	0	3	0.0
subroutine	5	7	71.4
pod	2	2	100.0
total	22	65	33.8

package WebService::Antispam;

use 5.006;
use strict;
use warnings FATAL => 'all';
use JSON::XS;
use LWP::UserAgent;

our $VERSION = '1.04';

# JSON object
my $json_xs = JSON::XS->new;
$json_xs->utf8(1);

my %connection_params = (
    'server_url' => 'http://moderate.cleantalk.ru',
    'server_url' => 'http://localhost',
    'api_url' => '/api2.0',
    'auth_key' => undef,
    'connection_timeout' => 3,
    'method_name' => 'check_message',
    'agent' => 'perl-api-' . $VERSION,
);

my %response = (
    'allow' => 0,
    'id' => undef,
    'comment' => '*** Connection error: %s Automoderator cleantalk.org ***',
    'stop_queue' => 0,
    'inactive' => 0,
);

sub new {
    my $class = shift;
    my $params = shift;
    my $self = bless {} , $class;

    foreach (keys %connection_params) {
        $connection_params{$_} = $$params{$_} if defined($$params{$_});
    }

    return $self;
}

sub request {
    my $class = shift;
    my $params = shift;

    $$params{'auth_key'} = $connection_params{'auth_key'};
    $$params{'method_name'} = $connection_params{'method_name'} if !defined($$params{'method_name'});
    $$params{'agent'} = $connection_params{'agent'} if !defined($$params{'agent'});

    my $ua = LWP::UserAgent->new;
    $ua->timeout($connection_params{'connection_timeout'});

    my $server_url = $connection_params{'server_url'} . $connection_params{'api_url'};

    my $request = HTTP::Request->new(POST => $server_url);
    $request->header('content-type' => 'application/json');
    $request->content($json_xs->encode($params));

    my $result = undef;
    my $response = $ua->request($request);
    if ($response->is_success) {
        eval{
            $result = $json_xs->decode($response->decoded_content);
        };
        if ($@ || ref($result) ne 'HASH') {
            $response{'comment'} = sprintf($response{'comment'}, $response->decoded_content);
            return \%response;
        }
    } else {
        $response{'comment'} = sprintf($response{'comment'}, $response->message);
        return \%response;
    }

    return $result;
}

__END__