diff options
| -rw-r--r-- | lib/Net/Riak/Role/REST/Object.pm | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/lib/Net/Riak/Role/REST/Object.pm b/lib/Net/Riak/Role/REST/Object.pm index 545e4e0..1a27d23 100644 --- a/lib/Net/Riak/Role/REST/Object.pm +++ b/lib/Net/Riak/Role/REST/Object.pm @@ -12,7 +12,7 @@ sub store_object { $params->{returnbody} = 'false' if $self->disable_return_body; - + my $request; if ( defined $object->key ) { $request = $self->new_request('PUT', @@ -33,12 +33,12 @@ sub store_object { $request->header('link' => $self->_links_to_header($object)); } - if ( $object->i2indexes) { - - foreach (keys %{$object->i2indexes}) { - $request->header(':x-riak-index-' . lc($_) => $object->i2indexes->{$_}); - } - } + if ( $object->i2indexes) { + + foreach (keys %{$object->i2indexes}) { + $request->header(':x-riak-index-' . lc($_) => $object->i2indexes->{$_}); + } + } if (ref $object->data && $object->content_type eq 'application/json') { $request->content(JSON::encode_json($object->data)); @@ -46,7 +46,7 @@ sub store_object { else { $request->content($object->data); } - + my $response = $self->send_request($request); $self->populate_object($object, $response, [200, 201, 204, 300]); return $object; @@ -83,8 +83,8 @@ sub populate_object { $obj->exists(0); return if (!$http_response); - - + + my $status = $http_response->code; $obj->data($http_response->content) @@ -100,11 +100,11 @@ sub populate_object { . (join(', ', @$expected)) . ", received: ".$http_response->status_line } - + $HTTP::Headers::TRANSLATE_UNDERSCORE = 0; foreach ( $http_response->header_field_names ) { - next unless /^X-Riak-Index-(.+_bin)$/ || /^X-Riak-Index-(.+_int)$/; - $obj->add_index(lc($1), $http_response->header($_) ) + next unless /^X-Riak-Index-(.+_bin)$/ || /^X-Riak-Index-(.+_int)$/; + $obj->add_index(lc($1), $http_response->header($_) ) } $HTTP::Headers::TRANSLATE_UNDERSCORE = 1; @@ -125,13 +125,13 @@ sub populate_object { my %seen; @siblings = grep { !$seen{$_}++ } @siblings; $obj->siblings(\@siblings); } - + if ($status == 201) { my $location = $http_response->header('location'); my ($key) = ($location =~ m!/([^/]+)$!); $obj->key($key); - } - + } + if ($status == 200 || $status == 201) { $obj->content_type($http_response->content_type) @@ -147,12 +147,12 @@ sub retrieve_sibling { my $request = $self->new_request( 'GET', - [$self->prefix, $object->bucket->name, $object->key], + [$self->prefix, $object->bucket->name, $object->key], $params ); my $response = $self->send_request($request); - + my $sibling = Net::Riak::Object->new( client => $self, bucket => $object->bucket, |