File Coverage

blib/lib/Net/FleetDB.pm

Criterion	Covered	Total	%
statement	19	32	59.3
branch	0	4	0.0
condition	3	8	37.5
subroutine	6	7	85.7
pod	0	2	0.0
total	28	53	52.8

package Net::FleetDB;
use warnings;
use strict;
use Carp qw(croak);
use IO::Socket::INET;
use JSON::XS::VersionOneAndTwo;
our $VERSION = '0.33';

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

    my $host = delete $args{host} || '127.0.0.1';
    my $port = delete $args{port} || 3400;

    my $socket = IO::Socket::INET->new(
        PeerHost => $host,
        PeerPort => $port,
        Timeout  => 60
    ) || die "Error connecting to $host:$port: $!";

    my $self = bless {
        host   => $host,
        port   => $port,
        socket => $socket,
    }, $class;
    return $self;
}

sub query {
    my ( $self, @args ) = @_;
    my $socket  = $self->{socket};
    my $request = to_json( \@args );
    warn "-> $request\n" if 0;
    $socket->print( $request . "\n" ) || die $!;
    my $response = $socket->getline || die $!;
    warn "<- $response" if 0;
    my $return = from_json($response);

    if ( $return->[0] != 0 ) {
        croak( $return->[1] );
    } else {
        return $return->[1];
    }
}

1;

__END__