use strict;
use warnings;

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

#plan tests => 6;

my $host = 'http://10.0.0.42:8098';
my $path = 'riak';

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

my $cv = AnyEvent->condvar;

$riak->is_alive(
    callback => sub {
        my $res = shift;
        ok $res, "is alive in cb";
    }
);

$riak->list_bucket(
    'blog_content_temp',
    {keys => 'false'},
    sub {
        my $res = shift;
        ok $res, "got result list_bucket";
    }
);

$riak->set_bucket(
    'blog_content_temp',
    {n_val => 5},
    sub {
        my $res = shift;
        ok $res, "got result in set_bucket"
    }
);

$riak->fetch(
    'blog_content_temp',
    '012853de99ce67c2f0f09c0c2ea28cbe5de8f653137d273803f85a398d1de840',
    sub {
        my $res = shift;
        ok $res, "got result in fetch"
    }
);

$riak->store(
    'blog_content_temp',
    {foo => 1},
    sub {
        my $res = shift;
        ok $res, "got result in store"
    }
);

$cv->recv;

# 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


# }

# # {
# #     my $cv = AnyEvent->condvar;
# #     $cv->begin(sub { $cv->send });
# #     $cv->begin;
# #     # list bucket
# #     $riak->list_bucket(
# #         $bucket,
# #         parameters => {props => 'true', keys => 'true'},
# #         callback   => sub {
# #             my $res = shift;
# #             ok $res->{props}, 'got props';
# #             $cv->end;
# #         }
# #     );
# #     $cv->end;
# #     $cv->recv;
# # }

# # {
# #     my $key   = 'bar';
# #     my $value = {foo => 'bar',};
# #     my $cv    = AnyEvent->condvar;
# #     $cv->begin(sub { $cv->send });
# #     $cv->begin;

# #     # store object
# #     $riak->store(
# #         $bucket, $key, $value,
# #         callback => sub {
# #             pass "store value ok";
# #             $riak->fetch(
# #                 $bucket, $key,
# #                 callback => sub {
# #                     my $body = shift;
# #                     is_deeply($body, $value, 'value is ok in cb');
# #                     $riak->delete(
# #                         $bucket, $key,
# #                         callback => sub {
# #                             my $res = shift;
# #                             is $res, 1, 'key deleted';
# #                             $cv->end;
# #                         }
# #                     );

# #                 }
# #             );
# #         }
# #     );
# #     $cv->end;
# #     $cv->recv;
# # }

done_testing();