1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
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 );
}
ok my $riak = AnyEvent::Riak->new( host => $host, path => $path, w => 1,
dw => 1),
'create riak object';
# ping
ok my $ping_one = $riak->is_alive(
callback => sub {
my $res = shift;
pass "is alive in cb" if $res;
}
),
'ping with callback';
ok my $ping_two = $riak->is_alive()->recv, 'ping without callback';
ok my $s = $ping_one->recv, 'response from ping without callback';
is $s, 1, 'valid response from ping';
# list bucket
ok my $bucket_cb = $riak->list_bucket(
'bar',
parameters => { props => 'true', keys => 'true' },
callback => sub {
my $res = shift;
ok $res->{props};
is scalar @{ $res->{keys} }, 0, '0 keys in cb';
}
),
'fetch bucket list';
ok my $buckets = $riak->list_bucket('bar')->recv, "fetch bucket list, twice";
is scalar @{ $buckets->{keys} }, '0', 'no keys';
ok my $res_bucket = $bucket_cb->recv, 'get bucket';
# set bucket
ok my $new_bucket
= $riak->set_bucket( 'foo', { props => { n_val => 2 } } )->recv,
'set a new bucket';
my $value = {
foo => 'bar',
};
ok my $res = $riak->store('foo', 'bar', $value)->recv, 'set a new key';
# ok $res = $riak->fetch( 'foo', 'bar' )->recv, 'fetch our new key';
# is_deeply $res, $value, 'value is ok';
# ok $res = $riak->delete( 'foo', 'bar' )->recv, 'delete our key';
# ok my $store_w_cb = $riak->store(
# 'foo', 'bar3', $value, undef, undef,
# sub {
# pass "store value ok";
# $riak->fetch(
# 'foo', 'bar3', undef,
# sub {
# my $body = shift;
# is_deeply (JSON::decode_json($body), $value, 'value is ok in cb');
# }
# );
# }
# );
# ok my $final_res = $store_w_cb->recv;
# $final_res->recv; # FIXME all cb should be called at this point
# ok $res = $riak->store($value)->recv, '... set a new key';
# my $second_value = {
# bucket => 'foo',
# key => 'baz',
# object => { foo => "bar", baz => 2 },
# links => [ [ 'foo', 'bar', 'tagged' ] ],
# };
# ok $res = $riak->store($second_value)->recv, '... set another new key';
# ok $res = $riak->walk( 'foo', 'baz', [ { bucket => 'foo', } ] )->recv,
# '... walk';
# is $res->{results}->[0]->[0]->{key}, "bar", "... walked to bar";
done_testing();
|
