Merge pull request #1312 from metacpan/haarg/speed-up-contribs

contributors: fetch all contrib pauseids in one query

Author: haarg

lib/MetaCPAN/Query/Release.pm

@@ -153,6 +153,7 @@ sub get_contributors {
         $dupe ? () : $info;
     } ( @$authors, @$contribs );
 
+    my %want_email;
     for my $contrib (@contribs) {
 
         # heuristic to autofill pause accounts
@@ -165,20 +166,27 @@ sub get_contributors {
 
         }
 
-        # check if contributor's email points to a registered author
-        if ( !$contrib->{pauseid} ) {
-            for my $email ( @{ $contrib->{email} } ) {
-                my $check_author = $self->es->search(
-                    es_doc_path('author'),
-                    body => {
-                        query => { term => { email => $email } },
-                        size  => 10,
-                    }
-                );
+        push @{ $want_email{$_} }, $contrib for @{ $contrib->{email} };
+    }
+
+    if (%want_email) {
+        my $check_author = $self->es->search(
+            es_doc_path('author'),
+            body => {
+                query => { terms => { email => [ sort keys %want_email ] } },
+                _source => [ 'email', 'pauseid' ],
+                size    => 100,
+            },
+        );
 
-                if ( hit_total($check_author) ) {
-                    $contrib->{pauseid}
-                        = uc $check_author->{hits}{hits}[0]{_source}{pauseid};
+        for my $author ( @{ $check_author->{hits}{hits} } ) {
+            my $emails = $author->{_source}{email};
+            $emails = [$emails]
+                if !ref $emails;
+            my $pauseid = uc $author->{_source}{pauseid};
+            for my $email (@$emails) {
+                for my $contrib ( @{ $want_email{$email} } ) {
+                    $contrib->{pauseid} = $pauseid;
                 }
             }
         }