1 package Koha::BackgroundJob;
3 # This file is part of Koha.
5 # Koha is free software; you can redistribute it and/or modify it
6 # under the terms of the GNU General Public License as published by
7 # the Free Software Foundation; either version 3 of the License, or
8 # (at your option) any later version.
10 # Koha is distributed in the hope that it will be useful, but
11 # WITHOUT ANY WARRANTY; without even the implied warranty of
12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 # GNU General Public License for more details.
15 # You should have received a copy of the GNU General Public License
16 # along with Koha; if not, see <http://www.gnu.org/licenses>.
19 use JSON qw( encode_json decode_json );
25 use Koha::DateUtils qw( dt_from_string );
27 use Koha::BackgroundJob::BatchUpdateBiblio;
28 use Koha::BackgroundJob::BatchUpdateAuthority;
30 use base qw( Koha::Object );
34 Koha::BackgroundJob - Koha BackgroundJob Object class
36 This is a base class for BackgroundJob, some methods must be subclassed.
41 my $job_id = Koha::BackgroundJob->enqueue(
43 job_type => $job_type,
44 job_size => $job_size,
50 Koha::BackgrounJobs->find($job_id)->process;
51 See also C<misc/background_jobs_worker.pl> for a full example
59 Connect to the message broker using default guest/guest credential
65 my $stomp = Net::Stomp->new( { hostname => 'localhost', port => '61613' } );
66 $stomp->connect( { login => 'guest', passcode => 'guest' } );
72 Enqueue a new job. It will insert a new row in the DB table and notify the broker that a new job has been enqueued.
74 C<job_size> is the size of the job
75 C<job_args> is the arguments of the job. It's a structure that will be JSON encoded.
77 Return the job_id of the newly created job.
82 my ( $self, $params ) = @_;
84 my $job_type = $self->job_type;
85 my $job_size = $params->{job_size};
86 my $job_args = $params->{job_args};
88 my $borrowernumber = C4::Context->userenv->{number}; # FIXME Handle non GUI calls
89 my $json_args = encode_json $job_args;
91 $self->_result->result_source->schema->txn_do(
99 enqueued_on => dt_from_string,
100 borrowernumber => $borrowernumber,
105 $job_args->{job_id} = $job_id;
106 $json_args = encode_json $job_args;
109 my $conn = $self->connect;
110 # This namespace is wrong, it must be a vhost instead.
111 # But to do so it needs to be created on the server => much more work when a new Koha instance is created.
112 # Also, here we just want the Koha instance's name, but it's not in the config...
113 # Picking a random id (memcached_namespace) from the config
114 my $namespace = C4::Context->config('memcached_namespace');
115 $conn->send_with_receipt( { destination => sprintf("/queue/%s-%s", $namespace, $job_type), body => $json_args } )
116 or Koha::Exceptions::Exception->throw('Job has not been enqueued');
118 if ( ref($_) eq 'Koha::Exceptions::Exception' ) {
121 warn sprintf "The job has not been sent to the message broker: (%s)", $_;
137 my ( $self, $args ) = @_;
139 my $job_type = $self->type;
140 return $job_type eq 'batch_biblio_record_modification'
141 ? Koha::BackgroundJob::BatchUpdateBiblio->process($args)
142 : $job_type eq 'batch_authority_record_modification'
143 ? Koha::BackgroundJob::BatchUpdateAuthority->process($args)
144 : Koha::Exceptions::Exception->throw('->process called without valid job_type');
149 Return the job type of the job. Must be a string.
153 sub job_type { croak "This method must be subclassed" }
157 Messages let during the processing of the job.
165 my $data_dump = decode_json $self->data;
166 if ( exists $data_dump->{messages} ) {
167 @messages = @{ $data_dump->{messages} };
182 my $data_dump = decode_json $self->data;
183 return $data_dump->{report};
194 $self->status('cancelled')->store;
198 return 'BackgroundJob';