use strict;
use warnings;

use Test::More;
use JSON::XS;
use Test::Exception;
use AnyEvent::Riak;
use YAML::Syck;

#plan tests => 15;

my ( $host, $path );

BEGIN {
    my $riak_test = $ENV{RIAK_TEST_SERVER};
    ($host, $path) = split ";", $riak_test if $riak_test;
    plan skip_all => 'set $ENV{RIAK_TEST_SERVER} if you want to run the tests'
      unless ($host && $path);
}



my $bucket = 'test';

ok my $riak = AnyEvent::Riak->new(
    host => $host,
    path => $path,
    w    => 1,
    dw   => 1
  ),
  'create riak object';

my $cv = AnyEvent->condvar;
$cv->begin(sub { $cv->send });
$cv->begin;

# ping
$riak->is_alive(
    callback => sub {
        my $res = shift;
        pass "is alive in cb" if $res;
    }
);

# list bucket
$riak->list_bucket(
    'bar',
    parameters => {props => 'true', keys => 'true'},
    callback   => sub {
        my $res = shift;
        ok $res->{props}, 'got props';
        is scalar @{$res->{keys}}, 0, '0 keys in cb';
    }
);

my $value = {foo => 'bar',};

# store object
$riak->store(
    'foo', 'bar3', $value,
    callback => sub {
        pass "store value ok";
        $riak->fetch(
            'foo', 'bar3',
            callback => sub {
                my $body = shift;
                is_deeply($body, $value, 'value is ok in cb');
                $cv->end;
            }
        );
    }
);

$cv->end;
$cv->recv;

done_testing();