initial import

1 files changed, 226 insertions, 0 deletions

diff --git a/t/01_basic.t b/t/01_basic.t
new file mode 100644
index 0000000..f55a263
--- /dev/null
+++ b/t/01_basic.t
@@ -0,0 +1,226 @@
+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;