Added index refreshing

Author: mickeyn

bin/backpan.pl

@@ -30,6 +30,8 @@
 update_files();
 
 $_->flush for values %bulk;
+$es_release->index_refresh;
+$es_file->index_refresh;
 
 log_info {"done"};
 

bin/checksum.pl

@@ -80,6 +80,7 @@
 }
 
 $bulk->flush unless $dry_run;
+$es->index_refresh;
 
 log_info {'Finished adding checksums'};
 

bin/cover.pl

@@ -69,6 +69,7 @@
 }
 
 $bulk_cover->flush;
+$es_cover->index_refresh;
 
 ###
 

bin/cve.pl

@@ -193,6 +193,11 @@
 }
 
 $bulk_cve->flush;
+$es_cve->index_refresh;
+
+log_info {"done."};
+
+###
 
 sub retrieve_cve_data {
     return decode_json( path($json_file)->slurp ) if $json_file;

bin/external.pl

@@ -18,7 +18,7 @@
     "external_source=s" => \$external_source,
 );
 
-die "wrong external source: $external\n"
+die "wrong external source: $external_source\n"
     unless $external_source
     and grep { $_ eq $external_source } qw< cygwin debian >;
 
@@ -100,6 +100,9 @@
 }
 
 $bulk->flush;
+$es->index_refresh;
+
+log_info {"done"};
 
 1;
 

bin/permission.pl

@@ -54,6 +54,7 @@
 }
 
 $bulk->flush;
+$es->index_refresh;
 
 run_cleanup( \%seen ) if $cleanup;
 

bin/purge.pl

@@ -73,6 +73,7 @@ (%args)
     $bulk->delete_ids(@$ids);
 
     $bulk->flush;
+    $es->index_refresh;
 }
 
 1;

bin/river.pl

@@ -39,6 +39,9 @@
 }
 
 $bulk->flush;
+$es->index_refresh;
+
+log_info {'done'};
 
 1;
 

bin/session.pl

@@ -24,6 +24,7 @@
 }
 
 $bulk->flush;
+$es->index_refresh;
 
 log_info {'done'};
 

bin/suggest.pl

@@ -97,6 +97,7 @@ ($range)
     }
 
     $bulk->flush;
+    $es->index_refresh;
 }
 
 __END__