File Coverage

blib/lib/WebService/Lingr/Archives.pm

Criterion	Covered	Total	%
statement	52	60	86.6
branch	15	20	75.0
condition	11	15	73.3
subroutine	11	11	100.0
pod	2	2	100.0
total	91	108	84.2

package WebService::Lingr::Archives;
use strict;
use warnings;
use 5.10.0;
use Carp;
use LWP::UserAgent;
use URI;
use JSON qw(decode_json);

our $VERSION = '0.03';

sub new {
    my ($class, %args) = @_;
    if(!defined($args{user})) {
        croak "user parameter is mandatory";
    }
    if(!defined($args{password})) {
        croak "password parameter is mandatory";
    }
    my $self = bless {
        user_agent => $args{user_agent} // do {
            my $ua = LWP::UserAgent->new;
            $ua->env_proxy();
            $ua;
        },
        user => $args{user},
        password => $args{password},
        app_key => $args{app_key},
        api_base => $args{api_base} // 'http://lingr.com/api',
        session_id => undef,
    }, $class;
    $self->{api_base} =~ s{/+$}{};
    return $self;
}

sub get_archives {
    my ($self, $room, $options) = @_;
    $options //= {};
    if(!defined($room)) {
        croak "room parameter is mandatory";
    }
    my $retry_allowed = 1;
    if(!defined($self->{session_id})) {
        $self->_create_session();
        $retry_allowed = 0;
    }
    my $result = $self->_get_request('/room/get_archives', [
        session => $self->{session_id}, room => $room,
        before => $options->{before} // 99999999,
        (defined($options->{limit}) ? (limit => $options->{limit}) : ())
    ]);
    if(!defined($result->{status}) || lc($result->{status}) ne "ok") {
        if($retry_allowed) {
            $self->{session_id} = undef;
            return $self->get_archives($room, $options);
        }
        croak "Lingr API Error: code =  $result->{code}, detail = $result->{detail}";
    }
    return @{$result->{messages}};
}

sub _create_session {
    my ($self) = @_;
    my $result = $self->_get_request('/session/create', [user => $self->{user},
                                                         password => $self->{password},
                                                         (defined($self->{app_key}) ? (app_key => $self->{app_key}) : ())]);
    if(!defined($result->{status}) || lc($result->{status}) ne "ok") {
        croak "Cannot create session with user $self->{user}: $result->{code}, $result->{detail}";
    }
    $self->{session_id} = $result->{session};
}

sub _get_request {
    my ($self, $endpoint, $params) = @_;
    my $url = URI->new($self->{api_base} . $endpoint);
    $url->query_form($params);
    my $res = $self->{user_agent}->get($url);
    if(!$res->is_success) {
        croak "Network Error: " . $res->status_line;
    }
    return decode_json($res->content);
}

1;

__END__