File Coverage

blib/lib/Geoffrey/Changeset.pm

Criterion	Covered	Total	%
statement	46	48	95.8
branch	11	16	68.7
condition	4	9	44.4
subroutine	12	12	100.0
pod	6	6	100.0
total	79	91	86.8

package Geoffrey::Changeset;

use utf8;
use 5.016;
use strict;
use warnings;
use Geoffrey::Utils;

$Geoffrey::Changeset::VERSION = '0.000203';

use parent 'Geoffrey::Role::Core';

sub action {
    my ( $self, $s_action ) = @_;
    return Geoffrey::Utils::action_obj_from_name(
        $s_action,
        dbh       => $self->dbh,
        converter => $self->converter,
        template  => $self->template,
    );
}

sub postfix {
    return $_[0]->{postfix} // q~~ if !defined $_[1];
    $_[0]->{postfix} = $_[1];
    return $_[0]->{postfix};
}

sub prefix {
    return $_[0]->{prefix} // q~~ if !defined $_[1];
    $_[0]->{prefix} = $_[1];
    return $_[0]->{prefix};
}

sub template {
    return $_[0]->{template} // q~~ if !defined $_[1];
    $_[0]->{template} = $_[1];
    return $_[0]->{template};
}

sub handle_entry {
    my ( $self, $hr_entry ) = @_;
    return unless $hr_entry;
    unless ( $hr_entry->{action} ) {
        require Geoffrey::Exception::General;
        Geoffrey::Exception::General::throw_no_params( 'handle_entry', 'action', $hr_entry );
    }
    my ( $s_sub, $s_action ) = Geoffrey::Utils::parse_package_sub( delete $hr_entry->{action} );
    my $o_action = $self->action($s_action);
    if ( !$s_sub || !$o_action->can($s_sub) ) {
        require Geoffrey::Exception::RequiredValue;
        Geoffrey::Exception::RequiredValue::throw_action_sub($s_action);
    }
    $o_action->dryrun(1) if delete $hr_entry->{dryrun};
    my $result = $o_action->$s_sub($hr_entry);
    $o_action->dryrun(0);
    return $result;

}

sub handle_entries {
    my ( $self, $ar_entries ) = @_;
    return unless $ar_entries;
    $self->handle_entry($_) for ( @{$ar_entries} );
    return scalar @{$ar_entries};
}

1;    # End of Geoffrey::Changeset

__END__