File Coverage

blib/lib/Net/Calais.pm

Criterion	Covered	Total	%
statement	15	57	26.3
branch	0	16	0.0
condition	0	6	0.0
subroutine	5	8	62.5
pod	3	3	100.0
total	23	90	25.5

# ===========================================================================
# Net::Calais
#
# Interface to OpenCalais web service
#
# Alessandro Ranellucci
#
package Net::Calais;
use strict;
use warnings;

use HTTP::Request::Common;
use LWP::UserAgent;
use XML::Writer;

our $VERSION = '1.02';

our $CALAIS_URL = 'http://api.opencalais.com/enlighten/rest/';
our $SEMANTICPROXY_URL = 'http://service.semanticproxy.com/processurl/';

#--
sub new {
    my ($class, %params) = @_;
    die "Calais apikey required\n" unless $params{apikey};
    my $self = { apikey => $params{apikey} };
    $self->{ua} = LWP::UserAgent->new() or return undef;
    bless $self, $class;
    return $self;
}
#--
sub enlighten {
    my __PACKAGE__ $self = shift;
    my ($content, %params) = @_;

    # process user params and set some defaults
    my %request_params = (licenseID => $self->{apikey}, content => $content);
    my (%processingDirectives, %userDirectives) = ();
    $processingDirectives{'c:contentType'} = $params{contentType} || 'text/txt';
    $processingDirectives{'c:outputFormat'} = $params{outputFormat} || 'XML/RDF';
    for (qw(reltagBaseURL calculateRelevanceScore enableMetadataType discardMetadata)) {
        $processingDirectives{"c:$_"} = $params{$_} if $params{$_};
    }
    for (qw(allowDistribution allowSearch externalID submitter)) {
        $userDirectives{"c:$_"} = $params{$_} if $params{$_};
    }

    # build the paramxXML parameter
    my $xmlWriter = XML::Writer->new(
        OUTPUT => \$request_params{paramsXML},
        DATA_MODE => 1,
        DATA_INDENT => 0,
        ENCODING => 'UTF-8'
    );
    $xmlWriter->startTag('c:params',
        'xmlns:c' => 'http://s.opencalais.com/1/pred/',
        'xmlns:rdf' => 'http://www.w3.org/1999/02/22-rdf-syntax-ns#');
    $xmlWriter->startTag('c:processingDirectives', %processingDirectives);
    $xmlWriter->endTag('c:processingDirectives');
    $xmlWriter->startTag('c:userDirectives', %userDirectives);
    $xmlWriter->endTag('c:userDirectives');
    $xmlWriter->startTag('c:externalMetadata');
    $xmlWriter->raw($params{externalMetadata}) if $params{externalMetadata};
    $xmlWriter->endTag('c:externalMetadata');
    $xmlWriter->endTag('c:params');
    $xmlWriter->end;

    # do REST request and return response
    my $response = $self->{ua}->request(POST $CALAIS_URL, \%request_params);
    if (!$response->is_success) {
        $self->{error} = $response->status_line;
        return undef;
    }
    return $response->content;
}
#--
sub semanticproxy {
    my __PACKAGE__ $self = shift;
    my ($url, %params) = @_;

    die "URL is required\n" unless $url;
    $params{output} ||= 'html';

    my $reqUrl = sprintf("%s%s/%s/%s", $SEMANTICPROXY_URL, $self->{apikey}, $params{output}, $url);
    my $response = $self->{ua}->request(GET $reqUrl);
    if (!$response->is_success) {
        $self->{error} = $response->status_line;
        return undef;
    }
    return $response->content;
}
#--
1;
__END__