File Coverage

blib/lib/Apertur/SDK/Resource/Polling.pm

Criterion	Covered	Total	%
statement	11	36	30.5
branch	0	6	0.0
condition	0	15	0.0
subroutine	4	8	50.0
pod	4	5	80.0
total	19	70	27.1

package Apertur::SDK::Resource::Polling;

use strict;
use warnings;

use Time::HiRes qw(sleep time);

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

sub list {
    my ($self, $uuid) = @_;
    return $self->{http}->request('GET', "/api/v1/upload-sessions/$uuid/poll");
}

sub download {
    my ($self, $uuid, $image_id) = @_;
    return $self->{http}->request_raw(
        'GET', "/api/v1/upload-sessions/$uuid/images/$image_id",
    );
}

sub ack {
    my ($self, $uuid, $image_id) = @_;
    return $self->{http}->request(
        'POST', "/api/v1/upload-sessions/$uuid/images/$image_id/ack",
    );
}

sub poll_and_process {
    my ($self, $uuid, $handler, %options) = @_;

    my $interval = $options{interval} || 3;
    my $timeout  = $options{timeout}  || 0;
    my $start    = time();

    while (1) {
        if ($timeout > 0 && (time() - $start) >= $timeout) {
            last;
        }

        my $result = $self->list($uuid);
        my $images = $result->{images} || [];

        for my $image (@$images) {
            if ($timeout > 0 && (time() - $start) >= $timeout) {
                return;
            }
            my $data = $self->download($uuid, $image->{id});
            $handler->($image, $data);
            $self->ack($uuid, $image->{id});
        }

        if ($timeout > 0 && (time() - $start) >= $timeout) {
            last;
        }

        sleep($interval);
    }

    return;
}

1;

__END__