File Coverage

lib/Ubic/Service/Utils.pm

Criterion	Covered	Total	%
statement	34	39	87.1
branch	2	6	33.3
condition	2	4	50.0
subroutine	7	7	100.0
pod	1	1	100.0
total	46	57	80.7

package Ubic::Service::Utils;
$Ubic::Service::Utils::VERSION = '1.59';
use strict;
use warnings;

# ABSTRACT: helpers for custom service authors


use Params::Validate qw(:all);
use Time::HiRes qw(sleep);
use Ubic::Result qw(result);

use parent qw(Exporter);
our @EXPORT_OK = qw(wait_for_status);

sub wait_for_status {
    my $params = validate(@_, {
        service => { isa => 'Ubic::Service' },
        trials => { type => SCALAR | UNDEF, optional => 1 },
        step => { type => SCALAR | UNDEF, optional => 1 },
        expect_status => { type => SCALAR | ARRAYREF },
    });
    my $trials = $params->{trials} || 1;
    my $step = $params->{step} || 0.1;
    my $service = $params->{service};
    my $expect_status = $params->{expect_status};
    my @expect_status;
    if (ref $expect_status) {
        @expect_status = @$expect_status;
    }
    else {
        @expect_status = ($expect_status);
    }

    my $time = 0;
    my $status;
    for my $trial (1..$trials) {
        $status = result($service->status);
        my $status_str = $status->status;
        last if grep { $_ eq $status_str } @expect_status;

        if ($trial < $trials) {
            my $sleep = $step * $trial;
            sleep($sleep);
            $time += $sleep;
        }
    }
    return $status;
}


1;

__END__