t/db_dependent/Koha/SearchEngine/Indexer.t

   1 #!/usr/bin/perl
   2
   3 # Tests for Koha/SearchEngine/Search
   4
   5 use Modern::Perl;
   6
   7 use Test::More tests => 2;
   8 use Test::Warn;
   9
  10 use MARC::Field;
  11 use MARC::Record;
  12 use Test::MockModule;
  13 use Test::MockObject;
  14
  15 use t::lib::Mocks;
  16
  17 #use C4::Biblio qw//;
  18 use C4::AuthoritiesMarc qw( AddAuthority DelAuthority merge );
  19 use C4::Biblio qw( ModZebra ModBiblio ModBiblioMarc DelBiblio );
  20 use C4::Circulation qw( MarkIssueReturned AddReturn LostItem );
  21 use C4::Items qw( ModDateLastSeen ModItemTransfer );
  22 use Koha::Database;
  23 use Koha::DateUtils;
  24 use Koha::SearchEngine::Elasticsearch;
  25 use Koha::SearchEngine::Indexer;
  26
  27 use t::lib::TestBuilder;
  28 use t::lib::Mocks;
  29
  30 my $schema  = Koha::Database->new->schema;
  31 my $builder = t::lib::TestBuilder->new;
  32
  33 $schema->storage->txn_begin;
  34
  35 subtest 'Test indexer object creation' => sub {
  36     plan tests => 6;
  37
  38     t::lib::Mocks::mock_preference( 'SearchEngine', 'Zebra' );
  39     my $indexer = Koha::SearchEngine::Indexer->new({ index => $Koha::SearchEngine::BIBLIOS_INDEX });
  40     is( ref $indexer, 'Koha::SearchEngine::Zebra::Indexer', 'We get the correct class for Zebra biblios');
  41     $indexer = Koha::SearchEngine::Indexer->new({ index => $Koha::SearchEngine::AUTHORITIES_INDEX });
  42     is( ref $indexer, 'Koha::SearchEngine::Zebra::Indexer', 'We get the correct class for Zebra authorities');
  43
  44     t::lib::Mocks::mock_preference( 'SearchEngine', 'Elasticsearch' );
  45
  46     SKIP: {
  47
  48         eval { Koha::SearchEngine::Elasticsearch->get_elasticsearch_params; };
  49
  50         skip 'Elasticsearch configuration not available', 4
  51             if $@;
  52
  53         $indexer = Koha::SearchEngine::Indexer->new({ index => $Koha::SearchEngine::BIBLIOS_INDEX });
  54         is( ref $indexer, 'Koha::SearchEngine::Elasticsearch::Indexer', 'We get the correct class for Elasticsearch biblios');
  55         ok( $indexer->index_name =~ /biblios$/, "The index is set correctly for biblios");
  56         $indexer = Koha::SearchEngine::Indexer->new({ index => $Koha::SearchEngine::AUTHORITIES_INDEX });
  57         is( ref $indexer, 'Koha::SearchEngine::Elasticsearch::Indexer', 'We get the correct class for Elasticsearch authorities');
  58         ok( $indexer->index_name =~ /authorities$/, "The index is set correctly for authorities");
  59
  60     }
  61 };
  62
  63 subtest 'Test indexer calls' => sub {
  64     plan tests => 46;
  65
  66     my @engines = ('Zebra');
  67     eval { Koha::SearchEngine::Elasticsearch->get_elasticsearch_params; };
  68     push @engines, 'Elasticsearch' unless $@;
  69     SKIP: {
  70     skip 'Elasticsearch configuration not available', 20
  71             if scalar @engines == 1;
  72     }
  73
  74     t::lib::Mocks::mock_preference( 'BiblioAddsAuthorities', 0 );
  75
  76     for my $engine ( @engines ){
  77         t::lib::Mocks::mock_preference( 'SearchEngine', $engine );
  78         my $mock_index = Test::MockModule->new("Koha::SearchEngine::".$engine."::Indexer");
  79
  80         my $biblionumber1 = $builder->build_sample_biblio()->biblionumber;
  81         my $biblionumber2 = $builder->build_sample_biblio()->biblionumber;
  82
  83         my $mock_zebra = Test::MockModule->new("Koha::SearchEngine::Zebra::Indexer");
  84         $mock_zebra->mock( ModZebra => sub { warn "ModZebra"; } );
  85         my $indexer = Koha::SearchEngine::Indexer->new({ index => $Koha::SearchEngine::BIBLIOS_INDEX });
  86         warnings_are{
  87             $indexer->index_records([$biblionumber1,$biblionumber1],"specialUpdate","biblioserver",undef);
  88         } ["ModZebra","ModZebra"],"ModZebra called for each record being indexed for $engine";
  89
  90         $mock_index->mock( index_records => sub {
  91             warn $engine;
  92             my ($package, undef, undef) = caller;
  93             warn $package;
  94         });
  95
  96         my $auth = MARC::Record->new;
  97         my $authid;
  98         warnings_are{
  99             $authid = AddAuthority( $auth, undef, 'TOPIC_TERM' );
 100         } [$engine,"C4::AuthoritiesMarc"], "index_records is called for $engine is called when adding authority";
 101
 102         warnings_are{
 103             $authid = DelAuthority({ authid => $authid, skip_merge => 1 });
 104         } [$engine,"C4::AuthoritiesMarc"], "index_records is called for $engine is called when adding authority";
 105
 106         my $biblio;
 107         my $biblio2;
 108         warnings_are{
 109             $biblio = $builder->build_sample_biblio();
 110             $biblio2 = $builder->build_sample_biblio();
 111         } [$engine,'C4::Biblio',$engine,'C4::Biblio'], "index_records is called for $engine when adding a biblio (ModBiblioMarc)";
 112
 113
 114         my $item;
 115         my $item2;
 116         my $item3;
 117         my $item4;
 118         my $item5;
 119         my $item6;
 120         warnings_are{
 121             $item = $builder->build_sample_item({
 122                 biblionumber => $biblio->biblionumber,
 123                 onloan => '2020-02-02',
 124                 datelastseen => '2020-01-01',
 125                 replacementprice => 0
 126             });
 127             $item2 = $builder->build_sample_item({
 128                 biblionumber => $biblio->biblionumber,
 129                 onloan => '2020-12-12',
 130                 datelastseen => '2020-11-11',
 131                 replacementprice => 0
 132             });
 133             $item3 = $builder->build_sample_item({biblionumber => $biblio->biblionumber});
 134             $item4 = $builder->build_sample_item({biblionumber => $biblio->biblionumber});
 135             $item5 = $builder->build_sample_item({biblionumber => $biblio->biblionumber});
 136             $item6 = $builder->build_sample_item({biblionumber => $biblio->biblionumber});
 137         } [$engine,"Koha::Item",
 138            $engine,"Koha::Item",
 139            $engine,"Koha::Item",
 140            $engine,"Koha::Item",
 141            $engine,"Koha::Item",
 142            $engine,"Koha::Item"], "index_records is called for $engine when adding an item (Item->store)";
 143         warnings_are{
 144             $item->store({ skip_record_index => 1 });
 145         } undef, "index_records is not called for $engine when adding an item (Item->store) if skip_record_index passed";
 146
 147         my $issue = $builder->build({
 148             source => 'Issue',
 149             value  => {
 150                 itemnumber => $item->itemnumber
 151             }
 152         });
 153         my $issue2 = $builder->build({
 154             source => 'Issue',
 155             value  => {
 156                 itemnumber => $item2->itemnumber
 157             }
 158         });
 159         warnings_are{
 160             MarkIssueReturned( $issue->{borrowernumber}, $item->itemnumber);
 161         } [$engine,"Koha::Item"], "index_records is called for $engine when calling MarkIssueReturned";
 162         warnings_are{
 163             MarkIssueReturned( $issue2->{borrowernumber}, $item2->itemnumber, undef, undef, { skip_record_index => 1});
 164         } undef, "index_records is not called for $engine when calling MarkIssueReturned if skip_record_index passed";
 165
 166         warnings_are{
 167             AddReturn($item->barcode, $item->homebranch, 0, undef);
 168         } [$engine,'C4::Circulation'], "index_records is called once for $engine when calling AddReturn if item not issued";
 169         $issue = $builder->build({
 170             source => 'Issue',
 171             value  => {
 172                 itemnumber => $item->itemnumber
 173             }
 174         });
 175         warnings_are{
 176             AddReturn($item->barcode, $item->homebranch, 0, undef);
 177         } [$engine,'C4::Circulation'], "index_records is called once for $engine when calling AddReturn if item not issued";
 178
 179         warnings_are{
 180             $item3->move_to_biblio($biblio2);
 181         } [$engine,"Koha::Item",$engine,"Koha::Item"], "index_records is called twice for $engine when moving an item to another biblio (Item->move_to_biblio)";
 182         warnings_are{
 183             $item4->move_to_biblio($biblio2, { skip_record_index => 1 });
 184         } undef, "index_records is not called for $engine when moving an item to another biblio (Item->move_to_biblio) if skip_record_index passed";
 185
 186         warnings_are{
 187             $biblio->items->move_to_biblio($biblio2);
 188         } [$engine,"Koha::Biblio",$engine,"Koha::Biblio"], "index_records is called for both biblios for $engine when adopting items (Biblio->items->move_to_biblio(Biblio)";
 189
 190         $builder->build({
 191             source => 'Issue',
 192             value  => {
 193                 itemnumber => $item->itemnumber
 194             }
 195         });
 196         $item->onloan('2000-01-01')->store({ skip_record_index => 1 });
 197         warnings_are{
 198             LostItem( $item->itemnumber, "tests", 1);
 199         } [$engine,"Koha::Item"], "index_records is called for $engine when calling LostItem with 'force_mark_returned'";
 200         $builder->build({
 201             source => 'Issue',
 202             value  => {
 203                 itemnumber => $item->itemnumber
 204             }
 205         });
 206         $item->onloan('2000-01-01')->store({ skip_record_index => 1 });
 207         warnings_are{
 208             LostItem( $item->itemnumber, "tests", 1, { skip_record_index => 1 });
 209         } undef, "index_records is not called for $engine when calling LostItem with 'force_mark_returned' if skip_record_index";
 210
 211         $item->datelastseen('2001-01-01')->store({skip_record_index=>1});
 212         warnings_are{
 213             my $t1 = ModDateLastSeen( $item->itemnumber, 1, undef );
 214         } [$engine, "Koha::Item"], "index_records is called for $engine when calling ModDateLastSeen";
 215         warnings_are{
 216             ModDateLastSeen( $item->itemnumber, 1, { skip_record_index =>1 } );
 217         } undef, "index_records is not called for $engine when calling ModDateLastSeen if skip_record_index";
 218
 219         warnings_are{
 220             ModItemTransfer( $item->itemnumber, $item2->homebranch, $item->homebranch,'Manual');
 221         } [$engine,"Koha::Item"], "index_records is called for $engine when calling ModItemTransfer";
 222         warnings_are{
 223             ModItemTransfer( $item->itemnumber, $item->homebranch, $item2->homebranch,'Manual',{skip_record_index=>1});
 224         } undef, "index_records is not called for $engine when calling ModItemTransfer with skip_record_index";
 225
 226         warnings_are{
 227             $item->delete();
 228         } [$engine,"Koha::Item"], "index_records is called for $engine when deleting an item (Item->delete)";
 229         warnings_are{
 230             $item2->delete({ skip_record_index => 1 });
 231         } undef, "index_records is not called for $engine when adding an item (Item->store) if skip_record_index passed";
 232
 233         warnings_are{
 234             DelBiblio( $biblio->biblionumber );
 235         } [$engine, "C4::Biblio"], "index_records is called for $engine when calling DelBiblio";
 236         warnings_are{
 237             DelBiblio( $biblio->biblionumber, { skip_record_index =>1 });
 238         } undef, "index_records is not called for $engine when calling DelBiblio if skip_record_index passed";
 239
 240     }
 241
 242 };
 243
 244 $schema->storage->txn_rollback;