File Coverage

blib/lib/Catmandu/Store/Resolver/Bag.pm

Criterion	Covered	Total	%
statement	12	16	75.0
branch			n/a
condition			n/a
subroutine	4	6	66.6
pod	0	1	0.0
total	16	23	69.5

package Catmandu::Store::Resolver::Bag;

use Moo;
use JSON;

use Catmandu::Sane;
use Catmandu::Store::Resolver::API;

with 'Catmandu::Bag';

has api => (is => 'lazy');

has pid => (is => 'rw');

sub _build_api {
    my $self = shift;
    my $api = Catmandu::Store::Resolver::API->new(
        url => $self->store->url,
        username => $self->store->username,
        password => $self->store->password
    );
    return $api;
}

around add => sub {
    my ($orig, $self, $data) = @_;
    $self->$orig($data);
    $data->{'_id'} = $self->pid;
    return $data;
};

around update => sub {
    my ($orig, $self, $data) = @_;
    $self->$orig($data);
    $data->{'_id'} = $self->pid;
    return $data;
};

sub generator {
    my $self = shift;
}

sub get {
    my ($self, $id) = @_;
    return $self->api->get($id);
}

sub add {
    my ($self, $data) = @_;
    my $response = $self->api->post($data);
    if (defined($response->{'data'}->{'work_pid'})) {
        $self->pid($response->{'data'}->{'work_pid'});
    } else {
        $self->pid($response->{'data'}->{'persistentURIs'}->[0]);
    }
}

sub update {
    my ($self, $id, $data) = @_;
    my $response = $self->api->put($id, $data);
    if (defined($response->{'data'}->{'work_pid'})) {
        $self->pid($response->{'data'}->{'work_pid'});
    } else {
        $self->pid($response->{'data'}->{'persistentURIs'}->[0]);
    }
}

sub delete {
    my ($self, $id) = @_;
    return $self->api->delete($id);
}

sub delete_all {
    my $self = shift;
}

1;