File Coverage

blib/lib/Footprintless/Plugin/Atlassian/Confluence/RequestBuilder.pm

Criterion	Covered	Total	%
statement	33	43	76.7
branch	8	12	66.6
condition			n/a
subroutine	9	13	69.2
pod	6	6	100.0
total	56	74	75.6

use strict;
use warnings;

package Footprintless::Plugin::Atlassian::Confluence::RequestBuilder;
$Footprintless::Plugin::Atlassian::Confluence::RequestBuilder::VERSION = '1.02';
# ABSTRACT: A request builder for the Atlassian Confluence REST API
# PODNAME: Footprintless::Plugin::Atlassian::Confluence::RequestBuilder

use HTTP::Request;
use JSON;
use Log::Any;

my $logger = Log::Any->get_logger();

sub new {
    return bless( {}, shift )->_init(@_);
}

sub create_content {
    my ( $self, $content, %options ) = @_;

    return HTTP::Request->new(
        'POST',
        $self->_url( "/rest/api/content", %options ),
        [ 'Content-Type' => 'application/json' ],
        encode_json($content)
    );
}

sub delete_content {
    my ( $self, $id ) = @_;

    return HTTP::Request->new( 'DELETE', $self->_url("/rest/api/content/$id") );
}

sub get_content {
    my ( $self, %options ) = @_;

    my $id = delete( $options{id} );
    return HTTP::Request->new( 'GET',
          $id
        ? $self->_url( "/rest/api/content/$id", %options )
        : $self->_url( "/rest/api/content",     %options ) );
}

sub get_content_children {
    my ( $self, $id, %options ) = @_;

    my $type = delete( $options{type} );
    return HTTP::Request->new( 'GET',
          $type
        ? $self->_url( "/rest/api/content/$id/child/$type", %options )
        : $self->_url( "/rest/api/content/$id/child",       %options ) );
}

sub _init {
    my ( $self, $base_url ) = @_;

    $self->{base_url} = $base_url;

    return $self;
}

sub update_content {
    my ( $self, $id, $content, %options ) = @_;

    return HTTP::Request->new(
        'PUT',
        $self->_url( "/rest/api/content/$id", %options ),
        [ 'Content-Type' => 'application/json' ],
        encode_json($content)
    );
}

sub _url {
    my ( $self, $path, %query_params ) = @_;

    my $url = "$self->{base_url}$path";
    if (%query_params) {
        require URI::Escape;
        my @query_string = ();
        foreach my $key ( sort( keys(%query_params) ) ) {
            push( @query_string, ( @query_string ? '&' : '?' ) );

            push(
                @query_string,
                join(
                    '&',
                    map { URI::Escape::uri_escape($key) . '=' . URI::Escape::uri_escape($_) } (
                        ref( $query_params{$key} ) eq 'ARRAY'
                        ? @{ $query_params{$key} }
                        : ( $query_params{$key} )
                    )
                )
            );
        }
        $url .= ( @query_string ? join( '', @query_string ) : '' );
    }

    return $url;
}

1;

__END__