File Coverage

blib/lib/Norikra/Client.pm

Criterion	Covered	Total	%
statement	13	15	86.6
branch			n/a
condition			n/a
subroutine	5	5	100.0
pod			n/a
total	18	20	90.0

package Norikra::Client;
use 5.008005;
use strict;
use warnings;

use Data::MessagePack;
use MessagePack::RPC::HTTP::Client;

our $VERSION = "0.03";

my $RPC_DEFAULT_PORT = 26571;

sub new {
    my ($this, $host, $port, %opts) = @_;
    $host ||= "localhost";
    $port ||= $RPC_DEFAULT_PORT;
    return bless +{client => MessagePack::RPC::HTTP::Client->new("http://$host:$port/")}, $this;
}

sub client {
    (shift)->{client};
}

sub targets {
    my ($self) = @_;
    $self->client->call("targets");
}

sub open {
    my ($self, $target, $fields, $auto_field) = @_;
    $auto_field = 1 unless defined $auto_field;
    $self->client->call("open", $target, $fields, ($auto_field ? Data::MessagePack::true() : Data::MessagePack::false() ));
}

sub close {
    my ($self, $target) = @_;
    $self->client->call("close", $target);
}

sub modify {
    my ($self, $target, $auto_field) = @_;
    $self->client->call("modify", $target, ($auto_field ? Data::MessagePack::true() : Data::MessagePack::false() ));
}

sub queries {
    my ($self) = @_;
    $self->client->call("queries");
}

sub register {
    my ($self, $query_name, $query_group, $query_expression) = @_;
    $self->client->call("register", $query_name, $query_group, $query_expression);
}

sub deregister {
    my ($self, $query_name) = @_;
    $self->client->call("deregister", $query_name);
}

sub fields {
    my ($self, $target) = @_;
    $self->client->call("fields", $target);
}

sub reserve {
    my ($self, $target, $field, $type) = @_;
    $self->client->call("reserve", $target, $field, $type);
}

sub send {
    my ($self, $target, $events) = @_;
    $self->client->call("send", $target, $events);
}

sub event {
    my ($self, $query_name) = @_;
    $self->client->call("event", $query_name);
}

sub see {
    my ($self, $query_name) = @_;
    $self->client->call("see", $query_name);
}

sub sweep {
    my ($self, $query_group) = @_;
    $self->client->call("sweep", $query_group);
}

1;
__END__