File Coverage

blib/lib/WebService/ImKayac/Simple.pm

Criterion	Covered	Total	%
statement	19	21	90.4
branch			n/a
condition			n/a
subroutine	7	7	100.0
pod			n/a
total	26	28	92.8

package WebService::ImKayac::Simple;
use 5.008005;
use strict;
use warnings;
use Carp;
use Digest::SHA1 qw/sha1_hex/;
use Encode qw/encode_utf8 decode_utf8/;
use Furl;
use JSON ();

use constant IM_KAYAC_BASE_URL => 'http://im.kayac.com/api/post/';

our $VERSION = '0.10';

sub new {
    my ($class, @arg) = @_;

    my $user;
    my $password;
    my $type;
    if (scalar @arg == 1) {
        require YAML::Tiny;
        my $yaml_file = shift @arg;
        my $conf = YAML::Tiny->read($yaml_file)->[0];
        $user     = $conf->{user};
        $type     = $conf->{type}     || '';
        $password = $conf->{password} || '';
    }
    else {
        my %arg = @arg;
        $user     = $arg{user};
        $type     = $arg{type}     || '';
        $password = $arg{password} || '';
    }

    croak '[ERROR] User name is required' unless $user;
    if ($type) {
        if ($type !~ /^(?:password|secret)$/) {
            croak "[ERROR] Invalid type: $type (type must be 'password' or 'secret')";
        }
        croak '[ERROR] Password is required' unless $password;
    }

    bless {
        user     => $user,
        password => $password,
        type     => $type,
        furl     => Furl->new(
            agent   => 'WebService::ImKayac::Simple (Perl)',
            timeout => 10,
        ),
    }, $class;
}

sub send {
    my ($self, $message, $handler) = @_;

    croak '[ERROR] Message is required' unless $message;
    eval { $message = decode_utf8($message) };
    $message = encode_utf8($message);

    my $param = {message => $message};

    if (my $type = $self->{type}) {
        if ($type eq 'password') {
            $param->{password} = $self->{password};
        }
        elsif ($type eq 'secret') {
            $param->{sig} = sha1_hex($message . $self->{password});
        }
    }

    if ($handler) {
        $param->{handler} = $handler;
    }

    my $res = $self->{furl}->post(
        IM_KAYAC_BASE_URL . $self->{user},
        ['Content-Type' => 'application/x-www-form-urlencoded'],
        $param,
    );

    unless ($res->is_success) {
        croak "[ERROR] " . $res->status_line;
    }

    my $json = JSON::decode_json($res->{content});
    if (my $error = $json->{error}) {
        croak "[ERROR] $error";
    }
}

1;
__END__