summaryrefslogtreecommitdiff
path: root/lib/Net/Riak
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Net/Riak')
-rw-r--r--lib/Net/Riak/Role/REST/Search.pm18
1 files changed, 9 insertions, 9 deletions
diff --git a/lib/Net/Riak/Role/REST/Search.pm b/lib/Net/Riak/Role/REST/Search.pm
index 6748b20..b83e3d4 100644
--- a/lib/Net/Riak/Role/REST/Search.pm
+++ b/lib/Net/Riak/Role/REST/Search.pm
@@ -18,7 +18,7 @@ sub search {
$self->new_request( 'GET',
[ $self->search_prefix, $index, "select" ], \%params );
}
-
+
my $http_response = $self->send_request($request);
return if (!$http_response);
@@ -34,23 +34,23 @@ sub search {
sub setup_indexing {
my ( $self, $bucket ) = @_;
- my $request =
+ 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 ] );
@@ -58,19 +58,19 @@ sub setup_indexing {
$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 =
+ $request =
$self->new_request( 'GET',
[ $self->prefix, $bucket ] );
$http_response = $self->send_request($request);
JSON::decode_json($http_response->content);
-}
+}
-1; \ No newline at end of file
+1;