File Coverage

blib/lib/WWW/Gitea/Role/HTTP.pm

Criterion	Covered	Total	%
statement	55	71	77.4
branch	13	26	50.0
condition	7	23	30.4
subroutine	11	13	84.6
pod	2	2	100.0
total	88	135	65.1

package WWW::Gitea::Role::HTTP;

# ABSTRACT: HTTP + token/basic auth role for the Gitea REST API

use Moo::Role;
use Carp qw(croak);
use JSON::MaybeXS qw(decode_json encode_json);
use HTTP::Request;
use HTTP::Request::Common ();
use LWP::UserAgent;
use MIME::Base64 qw(encode_base64);
use URI;
use Log::Any qw($log);


requires 'api_url';
requires 'token';
requires 'username';
requires 'password';

has ua => (
    is      => 'lazy',
    builder => sub {
        LWP::UserAgent->new(
            agent   => 'WWW-Gitea/' . ($WWW::Gitea::VERSION // 'dev'),
            timeout => 30,
        );
    },
);


sub _apply_auth {
    my ($self, $req) = @_;
    if (defined $self->token && length $self->token) {
        $req->header(Authorization => 'token ' . $self->token);
    }
    elsif (defined $self->username && defined $self->password) {
        $req->header(Authorization => 'Basic '
            . encode_base64($self->username . ':' . $self->password, ''));
    }
    return;
}

sub request {
    my ($self, $method, $path, %args) = @_;

    my $uri = URI->new($self->api_url . $path);
    $uri->query_form($args{query}) if $args{query};

    my $req;
    if (my $up = $args{upload}) {
        my $field = $up->{field} || 'attachment';
        my $value = defined $up->{file}
            ? [ $up->{file}, $up->{filename} ]
            : [ undef, $up->{filename}, Content => ($up->{content} // '') ];
        $req = HTTP::Request::Common::POST(
            "$uri",
            Content_Type => 'form-data',
            Content      => [ $field => $value ],
        );
        $req->method($method);
    }
    else {
        $req = HTTP::Request->new($method => $uri);
    }
    $self->_apply_auth($req);
    $req->header(Accept => 'application/json');
    for my $k (keys %{ $args{headers} || {} }) {
        $req->header($k => $args{headers}{$k});
    }

    if (defined $args{body}) {
        my $ct = $args{content_type} || 'application/json';
        $req->header('Content-Type' => $ct);
        $req->content(ref $args{body} ? encode_json($args{body}) : $args{body});
    }

    $log->debugf('Gitea %s %s', $method, $uri);
    my $res = $self->ua->request($req);

    my $body = $res->decoded_content;
    my $data;
    if (defined $body && length $body && $body =~ /\A\s*[\{\[]/) {
        $data = decode_json($body);
    }

    unless ($res->is_success) {
        my $msg = ref $data eq 'HASH'
            ? ($data->{message} || $data->{error} || $res->status_line)
            : $res->status_line;
        $log->errorf('Gitea API error: %s', $msg);
        croak "Gitea API error ($method $path): $msg";
    }

    # 204 No Content (deletes etc.) — no body to decode
    return defined $data ? $data : 1;
}


sub request_status {
    my ($self, $method, $path, %args) = @_;
    my $uri = URI->new($self->api_url . $path);
    $uri->query_form($args{query}) if $args{query};
    my $req = HTTP::Request->new($method => $uri);
    $self->_apply_auth($req);
    $req->header(Accept => 'application/json');
    $log->debugf('Gitea %s %s (status only)', $method, $uri);
    return $self->ua->request($req)->code;
}



1;

__END__