Bug 17600: Standardize our EXPORT_OK
[srvgit] / admin / background_jobs.pl
index ef8422d..9a47485 100755 (executable)
 
 use Modern::Perl;
 use CGI qw ( -utf8 );
-use JSON qw( decode_json );
-use Try::Tiny;
 
 use C4::Context;
-use C4::Auth;
-use C4::Output;
+use C4::Auth qw( get_template_and_user );
+use C4::Output qw( output_html_with_http_headers );
 
 use Koha::BackgroundJobs;
 use Koha::Virtualshelves;
 
-my $input             = new CGI;
+my $input             = CGI->new;
 my $op                = $input->param('op') || 'list';
 my @messages;
 
@@ -40,7 +38,6 @@ my ( $template, $loggedinuser, $cookie ) = get_template_and_user(
         query           => $input,
         type            => "intranet",
         flagsrequired   => $flags_required,
-        debug           => 1,
     }
 );
 
@@ -79,30 +76,7 @@ if ( $op eq 'cancel' ) {
 
 if ( $op eq 'list' ) {
     my $jobs = Koha::BackgroundJobs->search({}, { order_by => { -desc => 'enqueued_on' }});
-    my @pending_jobs;
-    try {
-        my $conn = Koha::BackgroundJob->connect;
-        my $job_type = 'batch_biblio_record_modification';
-        $conn->subscribe({ destination => $job_type, ack => 'client' });
-        my @frames;
-        while (my $frame = $conn->receive_frame({timeout => 1})) {
-            last unless $frame;
-            my $body = $frame->body;
-            my $args = decode_json($body);
-            push @pending_jobs, $args->{job_id};
-            push @frames, $frame;
-        }
-        $conn->nack( { frame => $_ } ) for @frames;
-        $conn->disconnect;
-    } catch {
-        push @messages, {
-            type => 'error',
-            code => 'cannot_retrieve_jobs',
-            error => $_,
-        };
-    };
-
-    $template->param( jobs => $jobs, pending_jobs => \@pending_jobs, );
+    $template->param( jobs => $jobs );
 }
 
 $template->param(