koha-dev.rot13.org Git - srvgit/blob - 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 => 40;
  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     for my $engine ( @engines ){
  75         t::lib::Mocks::mock_preference( 'SearchEngine', $engine );
  76         my $mock_index = Test::MockModule->new("Koha::SearchEngine::".$engine."::Indexer");
  77
  78         my $biblionumber1 = $builder->build_sample_biblio()->biblionumber;
  79         my $biblionumber2 = $builder->build_sample_biblio()->biblionumber;
  80
  81         my $mock_zebra = Test::MockModule->new("Koha::SearchEngine::Zebra::Indexer");
  82         $mock_zebra->mock( ModZebra => sub { warn "ModZebra"; } );
  83         my $indexer = Koha::SearchEngine::Indexer->new({ index => $Koha::SearchEngine::BIBLIOS_INDEX });
  84         warnings_are{
  85             $indexer->index_records([$biblionumber1,$biblionumber1],"specialUpdate","biblioserver",undef);
  86         } ["ModZebra","ModZebra"],"ModZebra called for each record being indexed for $engine";
  87
  88         $mock_index->mock( index_records => sub {
  89             warn $engine;
  90             my ($package, undef, undef) = caller;
  91             warn $package;
  92         });
  93
  94         my $auth = MARC::Record->new;
  95         my $authid;
  96         warnings_are{
  97             $authid = AddAuthority( $auth, undef, 'TOPIC_TERM' );
  98         } [$engine,"C4::AuthoritiesMarc"], "index_records is called for $engine is called when adding authority";
  99
 100         warnings_are{
 101             $authid = DelAuthority({ authid => $authid, skip_merge => 1 });
 102         } [$engine,"C4::AuthoritiesMarc"], "index_records is called for $engine is called when adding authority";
 103
 104         my $biblio;
 105         my $biblio2;
 106         warnings_are{
 107             $biblio = $builder->build_sample_biblio();
 108             $biblio2 = $builder->build_sample_biblio();
 109         } [$engine,'C4::Biblio',$engine,'C4::Biblio'], "index_records is called for $engine when adding a biblio (ModBiblioMarc)";
 110
 111
 112         my $item;
 113         my $item2;
 114         warnings_are{
 115             $item = $builder->build_sample_item({
 116                 biblionumber => $biblio->biblionumber,
 117                 onloan => '2020-02-02',
 118                 datelastseen => '2020-01-01',
 119                 replacementprice => 0
 120             });
 121             $item2 = $builder->build_sample_item({
 122                 biblionumber => $biblio->biblionumber,
 123                 onloan => '2020-12-12',
 124                 datelastseen => '2020-11-11',
 125                 replacementprice => 0
 126             });
 127         } [$engine,"Koha::Item",$engine,"Koha::Item"], "index_records is called for $engine when adding an item (Item->store)";
 128         warnings_are{
 129             $item->store({ skip_record_index => 1 });
 130         } undef, "index_records is not called for $engine when adding an item (Item->store) if skip_record_index passed";
 131
 132         my $issue = $builder->build({
 133             source => 'Issue',
 134             value  => {
 135                 itemnumber => $item->itemnumber
 136             }
 137         });
 138         my $issue2 = $builder->build({
 139             source => 'Issue',
 140             value  => {
 141                 itemnumber => $item2->itemnumber
 142             }
 143         });
 144         warnings_are{
 145             MarkIssueReturned( $issue->{borrowernumber}, $item->itemnumber);
 146         } [$engine,"Koha::Item"], "index_records is called for $engine when calling MarkIssueReturned";
 147         warnings_are{
 148             MarkIssueReturned( $issue2->{borrowernumber}, $item2->itemnumber, undef, undef, { skip_record_index => 1});
 149         } undef, "index_records is not called for $engine when calling MarkIssueReturned if skip_record_index passed";
 150
 151         warnings_are{
 152             AddReturn($item->barcode, $item->homebranch, 0, undef);
 153         } [$engine,'C4::Circulation'], "index_records is called once for $engine when calling AddReturn if item not issued";
 154         $issue = $builder->build({
 155             source => 'Issue',
 156             value  => {
 157                 itemnumber => $item->itemnumber
 158             }
 159         });
 160         warnings_are{
 161             AddReturn($item->barcode, $item->homebranch, 0, undef);
 162         } [$engine,'C4::Circulation'], "index_records is called once for $engine when calling AddReturn if item not issued";
 163         $builder->build({
 164             source => 'Issue',
 165             value  => {
 166                 itemnumber => $item->itemnumber
 167             }
 168         });
 169         $item->onloan('2000-01-01')->store({ skip_record_index => 1 });
 170         warnings_are{
 171             LostItem( $item->itemnumber, "tests", 1);
 172         } [$engine,"Koha::Item"], "index_records is called for $engine when calling LostItem with 'force_mark_returned'";
 173         $builder->build({
 174             source => 'Issue',
 175             value  => {
 176                 itemnumber => $item->itemnumber
 177             }
 178         });
 179         $item->onloan('2000-01-01')->store({ skip_record_index => 1 });
 180         warnings_are{
 181             LostItem( $item->itemnumber, "tests", 1, { skip_record_index => 1 });
 182         } undef, "index_records is not called for $engine when calling LostItem with 'force_mark_returned' if skip_record_index";
 183
 184         $item->datelastseen('2001-01-01')->store({skip_record_index=>1});
 185         warnings_are{
 186             my $t1 = ModDateLastSeen( $item->itemnumber, 1, undef );
 187         } [$engine, "Koha::Item"], "index_records is called for $engine when calling ModDateLastSeen";
 188         warnings_are{
 189             ModDateLastSeen( $item->itemnumber, 1, { skip_record_index =>1 } );
 190         } undef, "index_records is not called for $engine when calling ModDateLastSeen if skip_record_index";
 191
 192         warnings_are{
 193             ModItemTransfer( $item->itemnumber, $item2->homebranch, $item->homebranch,'Manual');
 194         } [$engine,"Koha::Item"], "index_records is called for $engine when calling ModItemTransfer";
 195         warnings_are{
 196             ModItemTransfer( $item->itemnumber, $item->homebranch, $item2->homebranch,'Manual',{skip_record_index=>1});
 197         } undef, "index_records is not called for $engine when calling ModItemTransfer with skip_record_index";
 198
 199         warnings_are{
 200             $item->delete();
 201         } [$engine,"Koha::Item"], "index_records is called for $engine when deleting an item (Item->delete)";
 202         warnings_are{
 203             $item2->delete({ skip_record_index => 1 });
 204         } undef, "index_records is not called for $engine when adding an item (Item->store) if skip_record_index passed";
 205
 206         warnings_are{
 207             DelBiblio( $biblio->biblionumber );
 208         } [$engine, "C4::Biblio"], "index_records is called for $engine when calling DelBiblio";
 209         warnings_are{
 210             DelBiblio( $biblio->biblionumber, { skip_record_index =>1 });
 211         } undef, "index_records is not called for $engine when calling DelBiblio if skip_record_index passed";
 212
 213     }
 214
 215 };
 216
 217 $schema->storage->txn_rollback;