Merge pull request metacpan#1008 from metacpan/mickey/author_script_updates

Author script updates

Author: oalders

lib/MetaCPAN/Script/Author.pm

@@ -15,6 +15,7 @@ use Log::Contextual qw( :log );
 use MetaCPAN::Document::Author ();
 use URI                        ();
 use XML::Simple qw( XMLin );
+use MetaCPAN::Types::TypeTiny qw( Str );
 
 =head1 SYNOPSIS
 
@@ -29,6 +30,11 @@ has author_fh => (
     default => sub { shift->cpan . '/authors/00whois.xml' },
 );
 
+has pauseid => (
+    is  => 'ro',
+    isa => Str,
+);
+
 sub run {
     my $self = shift;
 
@@ -46,9 +52,14 @@ sub index_authors {
     my $self    = shift;
     my $type    = $self->index->type('author');
     my $authors = XMLin( $self->author_fh )->{cpanid};
-    my $count   = keys %$authors;
-    log_debug {"Counting author"};
-    log_info {"Indexing $count authors"};
+    if ( $self->pauseid ) {
+        log_info {"Indexing 1 author"};
+    }
+    else {
+        my $count = keys %$authors;
+        log_debug {"Counting author"};
+        log_info {"Indexing $count authors"};
+    }
 
     log_debug {"Getting last update dates"};
     my $dates
@@ -70,19 +81,25 @@ sub index_authors {
 
     my @author_ids_to_purge;
 
-    while ( my ( $pauseid, $data ) = each %$authors ) {
+    for my $pauseid ( keys %$authors ) {
+        next if ( $self->pauseid and $self->pauseid ne $pauseid );
+        my $data = $authors->{$pauseid};
         my ( $name, $email, $homepage, $asciiname )
             = ( @$data{qw(fullname email homepage asciiname)} );
         $name      = undef if ( ref $name );
         $asciiname = q{} unless defined $asciiname;
         $email     = lc($pauseid) . '@cpan.org'
             unless ( $email && Email::Valid->address($email) );
+        my $is_pause_custodial_account
+            = ( $name && $name =~ /\(PAUSE Custodial Account\)/ );
         log_debug {
             Encode::encode_utf8(
                 sprintf( "Indexing %s: %s <%s>", $pauseid, $name, $email ) );
         };
-        my $conf = $self->author_config( $pauseid, $dates ) || next;
-        my $put  = {
+        my $conf = $self->author_config( $pauseid, $dates );
+        next unless ( $conf or $is_pause_custodial_account );
+        $conf ||= {};
+        my $put = {
             pauseid   => $pauseid,
             name      => $name,
             asciiname => ref $asciiname ? undef : $asciiname,
@@ -101,8 +118,7 @@ sub index_authors {
                 grep {$_} @{ $put->{website} }
         ];
 
-        $put->{is_pause_custodial_account} = 1
-            if $name and $name =~ /\(PAUSE Custodial Account\)/;
+        $put->{is_pause_custodial_account} = 1 if $is_pause_custodial_account;
 
         # Now check the format we have is actually correct
         my @errors = MetaCPAN::Document::Author->validate($put);
@@ -140,6 +156,7 @@ sub index_authors {
             }
         );
     }
+
     $bulk->flush;
     $self->index->refresh;
 
@@ -163,7 +180,7 @@ sub author_config {
     # Get the most recent version
     my ($file)
         = sort { $dir->child($b)->stat->mtime <=> $dir->child($a)->stat->mtime }
-        grep   {m/author-.*?\.json/} readdir($dh);
+        grep {m/author-.*?\.json/} readdir($dh);
     return $fallback unless ($file);
     $file = $dir->child($file);
     return $fallback if !-e $file;