use strict;
use warnings;
use utf8;

use FindBin ();
use lib "$FindBin::Bin/lib";

use Test::More;
use TestServer qw(csv_body new_client);

use Cepis;

{
    my $body = csv_body(
        '01001000,Praça da Sé,lado ímpar,,Sé,São Paulo,SP,São Paulo,Sudeste,3550308,1004,11,7107',
        '99999999,,,,,,,,,,,,',
        '20040020,Avenida Rio Branco,,,Centro,Rio de Janeiro,RJ,Rio de Janeiro,'
            . 'Sudeste,3304557,,21,6001',
    );
    my $server = TestServer->new(
        routes => { '/csv?ceps=01001000%2C99999999%2C20040020' => [ 200, $body, {} ] } );
    my $client = new_client($server);

    my $result = $client->lookup_many( [qw(01001000 99999999 20040020)] );
    is( scalar @$result, 3, 'the result is as long as the input' );
    is( $result->[0]->localidade, 'São Paulo', 'the first CEP resolved' );
    is( $result->[1], undef, 'a missing CEP is undef at its position' );
    is( $result->[2]->uf, 'RJ', 'and the third is not shifted up' );
    $server->stop;
}

{
    my $body = csv_body(
        '01001000,Praça da Sé,,,Sé,São Paulo,SP,São Paulo,Sudeste,3550308,1004,11,7107');
    my $server
        = TestServer->new( routes => { '/csv?ceps=01001000' => [ 200, $body, {} ] } );
    my $client = new_client($server);

    my $address = $client->lookup_many( ['01001000'] )->[0];
    is( $address->localidade, 'São Paulo', 'the batch resolved it' );
    is( $address->geo, undef, 'but a batch never carries a coordinate' );
    $server->stop;
}

{
    my $body = csv_body(
        '01001000,"Rua Um, Dois",,,Centro,São Paulo,SP,São Paulo,Sudeste,1,,11,1');
    my $server
        = TestServer->new( routes => { '/csv?ceps=01001000' => [ 200, $body, {} ] } );
    my $client = new_client($server);

    is( $client->lookup_many( ['01001000'] )->[0]->logradouro,
        'Rua Um, Dois', 'a quoted field holding a comma is parsed' );
    $server->stop;
}

{
    my $server = TestServer->new;
    my $client = new_client($server);

    is_deeply( $client->lookup_many( [] ), [], 'an empty list yields an empty list' );
    is( scalar( $server->calls ), 0, 'and makes no request' );
    $server->stop;
}

{
    my @ceps = map { sprintf '%08d', $_ } 1 .. 501;
    my @rows = map {"$_,,,,,X,SP,São Paulo,Sudeste,1,,11,1"} @ceps;

    my $server = TestServer->new(
        handler => sub {
            my ( $path, $seen ) = @_;
            my @slice = $seen == 1 ? @rows[ 0 .. 499 ] : @rows[ 500 .. 500 ];
            return [ 200, csv_body(@slice), {} ];
        }
    );
    my $client = new_client($server);

    my $result = $client->lookup_many( \@ceps );
    is( scalar( $server->calls ), 2,   '501 CEPs are split into two requests' );
    is( scalar @$result,          501, 'and the result is still 501 long' );
    is( $result->[500]->localidade, 'X', 'the last one is present' );
    $server->stop;
}

{
    my $body = csv_body('01001000,,,,,São Paulo,SP,São Paulo,Sudeste,1,,11,1');
    my $server = TestServer->new(
        routes => { '/csv?ceps=01001000%2C20040020' => [ 200, $body, {} ] } );
    my $client = new_client($server);

    my $result = $client->lookup_many( [qw(01001000 20040020)] );
    is( scalar @$result, 2, 'a truncated response is padded, not returned short' );
    is( $result->[1], undef, 'the missing tail is undef' );
    $server->stop;
}

{
    my $body = csv_body(
        '01001000,,,,,X,SP,São Paulo,Sudeste,1,,11,1',
        '01001001,,,,,Y,SP,São Paulo,Sudeste,1,,11,1',
        '01001002,,,,,Z,SP,São Paulo,Sudeste,1,,11,1',
        '01001003,,,,,W,SP,São Paulo,Sudeste,1,,11,1',
    );
    my $server = TestServer->new(
        routes => { '/csv?ceps=01001000%2C01001001' => [ 200, $body, {} ] } );
    my $client = new_client($server);

    my $result = $client->lookup_many( [qw(01001000 01001001)] );
    is( scalar @$result, 2, 'an over-long response is truncated to the input length' );
    $server->stop;
}

{
    my $body = csv_body( '123,,,,,,,,,,,,', '01001000,,,,,X,SP,São Paulo,Sudeste,1,,11,1' );
    my $server = TestServer->new(
        routes => { '/csv?ceps=123%2C01001000' => [ 200, $body, {} ] } );
    my $client = new_client($server);

    my $result = $client->lookup_many( [qw(123 01001000)] );
    is( $result->[0], undef, 'a malformed CEP is undef rather than an exception' );
    is( $result->[1]->localidade, 'X', 'and does not cost the rest of the batch' );
    $server->stop;
}

{
    my $server = TestServer->new(
        routes => { '/csv?ceps=01001000' => [ 200, '<html>captive portal</html>', {} ] } );
    my $client = new_client($server);

    my $ok = eval { $client->lookup_many( ['01001000'] ); 1 };
    ok( !$ok, 'a body that is not the expected CSV throws' );
    isa_ok( $@, 'Cepis::Error::InvalidResponse' );
    $server->stop;
}

{
    my $server = TestServer->new;
    my $client = new_client($server);

    my $ok = eval { $client->lookup_many('01001000'); 1 };
    ok( !$ok, 'lookup_many wants an array reference' );
    $server->stop;
}

done_testing();