#!/usr/bin/perl

use Modern::Perl;

use Net::RabbitFoot;

use JSON qw( encode_json decode_json );

use Koha::BackgroundJob::BatchUpdateBiblio;

use Koha::BackgroundJob;

my $conn = Koha::BackgroundJob->connect;

my $channel = $conn->open_channel();

my $job_type = 'batch_biblio_record_modification';

$channel->declare_queue(

    queue => $job_type,

    durable => 1,

);

$channel->qos(prefetch_count => 1,);

$channel->consume(

    on_consume => sub {

        my $var = shift;

        my $body = $var->{body}->{payload};

        say " [x] Received $body";

        my $args = decode_json( $body );

        Koha::BackgroundJob::BatchUpdateBiblio->process($args, $channel);

        say " [x] Done";

    },

    no_ack => 0,

);

# Wait forever

AnyEvent->condvar->recv;