#!perl

use strict;
use warnings;

use FindBin;
use WWW::GoDaddy::REST;
use LWP::UserAgent;
use Test::Exception;
use Test::MockObject::Extends;
use Test::More;
use WWW::GoDaddy::REST::Util qw(is_json json_decode json_encode );

my $URL_BASE    = 'http://example.com/v1';
my $SCHEMA_FILE = "$FindBin::Bin/schema.json";

my $lwp_mock = Test::MockObject::Extends->new( LWP::UserAgent->new );
$lwp_mock->mock(
    'simple_request' => sub {
        my ( $self, $request ) = @_;

        my $url = $request->uri->as_string;

        my $content_json = $request->decoded_content;
        my $content_perl = is_json($content_json) ? json_decode($content_json) : undef;

        my $echoResponse = {
            'id'                     => 'echo',
            'type'                   => 'echoResponse',
            'request_method'         => $request->method,
            'request_uri'            => $url,
            'request_content'        => $content_json,
            'request_content_struct' => $content_perl,
            'links'                  => {
                'self'    => $url,
                'schemas' => "http://example.com/v1/schemas"
            },
            'actions' => { 'reverb' => "$url?reverb", 'echoCount' => "$url?echoCount" },
        };

        my $content;

        if ( $request->method eq 'DELETE' ) {
            return HTTP::Response->new(204);
        }
        elsif ( $request->uri->path =~ m|^/v1/respondNonResource| ) {
            $content = $content_json;
        }
        elsif ( $request->uri->path =~ m|^/v1/echoResponses/*$| ) {

            # collection
            $content = {
                "type"         => "collection",
                "resourceType" => "echoResponse",
                "links"        => {
                    "self"    => $url,
                    "schemas" => "http://example.com/v1/schemas"
                },
                "data" => []
            };
            for ( 0 .. 3 ) {
                my %copy = %{$echoResponse};
                $copy{id}                = "echo$_";
                $copy{links}->{self}     = "http://example.com/v1/echoResponses/echo$_";
                $copy{actions}->{reverb} = "http://example.com/v1/echoResponses/echo$_?reverb";
                push @{ $content->{data} }, \%copy;
            }
            $content = json_encode($content);
        }
        else {
            if ( $url =~ m|^http://example.com/v1/echoResponses/(.*)$| ) {
                $echoResponse->{id} = $1;
            }
            $content = json_encode($echoResponse);
        }

        my $response = HTTP::Response->new(200);
        $response->content($content);
        return $response;
    }
);

my $client = WWW::GoDaddy::REST->new(
    {   url          => $URL_BASE,
        user_agent   => $lwp_mock,
        schemas_file => $SCHEMA_FILE,
    }
);

subtest 'query_by_id' => sub {
    my $response = $client->query_by_id( 'echoResponse', '1234' );
    is( $response->f('request_method'), "GET", "requested method is good" );
    is( $response->f('request_uri'), "$URL_BASE/echoResponses/1234", "requested URI is good" );
    is( $response->f('request_content'), '', "requested content is empty" );
};

subtest 'query' => sub {
    my $col = $client->query( 'echoResponse', { 'name' => 'foo' } );
    is( $col->type, 'collection', "scalar context gives back a collection" );
    my ($item) = $col->items();
    is( $item->type,                'echoResponse', 'correct item type returned' );
    is( $item->f('request_method'), "GET",          "requested method is good" );
    is( $item->f('request_uri'), "$URL_BASE/echoResponses?name=foo", "requested URI is good" );
    is( $item->f('request_content'), '', "requested content is empty" );

    my @items = $client->query( 'echoResponse', { 'name' => 'bar' } );
    ($item) = @items;
    is( $item->type,                'echoResponse', 'correct item type returned' );
    is( $item->f('request_method'), "GET",          "requested method is good" );
    is( $item->f('request_uri'), "$URL_BASE/echoResponses?name=bar", "requested URI is good" );
    is( $item->f('request_content'), '', "requested content is empty" );
};

subtest 'non resource responding' => sub {

    # test the case where we don't return a resource
    my $response;

    $response = $client->create( 'respondNonResource', "asdf" );
    is( $response->data, "asdf", "simple string response is ok" );

    $response = $client->create( 'respondNonResource', "3" );
    is( $response->data, "3", "simple number response is ok" );

    $response = $client->create( 'respondNonResource', 'asdf asdf' );
    is( $response->data, "asdf asdf", "simple string response is ok" );

};

subtest 'save' => sub {
    my $response = $client->query_by_id( 'echoResponse', '1234' );
    $response->f( 'new_field', 'new_value' );

    my $result    = $response->save();
    my $submitted = $result->f('request_content_struct');

    is( $result->f('request_method'), 'PUT', 'http method is PUT' );
    is( $result->f('request_uri'),
        'http://example.com/v1/echoResponses/1234',
        'PUT url is correct'
    );
    is( $submitted->{new_field}, 'new_value', 'test submit field was submitted and matched' );
};

subtest 'delete' => sub {
    my $response = $client->query_by_id( 'echoResponse', '1234' );
    $response->f( 'new_field', 'new_value' );

    my $result = $response->delete();
    is_deeply( $result->fields, {}, 'fields are empty' );
    ok( $result->http_response->is_success, 'DELETE was ok' );
    is( $result->http_response->code, 204, 'DELETE came back with expected response code' );
};

subtest 'follow_link' => sub {
    my $response = $client->query_by_id( 'echoResponse', '1234' );
    my $fetched = $response->follow_link('schemas');

    is( $fetched->f('request_method'), 'GET', 'link HTTP method ok' );
    is( $fetched->f('request_uri'), 'http://example.com/v1/schemas', 'link url ok' );

    dies_ok { $response->follow_link('asfasfsafasf') } 'bad fetch url should die';
};

subtest 'do_action' => sub {
    my $response = $client->query_by_id( 'echoResponse', '1234' );
    my $done1 = $response->do_action('reverb');
    is( $done1->f('request_method'), 'POST', 'action http method is POST' );
    is( $done1->f('request_uri'),
        'http://example.com/v1/echoResponses/1234?reverb',
        'action url is correct'
    );
    is( $done1->f('request_content'), '', 'action request content is empty' );

    my $done2 = $response->do_action( 'reverb', { 'amount' => 'alot' } );
    is( $done2->f('request_method'), 'POST', 'action http method is POST' );
    is( $done2->f('request_uri'),
        'http://example.com/v1/echoResponses/1234?reverb',
        'action url is correct'
    );
    isnt( $done2->f('request_content'), '', 'action request content is present' );
    is_deeply(
        $done2->f('request_content_struct'),
        { 'amount' => 'alot' },
        'action request content is correct'
    );

    my $done3 = $response->do_action( 'echoCount', "3" );
    is( $done3->f('request_method'), 'POST', 'action http method is POST' );
    is( $done3->f('request_uri'),
        'http://example.com/v1/echoResponses/1234?echoCount',
        'action url is correct'
    );
    is( $done3->f('request_content'),        '"3"', 'action request content is present' );
    is( $done3->f('request_content_struct'), '3',   'perl data struct is correct' );
};

done_testing();