1 package Koha::BackgroundJob;
4 use JSON qw( encode_json decode_json );
9 use Koha::DateUtils qw( dt_from_string );
10 use Koha::BackgroundJobs;
12 use base qw( Koha::Object );
16 my $conn = Net::RabbitFoot->new()->load_xml_spec()->connect(
17 host => 'localhost', # TODO Move this to KOHA_CONF
28 my ( $self, $params ) = @_;
30 my $job_type = $params->{job_type};
31 my $job_size = $params->{job_size};
32 my $job_args = $params->{job_args};
34 my $json_args = encode_json $job_args;
40 enqueued_on => dt_from_string,
41 borrowernumber => C4::Context->userenv->{id}, # FIXME Handle non GUI calls
44 my $job_id = $self->id;
45 $job_args->{job_id} = $job_id;
46 $json_args = encode_json $job_args,
48 my $conn = $self->connect;
49 my $channel = $conn->open_channel();
51 $channel->declare_queue(
58 routing_key => $job_type, # TODO Must be different?
65 sub process { croak "This method must be subclassed" }
71 my $data_dump = decode_json $self->data;
72 if ( exists $data_dump->{messages} ) {
73 @messages = @{ $data_dump->{messages} };
82 my $data_dump = decode_json $self->data;
83 return $data_dump->{report};
88 $self->status('cancelled')->store;
92 return 'BackgroundJob';