Skip to content

Commit

Permalink
Use /rating/by_distributions API endpoint
Browse files Browse the repository at this point in the history
Replace query sending with using new API endpoint.
  • Loading branch information
mickeyn committed Jul 4, 2017
1 parent b2f653c commit d33002f
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 36 deletions.
36 changes: 2 additions & 34 deletions lib/MetaCPAN/Web/Model/API/Rating.pm
Expand Up @@ -36,40 +36,8 @@ sub get {
return Future->done( {} );
}

return $self->request(
'/rating/_search',
{
size => 0,
query => {
terms => { distribution => \@distributions }
},
aggregations => {
ratings => {
terms => {
field => 'distribution'
},
aggregations => {
ratings_dist => {
stats => {
field => 'rating'
}
}
}
}
}
}
)->transform(
done => sub {
my $data = shift;
return {
took => $data->{took},
ratings => {
map { $_->{key} => $_->{ratings_dist} }
@{ $data->{aggregations}->{ratings}->{buckets} }
}
};
}
);
return $self->request( '/rating/by_distributions',
{ distribution => \@distributions } );
}

__PACKAGE__->meta->make_immutable;
Expand Down
4 changes: 2 additions & 2 deletions lib/MetaCPAN/Web/Role/ReleaseInfo.pm
Expand Up @@ -66,8 +66,8 @@ sub stash_api_results {
my %to_stash = (
author => $reqs->{author},
distribution => $reqs->{distribution},
rating => $reqs->{rating}->{ratings}->{ $data->{distribution} },
versions => $reqs->{versions}{releases},
rating => $reqs->{rating}{distributions}{ $data->{distribution} },
versions => $reqs->{versions}{releases},
);

my %stash
Expand Down

0 comments on commit d33002f

Please sign in to comment.