path: root/t/11_get_keys.t

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";
};