File Coverage

blib/lib/WWW/CybozuOffice6.pm

Criterion	Covered	Total	%
statement	74	94	78.7
branch	10	28	35.7
condition	1	9	11.1
subroutine	21	24	87.5
pod	9	11	81.8
total	115	166	69.2

package WWW::CybozuOffice6;


#                        !!! ATTENTION !!!
#
#          This package is NOT a product of Cybozu, Inc.
#     DO NOT CONTACT CYBOZU, INC. for the use of the software.
#
# For support, please visit http://labs.cybozu.co.jp/blog/kazuho/


use 5.006;
use strict;
use warnings;
use fields qw(url user id pass ua response ocode);
use vars qw($VERSION);

use Carp;
use Jcode;
use LWP;
use Text::CSV_XS;
use URI::Escape;


$VERSION = 0.04;


# instantiation
sub new {
    # setup
    my WWW::CybozuOffice6 $self = shift;
    unless (ref $self) {
        $self = fields::new($self);
    }
    # set params
    while ($#_ >= 0) {
        croak('CybozuOffice65->new() called with odd number of option parameters - should be of the form option => value') if ($#_ == 0);
        my $n = lc(shift);
        my $v = shift;
        $self->_init_param($n, $v);
    }
    # set default
    $self->{ua} = LWP::UserAgent->new() unless defined($self->{ua});
    $self->{ocode} = 'utf8' unless defined($self->{ocode});

    return $self;
}

# accessors
sub url (\$@) {
    my $self = shift;
    return $self->_accessor('url', @_);
}

sub user (\$@) {
    my $self = shift;
    return $self->_accessor('user', @_);
}

sub id (\$@) {
    my $self = shift;
    return $self->_accessor('id', @_);
}

sub password (\$@) {
    my $self = shift;
    return $self->_accessor('pass', @_);
}

sub ua (\$@) {
    my $self = shift;
    return $self->_accessor('ua', @_);
}

sub response (\$) {
    # no setter
    my $self = shift;
    return $self->{response};
}

sub ocode (\$@) {
    my $self = shift;
    return $self->_accessor('ocode', @_);
}

# checks if username/password is valid
sub test_credentials (\$) {
    my $self = shift;
    my $items = $self->externalAPINotify;
    return defined($items) && ref($items) eq 'ARRAY';
}

# returns new items
sub externalAPINotify (\$) {
    my $self = shift;
    # get RSS
    if (! $self->_request('ExternalAPINotify')) {
        return;
    }
    # parse and return the result
    my $content = Jcode::convert($self->{response}->content, $self->{ocode});
    return $self->parse_externalAPINotify($content);
}

sub parse_externalAPINotify (\$$) {
    my ($self, $content) = @_;
    my @items;
    # split into lines
    my @lines = split(/\x0d\x0a/, $content);
    # check first line
    if ($#lines == -1 || $lines[0] !~ /ts\./) {
        return;
    }
    shift(@lines);
    # parse the rest (but not the last line)
    my $csv = Text::CSV_XS->new({ binary => 1 });
    while ($#lines > 0) {
        my $line = shift(@lines);
        if (! $csv->parse($line)) {
            croak 'failed to parse CSV input';
        }
        my @fields = $csv->fields;
        if ($#fields < 6) {
            croak 'unexpected number of fields in CSV';
        }
        my $item = {
            app => $fields[0],
            app_jp => $fields[1],
            timestamp => $fields[3],
            title => $fields[4],
            description => $fields[5],
            from => $fields[6],
            link => $fields[7] };
        $item->{timestamp} =~ s/^ts\.//;
        push(@items, $item);
    }

    return \@items;
}

# initialization
sub _init_param (\$$$) {
    my ($self, $n, $v) = @_;
    $self->{$n} = $v;
}

# general accessor
sub _accessor (\$$@) {
    my $self = shift;
    my $name = shift;
    if ($#_ <=> -1) {
        $self->{$name} = $_[0];
    }
    return $self->{$name};
}

# request handler
sub _request (\$$) {
    my ($self, $page) = @_;
    croak 'url not set' unless defined($self->{url});
    croak 'user/id not set' unless defined $self->{user} or defined $self->{id};
    croak 'password not set' unless defined($self->{pass});
    $self->{response} =
        $self->{ua}->post($self->{url} . '?page=' . uri_escape($page),
                          { _System => 'login',
                            _Login => '1',
                            GuideNavi => '1',
                            defined $self->{user} ? (_Account => $self->{user}) : (),
                            defined $self->{id} ? (_Id => $self->{id}) : (),
                            Password => $self->{pass} });
    return $self->{response}->is_success;
}


1;
__END__