File Coverage

blib/lib/XAS/Lib/RPC/JSON/Client.pm

Criterion	Covered	Total	%
statement	6	28	21.4
branch	0	6	0.0
condition	0	6	0.0
subroutine	2	4	50.0
pod	1	1	100.0
total	9	45	20.0

package XAS::Lib::RPC::JSON::Client;

our $VERSION = '0.02';

use XAS::Class
  debug     => 0,
  version   => $VERSION,
  base      => 'XAS::Lib::Net::Client',
  utils     => ':validation dotid',
  codec     => 'JSON',
  constants => ':jsonrpc HASHREF',
;

use Data::Dumper;

# ----------------------------------------------------------------------
# Public Methods
# ----------------------------------------------------------------------

sub call {
    my $self = shift;
    my $p = validate_params(\@_, {
        -method => 1,
        -id     => 1,
        -params => { type => HASHREF }
    });

    my $params;
    my $response;

    while (my ($key, $value) = each(%{$p->{'params'}})) {

        $key =~ s/^-//;
        $params->{$key} = $value;

    }

    my $packet = {
        jsonrpc => RPC_JSON,
        id      => $p->{'id'},
        method  => $p->{'method'},
        params  => $params
    };

    $self->log->debug(Dumper($packet));

    $self->puts(encode($packet));

    if ($response = $self->gets()) {

        $response = decode($response);
        $self->log->debug(Dumper($response));

        if ($response->{'id'} eq $p->{'id'}) {

            $self->_check_for_errors($response);
            return $response->{'result'};

        } else {

            $self->throw_msg(
                dotid($self->class) . '.call.invalid_id',
                'json_rpc_invalid_id',
            );

        }

    } else {

        $self->throw_msg(
            dotid($self->class) . '.call.invalid_response',
            'json_rpc_invalid_response',
            $p->{'method'}
        );

    }

}

# ----------------------------------------------------------------------
# Private Methods
# ----------------------------------------------------------------------

sub _check_for_errors {
    my $self = shift;
    my $response = shift;

    if ($response->{'error'}) {

        $self->throw_msg(
            dotid($self->class) . '.call.rpc_error',
            'json_rpc_error',
            $response->{'error'}->{'code'} || '',
            $response->{'error'}->{'message'} || '',
            $response->{'error'}->{'data'} || '',
        );

    }

}

1;

__END__