t/11_get_keys.t


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

use lib 't/lib';
use Test::More;
use Test::Riak;

test_riak {
    my ($client, $bucket_name) = @_;

    my $bucket  = $client->bucket($bucket_name);

    for (1..4) {
        my $obj = $bucket->new_object("foo$_", [ "foo_test" ]);
        ok $obj->store, 'object is stored';
    }

    my $keys = $bucket->get_keys;

    is_deeply [sort @$keys], [ map { "foo$_" } 1..4 ], "got keys";


    my @keys2;

    $bucket->get_keys( {
            stream => 'true',
            cb     => sub {
                ok 1, "call back called for $_[0]";
                push @keys2, $_[0];
            }
        }
    );

    $bucket->delete_object($_) for @keys2;

    $keys = $bucket->get_keys;

    is scalar @$keys, 0, "deleted keys";
};