File Coverage

blib/lib/ArangoDB2/Replication.pm

Criterion	Covered	Total	%
statement	15	60	25.0
branch	0	4	0.0
condition			n/a
subroutine	5	23	21.7
pod	18	18	100.0
total	38	105	36.1

package ArangoDB2::Replication;

use strict;
use warnings;

use base qw(
    ArangoDB2::Base
);

use Data::Dumper;
use JSON::XS;

my $JSON = JSON::XS->new->utf8;



###############
# API METHODS #
###############

# applierConfig
#
# GET /_api/replication/applier-config
# PUT /_api/replication/applier-config
sub applierConfig
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['configuration']);
    # build path
    my $path = $self->api_path('replication', 'applier-config');
    # make request
    return $args->{configuration}
        ? $self->arango->http->put($path, $args)
        : $self->arango->http->get($path);
}

# applierStart
#
# PUT /_api/replication/applier-start
sub applierStart
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['from']);
    # make request
    return $self->arango->http->put(
        $self->api_path('replication', 'applier-start'),
        $args,
    );
}

# applierState
#
# GET /_api/replication/applier-state
sub applierState
{
    my($self) = @_;
    # make request
    return $self->arango->http->get(
        $self->api_path('replication', 'applier-state'),
    );
}

# applierStop
#
# PUT /_api/replication/applier-stop
sub applierStop
{
    my($self) = @_;
    # make request
    return $self->arango->http->get(
        $self->api_path('replication', 'applier-stop'),
    );
}

# clusterInventory
#
# GET /_api/replication/clusterInventory
sub clusterInventory
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['includeSystem']);
    # make request
    return $self->arango->http->get(
        $self->api_path('replication', 'clusterInventory'),
        $args,
    );
}

# dump
#
# GET /_api/replication/dump
sub dump
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['chunkSize', 'collection', 'from', 'ticks', 'to']);
    # make request
    return $self->arango->http->get(
        $self->api_path('replication', 'dump'),
        $args,
    );
}

# inventory
#
# GET /_api/replication/inventory
sub inventory
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['includeSystem']);
    # make request
    return $self->arango->http->get(
        $self->api_path('replication', 'inventory'),
        $args,
    );
}

# loggerFollow
#
# GET /_api/replication/loggerFollow
sub loggerFollow
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['chunkSize', 'from', 'to']);
    # make request
    my $res = $self->arango->http->get(
        $self->api_path('replication', 'logger-follow'),
        $args,
        1, # get raw response
    ) or return;
    # build our own response
    my $ret = {};
    # response is newline separated JSON log entries
    $ret->{log} = [ map { $JSON->decode($_) } split(/\n/, $res->content) ];

    # get response header values
    $ret->{replication}->{active} = $res->header('x-arango-replication-active');
    $ret->{replication}->{checkmore} = $res->header('x-arango-replication-checkmore');
    $ret->{replication}->{lastincluded} = $res->header('x-arango-replication-lastincluded');
    $ret->{replication}->{lasttick} = $res->header('x-arango-replication-lasttick');

    return $ret;
}

# loggerState
#
# GET /_api/replication/loggerState
sub loggerState
{
    my($self) = @_;
    # make request
    return $self->arango->http->get(
        $self->api_path('replication', 'logger-state'),
    );
}

# serverId
#
# GET /_api/replication/server-id
sub serverId
{
    my($self) = @_;
    # make request
    return $self->arango->http->get(
        $self->api_path('replication', 'server-id'),
    );
}

# sync
#
# PUT /_api/replication/sync
sub sync
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['configuration']);
    # make request
    return $self->arango->http->put(
        $self->api_path('replication', 'sync'),
        $args,
    );
}


####################
# PROPERTY METHODS #
####################

# chunkSize
#
# get/set chunkSize
sub chunkSize { shift->_get_set('chunkSize', @_) }

# collection
#
# get/set collection
sub collection { shift->_get_set_name('collection', @_) }

# configuration
#
# get/set configuration
sub configuration { shift->_get_set('configuration', @_) }

# from
#
# get/set from
sub from { shift->_get_set('from', @_) }

# includeSystem
#
# get/set includeSystem
sub includeSystem { shift->_get_set('includeSystem', @_) }

# ticks
#
# get/set ticks
sub ticks { shift->_get_set_bool('ticks', @_) }

#
#
# get/set
sub to { shift->_get_set('', @_) }


1;

__END__