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
103
|
package Net::Riak::Role::REST::Search;
use Moose::Role;
use JSON;
use Data::Dumper;
#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
);
if ( defined($last) ) { push(@req, $last); }
}
$request = $self->new_request('GET', [ @req ] );
my $http_response = $self->send_request($request);
JSON::decode_json($http_response->content)->{keys};
}
1;
|
