File Coverage

blib/lib/Etcd/Response.pm

Criterion	Covered	Total	%
statement	24	24	100.0
branch			n/a
condition			n/a
subroutine	7	7	100.0
pod	0	1	0.0
total	31	32	96.8

package Etcd::Response;
$Etcd::Response::VERSION = '0.002';
use namespace::sweep;

use Etcd::Node;

use JSON qw(decode_json);

use Moo;
use Type::Utils qw(class_type);
use Types::Standard qw(Str Int);

has action     => ( is => 'ro', isa => Str, required => 1 );
has etcd_index => ( is => 'ro', isa => Int, required => 1 );
has raft_index => ( is => 'ro', isa => Int, required => 1 );
has raft_term  => ( is => 'ro', isa => Int, required => 1 );

my $node_coercion = sub { ref $_[0] eq 'HASH' ? Etcd::Node->new(%{$_[0]}) : $_[0] };
has node       => ( is => 'ro', isa => class_type('Etcd::Node'), coerce => $node_coercion, required => 1 );
has prev_node  => ( is => 'ro', isa => class_type('Etcd::Node'), coerce => $node_coercion, init_arg => 'prevNode' );

sub new_from_http {
    my ($class, $res) = @_;
    my $data = decode_json($res->{content});
    my %headers;
    @headers{qw(etcd_index raft_index raft_term)} = @{$res->{headers}}{qw(x-etcd-index x-raft-index x-raft-term)};
    $class->new(%$data, %headers);
}

1;

__END__