skip 'Elasticsearch configuration not available', 2

    skip 'Elasticsearch configuration not available', 3

my $builder = t::lib::TestBuilder->new;

    my $builder = t::lib::TestBuilder->new;

my $biblio = $builder->build_sample_biblio; # create biblio before we start mocking to avoid trouble indexing on creation

    my $biblio =

        $builder->build_sample_biblio;    # create biblio before we start mocking to avoid trouble indexing on creation

subtest 'create_index() tests' => sub {

    plan tests => 6;

    subtest 'create_index() tests' => sub {

    my $se = Test::MockModule->new( 'Koha::SearchEngine::Elasticsearch' );

        plan tests => 6;

    $se->mock( '_read_configuration', sub {

        my $se = Test::MockModule->new('Koha::SearchEngine::Elasticsearch');

            my ($self, $sub ) = @_;

        $se->mock(

            my $method = $se->original( '_read_configuration' );

            '_read_configuration',

            my $conf = $method->( $self );

            sub {

            $conf->{index_name} .= '__test';

                my ( $self, $sub ) = @_;

            return $conf;

                my $method = $se->original('_read_configuration');

        });

                my $conf   = $method->($self);

                $conf->{index_name} .= '__test';

    my $indexer;

                return $conf;

    ok(

            }

        $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new({ 'index' => 'biblios' }),

        );

        'Creating a new indexer object'

    );

        my $indexer;

        ok(

    is(

            $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new( { 'index' => 'biblios' } ),

        $indexer->create_index(),

            'Creating a new indexer object'

        Koha::SearchEngine::Elasticsearch::Indexer::INDEX_STATUS_OK(),

        );

        'Creating an index'

    );

        is(

            $indexer->create_index(),

    my $marc_record = MARC::Record->new();

            Koha::SearchEngine::Elasticsearch::Indexer::INDEX_STATUS_OK(),

    $marc_record->append_fields(

            'Creating an index'

        MARC::Field->new('001', '1234567'),

        );

        MARC::Field->new('020', '', '', 'a' => '1234567890123'),

        MARC::Field->new('245', '', '', 'a' => 'Title')

        my $marc_record = MARC::Record->new();

    );

        $marc_record->append_fields(

    my $records = [$marc_record];

            MARC::Field->new( '001', '1234567' ),

            MARC::Field->new( '020', '', '', 'a' => '1234567890123' ),

    my $response = $indexer->update_index([1], $records);

            MARC::Field->new( '245', '', '', 'a' => 'Title' )

    is( $response->{errors}, 0, "no error on update_index" );

        );

    is( scalar(@{$response->{items}}), 1, "1 item indexed" );

        my $records = [$marc_record];

    is( $response->{items}[0]->{index}->{_id},"1", "We should get a string matching the bibnumber passed in");

        my $response = $indexer->update_index( [1], $records );

    is(

        is( $response->{errors},                   0,   "no error on update_index" );

        $indexer->drop_index(),

        is( scalar( @{ $response->{items} } ),     1,   "1 item indexed" );

        Koha::SearchEngine::Elasticsearch::Indexer::INDEX_STATUS_RECREATE_REQUIRED(),

        is( $response->{items}[0]->{index}->{_id}, "1", "We should get a string matching the bibnumber passed in" );

        'Dropping the index'

    );

        is(

};

            $indexer->drop_index(),

            Koha::SearchEngine::Elasticsearch::Indexer::INDEX_STATUS_RECREATE_REQUIRED(),

subtest 'index_records() tests' => sub {

            'Dropping the index'

    plan tests => 4;

        );

    my $mock_index = Test::MockModule->new("Koha::SearchEngine::Elasticsearch::Indexer");

    };

    $mock_index->mock( update_index => sub {

        my ($self, $record_ids, $records) = @_;

    subtest 'index_records() tests' => sub {

        warn "Update " . $record_ids->[0] . $records->[0]->as_usmarc;

        plan tests => 4;

    });

        my $mock_index = Test::MockModule->new("Koha::SearchEngine::Elasticsearch::Indexer");

    $mock_index->mock( update_index_background => sub {

        $mock_index->mock(

        my ($self, $record_ids) = @_;

            update_index => sub {

        warn "Update background " . $record_ids->[0];

                my ( $self, $record_ids, $records ) = @_;

    });

                warn "Update " . $record_ids->[0] . $records->[0]->as_usmarc;

            }

    my $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new({ 'index' => 'authorities' });

        );

        $mock_index->mock(

    my $marc_record = MARC::Record->new();

            update_index_background => sub {

    $marc_record->append_fields(

                my ( $self, $record_ids ) = @_;

        MARC::Field->new('001', '1234567'),

                warn "Update background " . $record_ids->[0];

        MARC::Field->new('100', '', '', 'a' => 'Rosenstock, Jeff'),

            }

    );

        );

    warning_is {

        $indexer->index_records( [42], 'specialUpdate', 'authorityserver',

        my $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new( { 'index' => 'authorities' } );

            [$marc_record] );

    }

        my $marc_record = MARC::Record->new();

    "Update 42" . $marc_record->as_usmarc,

        $marc_record->append_fields(

    "When passing record and ids to index_records they are correctly passed through to update_index";

            MARC::Field->new( '001', '1234567' ),

            MARC::Field->new( '100', '', '', 'a' => 'Rosenstock, Jeff' ),

    $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new({ 'index' => 'biblios' });

        );

    $marc_record = $biblio->metadata->record({ embed_items => 1 });

        warning_is {

    warning_is {

            $indexer->index_records(

        $indexer->index_records( [ $biblio->biblionumber ],

                [42], 'specialUpdate', 'authorityserver',

            'specialUpdate', 'biblioserver' );

                [$marc_record]

    }

            );

    "Update background " . $biblio->biblionumber,

    "When passing id only to index_records the marc record is fetched and passed through to update_index";

    my $chunks = 0;

    $mock_index->mock(

        update_index => sub {

            my ( $self, $record_ids, $records ) = @_;

            $chunks++;

    );

        "Update 42" . $marc_record->as_usmarc,

            "When passing record and ids to index_records they are correctly passed through to update_index";

    t::lib::Mocks::mock_config( 'elasticsearch', { server => 'false', index_name => 'pseudo' } );

    my @big_array = 1 .. 10000;

        $indexer     = Koha::SearchEngine::Elasticsearch::Indexer->new( { 'index' => 'biblios' } );

    $indexer->index_records( \@big_array, 'specialUpdate', 'biblioserver', \@big_array );

        $marc_record = $biblio->metadata->record( { embed_items => 1 } );

    is( $chunks, 2, "We split 10000 records into two chunks when chunk size not set" );

        warning_is {

            $indexer->index_records(

    $chunks = 0;

                [ $biblio->biblionumber ],

    t::lib::Mocks::mock_config( 'elasticsearch', { server => 'false', index_name => 'pseudo', chunk_size => 10 } );

                'specialUpdate', 'biblioserver'

    $indexer->index_records( \@big_array, 'specialUpdate', 'biblioserver', \@big_array );

            );

    is( $chunks, 1000, "We split 10000 records into 1000 chunks when chunk size is 10" );

        }

        "Update background " . $biblio->biblionumber,

};

            "When passing id only to index_records the marc record is fetched and passed through to update_index";

subtest 'update_index' => sub {

        my $chunks = 0;

    plan tests => 1;

        $mock_index->mock(

            update_index => sub {

    my $biblio = $builder->build_sample_biblio;

                my ( $self, $record_ids, $records ) = @_;

    my $biblionumber = $biblio->biblionumber;

                $chunks++;

    $biblio->delete;

            }

        );

    my $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new({ 'index' => 'biblios' });

    warning_is {

        t::lib::Mocks::mock_config( 'elasticsearch', { server => 'false', index_name => 'pseudo' } );

        $indexer->update_index([$biblionumber]);

        my @big_array = 1 .. 10000;

        $indexer->index_records( \@big_array, 'specialUpdate', 'biblioserver', \@big_array );

        is( $chunks, 2, "We split 10000 records into two chunks when chunk size not set" );

        $chunks = 0;

        t::lib::Mocks::mock_config(

            'elasticsearch',

            { server => 'false', index_name => 'pseudo', chunk_size => 10 }

        );

        $indexer->index_records( \@big_array, 'specialUpdate', 'biblioserver', \@big_array );

        is( $chunks, 1000, "We split 10000 records into 1000 chunks when chunk size is 10" );

    };

    subtest 'update_index' => sub {

        plan tests => 1;

        my $biblio       = $builder->build_sample_biblio;

        my $biblionumber = $biblio->biblionumber;

        $biblio->delete;

        my $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new( { 'index' => 'biblios' } );

        warning_is {

            $indexer->update_index( [$biblionumber] );

    } "", "update_index called with deleted biblionumber should not crash";

        }

        "", "update_index called with deleted biblionumber should not crash";

};

    };