File Coverage

blib/lib/LINE/Notify/Simple.pm

Criterion	Covered	Total	%
statement	58	63	92.0
branch	3	8	37.5
condition			n/a
subroutine	14	14	100.0
pod	1	2	50.0
total	76	87	87.3

package LINE::Notify::Simple;

use strict;
use warnings;
use utf8;
use feature qw(say);
use parent qw(Class::Accessor);
use JSON;
use Encode;
use Encode::Guess qw(euc-jp shiftjis 7bit-jis);
use LWP::UserAgent;
use HTTP::Request;
use URI::Escape;
use LINE::Notify::Simple::Response;

__PACKAGE__->mk_accessors(qw(access_token));

our $LINE_NOTIFY_URL    = 'https://notify-api.line.me/api/notify';
our $VERSION            = '1.0';

sub notify {

	my($self, $message, $data) = @_;

	my $headers = [
			'Content-Type', 'application/x-www-form-urlencoded',
			'Authorization', sprintf('Bearer %s', $self->access_token)
		];

	if (ref($data) eq "HASH") {
		$data->{message} = $message;
	} else {
		$data = { message => $message };
	}
	my $content = $self->make_query($data);

	my $ua  = LWP::UserAgent->new;
	my $req = HTTP::Request->new("POST", $LINE_NOTIFY_URL, $headers, $content);
	my $res = $ua->request($req);

	my $rate_limit_headers = {};
	my @names = $res->header_field_names;
	foreach my $name (@names) {
		if ($name =~ /^X\-.*/) {
			$rate_limit_headers->{lc($name)} = $res->header($name);
		}
	}

	my $ref = JSON->new->decode($res->content);

	return LINE::Notify::Simple::Response->new({ rate_limit_headers => $rate_limit_headers, status => $ref->{status}, message => $ref->{message}, status_line => $res->status_line });
}


sub make_query {

	my($self, $data) = @_;

	my @pairs;
	foreach my $key(keys %{$data}) {

		my $val = $data->{$key};
		if (utf8::is_utf8($val)) {
			my $enc   = guess_encoding($val);
			my $guess = ref($enc) ? $enc->name : "UTF-8";
			$val = Encode::encode($guess, $val);
		}
		push @pairs, sprintf("%s=%s", $key, uri_escape($val));
	}
	return join("&", @pairs);
}

1;

__END__