File Coverage

blib/lib/Net/Chaton/API.pm

Criterion	Covered	Total	%
statement	25	27	92.5
branch			n/a
condition			n/a
subroutine	9	9	100.0
pod			n/a
total	34	36	94.4

package Net::Chaton::API;

use 5.012001;
use strict;
use warnings;
use Pipe::Between::Object;
use LWP::UserAgent;
use HTTP::Request::Common qw(GET POST);
use JSON;
use utf8;
use Desktop::Notify;
use Encode::Guess qw/shiftjis euc-jp 7bit-jis/;
use Encode qw/from_to decode encode/;

require Exporter;

our @ISA = qw(Exporter);

# Items to export into callers namespace by default. Note: do not export
# names by default without a very good reason. Use EXPORT_OK instead.
# Do not simply export all your public functions/methods/constants.

# This allows declaration	use Net::Chaton::API ':all';
# If you do not need this, moving things directly into @EXPORT or @EXPORT_OK
# will save memory.
our %EXPORT_TAGS = ( 'all' => [ qw(

) ] );

our @EXPORT_OK = ( @{ $EXPORT_TAGS{'all'} } );

our @EXPORT = qw(

);

our $VERSION = '0.02';


# Preloaded methods go here.

our $ua = LWP::UserAgent->new;
our $json = JSON->new->allow_nonref;

sub new {#{{{
	my $class = shift;
	my $self = {
		who => 'Net::Chaton::API',
		@_,
	};
	return bless($self, $class);
}#}}}

sub login {#{{{
	my $self = shift;
	defined($self->{'room'}) or die "Error::Room uri is undefined";
	my $apilogin_url = $self->{'room'} . "apilogin";
	my %postdata = (
		who => $self->{who},
		s => 0,
	);
	my $req = POST($apilogin_url, [%postdata]);
	my $responce = $ua->request($req);
	my $decoded_responce = $json->decode($responce->content);
	$self->{'post-uri'} = $decoded_responce->{'post-uri'};
	$self->{'comet-uri'} = $decoded_responce->{'comet-uri'};
	$self->{'cid'} = $decoded_responce->{'cid'};
	$self->{'pos'} = $decoded_responce->{'pos'};
}#}}}

sub Post {#{{{
	my ($self, $nick, $message) = @_;
	my $enc_nick    = guess_encoding($nick);
	my $enc_message = guess_encoding($message);

	if(ref $enc_nick) {
		from_to($nick,$enc_nick->name, 'utf8');
	}
	if(ref $enc_message) {
		from_to($message,$enc_message->name, 'utf8');
	}
	my %postdata = (
		nick => $nick,
		text => $message,
		cid  => $self->{'cid'},
	);
	my $req = HTTP::Request::Common::POST($self->{'post-uri'}, [%postdata]);
	$ua->request($req);
}#}}}

sub Observe{#{{{
	my ($self,$p, $c) = @_;
	my $decoded_responce;
	if(defined($p) && defined($c)) {
		my $req = GET("$self->{'comet-uri'}?p=$p&c=$c&s=0");
		my $res = $ua->request($req);
		$decoded_responce = $json->decode($res->content);
		$self->{'cid'} = $decoded_responce->{'cid'};
		$self->{'pos'} = $decoded_responce->{'pos'};
		if($decoded_responce->{'content'} eq ""){
			#if responce is empty the observe again immidietry.
			@_ = ($self,$self->{'pid'}, $self->{'cid'});
			goto &Observe;
		}
	}
	else {
		my $req = GET("$self->{'comet-uri'}?p=$self->{'pos'}&c=$self->{'cid'}&s=0");
		my $res = $ua->request($req);
		$decoded_responce = $json->decode($res->content);
		$self->{'cid'} = $decoded_responce->{'cid'};
		$self->{'pos'} = $decoded_responce->{'pos'};

		# if content is empty retry immediately
		if($decoded_responce->{'content'} eq "") {
			@_ = ($self,$self->{'pid'}, $self->{'cid'});
			goto &Observe;
		}
	}
	my $name = @{$decoded_responce->{'content'}}[0]->[0];
	my $txt = @{$decoded_responce->{'content'}}[0]->[2];

	my $enc_name = guess_encoding($name);
	my $enc_txt  = guess_encoding($txt);

	if(ref $enc_name) {
		from_to($name,$enc_name->name, 'utf8');
	}
	if(ref $enc_txt) {
		from_to($txt,$enc_txt->name, 'utf8');
	}

	my $notify = Desktop::Notify->new();
	$notify->create(
		summary => $name,
		body => $txt,
		timeout => 5000)->show();
	@_ = ($self,$self->{'pid'}, $self->{'cid'});
	goto &Observe;
}#}}}
__END__