File Coverage

blib/lib/GrowthForecast/Aggregator/DB.pm

Criterion	Covered	Total	%
statement	21	36	58.3
branch			n/a
condition	0	8	0.0
subroutine	7	8	87.5
pod	0	1	0.0
total	28	53	52.8

package GrowthForecast::Aggregator::DB;
use strict;
use warnings;
use utf8;
use Encode qw(encode_utf8);
use HTTP::Request::Common;

use Mouse;

has name => (
    is => 'ro',
    isa => 'Str',
    required => 1,
);

has description => (
    is => 'ro',
    isa => 'Str',
    required => 1,
);

has section => (
    is => 'ro',
    isa => 'Str',
    required => 1,
);

has query => (
    is => 'rw',
    isa => 'Str',
    required => 1,
);

has binds => (
    is => 'rw',
    isa => 'ArrayRef',
    default => sub { +[ ] },
);

no Mouse;

sub run {
    my $self = shift;
    my %args = @_;

    my $dbh      = $args{dbh}      // die "Missing mandatory parameter: dbh";
    my $service  = $args{service}  // die "Missing mandatory parameter: service";
    my $endpoint = $args{endpoint} // die "Missing mandatory parameter: endpoint";
    my $ua       = $args{ua}       // die "Missing mandatory parameter: ua";

    $endpoint =~ s!/$!!;

    my $url = "$endpoint/$service/$self->{section}/$self->{name}";

    my $sth = $dbh->prepare($self->query);
    $sth->execute(@{$self->binds});
    my ($number) = $sth->fetchrow_array();
    my $req = POST $url, [
        number => $number,
        description => encode_utf8($self->description),
    ];
    my $res = $ua->request($req);
    return $res;
}

1;
__END__