From b1c150dc19ae1110bbc56ebac6124540e505017a Mon Sep 17 00:00:00 2001 From: Tomas Cohen Arazi Date: Tue, 29 Nov 2022 16:01:04 -0300 Subject: [PATCH] Bug 32370: (follow-up) Make Koha::BackgroundJob use Koha::Object::JSONFields --- Koha/BackgroundJob.pm | 53 ++++++------------- misc/background_jobs_worker.pl | 2 +- t/db_dependent/Koha/BackgroundJob.t | 10 ++-- t/db_dependent/Koha/BackgroundJobs.t | 2 +- .../Koha/BackgroundJobs/BatchUpdateBiblio.t | 13 +++-- t/lib/Koha/BackgroundJob/BatchTest.pm | 4 +- 6 files changed, 34 insertions(+), 50 deletions(-) diff --git a/Koha/BackgroundJob.pm b/Koha/BackgroundJob.pm index 727bc3b2f7b..897f520bb94 100644 --- a/Koha/BackgroundJob.pm +++ b/Koha/BackgroundJob.pm @@ -17,7 +17,6 @@ package Koha::BackgroundJob; use Modern::Perl; use Encode qw(); -use JSON; use Carp qw( croak ); use Net::Stomp; use Try::Tiny qw( catch try ); @@ -28,7 +27,7 @@ use Koha::Exceptions; use Koha::Plugins; use Koha::Exceptions::BackgroundJob; -use base qw( Koha::Object ); +use base qw( Koha::Object Koha::Object::JSONFields ); =head1 NAME @@ -101,21 +100,18 @@ sub enqueue { my $job_args = $params->{job_args}; my $job_context = $params->{job_context} // C4::Context->userenv; my $job_queue = $params->{job_queue} // 'default'; - my $json = $self->json; my $borrowernumber = (C4::Context->userenv) ? C4::Context->userenv->{number} : undef; $job_context->{interface} = C4::Context->interface; - my $json_context = $json->encode($job_context); - my $json_args = $json->encode($job_args); + + $self->set_encoded_json_field( { data => $job_context, field => 'context' } ); + $self->set_encoded_json_field( { data => $job_args, field => 'data' } ); $self->set( - { - status => 'new', + { status => 'new', type => $job_type, queue => $job_queue, size => $job_size, - data => $json_args, - context => $json_context, enqueued_on => dt_from_string, borrowernumber => $borrowernumber, } @@ -131,7 +127,7 @@ sub enqueue { }; return unless $conn; - $json_args = $json->encode($job_args); + my $json_args = $self->decode_json_field({ field => 'data' }); try { # This namespace is wrong, it must be a vhost instead. # But to do so it needs to be created on the server => much more work when a new Koha instance is created. @@ -169,7 +165,7 @@ sub process { $args ||= {}; if ( $self->context ) { - my $context = $self->json->decode($self->context); + my $context = $self->decode_json_field({ field => 'context' }); C4::Context->_new_userenv(-1); C4::Context->interface( $context->{interface} ); C4::Context->set_userenv( @@ -249,28 +245,9 @@ sub finish { my ( $self, $data ) = @_; $self->status('finished') unless $self->status eq 'cancelled' or $self->status eq 'failed'; + $self->set_encoded_json_field({ data => $data, field => 'data' }); - return $self->set( - { - ended_on => \'NOW()', - data => $self->json->encode($data), - } - )->store; -} - -=head3 json - - my $JSON_object = $self->json; - -Returns a JSON object with utf8 disabled. Encoding to UTF-8 should be -done later. - -=cut - -sub json { - my ( $self ) = @_; - $self->{_json} //= JSON->new->utf8(0); # TODO Should we allow_nonref ? - return $self->{_json}; + return $self->set({ ended_on => \'NOW()' })->store; } =head3 decoded_data @@ -284,7 +261,7 @@ Returns the decoded JSON contents from $self->data. sub decoded_data { my ($self) = @_; - return $self->data ? $self->json->decode( $self->data ) : undef; + return $self->decode_json_field({ field => 'data' }); } =head3 set_encoded_data @@ -298,7 +275,7 @@ Serializes I<$data> as a JSON string and sets the I attribute with it. sub set_encoded_data { my ( $self, $data ) = @_; - return $self->data( $data ? $self->json->encode($data) : undef ); + return $self->set_encoded_json_field({ data => $data, field => 'data' }); } =head3 job_type @@ -319,7 +296,7 @@ sub messages { my ( $self ) = @_; my @messages; - my $data_dump = $self->json->decode($self->data); + my $data_dump = $self->decode_json_field({ field => 'data' }); if ( exists $data_dump->{messages} ) { @messages = @{ $data_dump->{messages} }; } @@ -336,7 +313,7 @@ Report of the job. sub report { my ( $self ) = @_; - my $data_dump = $self->json->decode($self->data); + my $data_dump = $self->decode_json_field({ field => 'data' }); return $data_dump->{report} || {}; } @@ -489,9 +466,9 @@ sub to_api { my $json = $self->SUPER::to_api( $params ); - $json->{context} = $self->json->decode($self->context) + $json->{context} = $self->decode_json_field({ field => 'context' }) if defined $self->context; - $json->{data} = $self->decoded_data; + $json->{data} = $self->decode_json_field({ field => 'data' }); return $json; } diff --git a/misc/background_jobs_worker.pl b/misc/background_jobs_worker.pl index eb36f34f964..ee5e7293bd2 100755 --- a/misc/background_jobs_worker.pl +++ b/misc/background_jobs_worker.pl @@ -102,7 +102,7 @@ while (1) { } else { my $jobs = Koha::BackgroundJobs->search({ status => 'new', queue => \@queues }); while ( my $job = $jobs->next ) { - my $args = $job->json->decode($job->data); + my $args = $job->decoded_data; process_job( $job, { job_id => $job->id, %$args } ); } sleep 10; diff --git a/t/db_dependent/Koha/BackgroundJob.t b/t/db_dependent/Koha/BackgroundJob.t index 80674fbde58..a67bc1361b6 100755 --- a/t/db_dependent/Koha/BackgroundJob.t +++ b/t/db_dependent/Koha/BackgroundJob.t @@ -108,7 +108,7 @@ subtest 'enqueue() tests' => sub { is( $job->size, 3, 'Three steps' ); is( $job->status, 'new', 'Initial status set correctly' ); is( $job->borrowernumber, $patron->id, 'Borrowernumber set from userenv' ); - is_deeply( $job->json->decode( $job->context ), $job_context, 'Context set from userenv + interface' ); + is_deeply( $job->decode_json_field({ field => 'context' }), $job_context, 'Context set from userenv + interface' ); $schema->storage->txn_rollback; }; @@ -150,14 +150,14 @@ subtest 'start(), step() and finish() tests' => sub { is( $job->status, 'cancelled', "'finish' leaves 'cancelled' untouched" ); isnt( $job->ended_on, undef, 'ended_on set' ); - is_deeply( $job->json->decode( $job->data ), $data ); + is_deeply( $job->decode_json_field({ field => 'data' }), $data ); $job->status('started')->store; $job->finish( $data ); is( $job->status, 'finished' ); isnt( $job->ended_on, undef, 'ended_on set' ); - is_deeply( $job->json->decode( $job->data ), $data ); + is_deeply( $job->decode_json_field({ field => 'data' }), $data ); throws_ok { $job->start; } @@ -224,7 +224,7 @@ subtest 'process tests' => sub { is_deeply( C4::Context->interface, 'intranet', "Interface set from job context on process" ); # Manually add a job (->new->store) without context - my $json = $job->json; # sorry, quickly borrowing your json object + my $json = $job->_json; # sorry, quickly borrowing your json object my $data = $json->encode({ a => 'a', b => 'b' }); my $incomplete_job = t::lib::Koha::BackgroundJob::BatchTest->new( { status => 'new', @@ -254,7 +254,7 @@ subtest 'decoded_data() and set_encoded_data() tests' => sub { $job->set_encoded_data( $data ); - is_deeply( $job->json->decode($job->data), $data, 'decode what we sent' ); + is_deeply( $job->_json->decode($job->data), $data, 'decode what we sent' ); is_deeply( $job->decoded_data, $data, 'check with decoded_data' ); # Let's get some Unicode stuff into the game diff --git a/t/db_dependent/Koha/BackgroundJobs.t b/t/db_dependent/Koha/BackgroundJobs.t index c8089d4488b..40292c6dd1a 100755 --- a/t/db_dependent/Koha/BackgroundJobs.t +++ b/t/db_dependent/Koha/BackgroundJobs.t @@ -62,7 +62,7 @@ my $job_id = t::lib::Koha::BackgroundJob::BatchTest->new->enqueue( # Enqueuing a new job my $new_job = Koha::BackgroundJobs->find($job_id); ok( $new_job, 'New job correctly enqueued' ); -is_deeply( $new_job->json->decode( $new_job->data ), +is_deeply( $new_job->_json->decode( $new_job->data ), $data, 'data retrieved and json encoded correctly' ); is( t::lib::Dates::compare( $new_job->enqueued_on, dt_from_string ), 0, 'enqueued_on correctly filled with now()' ); diff --git a/t/db_dependent/Koha/BackgroundJobs/BatchUpdateBiblio.t b/t/db_dependent/Koha/BackgroundJobs/BatchUpdateBiblio.t index aa9b0e49d56..13ac116e6f0 100755 --- a/t/db_dependent/Koha/BackgroundJobs/BatchUpdateBiblio.t +++ b/t/db_dependent/Koha/BackgroundJobs/BatchUpdateBiblio.t @@ -51,13 +51,20 @@ subtest "Exceptions must be stringified" => sub { type => 'batch_biblio_record_modification', } ); - my $data = $job->json->encode({ record_ids => [ $biblio->biblionumber ] }); - $job->data( $data )->store; + + $job->set_encoded_json_field( + { data => { record_ids => [ $biblio->biblionumber ] }, + field => 'data' + } + )->store; + $job = Koha::BackgroundJobs->find( $job->id ); $job->process( { job_id => $job->id, record_ids => [ $biblio->biblionumber ] } ); - $data = $job->json->decode( $job->get_from_storage->data ); + $job = $job->get_from_storage; + + my $data = $job->decode_json_field({ field => 'data' }); is_deeply( $data->{messages}->[0], { diff --git a/t/lib/Koha/BackgroundJob/BatchTest.pm b/t/lib/Koha/BackgroundJob/BatchTest.pm index 1ae84ef4e97..2d7c919459a 100644 --- a/t/lib/Koha/BackgroundJob/BatchTest.pm +++ b/t/lib/Koha/BackgroundJob/BatchTest.pm @@ -56,12 +56,12 @@ sub process { $self->progress( ++$job_progress )->store; } - my $job_data = $self->json->decode($self->data); + my $job_data = $self->_json->decode($self->data); $job_data->{messages} = \@messages; $job_data->{report} = $report; $self->ended_on(dt_from_string) - ->data( $self->json->encode($job_data) ); + ->set_encoded_json_field({ data => $job_data, field => 'data' }); $self->status('finished') if $self->status ne 'cancelled'; $self->store; } -- 2.34.1