File Coverage

blib/lib/Job/Async/Job.pm

Criterion	Covered	Total	%
statement	26	39	66.6
branch	1	10	10.0
condition	0	6	0.0
subroutine	10	14	71.4
pod	0	7	0.0
total	37	76	48.6

package Job::Async::Job;

use strict;
use warnings;

our $VERSION = '0.004'; # VERSION

=head1 NAME

Job::Async::Job - represents a single job for L

=head1 SYNOPSIS

=head1 DESCRIPTION

=cut

use Sereal;
use JSON::MaybeUTF8 qw(:v1);

use constant SEREAL_DEFAULT => 1;

my $sereal_encode = Sereal::Encoder->new;
my $sereal_decode = Sereal::Decoder->new;

sub id { shift->{id} }

sub data {
    my ($self, $key) = @_;
    return $self->{data} unless defined $key;
    return $self->{data}{$key};
}

sub encode_keypair {
    my ($self, $k, $v) = @_;
    return !ref($v)
        ? ("text_$k" => $v)
        : SEREAL_DEFAULT
        ? ("sereal_$k" => $sereal_encode->encode($v))
        : ("json_$k" => encode_json_utf8($v))
}

sub flattened_data {
    my ($self, $data) = @_;
    $data //= $self->{data};
    return { map { $self->encode_keypair($_ => $data->{$_}) } keys %$data };
}

sub structured_data {
    my ($self, $data) = @_;
    $data //= $self->{data};
    return {
        (map {
            die "invalid format for $_" unless my ($type, $k) = /^(json|text|sereal)_(.*)$/;
            $k => (
                $type eq 'text'
                ? $data->{$_}
                : $type eq 'json'
                ? decode_json_utf8($data->{$_})
                : $sereal_decode->decode($data->{$_})
            )
        } grep /^[a-z]/, keys %$data),
        map {; $_ => $data->{$_} } grep /^_/, keys %$data
    };
}

sub future { shift->{future} }

for my $method (qw(then get done fail else catch on_done on_cancel on_fail on_ready is_ready is_done is_failed failure)) {
    no strict 'refs';
    *$method = sub { my $self = shift; $self->future->$method(@_) }
}

sub new {
    my ($class, %args) = @_;
    bless \%args, $class
}


1;