File Coverage

lib/WebService/Shippo/Fetch.pm

Criterion	Covered	Total	%
statement	17	55	30.9
branch	0	20	0.0
condition	0	3	0.0
subroutine	6	12	50.0
pod	0	4	0.0
total	23	94	24.4

use strict;
use warnings;
use MRO::Compat 'c3';

package WebService::Shippo::Fetch;
require WebService::Shippo::Request;
use Params::Callbacks ( 'callbacks' );

sub fetch
{
    my ( $callbacks, $invocant, $id, @params ) = &callbacks;
    my $class = $invocant->item_class;
    my $response = Shippo::Request->get( $class->url( $id ), @params );
    return $class->construct_from( $response, $callbacks );
}

sub all
{
    my ( $callbacks, $invocant, @params ) = &callbacks;
    @params = ( {} )
        unless @params;
    my $params = ref( $params[0] ) ? $params[0] : {@params};
    my $class = $invocant->item_class;
    my $response;
    $params->{results} = 200
        unless $params->{results};
    $response = WebService::Shippo::Request->get( $class->url, $params );
    return $class->construct_from( $response, $callbacks );
}

sub iterator
{
    my ( $callbacks, $invocant, @params ) = &callbacks;
    @params = ( {} )
        unless @params;
    my $params = ref( $params[0] ) ? $params[0] : {@params};
    $params->{results} = 200
        unless $params->{results};
    my $collection = $invocant->all( $params );
    my $index      = 0;
    my $iterator   = sub {
        my @results;
        while ( $collection && !@results ) {
            if ( $index == @{ $collection->results } ) {
                $collection = $collection->next_page;
                last unless $collection;
                $index = 0;
            }
            @results = $callbacks->transform( $collection->{results}[ $index++ ] );
        }
        return @results if wantarray;
        return \@results;
    };
    return $iterator;
}

sub collector
{
    my $iterator = &iterator;
    my $collector = sub {
        my @results;
        while ( my @list = $iterator->() ) {
            push @results, @list;
        }
        return @results if wantarray;
        return \@results;
    };
    return $collector;
}

BEGIN {
    no warnings 'once';
    *retrieve          = *fetch;
    *Shippo::Fetcher:: = *WebService::Shippo::Fetcher::;
}

1;