File Coverage

blib/lib/Catmandu/Importer/MODS.pm

Criterion	Covered	Total	%
statement	4	6	66.6
branch			n/a
condition			n/a
subroutine	2	2	100.0
pod			n/a
total	6	8	75.0

package Catmandu::Importer::MODS;

our $VERSION = "0.31";

use Catmandu::Sane;
use MODS::Record;
use Moo;

with 'Catmandu::Importer';

has type => (
    is => 'ro',
    isa => sub {
        die "type must be 'xml' or 'json'" unless grep { $_[0] eq $_ } qw(xml json);
    },
    lazy => 1,
    builder => sub {
        ($_[0]->file and $_[0]->file =~ /\.json$/) ? 'json' : 'xml';
    }
);

sub generator {
    my ($self) = @_;
    sub {
        state $i = 0;
        #result: MODS::Record::Mods or MODS::Record::ModsCollection
        state $mods = do {
            #starting from version 0.11 of MODS::Record utf8 is enabled by issuing JSON->new->utf8(1)
            if($MODS::Record::VERSION >= 0.11){
                if($self->type eq "json"){
                    $self->fh->binmode(":raw");
                }
            }
            #before version 0.11 of MODS::Record, decoding needed to be done yourself
            else{
                if($self->type eq "json"){
                    $self->fh->binmode(':utf8');
                }
            }
            my $m = $self->type eq "xml" ? MODS::Record->from_xml($self->fh) : MODS::Record->from_json($self->fh);
            my $res = ref($m) eq "MODS::Element::Mods" ? [$m] : $m->mods;
            $res;
        };
        return $i < scalar(@$mods) ? $mods->[$i++] : undef;
    };
}

1;
__END__