File Coverage

blib/lib/JSON/RPC2/AnyEvent/Server/PSGI.pm

Criterion	Covered	Total	%
statement	48	50	96.0
branch	7	8	87.5
condition	2	3	66.6
subroutine	16	17	94.1
pod	0	1	0.0
total	73	79	92.4

package JSON::RPC2::AnyEvent::Server::PSGI;
use 5.008005;
use strict;
use warnings;

our $VERSION = "0.01";

use AnyEvent;
use JSON;
use Plack::Request;
use Try::Tiny;

use JSON::RPC2::AnyEvent::Constants qw(ERR_PARSE_ERROR);
use JSON::RPC2::AnyEvent::Server;


sub JSON::RPC2::AnyEvent::Server::to_psgi_app {
    my ($self) = @_;
    sub{
        my $req = Plack::Request->new(shift);
        if ( $req->method eq 'GET' or  $req->method eq 'HEAD' ) {
            return _dispatch_url_query($self, $req);
        } elsif ( $req->method eq 'POST' ) {
            return $req->content_type =~ m|^application/x-www-form-urlencoded$|i
                ? _dispatch_url_query($self, $req)
                : _dispatch_json($self, $req);
        } else {
            return [405, ['Content-type' => 'text/plain'], ['Method Not Allowed']]
        }
    }
}

my $json = JSON->new->utf8;

sub _dispatch_url_query {
    my ($self, $req) = @_;
    _dispatch_aux($self, {
        jsonrpc => '2.0',
        id      => undef,
        method  => substr($req->path_info, 1),
        params  => $req->parameters->mixed,
    });
}

sub _dispatch_json {
    my ($self, $req) = @_;
    try{
        my $hash = $json->decode($req->content);
        _dispatch_aux($self, $hash);
    } catch {
        [200, ['Content-Type', 'application/json'], [$json->encode({
            jsonrpc => '2.0',
            id      => undef,
            error   => {code => ERR_PARSE_ERROR, message => 'Parse error', data => shift}
        })]]
    };
}

sub _dispatch_aux {
    my ($self, $hash) = @_;
    my $cv = $self->dispatch($hash);
    return [200, [], []]  unless $cv;  # notification
    sub{
        my $writer = shift->([200, ['Content-Type', 'application/json']]);
        $cv->cb(sub{
            my $res = shift->recv;
            $writer->write($json->encode($res));
            $writer->close;
        });
    };
}


1;
__END__