package Net::Riak::Role::REST::Search;
{
$Net::Riak::Role::REST::Search::VERSION = '0.1702';
}
use Moose::Role;
use JSON;
#ABSTRACT: Search interface
sub search {
my $self = shift;
my %params = @_;
my $request;
$request =
$self->new_request( 'GET',
[ $self->search_prefix, "select" ], \%params ) unless $params{index};
if ( $params{index} ){
my $index = delete $params{index};
$request =
$self->new_request( 'GET',
[ $self->search_prefix, $index, "select" ], \%params );
}
my $http_response = $self->send_request($request);
return if (!$http_response);
my $status = $http_response->code;
if ($status == 404) {
return;
}
return JSON::decode_json($http_response->content) if $params{wt} =~ /json/i;
$http_response->content;
};
sub setup_indexing {
my ( $self, $bucket ) = @_;
my $request =
$self->new_request( 'GET',
[ $self->prefix, $bucket ] );
my $http_response = $self->send_request($request);
return if (!$http_response);
my $status = $http_response->code;
if ($status == 404) {
return;
}
my $precommits = JSON::decode_json($http_response->content)->{props}->{precommit};
for (@$precommits){
return JSON::decode_json($http_response->content) if $_->{mod} eq "riak_search_kv_hook";
}
push ( @$precommits, { mod => "riak_search_kv_hook" , fun => "precommit" } );
$request = $self->new_request( 'PUT', [ $self->prefix, $bucket ] );
$request->content( JSON::encode_json({ props => { precommit => $precommits } } ) );
$request->header('Content-Type' => "application/json" );
$http_response = $self->send_request($request);
return if (!$http_response);
$status = $http_response->code;
if ($status == 404) {
return;
}
$request =
$self->new_request( 'GET',
[ $self->prefix, $bucket ] );
$http_response = $self->send_request($request);
JSON::decode_json($http_response->content);
}
sub index {
my ($self, $bucket, $index, $first, $last) = @_;
my $request;
my @req = ();
my $org_prefix = $self->prefix;
if (defined $bucket && defined $index && defined $first) {
@req = ('buckets', $bucket, 'index', $index, $first);
push(@req, $last) if (defined $last);
}
$request = $self->new_request('GET', [ @req ]);
my $http_response = $self->send_request($request);
JSON::decode_json($http_response->content)->{keys};
}
1;
__END__
=pod
=head1 NAME
Net::Riak::Role::REST::Search - Search interface
=head1 VERSION
version 0.1702
=head1 AUTHOR
franck cuny <franck@lumberjaph.net>, robin edwards <robin.ge@gmail.com>
=head1 COPYRIGHT AND LICENSE
This software is copyright (c) 2013 by linkfluence.
This is free software; you can redistribute it and/or modify it under
the same terms as the Perl 5 programming language system itself.
=cut