File Coverage

blib/lib/TableDataRole/Munge/SerializeRef.pm

Criterion	Covered	Total	%
statement	11	47	23.4
branch	0	12	0.0
condition	0	4	0.0
subroutine	4	13	30.7
pod	1	8	12.5
total	16	84	19.0

package TableDataRole::Munge::SerializeRef;

use 5.010001;
use strict;
use warnings;

use Role::Tiny;

our $AUTHORITY = 'cpan:PERLANCAR'; # AUTHORITY
our $DATE = '2024-05-14'; # DATE
our $DIST = 'TableDataRoles-Standard'; # DIST
our $VERSION = '0.025'; # VERSION

with 'TableDataRole::Spec::Basic';

sub new {
    require Module::Load::Util;

    my ($class, %args) = @_;

    my $tabledata = delete $args{tabledata} or die "Please specify 'tabledata' argument";
    my $load = delete($args{load}) // 1;
    my $serializer = delete($args{serializer}) // 'json';
    die "Unknown argument(s): ". join(", ", sort keys %args)
        if keys %args;

    my $td = Module::Load::Util::instantiate_class_with_optional_args(
        {load=>$load, ns_prefix=>"TableData"}, $tabledata);

    if ($serializer eq 'json') {
        require JSON::MaybeXS;
        $serializer = sub {
            JSON::MaybeXS::encode_json($_[0]);
        };
    } elsif (ref($serializer) ne 'CODE') {
        die "Invalid value for serializer '$serializer': please supply a coderef or 'json'";
    }

    bless {
        tabledata => $tabledata,
        td => $td,
        pos => 0,
        serializer => $serializer,
    }, $class;
}

sub get_column_count {
    my $self = shift;
    $self->{td}->get_column_count;
}

sub get_column_names {
    my $self = shift;
    $self->{td}->get_column_names;
}

sub has_next_item {
    my $self = shift;
    $self->{td}->has_next_item;
}

sub get_next_item {
    my $self = shift;
    my $row = $self->{td}->get_next_item;
    for (@$row) {
        if (ref $_) { $_ = $self->{serializer}->($_) }
    }
    $row;
}

sub get_next_row_hashref {
    my $self = shift;
    my $row = $self->get_next_item;
    unless ($self->{_column_names}) {
        $self->{_column_names} = $self->{td}->get_column_names;
    }
    +{ map {($self->{_column_names}->[$_] => $row->[$_])} 0..$#{$row} };
}

sub get_iterator_pos {
    my $self = shift;
    $self->{td}->get_iterator_pos;
}

sub reset_iterator {
    my $self = shift;
    $self->{td}->reset_iterator;
}

1;
# ABSTRACT: Serialize references in columns

__END__