use strict;
use warnings;
use Test::More;
use Net::Riak;
use YAML::Syck;

my $host = 'http://localhost:8098';
my $bucket_name = 'test4';
my $bucket_multi = 'multiBucket1';

# is alive
{
    ok my $client = Net::Riak->new(), 'client created';
    ok $client->is_alive, 'riak is alive';
}

# store and get
{
    ok my $client = Net::Riak->new(), 'client created';
    ok my $bucket = $client->bucket($bucket_name), 'got bucket test';
    my $content = [int(rand(100))];
    ok my $obj = $bucket->new_object('foo', $content),
      'created a new riak object';
    ok $obj->store,       'store object foo';
    is $obj->status,      200, 'valid status';
    is $obj->key,         'foo', 'valid key';
    is_deeply $obj->data, $content, 'valid content';
}

# missing object
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj    = $bucket->get("missing");
    ok !$obj->data, 'no data';
}

# delete object
{
    my $client  = Net::Riak->new();
    my $bucket  = $client->bucket($bucket_name);
    my $content = [int(rand(100))];
    my $obj     = $bucket->new_object('foo', $content);
    ok $obj->store, 'object is stored';
    $obj = $bucket->get('foo');
    ok $obj->exists, 'object exists';
    $obj->delete;
    $obj->load;
    ok !$obj->exists;
}

# test set bucket properties
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    $bucket->allow_multiples('True');
    my $res = $bucket->allow_multiples;
    $bucket->n_val(3);
    is $bucket->n_val, 3, 'n_val is set to 3';
    $bucket->set_properties({allow_mult => "False", "n_val" => 2});
    ok !$bucket->allow_multiples;
    is $bucket->n_val, 2, 'n_val is set to 2';
}

# test siblings
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_multi);
    $bucket->allow_multiples(1);
    ok $bucket->allow_multiples, 'multiples set to 1';
    my $obj = $bucket->get('foo');
    $obj->delete;
    for(1..5) {
        my $client = Net::Riak->new();
        my $bucket = $client->bucket($bucket_multi);
        my $rand = int(rand(100));
        $obj = $bucket->new_object('foo', [$rand]);
        $obj->store;
    }
    # my $siblings_count = $obj->get_siblings;
    # is $siblings_count, 5, 'got 5 siblings';
    # my $obj3 = $obj->sibling(3);
    # XXX FIXME
    # $obj3 = $obj3->sibling(3);
    # $obj3->store;
    # $obj->reload;
    # is_deeply $obj3->data, $obj->data;
    # $obj->delete;
}

# test js source map
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj = $bucket->new_object('foo', [2]);
    $obj->store;
    my $map_reduce = $client->add($bucket_name, 'foo');
    $map_reduce->map("function (v) {return [JSON.parse(v.values[0].data)];}");
    my $result = $map_reduce->run();
    is_deeply $result, [[2]], 'got valid result';
}

# javascript named map
{
    my $client     = Net::Riak->new();
    my $bucket     = $client->bucket($bucket_name);
    my $obj        = $bucket->new_object('foo', [2]);
    my $map_reduce = $client->add("bucket", "foo");
    $map_reduce->map("Riak.mapValuesJson");
    my $result = $map_reduce->run;
    use YAML::Syck;
    warn Dump $result;
}

# javascript source map reduce
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj = $bucket->new_object('foo', [2]);
    $obj->store;
    $obj = $bucket->new_object('bar', [3]);
    $obj->store;
    $bucket->new_object('baz', [4]);
    $obj->store;
    my $map_reduce = $client->add($bucket_name, "foo");
    $map_reduce->add($bucket_name, "bar");
    $map_reduce->add($bucket_name, "baz");
    $map_reduce->map("function (v) { return [1]; }");
    $map_reduce->reduce("function (v) { return [v.length]; }");
    my $result = $map_reduce->run;
    is $result->[0], 3, "success map reduce";
}

# javascript named map reduce
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj = $bucket->new_object("foo", [2]);
    $obj->store;
    $obj = $bucket->new_object("bar", [3]);
    $obj->store;
    $obj = $bucket->new_object("baz", [4]);
    $obj->store;
    my $map_reduce = $client->add($bucket_name, "foo");
    $map_reduce->add($bucket_name, "bar");
    $map_reduce->add($bucket_name, "baz");
    $map_reduce->map("Riak.mapValuesJson");
    $map_reduce->reduce("Riak.reduceSum");
    my $result = $map_reduce->run();
#    is $result->[0], 243; # ????
}

# javascript bucket map reduce
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj = $bucket->new_object("foo", [2]);
    $obj->store;
    $obj = $bucket->new_object("bar", [3]);
    $obj->store;
    $obj = $bucket->new_object("baz", [4]);
    $obj->store;
    my $map_reduce = $client->add($bucket->name);
    $map_reduce->map("Riak.mapValuesJson");
    $map_reduce->reduce("Riak.reduceSum");
    my $result = $map_reduce->run;
    ok 1, "ici";
#    is $result->[0], 243;
}

# javascript map reduce from object
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj = $bucket->new_object("foo", [2]);
    $obj->store;
    $obj = $bucket->get("foo");
    my $map_reduce = $obj->map("Riak.mapValuesJson");
    my $result = $map_reduce->run();
    is_deeply $result->[0], [2];
}

# store and get links
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj = $bucket->new_object("foo", [2]);
    my $obj1 = $bucket->new_object("foo1", {test => 1});
    $obj1->store;
    my $obj2 = $bucket->new_object("foo2", {test => 2});
    $obj2->store;
    my $obj3 = $bucket->new_object("foo3", {test => 3});
    $obj3->store;
    $obj->add_link($obj1);
    $obj->add_link($obj2, "tag");
    $obj->add_link($obj3, "tag2!@&");
    $obj->store;
    $obj = $bucket->get("foo");
    my $mr = $obj->link("bucket");
    my $results = $mr->run();
    # XXX fixme !!
    use YAML::Syck; warn Dump $results;
}

# link walking
{
    my $client = Net::Riak->new();
    my $bucket = $client->bucket($bucket_name);
    my $obj = $bucket->new_object("foo", [2]);
    my $obj1 = $bucket->new_object("foo1", {test => 1});
    $obj1->store;
    my $obj2 = $bucket->new_object("foo2", {test => 2});
    $obj2->store;
    my $obj3 = $bucket->new_object("foo3", {test => 3});
    $obj3->store;
    $obj->add_link($obj1);
    $obj->add_link($obj2, "tag");
    $obj->add_link($obj3, "tag2!@&");
    $obj->store;
    $obj = $bucket->get("foo");
    my $mr = $obj->link("bucket");
    my $results = $mr->run();
    use YAML::Syck; warn Dump $results;
}

done_testing;