File Coverage

blib/lib/Catmandu/Store/Datahub/OAuth.pm

Criterion	Covered	Total	%
statement	12	26	46.1
branch	0	2	0.0
condition			n/a
subroutine	4	7	57.1
pod	0	2	0.0
total	16	37	43.2

package Catmandu::Store::Datahub::OAuth;

use LWP::UserAgent;
use JSON;
use Moo;

use Catmandu::Sane;

has url => (is => 'ro', required => 1);

has username => (is => 'ro', required => 1);
has password => (is => 'ro', required => 1);

has client_id     => (is => 'ro', required => 1);
has client_secret => (is => 'ro', required => 1);

has ua => (is => 'lazy');


sub _build_ua {
    my $self = shift;
    return LWP::UserAgent->new();
}

sub token {
    my $self = shift;
    # Replace this with something better as soon as we figure out how we can get rid of the password
    return $self->get_token_u_p();
}

sub get_token_u_p {
    my ($self) = @_;
    my $auth_url = '%s/oauth/v2/token?grant_type=password&username=%s&password=%s&client_id=%s&client_secret=%s';
    my $req_url = sprintf($auth_url, $self->url, $self->username, $self->password, $self->client_id, $self->client_secret);
    my $response = $self->ua->get($req_url);
    if ($response->is_success) {
        my $token_raw = $response->decoded_content;
        my $token_parsed = decode_json($token_raw);
        return $token_parsed->{'access_token'};
    } else {
        Catmandu::HTTPError->throw({
                code             => $response->code,
                message          => $response->status_line,
                url              => $response->request->uri,
                method           => $response->request->method,
                request_headers  => [],
                request_body     => $response->request->decoded_content,
                response_headers => [],
                response_body    => $response->decoded_content,
            });
        return undef;
    }
}



1;